fix(agents): terminate ripgrep child on stdout/stderr stream errors

cxbAsDev · cxbAsDev · commit 5e0a53024757 · 2026-07-07T02:03:51.000+08:00
diff --git a/src/agents/sessions/tools/grep.stream-errors.test.ts b/src/agents/sessions/tools/grep.stream-errors.test.ts
@@ -49,6 +49,7 @@ describe("grep tool stream errors", () => {
     child.stdout.emit("error", new Error("stdout EPIPE"));
 
     await expect(resultPromise).rejects.toThrow("stdout EPIPE");
+    expect(child.killed).toBe(true);
   });
 
   it("rejects when stderr emits an error", async () => {
@@ -68,5 +69,6 @@ describe("grep tool stream errors", () => {
     child.stderr.emit("error", new Error("stderr EPIPE"));
 
     await expect(resultPromise).rejects.toThrow("stderr EPIPE");
+    expect(child.killed).toBe(true);
   });
 });
diff --git a/src/agents/sessions/tools/grep.ts b/src/agents/sessions/tools/grep.ts
@@ -267,10 +267,12 @@ export function createGrepToolDefinition(
               stderr = appendBoundedTextTail(stderr, chunk);
             });
             child.stdout?.on("error", (error) => {
+              stopChild();
               cleanup();
               settle(() => reject(new Error(`ripgrep stdout error: ${error.message}`)));
             });
             child.stderr?.on("error", (error) => {
+              stopChild();
               cleanup();
               settle(() => reject(new Error(`ripgrep stderr error: ${error.message}`)));
             });
