fix(chat): send a message with a search scope as its own turn, never steered

The steer body has no search scope, so a Summarize sent during a turn ran without
its document scope. canSteer now refuses such a message, and the path that steers
a send the chat refused as busy goes through it too, since it skips the step's gate.

Author: waleedlatif1

apps/sim/app/workspace/[workspaceId]/home/hooks/outgoing-state.test.ts

@@ -263,6 +263,15 @@ describe('transitions', () => {
     expect(notBefore).toBeGreaterThan(NOW)
   })
 
+  it('never steers a message with a search scope, and shows it waits for its own turn', () => {
+    const scoped = entry('a', {
+      payload: { content: 'Summarize', assistantSearch: { startDate: '2026-11-01T00:00:00.000Z' } },
+    })
+    expect(nextOutgoingStep([scoped], view({ liveStreamId: 'turn' })).kind).toBe('idle')
+    expect(deliveryOf(scoped, true)).toBe('waiting')
+    expect(nextOutgoingStep([scoped], view())).toMatchObject({ kind: 'send', message: scoped })
+  })
+
   it('clears the retry delay on every move to not delivered or applied', () => {
     const delayed = { notBefore: NOW - 1 }
     const context = { streamId: 'turn', turnErrored: false, now: NOW }

apps/sim/app/workspace/[workspaceId]/home/hooks/outgoing-state.ts

@@ -126,10 +126,16 @@ export function optimisticUserMessageFor(id: string, payload: SendPayload): Chat
 
 /**
  * Whether a message can be steered: steering carries its files and mentions like a
- * turn, but needs text, so a message of files alone goes out as a turn.
+ * turn, but needs text, so a message of files alone goes out as a turn. It has no
+ * search scope, so a message asking for one (a Summarize of found documents) goes
+ * out as a turn too, rather than running without it.
  */
-function canSteer(payload: SendPayload): boolean {
-  return payload.content.trim().length > 0 && payload.content.length <= MAX_STEERING_CONTENT_LENGTH
+export function canSteer(payload: SendPayload): boolean {
+  return (
+    !payload.assistantSearch &&
+    payload.content.trim().length > 0 &&
+    payload.content.length <= MAX_STEERING_CONTENT_LENGTH
+  )
 }
 
 /** The journal entry an outgoing message is restored from; a steer in flight restores as sent. */

apps/sim/app/workspace/[workspaceId]/home/hooks/use-chat.dom.test.tsx

@@ -4415,6 +4415,75 @@ describe('useChat remount send recovery', () => {
       }
     }, 30_000)
 
+    const SUMMARY_SCOPE = { startDate: '2026-11-01T00:00:00.000Z' }
+
+    it('holds a message with a search scope for its own turn, keeping the scope', async () => {
+      const { view, turn } = await startTurn()
+      await act(async () => {
+        await view.getResult().sendMessage('Summarize this', undefined, undefined, {
+          assistantSearch: SUMMARY_SCOPE,
+        })
+        await settle()
+      })
+
+      expect(state.steerBodies).toHaveLength(0)
+      expect(view.getResult().messages.at(-1)).toMatchObject({
+        content: 'Summarize this',
+        delivery: 'waiting',
+      })
+
+      await turn.end()
+      await waitFor(() => state.postBodies.length === 2)
+      expect(state.steerBodies).toHaveLength(0)
+      expect(state.postBodies[1]).toMatchObject({
+        message: 'Summarize this',
+        assistantSearch: SUMMARY_SCOPE,
+      })
+    })
+
+    /** A turn this surface did not know of refuses the send; steering it would drop the scope. */
+    it('never steers a message with a search scope into a turn that refused its send', async () => {
+      vi.useFakeTimers({ toFake: ['setTimeout', 'clearTimeout', 'Date'] })
+      try {
+        mockRequestJson.mockImplementation(() => Promise.resolve({ chat: history }))
+        let busy = true
+        vi.stubGlobal('fetch', async (input: RequestInfo | URL, init?: RequestInit) => {
+          if (String(input) === '/api/mothership/chat' && init?.method === 'POST') {
+            state.postBodies.push(JSON.parse(String(init.body)))
+            return busy
+              ? Response.json(
+                  { error: 'A response is already in progress.', activeStreamId: 'other-tab-run' },
+                  { status: 409 }
+                )
+              : emptySseResponse()
+          }
+          return fetchStub(input, init)
+        })
+        state.steerDispositions = ['queued', 'queued']
+        const view = renderUseChatInChat(chatId, history)
+        await act(async () => {
+          void view.getResult().sendMessage('Summarize this', undefined, undefined, {
+            assistantSearch: SUMMARY_SCOPE,
+          })
+          await vi.advanceTimersByTimeAsync(50)
+        })
+        expect(state.postBodies).toHaveLength(1)
+        expect(state.steerBodies).toHaveLength(0)
+
+        busy = false
+        await act(async () => vi.advanceTimersByTimeAsync(3_000))
+
+        expect(state.steerBodies).toHaveLength(0)
+        expect(state.postBodies.length).toBeGreaterThan(1)
+        expect(state.postBodies.at(-1)).toMatchObject({
+          message: 'Summarize this',
+          assistantSearch: SUMMARY_SCOPE,
+        })
+      } finally {
+        vi.useRealTimers()
+      }
+    })
+
     /** It waits for its marker in the saved transcript, which no timer brings any sooner. */
     it('stops waking for a message read as applied after an earlier read held it', async () => {
       vi.useFakeTimers({ toFake: ['setTimeout', 'clearTimeout', 'Date'] })

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

@@ -110,6 +110,7 @@ import {
   afterDispositionRead,
   afterRetry,
   afterUnsentAttempt,
+  canSteer,
   deliveryOf,
   fromJournaled,
   hasOutgoingFollowUp,
@@ -4587,6 +4588,11 @@ export function useChat(
             return
           }
           updateOutgoing(message.id, { attempts })
+          if (!canSteer(message.payload)) {
+            updateOutgoing(message.id, { notBefore: Date.now() + outgoingRetryDelay(attempts) })
+            deliverOutgoingRef.current()
+            return
+          }
           void steerOutgoing({ ...message, attempts }, result.streamId).then(() => {
             const current = outgoingRef.current.find((candidate) => candidate.id === message.id)
             if (current?.status === 'pending') {