Abonnements

Ein eigener Server

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.

Der Handshake

eth_subscribe und pickle_subscribe werden austauschbar angenommen und verhalten sich identisch:

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

Die vier Arten

Ein durchgerechnetes Beispiel

Der Mini-Block-Strom, mit der Rückfallebene, die der hauseigene Feed verwendet. Die Rückfallebene zählt: Ein abgerissener Socket ist normal, und der Abfragepfad ist der Weg, ohne Lücken aufzuholen.

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

Wenn der Socket schließt, fragen Sie pickle_miniBlockNumber und dann pickle_getMiniBlockByNumber ab Ihrer zuletzt gesehenen Höhe ab. Begrenzen Sie das Aufholen - der Referenz-Client holt höchstens 100 pro Durchgang -, sonst wird aus einer langen Trennung ein Schwall von Anfragen gegen das geteilte Budget für schwere Lesezugriffe.

Grenzen und die Abwurfregel

Keine dieser Grenzen ist über die Umgebung einstellbar, und die Verbindungsobergrenze wird beim Annehmen durchgesetzt: Die 257. Verbindung wird ohne Fehlerrahmen geschlossen, was nach einem Netzwerkausfall aussieht statt nach einer Ablehnung.

Gewöhnliche Aufrufe über den 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.