feat(sse): add real-time task status updates (RML-716)

- Enhanced SSE endpoint to include current task status in events
- Modified db.getRecentTaskEvents to join with tasks table
- Updated frontend SSE types to include taskStatus field
- Task store now updates task status in-place from SSE events
- Full refresh only triggered for terminal events or new tasks

This reduces API load and provides instant status updates in the
dashboard without polling.

Author: limaronaldo

packages/api/src/integrations/db.ts

@@ -398,34 +398,42 @@ export const db = {
     },
     taskId?: string,
     limit: number = 50,
-  ): Promise<TaskEvent[]> {
+  ): Promise<(TaskEvent & { taskStatus?: string })[]> {
     const sql = getDb();
     let results;
 
+    // Join with tasks table to get current task status for SSE updates
     if (taskId) {
       results = await sql`
-        SELECT * FROM task_events
+        SELECT e.*, t.status as task_status
+        FROM task_events e
+        LEFT JOIN tasks t ON e.task_id = t.id
         WHERE (
-          created_at > ${since.createdAt}
-          OR (created_at = ${since.createdAt} AND id > ${since.id})
+          e.created_at > ${since.createdAt}
+          OR (e.created_at = ${since.createdAt} AND e.id > ${since.id})
         )
-        AND task_id = ${taskId}
-        ORDER BY created_at ASC, id ASC
+        AND e.task_id = ${taskId}
+        ORDER BY e.created_at ASC, e.id ASC
         LIMIT ${limit}
       `;
     } else {
       results = await sql`
-        SELECT * FROM task_events
+        SELECT e.*, t.status as task_status
+        FROM task_events e
+        LEFT JOIN tasks t ON e.task_id = t.id
         WHERE (
-          created_at > ${since.createdAt}
-          OR (created_at = ${since.createdAt} AND id > ${since.id})
+          e.created_at > ${since.createdAt}
+          OR (e.created_at = ${since.createdAt} AND e.id > ${since.id})
         )
-        ORDER BY created_at ASC, id ASC
+        ORDER BY e.created_at ASC, e.id ASC
         LIMIT ${limit}
       `;
     }
 
-    return results.map(this.mapTaskEvent);
+    return results.map((row: any) => ({
+      ...this.mapTaskEvent(row),
+      taskStatus: row.task_status,
+    }));
   },
 
   // ============================================

packages/api/src/router.ts

@@ -3629,6 +3629,8 @@ route("GET", "/api/logs/stream", async (req) => {
                   level: getLogLevel(event.eventType),
                   tokensUsed: event.tokensUsed,
                   durationMs: event.durationMs,
+                  // Include current task status for real-time UI updates (RML-716)
+                  taskStatus: (event as any).taskStatus,
                 })}\n\n`,
               ),
             );

packages/web/src/services/sse.service.ts

@@ -9,6 +9,8 @@ export interface SSEEvent {
   level?: "info" | "warn" | "error" | "success";
   tokensUsed?: number;
   durationMs?: number;
+  // Current task status for real-time updates (RML-716)
+  taskStatus?: string;
 }
 
 export type SSEEventHandler = (event: SSEEvent) => void;
@@ -94,7 +96,7 @@ export class SSEService {
     const delay = this.reconnectDelay * Math.pow(2, this.reconnectAttempts - 1);
 
     console.log(
-      `[SSE] Reconnecting in ${delay}ms (attempt ${this.reconnectAttempts}/${this.maxReconnectAttempts})`
+      `[SSE] Reconnecting in ${delay}ms (attempt ${this.reconnectAttempts}/${this.maxReconnectAttempts})`,
     );
 
     setTimeout(() => {

packages/web/src/stores/task.store.ts

@@ -435,10 +435,35 @@ export class TaskStore {
           },
           ...this.liveEvents,
         ].slice(0, 100);
+
+        // RML-716: Update task status in-place if provided (avoids full refresh)
+        if (event.taskStatus && event.taskId) {
+          const taskIndex = this.tasks.findIndex((t) => t.id === event.taskId);
+          if (taskIndex !== -1) {
+            const currentStatus = this.tasks[taskIndex].status;
+            if (currentStatus !== event.taskStatus) {
+              this.tasks[taskIndex] = {
+                ...this.tasks[taskIndex],
+                status: event.taskStatus as TaskStatus,
+                updated_at: event.timestamp || new Date().toISOString(),
+              };
+            }
+          }
+        }
       });
 
-      // Debounce task refresh (avoid hammering API on rapid events)
-      this.debouncedRefresh();
+      // Only do full refresh for terminal events or if task not found locally
+      const terminalEvents = [
+        "PR_OPENED",
+        "COMPLETED",
+        "FAILED",
+        "BATCH_PR_CREATED",
+      ];
+      const taskExists = this.tasks.some((t) => t.id === event.taskId);
+
+      if (!taskExists || terminalEvents.includes(event.eventType || "")) {
+        this.debouncedRefresh();
+      }
     }
   }