fix incorrect numbers

Author: IslandRhythms

backend/actions/Task/getTasks.js

@@ -14,6 +14,9 @@ const GetTasksParams = new Archetype({
 
 const ALL_STATUSES = ['pending', 'in_progress', 'succeeded', 'failed', 'cancelled', 'unknown'];
 
+/** Status keys for statusCounts (same shape as getTaskOverview). */
+const STATUS_COUNT_KEYS = ['pending', 'succeeded', 'failed', 'cancelled'];
+
 /** Max documents per request to avoid excessive memory and response size. */
 const MAX_LIMIT = 2000;
 
@@ -62,6 +65,8 @@ module.exports = ({ db }) => async function getTasks(params) {
   const { Task } = db.models;
   const match = buildMatch(params);
 
+  const defaultCounts = STATUS_COUNT_KEYS.map(s => ({ k: s, v: 0 }));
+
   const pipeline = [
     { $match: match },
     {
@@ -72,14 +77,29 @@ module.exports = ({ db }) => async function getTasks(params) {
           { $limit: limit },
           { $project: TASK_PROJECT_STAGE }
         ],
-        count: [{ $count: 'total' }]
+        count: [{ $count: 'total' }],
+        statusCounts: [
+          { $group: { _id: { $ifNull: ['$status', 'unknown'] }, count: { $sum: 1 } } },
+          { $group: { _id: null, counts: { $push: { k: '$_id', v: '$count' } } } },
+          {
+            $project: {
+              statusCounts: {
+                $arrayToObject: {
+                  $concatArrays: [{ $literal: defaultCounts }, '$counts']
+                }
+              }
+            }
+          },
+          { $replaceRoot: { newRoot: '$statusCounts' } }
+        ]
       }
     }
   ];
 
   const [result] = await Task.aggregate(pipeline);
   const tasks = result.tasks || [];
   const numDocs = (result.count && result.count[0] && result.count[0].total) || 0;
+  const statusCounts = result.statusCounts?.[0] ?? {};
 
-  return { tasks, numDocs };
+  return { tasks, numDocs, statusCounts };
 };

frontend/src/task-by-name/task-by-name.js

@@ -43,7 +43,8 @@ module.exports = app => app.component('task-by-name', {
     pageSize: 50,
     numDocs: 0,
     pageSizeOptions: PAGE_SIZE_OPTIONS,
-    _loadId: 0
+    _loadId: 0,
+    _lastQueryFilters: null
   }),
   computed: {
     taskName() {
@@ -129,11 +130,12 @@ module.exports = app => app.component('task-by-name', {
       if (statusFromQuery) params.status = statusFromQuery;
       this._lastQueryFilters = `${dateRange}|${statusFromQuery ?? ''}`;
       try {
-        const { tasks, numDocs } = await api.Task.getTasks(params);
+        const { tasks, numDocs, statusCounts } = await api.Task.getTasks(params);
         if (loadId !== this._loadId) return;
         this.numDocs = numDocs ?? tasks.length;
         this.taskGroup = buildTaskGroup(this.taskName, tasks);
         this.taskGroup.totalCount = this.numDocs;
+        if (statusCounts) this.taskGroup.statusCounts = statusCounts;
         this.status = 'loaded';
       } catch (err) {
         if (loadId !== this._loadId) return;

test/Task.getTasks.test.js

@@ -30,11 +30,13 @@ describe('Task.getTasks()', function() {
     await Task.deleteMany();
   });
 
-  it('returns empty tasks and numDocs 0 when no documents', async function() {
+  it('returns empty tasks, numDocs 0, and statusCounts when no documents', async function() {
     const res = await actions.Task.getTasks({});
     assert.strictEqual(Array.isArray(res.tasks), true);
     assert.strictEqual(res.tasks.length, 0);
     assert.strictEqual(res.numDocs, 0);
+    assert.strictEqual(typeof res.statusCounts, 'object');
+    assert.ok(res.statusCounts.pending === 0 || res.statusCounts.pending === undefined);
   });
 
   it('returns tasks with projected shape (id, parameters from payload)', async function() {
@@ -200,6 +202,19 @@ describe('Task.getTasks()', function() {
     assert.strictEqual(res.numDocs, 6);
   });
 
+  it('returns statusCounts for matching documents', async function() {
+    await Task.insertMany([
+      { name: 'a', status: 'succeeded', scheduledAt: new Date() },
+      { name: 'b', status: 'succeeded', scheduledAt: new Date() },
+      { name: 'c', status: 'failed', scheduledAt: new Date() }
+    ]);
+    const res = await actions.Task.getTasks({});
+    assert.strictEqual(res.statusCounts.succeeded, 2);
+    assert.strictEqual(res.statusCounts.failed, 1);
+    assert.strictEqual(res.statusCounts.pending, 0);
+    assert.strictEqual(res.statusCounts.cancelled, 0);
+  });
+
   it('returns numDocs as total matching count when using pagination', async function() {
     const base = new Date('2025-01-01T12:00:00Z');
     await Task.insertMany([