Function startHttpServer

packages/fetch/src/fetch.e2e.test.ts:125–169

* Start a simple HTTP server for testing

()

 * Start a simple HTTP server for testing
 */
async function startHttpServer(): Promise<http.Server> {
  const server = http.createServer((req, res) => {
    const url = new URL(req.url!, `http://localhost:${HTTP_PORT}`);

    if (url.pathname === "/json") {
      res.writeHead(200, { "Content-Type": "application/json" });
      res.end(
        JSON.stringify({
          message: "Hello from HTTP server",
          method: req.method,
        }),
      );
    } else if (url.pathname === "/headers") {
      res.writeHead(200, { "Content-Type": "application/json" });
      res.end(JSON.stringify({ headers: req.headers }));
    } else if (url.pathname === "/body") {
      let body = "";
      req.on("data", (chunk) => {
        body += chunk.toString();
      });
      req.on("end", () => {
        res.writeHead(200, { "Content-Type": "application/json" });
        res.end(JSON.stringify({ body, headers: req.headers }));
      });
    } else if (url.pathname === "/status/404") {
      res.writeHead(404, { "Content-Type": "text/plain" });
      res.end("Not Found");
    } else if (url.pathname === "/slow") {
      setTimeout(() => {
        res.writeHead(200, { "Content-Type": "text/plain" });
        res.end("Slow response");
      }, 100);
    } else {
      res.writeHead(404);
      res.end("Not Found");
    }
  });

  await new Promise<void>((resolve) => {
    server.listen(HTTP_PORT, () => resolve());
  });

  serversToCleanup.push(server);
  return server;
}

/**
 * Start an HTTPS server with given certificates