Function withLocalServer

e2e/local/local-server.ts:38–123

(
  cli: CliSurface,
  runDir: string,
  body: (server: ServerHandle) => Effect.Effect<void>,
  options?: {
    /** Extra env merged into the `executor web` process, e.g. to force a
     *  published-version signal for the update check. */
    readonly env?: Record<string, string>;
  },
)

 * server.
 */
export const withLocalServer = (
  cli: CliSurface,
  runDir: string,
  body: (server: ServerHandle) => Effect.Effect<void>,
  options?: {
    /** Extra env merged into the `executor web` process, e.g. to force a
     *  published-version signal for the update check. */
    readonly env?: Record<string, string>;
  },
): Effect.Effect<void> =>
  Effect.gen(function* () {
    const dataDir = mkdtempSync(join(tmpdir(), "executor-local-e2e-"));

    let publishUrl!: (url: string) => void;
    const urlReady = new Promise<string>((res) => {
      publishUrl = res;
    });
    let signalBodyDone!: () => void;
    const bodyDone = new Promise<void>((res) => {
      signalBodyDone = res;
    });

    yield* Effect.all(
      [
        cli.session(
          ["bun", "run", "dev:cli", "web", "--foreground", "--port", "0"],
          async (term) => {
            markRecordingStart(runDir, "terminal");
            markFocus(runDir, "terminal");
            // Capture the latest rendered screen on every poll so a boot that
            // never prints the URL is still diagnosable: `waitUntil` rejects
            // with a tail-less "timed out" on its deadline, so without this the
            // failure tells us nothing about how far boot actually got.
            let lastText = "";
            const snapshot = await term.screen
              .waitUntil(
                (current) => {
                  lastText = current.text;
                  return TOKEN_URL.test(current.text);
                },
                // A cold `executor web` runs vite's optimizeDeps before it prints
                // the URL; 240s leaves headroom for isolated CI cold boots. Kept
                // BELOW each scenario's test timeout (300s) so that on a slow or
                // wedged boot THIS error surfaces, with the terminal tail, rather
                // than racing vitest's generic timeout at the same deadline.
                { timeoutMs: 240_000 },
              )
              .catch((cause: unknown) => {
                throw new Error(
                  `executor web --foreground printed no ?_token URL within 240s (${String(cause)}):\n${lastText.slice(-600)}`,
                );
              });
            const url = TOKEN_URL.exec(snapshot.text)?.[0];
            if (!url) {
              throw new Error(
                `executor web --foreground printed no ?_token URL:\n${snapshot.text.slice(-600)}`,
              );
            }