import { once } from "node:events";
import { createSecureServer } from "node:http2";
import pem from "@metcoder95/https-pem";
import { Client } from "undici";

const server = createSecureServer(
  await pem.generate({ opts: { keySize: 2048 } }),
);

const seen = [];
let session;

server.on("session", (s) => {
  session = s;
});

server.on("stream", (stream, headers) => {
  seen.push(headers[":path"]);

  stream.respond({ ":status": 200 });

  setTimeout(() => {
    if (!stream.closed) {
      stream.end(`ok:${headers[":path"]}`);
    }
  }, 200);

  if (seen.length === 3) {
    setTimeout(() => {
      session.goaway();
    }, 50);
  }
});

await once(server.listen(0), "listening");

const client = new Client(`https://localhost:${server.address().port}`, {
  pipelining: 10,
  connect: { rejectUnauthorized: false },
});

const results = await Promise.allSettled(
  [1, 2, 3].map((i) =>
    client
      .request({ path: `/${i}`, method: "GET" })
      .then(async (res) => res.body.text()),
  ),
);

console.log("server saw", seen);
console.log(
  results.map((r) => {
    return r.status === "fulfilled"
      ? { status: r.status, value: r.value }
      : { status: r.status, code: r.reason.code, message: r.reason.message };
  }),
);

await client.close();
await new Promise((resolve) => server.close(resolve));