fix(tui): handle stdin EPIPE race in chat ui

Author: Rexopia

AGENTS.md

@@ -95,6 +95,14 @@
   - in-flight wake tasks awaited with a short timeout, then aborted
   - MCP server stopped with graceful shutdown timeout fallback
 
+## TUI Pipe Safety
+
+- `crewforge-ts/src/chat/run-chat-ui.ts` must handle `child.stdin` stream errors.
+- Treat `EPIPE` and `ERR_STREAM_DESTROYED` as expected race conditions after core exit or stdin close.
+- Do not let `child.stdin.write(...)` related errors crash the launcher process.
+- Keep a regression test for this behavior in `crewforge-ts/src/tests/` whenever TUI command wiring changes.
+- Before release tags, verify local/global launcher behavior by running `npm test --prefix crewforge-ts` and checking a TTY `crewforge chat` invocation.
+
 ## Opencode + MCP Integration
 
 - Provider command is configurable (`opencode.command`, default `opencode`).

crewforge-rs/Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "crewforge"
-version = "0.2.1"
+version = "0.2.2"
 edition = "2024"
 
 [dependencies]

crewforge-rs/Cargo.toml

@@ -33,6 +33,10 @@ function withJsonlRpcFlag(args: string[]): string[] {
   return [...args, "--rpc", "jsonl"];
 }
 
+export function shouldIgnoreChildStdinError(error: NodeJS.ErrnoException): boolean {
+  return error.code === "EPIPE" || error.code === "ERR_STREAM_DESTROYED";
+}
+
 export async function runChatWithUi(binary: string, rawArgs: string[]): Promise<number> {
   const childArgs = withJsonlRpcFlag(rawArgs);
   const child = spawn(binary, childArgs, {
@@ -43,6 +47,15 @@ export async function runChatWithUi(binary: string, rawArgs: string[]): Promise<
   const state = new ChatStateStore();
   let forceExitTimer: NodeJS.Timeout | undefined;
 
+  const handleStdinError = (error: NodeJS.ErrnoException): void => {
+    if (shouldIgnoreChildStdinError(error)) {
+      return;
+    }
+    const message = error.message ?? String(error);
+    state.appendClientNotice(`[input pipe] ${message}`);
+  };
+  child.stdin?.on("error", handleStdinError);
+
   const sendCommand = (command: RpcCommand): void => {
     if (!child.stdin || child.stdin.destroyed || !child.stdin.writable) {
       return;

crewforge-ts/src/chat/run-chat-ui.ts

@@ -1,7 +1,11 @@
 import assert from "node:assert";
 import { test } from "node:test";
 
-import { encodeInputCommand, shouldUseChatUi } from "../chat/run-chat-ui";
+import {
+  encodeInputCommand,
+  shouldIgnoreChildStdinError,
+  shouldUseChatUi,
+} from "../chat/run-chat-ui";
 
 test("encodeInputCommand emits jsonl payload", () => {
   assert.strictEqual(
@@ -13,3 +17,18 @@ test("encodeInputCommand emits jsonl payload", () => {
 test("shouldUseChatUi disables UI when --rpc is explicit", () => {
   assert.strictEqual(shouldUseChatUi(["chat", "--rpc", "jsonl"]), false);
 });
+
+test("shouldIgnoreChildStdinError only suppresses expected pipe races", () => {
+  assert.strictEqual(
+    shouldIgnoreChildStdinError({ code: "EPIPE" } as NodeJS.ErrnoException),
+    true,
+  );
+  assert.strictEqual(
+    shouldIgnoreChildStdinError({ code: "ERR_STREAM_DESTROYED" } as NodeJS.ErrnoException),
+    true,
+  );
+  assert.strictEqual(
+    shouldIgnoreChildStdinError({ code: "EINVAL" } as NodeJS.ErrnoException),
+    false,
+  );
+});