From 996598e78cf261bae1f249af01ea9d23ac6bd15e Mon Sep 17 00:00:00 2001
From: Alex Alecu <a.marian.alexandru@gmail.com>
Date: Thu, 26 Feb 2026 13:49:20 +0200
Subject: [PATCH] fix(tui): allow terminateWorker retries after failure

---
 packages/opencode/src/cli/cmd/tui/thread.ts | 27 ++++++++++++++++++---
 1 file changed, 23 insertions(+), 4 deletions(-)

diff --git a/packages/opencode/src/cli/cmd/tui/thread.ts b/packages/opencode/src/cli/cmd/tui/thread.ts
index 0321233ec5f..814c6ce4c6d 100644
--- a/packages/opencode/src/cli/cmd/tui/thread.ts
+++ b/packages/opencode/src/cli/cmd/tui/thread.ts
@@ -141,14 +141,33 @@ export const TuiThreadCommand = cmd({
       // Guard against multiple invocations (SIGHUP + SIGTERM + onExit).
       const terminateWorker = () => {
         if (shutdown.pending) return shutdown.pending
-        shutdown.pending = new Promise<void>((resolve) => {
-          worker.addEventListener("close", () => resolve(), { once: true })
+        const state = {
+          closed: false,
+        }
+        const result = new Promise<void>((resolve) => {
+          worker.addEventListener(
+            "close",
+            () => {
+              state.closed = true
+              resolve()
+            },
+            { once: true },
+          )
           setTimeout(resolve, 5000).unref()
           client.call("shutdown", undefined).catch((error) => {
             Log.Default.debug("worker shutdown RPC failed", { error })
           })
-        }).then(() => worker.terminate())
-        return shutdown.pending
+        }).then(async () => {
+          if (state.closed) return
+          await Promise.resolve()
+            .then(() => worker.terminate())
+            .catch((error) => {
+              shutdown.pending = undefined
+              Log.Default.debug("worker terminate failed", { error })
+            })
+        })
+        shutdown.pending = result
+        return result
       }
       const shutdownAndExit = (input: { reason: string; code: number; signal?: NodeJS.Signals }) => {
         if (shutdown.exiting) return