Function deskTheater

e2e/src/clients/chat-theater.ts:177–217

(
  options: TheaterOptions,
  body: (theater: ChatTheater) => Effect.Effect<A, E, R>,
)

// ---------------------------------------------------------------------------

const deskTheater = <A, E, R>(
  options: TheaterOptions,
  body: (theater: ChatTheater) => Effect.Effect<A, E, R>,
): Effect.Effect<A, E, R> =>
  Effect.gen(function* () {
    const root = mkdtempSync(join(tmpdir(), "desk-theater-"));
    const fifo = join(root, "events.fifo");
    spawnSync("mkfifo", [fifo]);

    const xterm = spawn(
      "xterm",
      [
        // -u8 + a UTF-8 locale: the renderer speaks box-drawing and bullets.
        ...["-u8", "-fa", "DejaVu Sans Mono", "-fs", "13"],
        ...["-bg", "#0b0b10", "-fg", "#e8e8ea"],
        ...["-geometry", "112x34+48+40", "-T", options.title],
        ...["-e", "bun", RENDERER, options.title, fifo],
      ],
      { stdio: "ignore", env: { ...process.env, LANG: "C.UTF-8", LC_ALL: "C.UTF-8" } },
    );
    // Opening the write end parks until the renderer opens the read end.
    const writer = createWriteStream(fifo);
    const push = (event: TheaterEvent) =>
      Effect.sync(() => {
        writer.write(encode(event));
      });

    const result = yield* Effect.exit(body(makeTheater(push)));
    yield* push({ type: "done" });
    yield* Effect.promise(async () => {
      // Renderer acks the footer, lingers for the camera, then exits with
      // its xterm. Don't hang the run on a wedged terminal.
      const ackDeadline = Date.now() + 30_000;
      while (!existsSync(`${fifo}.done`) && Date.now() < ackDeadline) await sleep(200);
      const exitDeadline = Date.now() + 10_000;
      while (xterm.exitCode === null && Date.now() < exitDeadline) await sleep(200);
      if (xterm.exitCode === null) xterm.kill();
      writer.end();
    });
    return yield* result;
  });