Function createHTTPServer

packages/computerd/src/cli/computerd.ts:167–310

(
  info: ComputerdInfo,
  rpc: ReturnType<typeof createWorkspaceServer>,
  getStats?: () => Record<string, unknown>,
)

}

function createHTTPServer(
  info: ComputerdInfo,
  rpc: ReturnType<typeof createWorkspaceServer>,
  getStats?: () => Record<string, unknown>,
): HTTPHandle {
  // Holds the current outbound capnweb session opened via /connect.
  // Re-POSTing /connect (e.g. after a DO hibernate + new incarnation)
  // closes the previous socket so the old session doesn't leak for
  // the life of the container.
  const upstreamSlot: { ws: WebSocket | undefined } = { ws: undefined };
  const server = createServer((request, response) => {
    const path = requestPath(request);

    // /api — capnweb HTTP-batch endpoint. Single POST per call;
    // request body carries the serialized message, response body
    // carries the reply. Useful for environments that can't open
    // a WebSocket (curl, fetch from a Worker without ws upgrade).
    if (path === "/api") {
      if (request.method !== "POST") {
        send(response, 405, "method not allowed\n", {
          allow: "POST",
          "content-type": "text/plain; charset=utf-8",
        });
        return;
      }
      void serveHTTPBatch(request, response, rpc).catch((error) => {
        console.error("/api batch failed:", error);
        if (!response.headersSent) {
          send(response, 500, "internal error\n", {
            "content-type": "text/plain; charset=utf-8",
          });
        }
      });
      return;
    }

    // /connect — POST { url } where url is the http(s) base of an
    // egress endpoint the host wants us to dial back into. We open a
    // capnweb WebSocket session against `${url}/ws` and serve our RPC
    // over it, exactly like /ws but with the carrier inverted (we
    // dial out instead of accepting an inbound upgrade).
    if (path === "/connect") {
      if (request.method !== "POST") {
        send(response, 405, "method not allowed\n", {
          allow: "POST",
          "content-type": "text/plain; charset=utf-8",
        });
        return;
      }
      void handleConnect(request, response, rpc, upstreamSlot);
      return;
    }

    if (request.method !== "GET" && request.method !== "HEAD") {
      send(response, 405, "method not allowed\n", {
        allow: "GET, HEAD",
        "content-type": "text/plain; charset=utf-8",
      });