Inscrições

Um servidor separado

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.

O aperto de mão

eth_subscribe e pickle_subscribe são aceitos indiferentemente e se comportam de forma idêntica:

// ->
{"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.

Os quatro tipos

Um exemplo completo

O fluxo de miniblocos, com a alternativa que o fluxo de primeira parte usa. A alternativa importa: um socket caído é normal, e a via da sondagem é como você recupera o atraso sem buracos.

// 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.

Se o socket fechar, sonde pickle_miniBlockNumber e depois pickle_getMiniBlockByNumber a partir da última altura vista. Limite a recuperação - o cliente de referência busca no máximo 100 por passagem - ou uma desconexão longa se transforma numa rajada de pedidos contra o orçamento compartilhado de leituras pesadas.

Limites e política de expulsão

Nenhum desses limites é ajustável pelo ambiente, e o teto de conexões é aplicado na aceitação: a 257^a conexão é fechada sem trama de erro, o que parece uma falha de rede e não uma recusa.

As chamadas comuns no socket

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.