chore(release): cut 0.1.72

CHANGELOG.md

@@ -1,5 +1,15 @@
 # Changelog
 
+## 0.1.72 - 2026-05-10
+
+### Fixed
+
+- **Codex approval prompts no longer hang.** Fixes a regression introduced in 0.1.70 where Codex agents would wait forever on command and file approvals — the prompt never reached the app and the agent stayed stuck in "running". ([#866](https://github.com/getpaseo/paseo/pull/866), [#869](https://github.com/getpaseo/paseo/pull/869))
+- **Windows: daemon no longer crashes when Codex emits non-JSON output.** Localized stdout lines from the Codex CLI are now ignored instead of taking down the daemon worker. ([#866](https://github.com/getpaseo/paseo/pull/866))
+- Drag-and-drop images onto the new workspace screen now works. ([#850](https://github.com/getpaseo/paseo/pull/850))
+- Archiving a worktree from the toolbar redirects you immediately instead of leaving you on the dead screen for a beat. ([#852](https://github.com/getpaseo/paseo/pull/852))
+- Pi-backed sessions now shut down cleanly when you close them, releasing extension resources on the Pi side. ([#863](https://github.com/getpaseo/paseo/pull/863))
+
 ## 0.1.71 - 2026-05-09
 
 ### Added

package-lock.json

@@ -1,12 +1,12 @@
 {
   "name": "paseo",
-  "version": "0.1.71",
+  "version": "0.1.72",
   "lockfileVersion": 3,
   "requires": true,
   "packages": {
     "": {
       "name": "paseo",
-      "version": "0.1.71",
+      "version": "0.1.72",
       "hasInstallScript": true,
       "license": "AGPL-3.0-or-later",
       "workspaces": [
@@ -38854,7 +38854,7 @@
     },
     "packages/app": {
       "name": "@getpaseo/app",
-      "version": "0.1.71",
+      "version": "0.1.72",
       "dependencies": {
         "@dnd-kit/core": "^6.3.1",
         "@dnd-kit/sortable": "^10.0.0",
@@ -38980,10 +38980,10 @@
     },
     "packages/cli": {
       "name": "@getpaseo/cli",
-      "version": "0.1.71",
+      "version": "0.1.72",
       "dependencies": {
         "@clack/prompts": "^1.0.0",
-        "@getpaseo/server": "0.1.71",
+        "@getpaseo/server": "0.1.72",
         "chalk": "^5.3.0",
         "commander": "^12.0.0",
         "mime-types": "^2.1.35",
@@ -39026,7 +39026,7 @@
     },
     "packages/desktop": {
       "name": "@getpaseo/desktop",
-      "version": "0.1.71",
+      "version": "0.1.72",
       "license": "AGPL-3.0-or-later",
       "dependencies": {
         "@getpaseo/cli": "*",
@@ -39075,7 +39075,7 @@
     },
     "packages/expo-two-way-audio": {
       "name": "@getpaseo/expo-two-way-audio",
-      "version": "0.1.71",
+      "version": "0.1.72",
       "license": "MIT",
       "devDependencies": {
         "@types/react": "^18.0.25",
@@ -39111,7 +39111,7 @@
     },
     "packages/highlight": {
       "name": "@getpaseo/highlight",
-      "version": "0.1.71",
+      "version": "0.1.72",
       "dependencies": {
         "@lezer/common": "^1.5.0",
         "@lezer/cpp": "^1.1.5",
@@ -39137,7 +39137,7 @@
     },
     "packages/relay": {
       "name": "@getpaseo/relay",
-      "version": "0.1.71",
+      "version": "0.1.72",
       "dependencies": {
         "base64-js": "^1.5.1",
         "tweetnacl": "^1.0.3",
@@ -39152,12 +39152,12 @@
     },
     "packages/server": {
       "name": "@getpaseo/server",
-      "version": "0.1.71",
+      "version": "0.1.72",
       "dependencies": {
         "@agentclientprotocol/sdk": "^0.17.1",
         "@anthropic-ai/claude-agent-sdk": "^0.2.133",
-        "@getpaseo/highlight": "0.1.71",
-        "@getpaseo/relay": "0.1.71",
+        "@getpaseo/highlight": "0.1.72",
+        "@getpaseo/relay": "0.1.72",
         "@isaacs/ttlcache": "^2.1.4",
         "@mariozechner/pi-agent-core": "^0.70.2",
         "@mariozechner/pi-ai": "^0.70.2",
@@ -39691,7 +39691,7 @@
     },
     "packages/website": {
       "name": "@getpaseo/website",
-      "version": "0.1.71",
+      "version": "0.1.72",
       "dependencies": {
         "@cloudflare/vite-plugin": "^1.29.1",
         "@cloudflare/workers-types": "^4.20260317.1",

package.json

@@ -1,6 +1,6 @@
 {
   "name": "paseo",
-  "version": "0.1.71",
+  "version": "0.1.72",
   "private": true,
   "description": "Paseo: voice-controlled development environment with OpenAI Realtime API",
   "keywords": [

packages/app/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@getpaseo/app",
-  "version": "0.1.71",
+  "version": "0.1.72",
   "private": true,
   "main": "index.ts",
   "scripts": {

packages/cli/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@getpaseo/cli",
-  "version": "0.1.71",
+  "version": "0.1.72",
   "description": "Paseo CLI - control your AI coding agents from the command line",
   "bin": {
     "paseo": "bin/paseo"
@@ -24,7 +24,7 @@
   },
   "dependencies": {
     "@clack/prompts": "^1.0.0",
-    "@getpaseo/server": "0.1.71",
+    "@getpaseo/server": "0.1.72",
     "chalk": "^5.3.0",
     "commander": "^12.0.0",
     "mime-types": "^2.1.35",

packages/desktop/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@getpaseo/desktop",
-  "version": "0.1.71",
+  "version": "0.1.72",
   "private": true,
   "description": "Paseo desktop app (Electron wrapper)",
   "homepage": "https://paseo.sh",

packages/expo-two-way-audio/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@getpaseo/expo-two-way-audio",
-  "version": "0.1.71",
+  "version": "0.1.72",
   "description": "Native module for two way audio streaming",
   "keywords": [
     "ExpoTwoWayAudio",

packages/highlight/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@getpaseo/highlight",
-  "version": "0.1.71",
+  "version": "0.1.72",
   "files": [
     "dist"
   ],

packages/relay/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@getpaseo/relay",
-  "version": "0.1.71",
+  "version": "0.1.72",
   "description": "Paseo relay for bridging daemon and client connections",
   "files": [
     "dist"

packages/server/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@getpaseo/server",
-  "version": "0.1.71",
+  "version": "0.1.72",
   "description": "Paseo backend server",
   "files": [
     "dist/server",
@@ -58,8 +58,8 @@
   "dependencies": {
     "@agentclientprotocol/sdk": "^0.17.1",
     "@anthropic-ai/claude-agent-sdk": "^0.2.133",
-    "@getpaseo/highlight": "0.1.71",
-    "@getpaseo/relay": "0.1.71",
+    "@getpaseo/highlight": "0.1.72",
+    "@getpaseo/relay": "0.1.72",
     "@isaacs/ttlcache": "^2.1.4",
     "@mariozechner/pi-agent-core": "^0.70.2",
     "@mariozechner/pi-ai": "^0.70.2",

packages/server/src/server/agent/providers/codex-app-server-agent.test.ts

@@ -1,9 +1,11 @@
 import { describe, expect, test, vi } from "vitest";
 import type { ChildProcessWithoutNullStreams } from "node:child_process";
+import { EventEmitter } from "node:events";
 import { existsSync, mkdirSync, rmSync, writeFileSync } from "node:fs";
 import { mkdtemp } from "node:fs/promises";
 import { tmpdir } from "node:os";
 import path from "node:path";
+import { PassThrough } from "node:stream";
 
 import type {
   AgentLaunchContext,
@@ -16,10 +18,6 @@ import {
   CodexAppServerAgentClient,
   codexAppServerTurnInputFromPrompt,
 } from "./codex-app-server-agent.js";
-import {
-  createCodexAppServerChildProcessStub,
-  TestCodexAppServerPeer,
-} from "./codex/test-utils/test-app-server-peer.js";
 import { createTestLogger } from "../../../test-utils/test-logger.js";
 import { asInternals as castInternals, createStub } from "../../test-utils/class-mocks.js";
 
@@ -100,32 +98,120 @@ function markdownImageSource(markdown: string): string {
   return match[1].replace(/\\\)/g, ")");
 }
 
-function waitForNextPermission(
-  session: AgentSession,
-  events: AgentStreamEvent[],
-): Promise<Extract<AgentStreamEvent, { type: "permission_requested" }>> {
-  const existing = events.find(
-    (event): event is Extract<AgentStreamEvent, { type: "permission_requested" }> =>
-      event.type === "permission_requested",
-  );
-  if (existing) {
-    return Promise.resolve(existing);
-  }
+function createChildProcessStub(): ChildProcessWithoutNullStreams {
+  const child = new EventEmitter() as ChildProcessWithoutNullStreams;
+  child.stdin = new PassThrough() as ChildProcessWithoutNullStreams["stdin"];
+  child.stdout = new PassThrough() as ChildProcessWithoutNullStreams["stdout"];
+  child.stderr = new PassThrough() as ChildProcessWithoutNullStreams["stderr"];
+  child.exitCode = null;
+  child.signalCode = null;
+  child.kill = vi.fn((signal?: NodeJS.Signals | number) => {
+    queueMicrotask(() => child.emit("exit", null, signal ?? null));
+    return true;
+  }) as ChildProcessWithoutNullStreams["kill"];
+  return child;
+}
 
-  return new Promise((resolve, reject) => {
-    const timeout = setTimeout(() => {
-      unsubscribe();
-      reject(new Error("Timed out waiting for permission_requested"));
-    }, 1000);
-    const unsubscribe = session.subscribe((event) => {
-      if (event.type !== "permission_requested") {
-        return;
+function createScriptedCodexPeer(
+  child: ChildProcessWithoutNullStreams,
+  handlers: Record<string, (params: unknown) => unknown>,
+) {
+  const messages: Record<string, unknown>[] = [];
+  const errors: Error[] = [];
+  const waiters = new Set<{
+    predicate: (message: Record<string, unknown>) => boolean;
+    resolve: (message: Record<string, unknown>) => void;
+  }>();
+  let buffer = "";
+
+  const processMessage = (message: Record<string, unknown>) => {
+    messages.push(message);
+    for (const waiter of Array.from(waiters)) {
+      if (waiter.predicate(message)) {
+        waiters.delete(waiter);
+        waiter.resolve(message);
       }
-      clearTimeout(timeout);
-      unsubscribe();
-      resolve(event);
-    });
+    }
+
+    if (typeof message.id !== "number" || typeof message.method !== "string") {
+      return;
+    }
+
+    const handler = handlers[message.method];
+    if (!handler) {
+      errors.push(new Error(`Unexpected Codex app-server request: ${message.method}`));
+      return;
+    }
+
+    Promise.resolve(handler(message.params))
+      .then((result) => {
+        child.stdout.write(`${JSON.stringify({ id: message.id, result })}\n`);
+        return undefined;
+      })
+      .catch((error) => {
+        child.stdout.write(
+          `${JSON.stringify({
+            id: message.id,
+            error: { message: error instanceof Error ? error.message : String(error) },
+          })}\n`,
+        );
+        return undefined;
+      });
+  };
+
+  child.stdin.on("data", (chunk) => {
+    buffer += chunk.toString();
+    for (;;) {
+      const newlineIndex = buffer.indexOf("\n");
+      if (newlineIndex === -1) {
+        break;
+      }
+      const line = buffer.slice(0, newlineIndex).trim();
+      buffer = buffer.slice(newlineIndex + 1);
+      if (!line) {
+        continue;
+      }
+      try {
+        const parsed: unknown = JSON.parse(line);
+        if (parsed && typeof parsed === "object" && !Array.isArray(parsed)) {
+          processMessage(parsed as Record<string, unknown>);
+        }
+      } catch (error) {
+        errors.push(error instanceof Error ? error : new Error(String(error)));
+      }
+    }
   });
+
+  return {
+    assertNoErrors() {
+      if (errors.length > 0) {
+        throw errors[0];
+      }
+    },
+    waitForMessage(
+      predicate: (message: Record<string, unknown>) => boolean,
+      label: string,
+    ): Promise<Record<string, unknown>> {
+      const existing = messages.find(predicate);
+      if (existing) {
+        return Promise.resolve(existing);
+      }
+      return new Promise((resolve, reject) => {
+        const timeout = setTimeout(() => {
+          waiters.delete(waiter);
+          reject(new Error(`Timed out waiting for ${label}`));
+        }, 1000);
+        const waiter = {
+          predicate,
+          resolve: (message: Record<string, unknown>) => {
+            clearTimeout(timeout);
+            resolve(message);
+          },
+        };
+        waiters.add(waiter);
+      });
+    },
+  };
 }
 
 describe("Codex app-server provider", () => {
@@ -191,15 +277,21 @@ describe("Codex app-server provider", () => {
 
   test("disposes an unresponsive app-server child with SIGKILL", async () => {
     vi.useFakeTimers();
-    const child = createCodexAppServerChildProcessStub({ exitOnKill: false });
+    const child = new EventEmitter() as ChildProcessWithoutNullStreams;
+    child.stdin = new PassThrough() as ChildProcessWithoutNullStreams["stdin"];
+    child.stdout = new PassThrough() as ChildProcessWithoutNullStreams["stdout"];
+    child.stderr = new PassThrough() as ChildProcessWithoutNullStreams["stderr"];
+    child.exitCode = null;
+    child.signalCode = null;
+    child.kill = vi.fn(() => true) as ChildProcessWithoutNullStreams["kill"];
     const client = new __codexAppServerInternals.CodexAppServerClient(child, createTestLogger());
 
     try {
       const disposePromise = client.dispose();
-      expect(child.killSignals).toEqual(["SIGTERM"]);
+      expect(child.kill).toHaveBeenCalledWith("SIGTERM");
 
       await vi.advanceTimersByTimeAsync(2_000);
-      expect(child.killSignals).toEqual(["SIGTERM", "SIGKILL"]);
+      expect(child.kill).toHaveBeenCalledWith("SIGKILL");
 
       await vi.advanceTimersByTimeAsync(1_000);
       await expect(disposePromise).resolves.toBeUndefined();
@@ -209,7 +301,8 @@ describe("Codex app-server provider", () => {
   });
 
   test("round-trips server-initiated command approvals through the real app-server transport", async () => {
-    const peer = new TestCodexAppServerPeer({
+    const child = createChildProcessStub();
+    const peer = createScriptedCodexPeer(child, {
       initialize: () => ({}),
       "collaborationMode/list": () => ({ data: [] }),
       "skills/list": () => ({ data: [] }),
@@ -218,7 +311,7 @@ describe("Codex app-server provider", () => {
       createConfig({ cwd: "/workspace/project" }),
       null,
       createTestLogger(),
-      async () => peer.child,
+      async () => child,
     );
     const events: AgentStreamEvent[] = [];
     session.subscribe((event) => events.push(event));
@@ -226,19 +319,45 @@ describe("Codex app-server provider", () => {
     await session.connect();
     peer.assertNoErrors();
 
-    const permissionRequested = waitForNextPermission(session, events);
+    const permissionRequested = new Promise<
+      Extract<AgentStreamEvent, { type: "permission_requested" }>
+    >((resolve, reject) => {
+      const existing = events.find(
+        (event): event is Extract<AgentStreamEvent, { type: "permission_requested" }> =>
+          event.type === "permission_requested",
+      );
+      if (existing) {
+        resolve(existing);
+        return;
+      }
+      const timeout = setTimeout(() => {
+        unsubscribe();
+        reject(new Error("Timed out waiting for permission_requested"));
+      }, 1000);
+      const unsubscribe = session.subscribe((event) => {
+        if (event.type !== "permission_requested") {
+          return;
+        }
+        clearTimeout(timeout);
+        unsubscribe();
+        resolve(event);
+      });
+    });
 
-    peer.writeRequest(
-      "item/commandExecution/requestApproval",
-      {
-        itemId: "exec-approval-1",
-        threadId: "thread-1",
-        turnId: "turn-1",
-        command: "git restore README.md",
-        cwd: "/workspace/project",
-        reason: "requires escalated permissions",
-      },
-      41,
+    child.stdout.write(
+      `${JSON.stringify({
+        jsonrpc: "2.0",
+        id: 41,
+        method: "item/commandExecution/requestApproval",
+        params: {
+          itemId: "exec-approval-1",
+          threadId: "thread-1",
+          turnId: "turn-1",
+          command: "git restore README.md",
+          cwd: "/workspace/project",
+          reason: "requires escalated permissions",
+        },
+      })}\n`,
     );
 
     const permissionEvent = await permissionRequested;
@@ -262,7 +381,15 @@ describe("Codex app-server provider", () => {
 
     await session.respondToPermission(permissionEvent.request.id, { behavior: "allow" });
 
-    await expect(peer.waitForResponse(41, { decision: "accept" })).resolves.toMatchObject({
+    await expect(
+      peer.waitForMessage(
+        (message) =>
+          message.id === 41 &&
+          !("method" in message) &&
+          JSON.stringify(message.result) === JSON.stringify({ decision: "accept" }),
+        "command approval response",
+      ),
+    ).resolves.toMatchObject({
       id: 41,
       result: { decision: "accept" },
     });
@@ -280,12 +407,8 @@ describe("Codex app-server provider", () => {
       path.join(repoSkillDir, "SKILL.md"),
       "---\nname: shipper\ndescription: Ship changes carefully.\n---\n",
     );
-    const resolvedRepoRoots: string[] = [];
     const workspaceGitService = {
-      resolveRepoRoot: async (pathToResolve: string) => {
-        resolvedRepoRoots.push(pathToResolve);
-        return path.join(tempDir, "repo");
-      },
+      resolveRepoRoot: vi.fn().mockResolvedValue(path.join(tempDir, "repo")),
     };
 
     try {
@@ -296,7 +419,7 @@ describe("Codex app-server provider", () => {
         description: "Ship changes carefully.",
         argumentHint: "",
       });
-      expect(resolvedRepoRoots).toEqual([cwd]);
+      expect(workspaceGitService.resolveRepoRoot).toHaveBeenCalledWith(cwd);
     } finally {
       rmSync(tempDir, { recursive: true, force: true });
     }
@@ -1790,7 +1913,14 @@ describe("Codex persisted sessions", () => {
     castInternals<{ spawnAppServer: () => Promise<ChildProcessWithoutNullStreams> }>(
       provider,
     ).spawnAppServer = async () => {
-      return createCodexAppServerChildProcessStub();
+      const child = new EventEmitter() as ChildProcessWithoutNullStreams;
+      child.exitCode = 0;
+      child.signalCode = null;
+      child.stdin = new PassThrough();
+      child.stdout = new PassThrough();
+      child.stderr = new PassThrough();
+      child.kill = vi.fn(() => true) as ChildProcessWithoutNullStreams["kill"];
+      return child;
     };
 
     const descriptors = await provider.listPersistedAgents({ cwd: "/workspace/project-a" });

packages/server/src/server/agent/providers/codex/app-server-transport.test.ts

@@ -1,20 +1,35 @@
+import type { ChildProcessWithoutNullStreams } from "node:child_process";
+import { EventEmitter } from "node:events";
+import { PassThrough } from "node:stream";
 import { describe, expect, test } from "vitest";
 
 import { createTestLogger } from "../../../../test-utils/test-logger.js";
 import { CodexAppServerClient } from "./app-server-transport.js";
-import { TestCodexAppServerPeer } from "./test-utils/test-app-server-peer.js";
+
+function createChildProcessStub(): ChildProcessWithoutNullStreams {
+  const child = new EventEmitter() as ChildProcessWithoutNullStreams;
+  child.stdin = new PassThrough() as ChildProcessWithoutNullStreams["stdin"];
+  child.stdout = new PassThrough() as ChildProcessWithoutNullStreams["stdout"];
+  child.stderr = new PassThrough() as ChildProcessWithoutNullStreams["stderr"];
+  child.exitCode = null;
+  child.signalCode = null;
+  child.kill = (() => true) as ChildProcessWithoutNullStreams["kill"];
+  return child;
+}
 
 describe("Codex app-server transport", () => {
   test("ignores non-JSON stdout lines without dropping pending requests", async () => {
-    const peer = new TestCodexAppServerPeer();
-    const client = new CodexAppServerClient(peer.child, createTestLogger());
+    const child = createChildProcessStub();
+    const client = new CodexAppServerClient(child, createTestLogger());
 
     const request = client.request("model/list", {});
-    peer.writeNonJsonStdout("Codex ha iniciado en modo localizado");
-    peer.writeResponse(1, { data: [] });
+    child.stdout.write("Codex ha iniciado en modo localizado\n");
+    child.stdout.write('{"id":1,"result":{"data":[]}}\n');
 
     await expect(request).resolves.toEqual({ data: [] });
-    peer.close();
+    child.stdout.end();
+    child.stderr.end();
+    child.stdin.end();
   });
 
   test.each([
@@ -23,19 +38,23 @@ describe("Codex app-server transport", () => {
     "item/tool/requestUserInput",
     "tool/requestUserInput",
   ])("answers server-initiated %s requests through registered handlers", async (method) => {
-    const peer = new TestCodexAppServerPeer();
-    const client = new CodexAppServerClient(peer.child, createTestLogger());
+    const child = createChildProcessStub();
+    const client = new CodexAppServerClient(child, createTestLogger());
     const handlerCalls: unknown[] = [];
     client.setRequestHandler(method, async (params) => {
       handlerCalls.push(params);
       return { ok: true };
     });
 
-    const response = peer.nextPaseoOutputLine();
-    peer.writeRequest(method);
+    const response = new Promise<string>((resolve) => {
+      child.stdin.once("data", (chunk) => resolve(chunk.toString()));
+    });
+    child.stdout.write(`${JSON.stringify({ jsonrpc: "2.0", id: 7, method, params: {} })}\n`);
 
     await expect(response).resolves.toBe('{"id":7,"result":{"ok":true}}\n');
     expect(handlerCalls).toEqual([{}]);
-    peer.close();
+    child.stdout.end();
+    child.stderr.end();
+    child.stdin.end();
   });
 });

packages/server/src/server/agent/providers/codex/test-utils/test-app-server-peer.ts

@@ -1,183 +0,0 @@
-import type { ChildProcessWithoutNullStreams } from "node:child_process";
-import { EventEmitter } from "node:events";
-import { PassThrough } from "node:stream";
-import { isDeepStrictEqual } from "node:util";
-
-interface JsonRecord {
-  [key: string]: unknown;
-}
-
-type RequestHandler = (params: unknown) => unknown;
-type StubbedCodexAppServerChildProcess = ChildProcessWithoutNullStreams & {
-  stdin: PassThrough;
-  stdout: PassThrough;
-  stderr: PassThrough;
-  killSignals: Array<NodeJS.Signals | number | null>;
-};
-
-function isJsonRecord(value: unknown): value is JsonRecord {
-  return value != null && typeof value === "object" && !Array.isArray(value);
-}
-
-function parseJsonLine(line: string): JsonRecord | null {
-  const parsed: unknown = JSON.parse(line);
-  return isJsonRecord(parsed) ? parsed : null;
-}
-
-export function createCodexAppServerChildProcessStub(
-  options: { exitOnKill?: boolean } = {},
-): StubbedCodexAppServerChildProcess {
-  const child = new EventEmitter() as StubbedCodexAppServerChildProcess;
-  child.stdin = new PassThrough();
-  child.stdout = new PassThrough();
-  child.stderr = new PassThrough();
-  child.killSignals = [];
-  Object.defineProperty(child, "exitCode", { value: null, configurable: true });
-  Object.defineProperty(child, "signalCode", { value: null, configurable: true });
-  child.kill = ((signal?: NodeJS.Signals | number) => {
-    child.killSignals.push(signal ?? null);
-    if (options.exitOnKill !== false) {
-      queueMicrotask(() => child.emit("exit", null, signal ?? null));
-    }
-    return true;
-  }) as ChildProcessWithoutNullStreams["kill"];
-  return child;
-}
-
-export class TestCodexAppServerPeer {
-  readonly child: StubbedCodexAppServerChildProcess;
-  private readonly messages: JsonRecord[] = [];
-  private readonly errors: Error[] = [];
-  private readonly waiters = new Set<{
-    predicate: (message: JsonRecord) => boolean;
-    resolve: (message: JsonRecord) => void;
-  }>();
-  private buffer = "";
-
-  constructor(handlers: Record<string, RequestHandler> = {}) {
-    this.child = createCodexAppServerChildProcessStub();
-    this.child.stdin.on("data", (chunk) => {
-      this.acceptPaseoOutput(chunk.toString(), handlers);
-    });
-  }
-
-  writeNonJsonStdout(line: string): void {
-    this.child.stdout.write(`${line}\n`);
-  }
-
-  writeResponse(id: number, result: unknown): void {
-    this.child.stdout.write(`${JSON.stringify({ id, result })}\n`);
-  }
-
-  writeRequest(method: string, params: unknown = {}, id = 7): void {
-    this.child.stdout.write(`${JSON.stringify({ jsonrpc: "2.0", id, method, params })}\n`);
-  }
-
-  nextPaseoOutputLine(): Promise<string> {
-    return new Promise((resolve) => {
-      this.child.stdin.once("data", (chunk) => resolve(chunk.toString()));
-    });
-  }
-
-  async waitForResponse(id: number, result: unknown): Promise<JsonRecord> {
-    return this.waitForMessage(
-      (message) =>
-        message.id === id && !("method" in message) && isDeepStrictEqual(message.result, result),
-      `response ${id}`,
-    );
-  }
-
-  assertNoErrors(): void {
-    if (this.errors.length > 0) {
-      throw this.errors[0];
-    }
-  }
-
-  close(): void {
-    this.child.stdout.end();
-    this.child.stderr.end();
-    this.child.stdin.end();
-  }
-
-  private acceptPaseoOutput(chunk: string, handlers: Record<string, RequestHandler>): void {
-    this.buffer += chunk;
-    for (;;) {
-      const newlineIndex = this.buffer.indexOf("\n");
-      if (newlineIndex === -1) {
-        break;
-      }
-      const line = this.buffer.slice(0, newlineIndex).trim();
-      this.buffer = this.buffer.slice(newlineIndex + 1);
-      if (!line) {
-        continue;
-      }
-      try {
-        const message = parseJsonLine(line);
-        if (message) {
-          this.processPaseoMessage(message, handlers);
-        }
-      } catch (error) {
-        this.errors.push(error instanceof Error ? error : new Error(String(error)));
-      }
-    }
-  }
-
-  private processPaseoMessage(message: JsonRecord, handlers: Record<string, RequestHandler>): void {
-    this.messages.push(message);
-    for (const waiter of Array.from(this.waiters)) {
-      if (waiter.predicate(message)) {
-        this.waiters.delete(waiter);
-        waiter.resolve(message);
-      }
-    }
-
-    if (typeof message.id !== "number" || typeof message.method !== "string") {
-      return;
-    }
-
-    const handler = handlers[message.method];
-    if (!handler) {
-      this.errors.push(new Error(`Unexpected Codex app-server request: ${message.method}`));
-      return;
-    }
-
-    Promise.resolve(handler(message.params))
-      .then((result) => {
-        this.writeResponse(message.id as number, result);
-        return undefined;
-      })
-      .catch((error) => {
-        this.child.stdout.write(
-          `${JSON.stringify({
-            id: message.id,
-            error: { message: error instanceof Error ? error.message : String(error) },
-          })}\n`,
-        );
-        return undefined;
-      });
-  }
-
-  private waitForMessage(
-    predicate: (message: JsonRecord) => boolean,
-    label: string,
-  ): Promise<JsonRecord> {
-    const existing = this.messages.find(predicate);
-    if (existing) {
-      return Promise.resolve(existing);
-    }
-    return new Promise((resolve, reject) => {
-      const timeout = setTimeout(() => {
-        this.waiters.delete(waiter);
-        reject(new Error(`Timed out waiting for ${label}`));
-      }, 1000);
-      const waiter = {
-        predicate,
-        resolve: (message: JsonRecord) => {
-          clearTimeout(timeout);
-          resolve(message);
-        },
-      };
-      this.waiters.add(waiter);
-    });
-  }
-}

packages/website/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@getpaseo/website",
-  "version": "0.1.71",
+  "version": "0.1.72",
   "private": true,
   "type": "module",
   "scripts": {