Подписки

Отдельный сервер

On a deployment behind a reverse proxy, both /ws and /ws/ are served as two separate locations with no redirect between them: a WebSocket client mostly does not follow a 301 on its handshake, so whichever spelling was redirected would simply fail to connect.

Рукопожатие

eth_subscribe и pickle_subscribe принимаются как взаимозаменяемые и ведут себя одинаково:

// ->
{"jsonrpc":"2.0","id":1,"method":"pickle_subscribe","params":["miniBlocks"]}

// <-
{"jsonrpc":"2.0","id":1,"result":"0x1"}

// <- then, per event
{"jsonrpc":"2.0","method":"eth_subscription","params":{"subscription":"0x1","result":{…}}}

• Subscription ids come from a per-connection counter starting at 1, so two connections both see 0x1. Do not treat an id as globally unique.
• Notifications always arrive under the method name eth_subscription, even for a subscription opened as pickle_subscribe. Unwrap the payload at params.result.
• eth_unsubscribe and pickle_unsubscribe both return a boolean: true if the id was found on this connection, false otherwise.

Четыре вида

Разобранный пример

Поток мини-блоков, с тем же запасным путём, которым пользуется лента первой стороны. Запасной путь важен: оборванный сокет - это норма, а путь с опросом - то, чем вы догоняете без пропусков.

// WS_URL: wss://rpc.picklechain.xyz/ws/ on the public testnet, or a node of your own.
// The /ws path is required - an upgrade at the bare origin answers 405.
const socket = new WebSocket(WS_URL);

socket.addEventListener("open", () => {
  socket.send(JSON.stringify({
    jsonrpc: "2.0", id: 1, method: "pickle_subscribe", params: ["miniBlocks"],
  }));
});

socket.addEventListener("message", (event) => {
  const message = JSON.parse(event.data);
  // The subscribe reply carries an id; notifications carry params.result.
  if (!message.params) return;
  const mini = message.params.result;

  // Decimal numbers, not hex quantities - and microseconds, not seconds.
  console.log(mini.number, mini.transactions.length, mini.timestampUs);
});

// A slow handler is DROPPED from the stream rather than buffered, so do the
// work elsewhere and keep this callback cheap.

Если сокет закрылся, опрашивайте pickle_miniBlockNumber, а затем pickle_getMiniBlockByNumber от последней увиденной высоты. Ограничьте догоняющий проход - эталонный клиент забирает не больше 100 за проход, - иначе долгий обрыв связи превратится во всплеск запросов против общего бюджета тяжёлых чтений.

Ограничения и политика сброса

Ни одно из этих ограничений не настраивается через окружение, а предел числа соединений применяется при приёме: 257-е соединение закрывается без кадра ошибки, и это выглядит как сетевой сбой, а не как отказ.

Обычные вызовы через сокет

Any frame that is not a subscribe or unsubscribe is forwarded to the same handler the HTTP port uses, so every method in the reference is callable over the socket.