Fixes

Author: Sg312

apps/sim/app/workspace/[workspaceId]/home/hooks/use-chat.ts

@@ -1155,7 +1155,7 @@ export function useChat(
             }))
           : undefined
 
-      const requestChatId = selectedChatIdRef.current
+      const requestChatId = selectedChatIdRef.current ?? chatIdRef.current
       if (requestChatId) {
         const cachedUserMsg: TaskStoredMessage = {
           id: userMessageId,

apps/sim/lib/copilot/chat-streaming.ts

@@ -197,11 +197,6 @@ export function createSSEStream(params: StreamingOrchestrationParams): ReadableS
 
         const eventId = ++localSeq
 
-        const response = (event?.data?.response || {}) as Record<string, unknown>
-        if (event.type === 'done' && response.async_pause) {
-          await updateRunStatus(runId, 'paused_waiting_for_tool').catch(() => {})
-        }
-
         // Enqueue to client stream FIRST for minimal latency.
         // Redis persistence happens after so the client never waits on I/O.
         try {

apps/sim/lib/copilot/orchestrator/index.ts

@@ -1,10 +1,12 @@
 import { createLogger } from '@sim/logger'
+import { updateRunStatus } from '@/lib/copilot/async-runs/repository'
 import { SIM_AGENT_API_URL, SIM_AGENT_VERSION } from '@/lib/copilot/constants'
 import { prepareExecutionContext } from '@/lib/copilot/orchestrator/tool-executor'
 import type {
   ExecutionContext,
   OrchestratorOptions,
   OrchestratorResult,
+  SSEEvent,
 } from '@/lib/copilot/orchestrator/types'
 import { env } from '@/lib/core/config/env'
 import { getEffectiveDecryptedEnv } from '@/lib/environment/utils'
@@ -71,8 +73,28 @@ export async function orchestrateCopilotStream(
     let route = goRoute
     let payload = requestPayload
 
+    const callerOnEvent = options.onEvent
+
     for (;;) {
       context.streamComplete = false
+
+      const loopOptions = {
+        ...options,
+        onEvent: async (event: SSEEvent) => {
+          if (event.type === 'done') {
+            const d = (event.data ?? {}) as Record<string, unknown>
+            const response = (d.response ?? {}) as Record<string, unknown>
+            if (response.async_pause) {
+              if (runId) {
+                await updateRunStatus(runId, 'paused_waiting_for_tool').catch(() => {})
+              }
+              return
+            }
+          }
+          await callerOnEvent?.(event)
+        },
+      }
+
       await runStreamLoop(
         `${SIM_AGENT_API_URL}${route}`,
         {
@@ -86,7 +108,7 @@ export async function orchestrateCopilotStream(
         },
         context,
         execContext,
-        options
+        loopOptions
       )
 
       const continuation = context.awaitingAsyncContinuation