Function runServerInProcess

apps/kimi-code/src/cli/sub/server/run.ts:288–368

* Start the server in the current process and block until shutdown. Shared by * the detached daemon (`daemon: true`, with idle-exit) and the foreground * runner (`daemon: false`). `onReady` fires once the server is listening.

(
  options: ParsedServerOptions,
  mode: { daemon: boolean },
  onReady?: (origin: string) => void,
)

 * runner (`daemon: false`). `onReady` fires once the server is listening.
 */
async function runServerInProcess(
  options: ParsedServerOptions,
  mode: { daemon: boolean },
  onReady?: (origin: string) => void,
): Promise<never> {
  const version = getVersion();
  const telemetry = initializeServerTelemetry({ version });

  let running: RunningServer | undefined;
  let stopping = false;

  const idle = mode.daemon
    ? createIdleShutdownHandler({
        graceMs: options.idleGraceMs,
        onIdle: () => {
          void shutdown('idle');
        },
      })
    : undefined;

  async function shutdown(reason: string): Promise<void> {
    if (stopping) return;
    stopping = true;
    idle?.cancel();
    running?.logger.info({ reason }, 'server shutting down');
    try {
      await running?.close();
      await shutdownTelemetry({ timeoutMs: CLI_SHUTDOWN_TIMEOUT_MS });
    } catch (error) {
      running?.logger.error(
        { err: error instanceof Error ? error : new Error(String(error)) },
        'server shutdown error',
      );
    }
    process.exit(0);
  }

  running = await startServer({
    host: options.host,
    port: options.port,
    logLevel: options.logLevel,
    debugEndpoints: options.debugEndpoints,
    insecureNoTls: options.insecureNoTls,
    allowRemoteShutdown: options.allowRemoteShutdown,
    allowRemoteTerminals: options.allowRemoteTerminals,
    allowedHosts: options.allowedHosts,
    webAssetsDir: serverWebAssetsDir(),
    coreProcessOptions: {
      identity: createKimiCodeHostIdentity(version),
      telemetry,
    },
    wsGatewayOptions: {
      telemetry,
      onConnectionCountChange: idle
        ? (size) => {
            idle.onConnectionCountChange(size);
          }
        : undefined,