fix: tighten disconnect recovery guards

packages/ui/src/sync/session-actions.ts

@@ -429,6 +429,9 @@ export async function dismissPermission(
   sessionId: string,
   requestId: string,
 ): Promise<void> {
+  if (!useConfigStore.getState().isConnected) {
+    throw new Error("Connection lost. Please wait for reconnection.")
+  }
   const result = await getRequestReplyClient("permission", sessionId, requestId).permission.reply({
     requestID: requestId,
     reply: "reject",
@@ -463,6 +466,9 @@ export async function rejectQuestion(
   sessionId: string,
   requestId: string,
 ): Promise<void> {
+  if (!useConfigStore.getState().isConnected) {
+    throw new Error("Connection lost. Please wait for reconnection.")
+  }
   const result = await getRequestReplyClient("question", sessionId, requestId).question.reject({
     requestID: requestId,
   })

packages/web/server/lib/event-stream/runtime.js

@@ -10,6 +10,18 @@ import {
   sendMessageStreamWsFrame,
 } from './protocol.js';
 
+function shouldTriggerUpstreamHealthCheck(upstream) {
+  if (!upstream) {
+    return true;
+  }
+
+  if (!upstream.body) {
+    return upstream.ok || upstream.status >= 500;
+  }
+
+  return upstream.status >= 500;
+}
+
 export function createGlobalUiEventBroadcaster({
   sseClients,
   wsClients,
@@ -151,7 +163,9 @@ export function createMessageStreamWsRuntime({
           message: `OpenCode event stream unavailable (${upstream.status})`,
         });
         socket.close(1011, 'OpenCode event stream unavailable');
-        triggerHealthCheck?.();
+        if (shouldTriggerUpstreamHealthCheck(upstream)) {
+          triggerHealthCheck?.();
+        }
         return;
       }