GeezerVison

The latest updates on your projects. Learn more about Vercel for GitHub.

1 Skipped Deployment

Project	Deployment	Actions	Updated (UTC)
docs	Skipped		May 4, 2026 11:37pm

PR Summary

Medium Risk
Touches chat streaming stop/reconnect, queued-message handoff, and cache invalidation logic; regressions could cause stuck UI, dropped queued messages, or missed task refreshes under race conditions. Changes are bounded to mothership/copilot streaming paths but are behaviorally complex and timing-sensitive.

Overview
Propagates streamId through task status pubsub/SSE (taskPubSub, mothership events, copilot stop/post) so clients can correlate started/completed events to a specific stream.

Hardens use-chat streaming state transitions: adds explicit timeouts/abort-signal utilities, prevents duplicate cursor processing, supports resolving chatId from stream batches, recovers active streams on pageshow/visibility/online, and makes queued-message handoff robust with TTL/claims/backoff and a dedicated queued-handoff stop mode.

Updates task-event handling to invalidate/remove the right React Query caches (including detail on relevant events) while avoiding detail invalidation when a status event is stale relative to an optimistic/newer active stream; expands tests to cover these race cases.

^{Reviewed by Cursor Bugbot for commit b8d76f9. Configure here.}

Greptile Summary

This PR improves streaming state transitions in the mothership chat UI by: (1) adding streamId correlation to all task status events so clients can make smarter cache-invalidation decisions without spurious refetches, and (2) introducing a visibility/online recovery mechanism that resumes an active SSE stream when the user returns to a tab, fixing odd UI state caused by the stream stalling while the tab was hidden.

Supporting infrastructure includes combineAbortSignals, sleepWithAbort, resolveChatIdForStream, owner-tagged handoff claims, a queued-handoff stop mode, and targetChatId propagation through all finalize/reconnect code paths.

Confidence Score: 5/5

Safe to merge — no P0/P1 issues found; two P2 observations on abort-signal hygiene.

All findings are P2. The resolveChatIdForStream inside stopBarrier is bounded by its own internal 10 s timeout so it cannot hang indefinitely; the combineAbortSignals cleanup-listener ordering issue is a minor GC concern with no observable data-loss path. Core logic for stream recovery, cache invalidation, and cross-tab handoff is correct and well-tested.

use-chat.ts — the stopBarrier in stopGeneration (queued-handoff branch) and combineAbortSignals helper are worth a second read for abort-hygiene completeness.

Important Files Changed

Sequence Diagram

sequenceDiagram
    participant UI as Browser Tab
    participant useChat as useChat hook
    participant SSE as SSE Stream
    participant Server as Server (API)
    participant Redis as Redis/Pub-Sub
    participant OtherTab as Other Tab (sessionStorage)

    Note over UI,OtherTab: Normal streaming flow
    UI->>useChat: sendMessage()
    useChat->>Server: POST /stream
    Server-->>SSE: stream events
    SSE-->>useChat: processSSEStream (live)
    Server->>Redis: publishStatus(started, streamId)
    Redis-->>useChat: task_status SSE (streamId)
    useChat->>useChat: shouldSkipDetailInvalidation?

    Note over UI,OtherTab: Tab switch / visibility recovery
    UI->>useChat: visibilitychange / pageshow / online
    useChat->>useChat: recoverActiveStreamFromRedis()
    useChat->>useChat: cancelActiveStreamReader()
    useChat->>Server: fetchStreamBatch(afterCursor)
    Server-->>useChat: batch events + chatId
    useChat->>SSE: attachToExistingStream (resume)
    SSE-->>useChat: processSSEStream (resume)

    Note over UI,OtherTab: Queued message during active stream
    UI->>useChat: sendMessage() [while streaming]
    useChat->>useChat: createQueuedMessage(+handoff)
    useChat->>useChat: stopGeneration(queued-handoff)
    useChat->>Server: POST /abort (streamId)
    alt chatId unknown
        useChat->>Server: resolveChatIdForStream (poll)
        Server-->>useChat: chatId resolved
    end
    Server->>Redis: publishStatus(completed, streamId)
    Redis-->>useChat: task_status SSE
    useChat->>useChat: shouldSkipDetailInvalidation?
    useChat->>Server: POST /stream (new message)

    Note over UI,OtherTab: Cross-tab handoff recovery
    UI->>OtherTab: writeQueuedSendHandoffState (sessionStorage)
    OtherTab->>OtherTab: writeQueuedSendHandoffClaim (ownerId)
    OtherTab->>useChat: resolveChatIdForStream
    OtherTab->>Server: POST /stream (recovered message)

_{Reviews (2): Last reviewed commit: "address comments" | Re-trigger Greptile}

bugbot run

@greptile