import http from "node:http";
import { once } from "node:events";
import { setTimeout as delay } from "node:timers/promises";
import { Pool } from "undici";

const server = http.createServer((req, res) => res.end("ok"));

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

const pool = new Pool(`http://localhost:${server.address().port}`, {
  connections: 1,
  clientTtl: 1,
});
const request = () =>
  pool.request({ path: "/", method: "GET" }).then(({ body }) => body.text());

try {
  await request();
  await delay(20);
  await Promise.race([
    request(),
    delay(1000).then(() => {
      throw new Error("second request hung");
    }),
  ]);
} catch (err) {
  console.error(err.message);
  process.exitCode = 1;
} finally {
  pool.destroy();
  server.close();
}