fix: prevent infinite recovery loop on empty replay and optimize threadPlanCatalog selector

- Detect no-progress in recoverFromSequenceGap when latestSequence doesn't
  advance after an empty replay response; fall back to snapshot recovery
  instead of looping indefinitely.
- Replace useShallow+map selector with a direct threads subscription and
  useMemo so the O(n) mapping only runs when the threads array reference
  changes, not on every unrelated store update.

Author: cursoragent

apps/web/src/components/ChatView.tsx

@@ -28,7 +28,6 @@ import { useCallback, useEffect, useLayoutEffect, useMemo, useRef, useState } fr
 import { useMutation, useQuery, useQueryClient } from "@tanstack/react-query";
 import { useDebouncedValue } from "@tanstack/react-pacer";
 import { useNavigate, useSearch } from "@tanstack/react-router";
-import { useShallow } from "zustand/react/shallow";
 import { gitBranchesQueryOptions, gitCreateWorktreeMutationOptions } from "~/lib/gitReactQuery";
 import { projectSearchEntriesQueryOptions } from "~/lib/projectReactQuery";
 import { serverConfigQueryOptions, serverQueryKeys } from "~/lib/serverReactQuery";
@@ -591,9 +590,8 @@ export default function ChatView({ threadId }: ChatViewProps) {
   );
 
   const fallbackDraftProject = useProjectById(draftThread?.projectId);
-  const threadPlanCatalog = useStore(
-    useShallow((store) => store.threads.map(toThreadPlanCatalogEntry)),
-  );
+  const threads = useStore((store) => store.threads);
+  const threadPlanCatalog = useMemo(() => threads.map(toThreadPlanCatalogEntry), [threads]);
   const localDraftError = serverThread ? null : (localDraftErrorsByThreadId[threadId] ?? null);
   const localDraftThread = useMemo(
     () =>

apps/web/src/routes/__root.tsx

@@ -250,8 +250,10 @@ function EventRouter() {
         return;
       }
 
+      const sequenceBefore = recovery.getState().latestSequence;
+
       try {
-        const events = await api.orchestration.replayEvents(recovery.getState().latestSequence);
+        const events = await api.orchestration.replayEvents(sequenceBefore);
         if (!disposed) {
           applyEventBatch(events);
         }
@@ -261,7 +263,17 @@ function EventRouter() {
         return;
       }
 
-      if (!disposed && recovery.completeReplayRecovery()) {
+      if (disposed) {
+        return;
+      }
+
+      if (recovery.getState().latestSequence === sequenceBefore) {
+        recovery.failReplayRecovery();
+        void fallbackToSnapshotRecovery();
+        return;
+      }
+
+      if (recovery.completeReplayRecovery()) {
         void recoverFromSequenceGap();
       }
     };