Function uiCommand

packages/cli/src/commands/ui.ts:484–596

(getConfig: () => Config)

}

export function uiCommand(getConfig: () => Config): Command {
  return new Command('ui')
    .description('Serve the OpenKnowledge React editor UI')
    .option(
      '-p, --port <port>',
      `UI port (default: $PORT env or ${DEFAULT_UI_PORT}, kernel-allocated fallback if busy)`,
    )
    .option(
      '-H, --host <host>',
      'UI host. Default: two-socket loopback bind (`[::1]` + `127.0.0.1`) so cross-family collisions fail loud. Pass an explicit host (e.g. `127.0.0.1`, `0.0.0.0`) to bind a single socket on that host.',
    )
    .action(async (opts: { port?: string; host?: string }) => {
      const { dim } = await import('../ui/colors.ts');
      const { UiLockCollisionError } = await import('@inkeep/open-knowledge-server');
      const { resolveLockDir } = await import('@inkeep/open-knowledge-server');
      const config = getConfig();
      const host = opts.host;

      let resolved: ResolvedRequestedPort;
      try {
        resolved = resolveRequestedPort(opts.port, process.env.PORT);
      } catch (err) {
        console.error(err instanceof Error ? err.message : String(err));
        process.exitCode = 1;
        return;
      }
      const requestedPort = resolved.port;

      try {
        const handle = await startUiServer({
          config,
          cwd: process.cwd(),
          port: requestedPort,
          fallbackToKernel: resolved.fallbackToKernel,
          host,
        });
        const displayHost =
          host === undefined || host === '::' || host === '0.0.0.0' ? 'localhost' : host;
        console.log(`${dim('[ui]')} listening on http://${displayHost}:${handle.port}`);

        let shuttingDown = false;
        const shutdown = (signal: NodeJS.Signals) => {
          if (shuttingDown) return;
          shuttingDown = true;
          console.log(dim(`\n[ui] Shutting down (${signal})`));
          handle.detachSafetyNet();
          const finish = () => {
            try {
              handle.release();
            } finally {
              process.exit(process.exitCode ?? 0);
            }
          };
          handle.drainUpgradeSockets();
          closeHttpServers(handle.httpServers).then(finish, finish);
          setTimeout(finish, 2000).unref();
        };
        process.once('SIGINT', () => shutdown('SIGINT'));