server.ts

import { createServer } from "node:http";

import nextEnv from "@next/env";
import next from "next";

import { applyAppConfigToProcessEnv } from "./src/server/app-config";
import { createLabTerminalGateway } from "./src/server/labs/terminal-gateway";

const dev = process.env.NODE_ENV !== "production";
const { loadEnvConfig } = nextEnv;
loadEnvConfig(process.cwd(), dev);
applyAppConfigToProcessEnv();
const hostname = process.env.APP_HOST ?? process.env.HOST ?? "127.0.0.1";
const port = Number(process.env.PORT ?? "3210");
const useWebpack = process.env.NEXT_DEV_BUNDLER === "webpack";

const app = next({ dev, hostname, port, ...(useWebpack ? { webpack: true } : {}) });
const handle = app.getRequestHandler();
const terminalGateway = createLabTerminalGateway({
  mode: (process.env.PROJECT_LAB_TERMINAL_MODE as "auto" | "docker" | "local" | undefined) ?? "auto",
});

await app.prepare();

const server = createServer((request, response) => {
  void handle(request, response);
});

// Node defaults requestTimeout to five minutes. A local model may spend that
// long prefilling a wide context before its first streamed token, so the HTTP
// transport must not undercut the controller's two-hour maximum run budget.
server.requestTimeout = 2 * 60 * 60 * 1000;
server.timeout = 0;

server.on("upgrade", (request, socket, head) => {
  if (terminalGateway.handleUpgrade(request, socket, head)) {
    return;
  }
  // Leave Next.js dev/prod upgrade requests, including HMR, to Next's own
  // upgrade handler registered by getRequestHandler().
});

server.listen(port, hostname, () => {
  console.log(`> Ready on http://${hostname}:${port}`);
  console.log("> Lab terminal WebSocket mounted on the Next.js server");
});