fix(codex): close app-server client on stdio stream errors

mushuiyu886 · mushuiyu886 · commit ec64376be6a3 · 2026-07-07T16:34:41.000+08:00
diff --git a/extensions/codex/src/app-server/client.test.ts b/extensions/codex/src/app-server/client.test.ts
@@ -422,6 +422,32 @@ describe("CodexAppServerClient", () => {
     await expect(harness.client.request("another/method")).rejects.toThrow("write EPIPE");
   });
 
+  it("handles stdout stream errors without crashing the process", async () => {
+    const harness = createClientHarness();
+    clients.push(harness.client);
+
+    const pending = harness.client.request("test/method");
+    const readError = Object.assign(new Error("stdout pipe broke"), { code: "EIO" });
+
+    expect(() => harness.process.stdout.emit("error", readError)).not.toThrow();
+
+    await expect(pending).rejects.toThrow("stdout pipe broke");
+    await expect(harness.client.request("another/method")).rejects.toThrow("stdout pipe broke");
+  });
+
+  it("handles stderr stream errors without crashing the process", async () => {
+    const harness = createClientHarness();
+    clients.push(harness.client);
+
+    const pending = harness.client.request("test/method");
+    const stderrError = Object.assign(new Error("stderr pipe broke"), { code: "EIO" });
+
+    expect(() => harness.process.stderr.emit("error", stderrError)).not.toThrow();
+
+    await expect(pending).rejects.toThrow("stderr pipe broke");
+    await expect(harness.client.request("another/method")).rejects.toThrow("stderr pipe broke");
+  });
+
   it("preserves redacted app-server stderr on exit errors", async () => {
     const harness = createClientHarness();
     clients.push(harness.client);
diff --git a/extensions/codex/src/app-server/client.ts b/extensions/codex/src/app-server/client.ts
@@ -139,6 +139,12 @@ export class CodexAppServerClient {
     this.child = child;
     this.lines = createInterface({ input: child.stdout });
     this.lines.on("line", (line) => this.handleLine(line));
+    this.lines.on("error", (error) =>
+      this.closeWithError(error instanceof Error ? error : new Error(String(error))),
+    );
+    child.stdout.on("error", (error) =>
+      this.closeWithError(error instanceof Error ? error : new Error(String(error))),
+    );
     child.stderr.on("data", (chunk: Buffer | string) => {
       const text = chunk.toString("utf8");
       this.stderrTail = appendBoundedTail(this.stderrTail, text, CODEX_APP_SERVER_STDERR_TAIL_MAX);
@@ -147,6 +153,9 @@ export class CodexAppServerClient {
         embeddedAgentLog.debug(`codex app-server stderr: ${trimmed}`);
       }
     });
+    child.stderr.on("error", (error) =>
+      this.closeWithError(error instanceof Error ? error : new Error(String(error))),
+    );
     child.once("error", (error) =>
       this.closeWithError(error instanceof Error ? error : new Error(String(error))),
     );
