Abonnements

Un serveur séparé

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.

La poignée de main

eth_subscribe et pickle_subscribe sont acceptées indifféremment et se comportent à l'identique :

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

Les quatre types

Un exemple complet

Le flux de mini-blocs, avec le repli qu'utilise le flux de première partie. Le repli compte : un socket coupé est normal, et la voie du sondage est la façon de rattraper sans trous.

// WS_URL : wss://rpc.picklechain.xyz/ws/ sur le réseau de test public, ou un nœud à vous.
// Le chemin /ws est obligatoire - une montée en WebSocket sur l'origine nue répond 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.

Si le socket se ferme, sondez pickle_miniBlockNumber puis pickle_getMiniBlockByNumber depuis la dernière hauteur vue. Bornez le rattrapage - le client de référence en récupère au plus 100 par passe - ou une longue déconnexion se transforme en rafale de requêtes contre le budget de lectures lourdes partagé.

Limites et politique d'éjection

Aucune de ces limites n'est réglable par l'environnement, et le plafond de connexions est appliqué à l'acceptation : la 257^e connexion est fermée sans trame d'erreur, ce qui ressemble à une panne réseau plutôt qu'à un refus.

Les appels ordinaires sur le 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.