Function startUiServer

packages/cli/src/commands/ui.ts:66–380

(opts: StartUiServerOptions)

}

export async function startUiServer(opts: StartUiServerOptions): Promise<UiServerHandle> {
  const { existsSync } = await import('node:fs');
  const { createServer: createHttpServer } = await import('node:http');
  const { resolve } = await import('node:path');
  const {
    acquireUiLock,
    clearArmedPaneTarget,
    createAssetServeMiddleware,
    createContentFilter,
    readArmedPaneTarget,
    readServerLock,
    releaseUiLock,
    updateUiLockPort,
  } = await import('@inkeep/open-knowledge-server');
  const { default: sirv } = await import('sirv');
  const { resolveContentDir, resolveLockDir } = await import('@inkeep/open-knowledge-server');

  const contentDir = resolveContentDir(opts.config, opts.cwd);
  const lockDir = resolveLockDir(opts.cwd);

  acquireUiLock(lockDir, { port: 0, worktreeRoot: opts.cwd });

  const cliDir = import.meta.dirname ?? new URL('.', import.meta.url).pathname;
  const assetPaths = [
    resolve(cliDir, 'public'), // npm install: dist/public/ (bundled)
    resolve(cliDir, '../../app/dist'), // monorepo dev from src/
    resolve(cliDir, '../../../app/dist'), // monorepo dev from dist/
  ];
  const assetDir = opts.assetDir ?? assetPaths.find((p) => existsSync(p));
  const staticHandler = assetDir
    ? sirv(assetDir, { single: true, gzip: true, etag: true, dev: true, extensions: [] })
    : null;

  const assetServeMiddleware = existsSync(contentDir)
    ? createAssetServeMiddleware({
        contentFilter: createContentFilter({
          projectDir: opts.cwd,
          contentDir,
        }),
        contentSirv: sirv(contentDir, { dotfiles: false, dev: true, extensions: [] }),
        inlineExtensions: INLINE_RENDERABLE_EXTENSIONS,
        assetExtensions: ASSET_EXTENSIONS,
        blocklistExtensions: EXECUTABLE_BLOCKLIST_EXTENSIONS,
      })
    : null;

  let resolvedPort = opts.port;

  let apiConfigNudge: (() => void) | null = null;

  const requestHandler = (req: import('node:http').IncomingMessage, res: ServerResponse) => {
    const url = req.url?.split('?')[0];

    if (req.method === 'GET' && (url === '/' || url === '')) {
      const armed = readArmedPaneTarget(lockDir);
      if (armed && !/[\r\n]/.test(armed)) {
        clearArmedPaneTarget(lockDir);
        res.statusCode = 302;