BSC RPC Docs

# Latest block — sub-millisecond server-side; total = our processing time + your RTT to Ashburn, VA
curl -X POST 'https://va-bsc-01.streamsuite.io/?key=YOUR_API_KEY' \
  -H 'Content-Type: application/json' \
  -d '{"jsonrpc":"2.0","method":"eth_blockNumber","params":[],"id":1}'

# Batched call (RPC supports JSON arrays — processed in parallel server-side)
curl -X POST 'https://va-bsc-01.streamsuite.io/?key=YOUR_API_KEY' \
  -H 'Content-Type: application/json' \
  -d '[
    {"jsonrpc":"2.0","method":"eth_blockNumber","params":[],"id":1},
    {"jsonrpc":"2.0","method":"eth_chainId","params":[],"id":2},
    {"jsonrpc":"2.0","method":"net_peerCount","params":[],"id":3}
  ]'

# Bearer auth (equivalent to ?key=, keeps key out of URL logs)
curl -X POST 'https://va-bsc-01.streamsuite.io/' \
  -H 'Authorization: Bearer YOUR_API_KEY' \
  -H 'Content-Type: application/json' \
  -d '{"jsonrpc":"2.0","method":"eth_blockNumber","params":[],"id":1}'

# Gzipped response — ~80% smaller on full-block / large-log queries
curl --compressed -X POST 'https://va-bsc-01.streamsuite.io/?key=YOUR_API_KEY' \
  -H 'Content-Type: application/json' \
  -d '{"jsonrpc":"2.0","method":"eth_getBlockByNumber","params":["latest",true],"id":1}'

import { createPublicClient, http, webSocket } from 'viem';
import { bsc } from 'viem/chains';

const HTTP_URL = 'https://va-bsc-01.streamsuite.io/?key=YOUR_API_KEY';
const WS_URL   = 'wss://va-bsc-01.streamsuite.io/ws?key=YOUR_API_KEY';

// HTTP
const client = createPublicClient({ chain: bsc, transport: http(HTTP_URL) });
const block = await client.getBlockNumber();
console.log('Head block:', block);

// WebSocket: watch new blocks
const ws = createPublicClient({ chain: bsc, transport: webSocket(WS_URL) });
const unwatch = ws.watchBlocks({
  onBlock: (b) => console.log('newHead', b.number),
});

// Mempool tier+: subscribe to pending transactions
const unwatchPending = ws.watchPendingTransactions({
  onTransactions: (hashes) => console.log('pending:', hashes.length, 'tx'),
});

// Production-ready WebSocket pattern: exponential backoff + resubscribe.
// The connection WILL drop occasionally (network blip, server restart,
// nginx idle timeout). Your bot's job is to reconnect transparently.

import WebSocket from 'ws';

const WS_URL = 'wss://va-bsc-01.streamsuite.io/ws?key=YOUR_API_KEY';
let backoffMs = 250;
const MAX_BACKOFF = 30_000;

function connect() {
  const ws = new WebSocket(WS_URL);

  ws.on('open', () => {
    backoffMs = 250;                 // reset backoff on successful connect
    // resubscribe to whatever channels your bot needs
    ws.send(JSON.stringify({
      jsonrpc: '2.0', id: 1, method: 'eth_subscribe',
      params: ['newHeads'],
    }));
  });

  ws.on('message', (data) => {
    const msg = JSON.parse(data.toString());
    if (msg.method === 'eth_subscription') {
      handleEvent(msg.params.result);   // your handler
    }
  });

  ws.on('close', (code, reason) => {
    console.warn('ws closed', code, reason.toString(), 'retry in', backoffMs);
    setTimeout(connect, backoffMs);
    backoffMs = Math.min(backoffMs * 2, MAX_BACKOFF);
  });

  ws.on('error', (err) => {
    console.error('ws error', err.message);
    // close handler will fire next; don't double-reconnect here
  });
}

function handleEvent(_evt: unknown) { /* your bot logic */ }
connect();