WebSocket 数据服务

connect → auth → subscribe → listen events → ping/pong → reconnect

{"op":"auth","id":"a1","params":{"apiKey":"ak_xxx","timestamp":1780480800000,"nonce":"abc123...","signature":"..."}}
{"op":"subscribe","id":"s1","topic":"market.v1.ticker","params":{"chain":"bnb","contracts":["0x55d398326f99059ff775485246999027b3197955"]}}

{"type":"auth_ack","id":"a1","code":0,"msg":"ok","ts":1780480800001}

{"type":"subscribe_ack","id":"s1","topic":"market.v1.ticker","subId":"server-sub-id","code":0,"msg":"ok","ts":1780480800002}

{"type":"event","topic":"market.v1.ticker","subId":"server-sub-id","seq":1,"ts":1780480800003,"data":{...}}

{
  "op": "auth",
  "id": "auth-001",
  "params": {
    "apiKey": "ak_xxxxxxxxxxxxxxxxxx",
    "timestamp": 1780480800000,
    "nonce": "8f14e45fceea167a5a36dedd4bea2543",
    "signature": "Base64HmacSha256..."
  }
}

function buildSignString(apiKey, nonce, timestamp) {
  return JSON.stringify({ apiKey, nonce, timestamp });
}
 
function hmacSign(apiSecret, signString) {
  return crypto.createHmac('sha256', apiSecret).update(signString).digest('base64');
}
 
const ts = Date.now();
const nonce = randomNonce(); // 32 位随机字符串
const signature = hmacSign(apiSecret, buildSignString(apiKey, nonce, String(ts)));

{"type":"auth_ack","id":"auth-001","code":0,"msg":"ok","ts":1780480800001}

{"type":"auth_ack","id":"auth-001","code":40101,"msg":"invalid signature","ts":1780480800001}

{
  "op": "subscribe",
  "id": "sub-001",
  "topic": "market.v1.ticker",
  "params": {
    "chain": "bnb",
    "contracts": ["0x55d398326f99059ff775485246999027b3197955"]
  }
}

{
  "type": "subscribe_ack",
  "id": "sub-001",
  "topic": "market.v1.ticker",
  "subId": "server-sub-id",
  "code": 0,
  "msg": "ok",
  "ts": 1780480800002
}

{
  "op": "unsubscribe",
  "id": "unsub-001",
  "params": { "subId": "server-sub-id" }
}

{
  "type": "unsubscribe_ack",
  "id": "unsub-001",
  "topic": "market.v1.ticker",
  "subId": "server-sub-id",
  "code": 0,
  "msg": "ok",
  "ts": 1780480800003
}

{
  "op": "subscribe",
  "id": "sub-ticker",
  "topic": "market.v1.ticker",
  "params": {
    "chain": "sol",
    "contracts": ["4k3Dyjzvzp8eMZWUXbBCjEvwSkkk59S5iCNLY3QrkX6R"]
  }
}

{
  "op": "subscribe",
  "id": "sub-kline",
  "topic": "market.v1.kline",
  "params": {
    "chain": "bnb",
    "contracts": ["0x55d398326f99059ff775485246999027b3197955"],
    "periods": ["1m", "5m"]
  }
}

{
  "op": "subscribe",
  "id": "sub-kline-multi",
  "topic": "market.v1.kline",
  "params": {
    "chain": "sol",
    "contracts": [
      "EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v",
      "So11111111111111111111111111111111111111112"
    ],
    "periods": ["1m", "5m", "1h"]
  }
}

{
  "op": "subscribe",
  "id": "sub-token",
  "topic": "market.v1.token",
  "params": {
    "chain": "eth",
    "contracts": ["0xA0b86991c6218b36c1d19D4a2e9Eb0cE3606eB48"],
    "types": ["new", "update"]
  }
}

{
  "op": "subscribe",
  "id": "sub-rwa-ticker",
  "topic": "rwa.v1.ticker",
  "params": { "tickers": ["ONDO:USDY", "ONDO:OUSG"] }
}

{
  "op": "subscribe",
  "id": "sub-rwa-kline",
  "topic": "rwa.v1.kline",
  "params": {
    "tickers": ["ONDO:USDY"],
    "periods": ["1m", "1d"]
  }
}

{
  "type": "event",
  "topic": "market.v1.ticker",
  "subId": "server-sub-id",
  "seq": 1024,
  "ts": 1780480800000,
  "data": {}
}

{
  "type": "event",
  "topic": "market.v1.ticker",
  "subId": "sub-001",
  "seq": 1,
  "ts": 1780480800000,
  "data": {
    "chain": "sol",
    "contract": "Mint1",
    "side": "buy",
    "amount": "1250.5",
    "price": "1.0001",
    "value": "1250.63",
    "txHash": "Hash1",
    "txFrom": "From1",
    "blockNumber": 285,
    "index": 12,
    "timestamp": 1717382401
  }
}

{
  "type": "event",
  "topic": "market.v1.kline",
  "subId": "sub-002",
  "seq": 2,
  "ts": 1780480800001,
  "data": {
    "chain": "bnb",
    "contract": "0xabc",
    "period": "1m",
    "open": "1",
    "high": "2",
    "low": "0.8",
    "close": "1.5",
    "buyAmount": "10",
    "sellAmount": "5",
    "buyValue": "100",
    "sellValue": "50",
    "txn": 7,
    "timestamp": 1717382401
  }
}

{
  "type": "event",
  "topic": "market.v1.token",
  "subId": "sub-003",
  "seq": 3,
  "ts": 1780480800002,
  "data": {
    "chain": "eth",
    "contract": "0xabc",
    "type": "new",
    "symbol": "ABC",
    "name": "ABC Token",
    "icon": "https://example.com/a.png",
    "decimals": 18,
    "about": "about abc",
    "issueDate": "2024-01-01",
    "supplyTotal": "1000000"
  }
}

{
  "type": "event",
  "topic": "rwa.v1.ticker",
  "subId": "sub-004",
  "seq": 4,
  "ts": 1780480800003,
  "data": {
    "ticker": "ONDO:USDY",
    "chain": "eth",
    "symbol": "USDY",
    "address": "0xA0b",
    "dataSource": "ondo",
    "price": "1.0801",
    "price24hAgo": "1.0774",
    "price24hChange": "0.0027",
    "price24hChangeRatio": "0.0025",
    "timestamp": 1717382401,
    "chainAssets": [
      {"chain": "eth", "address": "0xA0b"},
      {"chain": "sol", "address": "EPjF"}
    ]
  }
}

{
  "type": "event",
  "topic": "rwa.v1.tx",
  "subId": "sub-005",
  "seq": 5,
  "ts": 1780480800004,
  "data": {
    "id": "evt-1",
    "ticker": "ONDO:USDY",
    "chain": "eth",
    "contract": "0xabc",
    "txHash": "0xhash",
    "txFrom": "0xfrom",
    "blockNumber": 123,
    "txIndex": 4,
    "eventIndex": 5,
    "side": "buy",
    "amount": "10.5",
    "priceUsd": "1.08",
    "volumeUsd": "11.34",
    "timestamp": 1717382401
  }
}

{"op":"ping","id":"client-ping-001"}

{"type":"pong","id":"client-ping-001","ts":1780480800003}

{"type":"ping","id":"conn-1-ping-1","ts":1780480800100}

{"type":"pong","id":"conn-1-ping-1","ts":1780480800101}

const crypto = require('node:crypto');
const WebSocket = require('ws');
 
const WS_URL = 'wss://bopenapi-ws.bgwapi.io/ws';
const API_KEY = process.env.WS_API_KEY;
const API_SECRET = process.env.WS_API_SECRET;
 
function buildSignString(apiKey, nonce, timestamp) {
  return JSON.stringify({ apiKey, nonce, timestamp });
}
 
function hmacSign(apiSecret, signString) {
  return crypto.createHmac('sha256', apiSecret).update(signString).digest('base64');
}
 
function randomNonce() {
  const chars = 'abcdefghijklmnopqrstuvwxyz0123456789';
  let out = '';
  for (let i = 0; i < 32; i++) out += chars[Math.floor(Math.random() * chars.length)];
  return out;
}
 
function send(ws, obj) {
  return new Promise((resolve, reject) => {
    ws.send(JSON.stringify(obj), (err) => (err ? reject(err) : resolve()));
  });
}
 
class MessageRouter {
  constructor(ws) {
    this.queue = [];
    this.waiters = [];
    this.closed = false;
    ws.on('message', (raw) => {
      let msg;
      try {
        msg = JSON.parse(raw.toString());
      } catch {
        return;
      }
      if (this.waiters.length) this.waiters.shift()(msg);
      else this.queue.push(msg);
    });
  }
 
  close() {
    this.closed = true;
    while (this.waiters.length) this.waiters.shift()(null);
  }
 
  next() {
    if (this.queue.length) return Promise.resolve(this.queue.shift());
    if (this.closed) return Promise.resolve(null);
    return new Promise((resolve) => this.waiters.push(resolve));
  }
}
 
async function readAck(router, wantType, wantID, onEarly) {
  while (true) {
    const msg = await router.next();
    if (!msg) throw new Error('connection closed while waiting for ack');
    if (msg.type === wantType && msg.id === wantID) return msg;
    if (onEarly) onEarly(msg);
  }
}
 
function handlePing(ws, msg) {
  send(ws, { type: 'pong', id: msg.id, ts: Date.now() }).catch(() => {});
}
 
async function auth(ws, router) {
  const id = `a-${Date.now()}`;
  const ts = Date.now();
  const nonce = randomNonce();
  const sig = hmacSign(API_SECRET, buildSignString(API_KEY, nonce, String(ts)));
  await send(ws, { op: 'auth', id, params: { apiKey: API_KEY, timestamp: ts, nonce, signature: sig } });
 
  const ack = await readAck(router, 'auth_ack', id, (msg) => {
    if (msg.type === 'ping') handlePing(ws, msg);
  });
  if (ack.code !== 0) throw new Error(`auth failed: ${ack.code} ${ack.msg}`);
}
 
async function subscribe(ws, router, topic, params) {
  const id = `s-${Date.now()}`;
  await send(ws, { op: 'subscribe', id, topic, params });
 
  const ack = await readAck(router, 'subscribe_ack', id, (msg) => {
    if (msg.type === 'ping') handlePing(ws, msg);
  });
  if (ack.code !== 0) throw new Error(`subscribe failed: ${ack.code} ${ack.msg}`);
  return ack.subId;
}
 
async function main() {
  const ws = new WebSocket(WS_URL);
  await new Promise((resolve, reject) => {
    ws.once('open', resolve);
    ws.once('error', reject);
  });
 
  const router = new MessageRouter(ws);
 
  await auth(ws, router);
  const subId = await subscribe(ws, router, 'market.v1.ticker', {
    chain: 'bnb',
    contracts: ['0x55d398326f99059ff775485246999027b3197955'],
  });
  console.log('subscribed:', subId);
 
  (async () => {
    while (true) {
      const msg = await router.next();
      if (!msg) break;
      if (msg.type === 'ping') {
        handlePing(ws, msg);
        continue;
      }
      if (msg.type === 'event') {
        console.log(`[${msg.topic}] seq=${msg.seq}`, msg.data);
      }
    }
  })();
 
  setInterval(() => {
    if (ws.readyState === WebSocket.OPEN) {
      send(ws, { op: 'ping', id: `kp-${Date.now()}` });
    }
  }, 15_000);
}
 
main().catch(console.error);