Function startHttpServer

src/server/http.ts:57–269

(options: HttpServerOptions)

};

export async function startHttpServer(options: HttpServerOptions): Promise<HttpServerHandle> {
  const host = options.host ?? '127.0.0.1';
  const port = options.port ?? 3100;
  const sessions = new Map<string, SessionEntry>();

  function touchSession(sessionId: string): void {
    const session = sessions.get(sessionId);
    if (session) {
      session.lastActivity = Date.now();
    }
  }

  function createSessionServer(): { server: Server; transport: StreamableHTTPServerTransport } {
    const server = createServer(
      { name: options.name, version: options.version },
      options.registerHandlers
    );

    const transport = new StreamableHTTPServerTransport({
      sessionIdGenerator: () => randomUUID()
    });

    return { server, transport };
  }

  // Session timeout reaper — evicts sessions idle for > SESSION_TIMEOUT_MS.
  const timeoutCheck = setInterval(() => {
    const now = Date.now();
    for (const [sessionId, session] of sessions.entries()) {
      if (now - session.lastActivity > SESSION_TIMEOUT_MS) {
        console.error(`[HTTP] Session ${sessionId} timed out`);
        void session.transport.close().catch(() => {
          /* best effort */
        });
        sessions.delete(sessionId);
      }
    }
  }, SESSION_CHECK_INTERVAL_MS);
  timeoutCheck.unref();

  const httpServer = createHttpServer(async (req: IncomingMessage, res: ServerResponse) => {
    try {
      const url = new URL(req.url ?? '/', `http://${host}:${port}`);

      // Health check on root
      if (url.pathname === '/' && req.method === 'GET') {
        res.writeHead(200, { 'Content-Type': 'application/json' });
        res.end(JSON.stringify({ status: 'ok', sessions: sessions.size }));
        return;
      }

      // Only handle /mcp
      if (url.pathname !== '/mcp') {
        res.writeHead(404, { 'Content-Type': 'application/json' });
        res.end(JSON.stringify({ error: 'Not found' }));
        return;
      }