fix(execution): recognise Firefox's NetworkError form as a stream drop

The transport-failure matcher only knew Chrome's "network error" with a
space, so Firefox's "NetworkError when attempting to fetch resource."
fell through as a plain failure. Now that every live stream shares this
classifier, match the browsers' known messages as patterns and cover each
form in the executor test.

Co-Authored-By: Claude Fable 5.1 <noreply@anthropic.com>

Author: icecrasher321

apps/sim/app/workspace/[workspaceId]/w/[workflowId]/utils/workflow-execution-utils.test.ts

@@ -96,29 +96,37 @@ describe('workflow-execution-utils', () => {
       return store
     }
 
-    it('classifies a transport drop after the server acknowledged the run as an interruption', async () => {
-      /*
-       * The Chat run tool only preserves a run for reconnect when it sees
-       * SSEStreamInterruptedError; a raw TypeError from the body reader used to
-       * fall through as a plain failure, reporting an error to Sim and tearing
-       * the run down while the server kept executing it.
-       */
-      const store = stubExecutionStore()
-      stubAcknowledgedStream(new TypeError('network error'))
-
-      const promise = executeWorkflowWithFullLogging({
-        workflowId: 'wf-1',
-        executionId: 'exec-1',
-        copilotToolCallId: 'tool-1',
-        preserveExecutionOnTerminal: true,
-      })
+    it.each([
+      ['Chrome', 'network error'],
+      ['Chrome before headers', 'Failed to fetch'],
+      ['Firefox', 'NetworkError when attempting to fetch resource.'],
+      ['Safari', 'Load failed'],
+    ])(
+      'classifies a %s transport drop after the server acknowledged the run as an interruption',
+      async (_browser, message) => {
+        /*
+         * The Chat run tool only preserves a run for reconnect when it sees
+         * SSEStreamInterruptedError; a raw TypeError from the body reader used to
+         * fall through as a plain failure, reporting an error to Sim and tearing
+         * the run down while the server kept executing it.
+         */
+        const store = stubExecutionStore()
+        stubAcknowledgedStream(new TypeError(message))
+
+        const promise = executeWorkflowWithFullLogging({
+          workflowId: 'wf-1',
+          executionId: 'exec-1',
+          copilotToolCallId: 'tool-1',
+          preserveExecutionOnTerminal: true,
+        })
 
-      await expect(promise).rejects.toBeInstanceOf(SSEStreamInterruptedError)
-      await expect(promise).rejects.toMatchObject({ executionId: 'exec-server' })
-      expect(store.setCurrentExecutionId).toHaveBeenCalledWith('wf-1', 'exec-server')
-      expect(store.setCurrentExecutionId).not.toHaveBeenCalledWith('wf-1', null)
-      expect(store.setIsExecuting).not.toHaveBeenCalled()
-    })
+        await expect(promise).rejects.toBeInstanceOf(SSEStreamInterruptedError)
+        await expect(promise).rejects.toMatchObject({ executionId: 'exec-server' })
+        expect(store.setCurrentExecutionId).toHaveBeenCalledWith('wf-1', 'exec-server')
+        expect(store.setCurrentExecutionId).not.toHaveBeenCalledWith('wf-1', null)
+        expect(store.setIsExecuting).not.toHaveBeenCalled()
+      }
+    )
 
     it.each([
       ['a client abort', new DOMException('Aborted', 'AbortError')],

apps/sim/hooks/use-execution-stream.ts

@@ -71,12 +71,22 @@ function isClientDisconnectError(error: any): boolean {
   return error.name === 'AbortError'
 }
 
+/**
+ * Messages browsers put on the TypeError a fetch or body read rejects with when
+ * the connection drops: Chrome's "network error" and "Failed to fetch",
+ * Firefox's "NetworkError when attempting to fetch resource.", and Safari's
+ * "Load failed".
+ */
+const TRANSPORT_FAILURE_MESSAGE_PATTERNS = [
+  /network\s?error/,
+  /failed to fetch/,
+  /load failed/,
+] as const
+
 function isRecoverableStreamError(error: any): boolean {
   if (isClientDisconnectError(error)) return false
   const msg = (error.message ?? '').toLowerCase()
-  return (
-    msg.includes('network error') || msg.includes('failed to fetch') || msg.includes('load failed')
-  )
+  return TRANSPORT_FAILURE_MESSAGE_PATTERNS.some((pattern) => pattern.test(msg))
 }
 
 /**