[BUG] Clients Sharing a WebSocket Transport Mix Up Their Responses #594

import { ccc } from "@ckb-ccc/core";
import { WebSocketServer } from "ws";

// A server that answers each request with its method name after 100 ms.
new WebSocketServer({ port: 18114 }).on("connection", (socket) =>
  socket.on("message", (raw) => {
    const { id, method } = JSON.parse(raw.toString());
    setTimeout(() => socket.send(JSON.stringify({ jsonrpc: "2.0", id, result: method })), 100);
  }),
);

// Requestors sharing one transport with a 1 s timeout.
const transport = ccc.JsonRpcTransportWebSocket.open("ws://127.0.0.1:18114", 1000).value;
const request = (method: string) => ccc.RequestorJsonRpc.new({ transport }).request(method, []);

await request("connect"); // Open the socket first.
for (const method of ["a", "b"]) {
  request(method).then(
    (result) => console.log(method, "got", result),
    (err) => console.log(method, "failed:", err.message),
  );
  await new Promise((resolve) => setTimeout(resolve, 10)); // Send `a` before `b`.
}
setTimeout(() => (console.log("3 s passed"), process.exit()), 3000);