feat(webapp): poll for unread work while the panel is closed

Author: kathiekiwi

apps/webapp/app/components/dashboard-agent/DashboardAgent.tsx

@@ -67,6 +67,9 @@ export function DashboardAgent({
   // Work that finished behind a closed panel. Counted server-side on page load and refreshed
   // with the chat list; the wake poll doesn't carry it.
   const [unreadWork, setUnreadWork] = useState(initialUnreadWork);
+  // A turn this tab started may finish after the panel closes; that is exactly the case the
+  // dot exists for, so the poll has to be running when it lands.
+  const [turnStarted, setTurnStarted] = useState(false);
   const toastedWakes = useRef(new Set<string>());
   // The toast source is recent deliveries, not unread, so the dedupe must survive a reload.
   useEffect(() => {
@@ -165,14 +168,16 @@ export function DashboardAgent({
         shouldPollWakeFeed({
           serverUnreadWakes: initialUnreadWakes,
           serverHasActiveWatches: hasActiveWatches,
+          serverUnreadWork: initialUnreadWork,
+          turnInFlight: turnStarted,
           organizationId: organization.id,
         })
       )
         setWatching(true);
     };
     sync();
     return subscribeWatchActivity(sync);
-  }, [organization.id, initialUnreadWakes, hasActiveWatches]);
+  }, [organization.id, initialUnreadWakes, hasActiveWatches, initialUnreadWork, turnStarted]);
 
   useEffect(() => {
     if (!hasAccess || !watching) return;
@@ -185,13 +190,19 @@ export function DashboardAgent({
           signal: AbortSignal.timeout(UNREAD_REQUEST_TIMEOUT_MS),
         });
         if (!res.ok) return;
-        const data = (await res.json()) as { unreadWakes?: number; wakes?: WatchWake[] };
+        const data = (await res.json()) as {
+          unreadWakes?: number;
+          unreadWork?: number;
+          wakes?: WatchWake[];
+        };
         if (cancelled) return;
         // The wakes list carries read ones too, so only unread ones are subtracted.
         const unreadInView = (data.wakes ?? []).filter(
           (wake) => wake.unread && wake.chatId === visibleChat.current
         ).length;
         setUnreadWakes(Math.max(0, (data.unreadWakes ?? 0) - unreadInView));
+        // A chat open in the panel is being read right now, so it isn't unread work.
+        setUnreadWork(Math.max(0, (data.unreadWork ?? 0) - (open && visibleChat.current ? 1 : 0)));
 
         const fresh = (data.wakes ?? []).filter((wake) => !toastedWakes.current.has(wake.watchId));
         for (const wake of fresh) rememberToasted(wake.watchId);

apps/webapp/app/components/dashboard-agent/watch-activity.ts

@@ -65,11 +65,17 @@ export function forgetWatchActivity(organizationId: string): void {
 export function shouldPollWakeFeed(params: {
   serverUnreadWakes: number;
   serverHasActiveWatches?: boolean;
+  /** Chats holding work their owner hasn't seen, as the page load counted them. */
+  serverUnreadWork?: number;
+  /** This tab sent a turn that may still be running behind a closed panel. */
+  turnInFlight?: boolean;
   organizationId: string;
 }): boolean {
   return (
     params.serverUnreadWakes > 0 ||
     params.serverHasActiveWatches === true ||
+    (params.serverUnreadWork ?? 0) > 0 ||
+    params.turnInFlight === true ||
     hasWatchActivity(params.organizationId)
   );
 }

apps/webapp/app/routes/resources.orgs.$organizationSlug.projects.$projectParam.env.$envParam.dashboard-agent.ts

@@ -3,6 +3,7 @@ import {
   cancelWatch,
   chatExists,
   countUnreadWatchWakes,
+  countChatsWithUnreadWork,
   countUserMessages,
   createChat,
   getChatMessages,
@@ -132,13 +133,20 @@ export const loader = async ({ request, params }: LoaderFunctionArgs) => {
     });
     if (!scoped) return json({ error: "Project not found" }, { status: 404 });
 
-    return json(
-      await readWatchWakeFeed(dashboardAgentDb, {
+    const [feed, unreadWork] = await Promise.all([
+      readWatchWakeFeed(dashboardAgentDb, {
         organizationId: scoped.organizationId,
         userId,
         deliveredAfter: new Date(Date.now() - 15 * 60 * 1000),
-      })
-    );
+      }),
+      // The dot has two sources; the poll is where a closed panel learns about either.
+      countChatsWithUnreadWork(dashboardAgentDb, {
+        organizationId: scoped.organizationId,
+        userId,
+      }),
+    ]);
+
+    return json({ ...feed, unreadWork });
   }
 
   const project = await findProjectBySlug(organizationSlug, projectParam, userId);