Function startDashboardServer

src/cli/dashboard-server.ts:49–96

(opts: {
  cwd: string;
  preferredPort?: number;
  buildHtml: (token: string) => Promise<string>;
  getState: () => Promise<any>;
})

/** Start the control server on 127.0.0.1. `renderHtml`/`getState` close over the token so the
 *  page can call the API. Returns a handle with the tokened URL. */
export async function startDashboardServer(opts: {
  cwd: string;
  preferredPort?: number;
  buildHtml: (token: string) => Promise<string>;
  getState: () => Promise<any>;
}): Promise<DashboardServer> {
  const token = randomBytes(16).toString('hex');

  const server = http.createServer((req, res) => {
    void (async () => {
      try {
        const u = new URL(req.url ?? '/', 'http://127.0.0.1');
        const provided = u.searchParams.get('k') ?? req.headers['x-qodex-token'];
        const tokenOk = provided === token;

        let body: any = undefined;
        if (req.method === 'POST') {
          const chunks: Buffer[] = [];
          for await (const c of req) chunks.push(c as Buffer);
          const raw = Buffer.concat(chunks).toString('utf-8');
          try { body = raw ? JSON.parse(raw) : {}; } catch { body = {}; }
        }

        const result = await handleRequest({
          method: req.method ?? 'GET', pathname: u.pathname, tokenOk, body, cwd: opts.cwd,
          renderHtml: () => opts.buildHtml(token), getState: opts.getState,
        });
        res.writeHead(result.status, { 'content-type': result.contentType, 'cache-control': 'no-store' });
        res.end(result.body);
      } catch (e: any) {
        res.writeHead(500, { 'content-type': 'application/json' });
        res.end(JSON.stringify({ ok: false, message: e?.message ?? 'error' }));
      }
    })();
  });

  await new Promise<void>((resolve, reject) => {
    server.once('error', reject);
    server.listen(opts.preferredPort ?? 0, '127.0.0.1', () => resolve());
  });
  const addr = server.address();
  const port = typeof addr === 'object' && addr ? addr.port : (opts.preferredPort ?? 0);
  return {
    port, token,
    url: `http://127.0.0.1:${port}/?k=${token}`,
    close: () => new Promise<void>(r => server.close(() => r())),
  };
}