Function startHttp

src/index.ts:1887–1961

* Start the server in HTTP mode. * Each connecting MCP client gets its own Server+Transport pair, * sharing the same module-level project state.

(explicitPort?: number)

 * sharing the same module-level project state.
 */
async function startHttp(explicitPort?: number): Promise<void> {
  await ensureMcpRuntimeLoaded();

  const serverConfig = await loadServerConfig();
  await applyServerConfig(serverConfig);

  // Port resolution priority: CLI flag > env var > config file > built-in default (3100)
  const portFromEnv = process.env.CODEBASE_CONTEXT_PORT
    ? Number.parseInt(process.env.CODEBASE_CONTEXT_PORT, 10)
    : undefined;
  const resolvedEnvPort = portFromEnv && Number.isFinite(portFromEnv) ? portFromEnv : undefined;
  const port = explicitPort ?? resolvedEnvPort ?? serverConfig?.server?.port ?? 3100;
  const host = serverConfig?.server?.host ?? '127.0.0.1';

  // Validate bootstrap root the same way main() does
  if (primaryRootPath) {
    try {
      const stats = await fs.stat(primaryRootPath);
      if (!stats.isDirectory()) {
        console.error(`ERROR: Root path is not a directory: ${primaryRootPath}`);
        process.exit(1);
      }
    } catch {
      console.error(`ERROR: Root path does not exist: ${primaryRootPath}`);
      process.exit(1);
    }
  }

  const handle = await startHttpServer({
    name: 'codebase-context',
    version: PKG_VERSION,
    port,
    host,
    registerHandlers,
    onSessionReady: (sessionServer) => {
      // Per-session roots change handler
      sessionServer.setNotificationHandler(RootsListChangedNotificationSchema, async () => {
        try {
          await refreshKnownRootsFromClient();
        } catch {
          /* best-effort */
        }
      });
    }
  });

  // Register cleanup — no parent death guard or stdin listeners in HTTP mode
  const stopAllWatchers = () => {
    for (const project of getAllProjects()) {
      project.stopWatcher?.();
    }
  };

  const shutdown = async () => {
    console.error('[HTTP] Shutting down...');
    stopAllWatchers();
    await handle.close();
    process.exit(0);