Function init

packages/socket.io/test/connection-state-recovery.ts:7–36

(httpServer: HttpServer, io: Server)

import { Adapter } from "socket.io-adapter";

async function init(httpServer: HttpServer, io: Server) {
  // Engine.IO handshake
  const sid = await eioHandshake(httpServer);

  // Socket.IO handshake
  await eioPush(httpServer, sid, "40");
  const handshakeBody = await eioPoll(httpServer, sid);

  expect(handshakeBody.startsWith("40")).to.be(true);

  const handshake = JSON.parse(handshakeBody.substring(2));

  expect(handshake.sid).to.not.be(undefined);
  // in that case, the handshake also contains a private session ID
  expect(handshake.pid).to.not.be(undefined);

  io.emit("hello");

  const message = await eioPoll(httpServer, sid);

  expect(message.startsWith('42["hello"')).to.be(true);

  const offset = JSON.parse(message.substring(2))[1];
  // in that case, each packet also includes an offset in the data array
  expect(offset).to.not.be(undefined);

  await eioPush(httpServer, sid, "1");

  return [handshake.sid, handshake.pid, offset];
}

describe("connection state recovery", () => {
  it("should restore session and missed packets", async () => {