import http2 from "node:http2";
import assert from "node:assert";
import { exec } from "node:child_process";

import { Client, fetch } from "undici";
import devcert from "devcert";

const ssl = await devcert.certificateFor("localhost");
const server = http2.createSecureServer(ssl, async (req, res) => {
  assert.equal(req.method, "POST");
  console.log("beginning to read body...");
  let body = [];
  for await (const chunk of req) {
    console.log({ chunk });
    body.push(chunk);
  }
  let buffer = Buffer.concat(body);
  console.log("end of reading body");
  res.end(buffer);
}).listen(3000);

const METHOD = "fetch";
const h2Client = new Client("https://localhost:3000", {
  connect: {
    rejectUnauthorized: false,
  },
  allowH2: true,
});

server.on("listening", async () => {
  console.log("listening on 3000");
  if (METHOD === "fetch") {
    const response = await fetch("https://localhost:3000", {
      dispatcher: h2Client,
      method: "POST",
      body: "12",
      headers: {
        "content-type": "text/plain",
        "content-length": "2",
      },
    });
    console.log("DONE", { response });
  } else if (METHOD === "curl") {
    const curl =
      `curl --no-progress-meter -k -X POST -H "content-type: text/plain" -H "content-length: 2" -d "12" https://localhost:3000`;
    exec(curl, (err, stdout, stderr) => {
      if (err) {
        console.error("DONE", err);
        return;
      }
      console.log("DONE", stdout);
    });
  } else {
    throw new Error();
  }
});

// with curl
beginning to read body...
{ chunk: <Buffer 31 32> }
end of reading body
DONE 12

// with fetch
beginning to read body...
{ chunk: <Buffer 31 32> }
// never gets passed here