Function createHttpServer

packages/runtime/src/http-server.ts:61–108

(opts: HttpServerOptions)

}

export function createHttpServer(opts: HttpServerOptions): http.Server {
  const { port, onRpc, onEvent, onHealth } = opts;

  const server = http.createServer(async (req, res) => {
    try {
      const url = new URL(req.url || '/', `http://localhost:${port}`);

      // Health check
      if (req.method === 'GET' && url.pathname === '/health') {
        sendJson(res, 200, onHealth());
        return;
      }

      // JSON-RPC endpoint
      if (req.method === 'POST' && url.pathname === '/rpc') {
        const rpcReq = await parseBody<JsonRpcRequest>(req);
        if (!rpcReq.jsonrpc || rpcReq.jsonrpc !== '2.0' || !rpcReq.method) {
          sendJson(res, 400, { error: 'Invalid JSON-RPC 2.0 request' });
          return;
        }
        const rpcRes = await onRpc(rpcReq);
        sendJson(res, 200, rpcRes);
        return;
      }

      // External events
      if (req.method === 'POST' && url.pathname === '/events') {
        const event = await parseBody<ExternalEvent>(req);
        onEvent(event);
        sendJson(res, 200, { status: 'accepted' });
        return;
      }

      sendJson(res, 404, { error: 'Not found' });
    } catch (err) {
      log.error('request error', { error: err instanceof Error ? err.message : String(err) });
      if (!res.headersSent) {
        sendJson(res, 500, { error: 'Internal server error' });
      }
    }
  });

  server.listen(port, '0.0.0.0', () => {
    log.info(`listening on port ${port}`);
  });

  return server;
}