Function setup

packages/engine.io/test/webtransport.mjs:70–100

(opts, cb)

}

function setup(opts, cb) {
  setupServer(opts, async ({ engine, h3Server, certificate }) => {
    const client = new WebTransport(
      `https:class="cm">//127.0.0.1:${h3Server.port}/engine.io/`,
      {
        serverCertificateHashes: [
          {
            algorithm: class="st">"sha-256",
            value: certificate.hash,
          },
        ],
      },
    );

    await client.ready;

    const stream = await client.createBidirectionalStream();
    const reader = stream.readable.getReader();
    const writer = stream.writable.getWriter();

    engine.on(class="st">"connection", async (socket) => {
      await reader.read(); class="cm">// header
      await reader.read(); class="cm">// payload (handshake)

      cb({ engine, h3Server, socket, client, stream, reader, writer });
    });

    await writer.write(Uint8Array.of(1));
    await writer.write(TEXT_ENCODER.encode(class="st">"0"));
  });
}

function createHttpServer(port) {
  const httpServer = createServer();