Merge PR #474: Activity track tier/risk changes

Activity: track tier/risk changes

Author: web3dev1337

client/activity-feed.js

@@ -301,6 +301,18 @@ class ActivityFeedPanel {
     if (kind === 'git.pull') return `Git pull (${data.ok ? 'ok' : 'failed'})`;
     if (kind === 'pr.merge') return `PR merge ${data.ok ? 'ok' : 'failed'} (${data.repo || 'repo'} #${data.prNumber || '?'})`;
     if (kind === 'pr.review') return `PR review ${data.ok ? 'ok' : 'failed'} (${data.repo || 'repo'} #${data.prNumber || '?'})`;
+    if (kind === 'task-record.updated') {
+      const id = data.id || 'record';
+      const ch = data.changes && typeof data.changes === 'object' ? data.changes : {};
+      const tierTo = ch.tier?.to ?? null;
+      const riskTo = ch.risk?.to ?? null;
+      const doneTo = ch.doneAt?.to ?? null;
+      const parts = [];
+      if (tierTo) parts.push(`T${tierTo}`);
+      if (riskTo) parts.push(`risk:${riskTo}`);
+      if (doneTo) parts.push('done');
+      return `Task record updated (${id})${parts.length ? ` • ${parts.join(' • ')}` : ''}`;
+    }
     if (kind.startsWith('tests.')) return `${kind} (${data.ok ? 'ok' : 'running'})`;
     if (kind.startsWith('agent.start')) return `Start agent (${data.agent || 'agent'}) for ${data.sessionId || 'session'}`;
     if (kind.startsWith('session.')) return `${kind} (${data.sessionId || ''})`.trim();

server/index.js

@@ -3416,7 +3416,24 @@ app.get('/api/process/task-records/:id', (req, res) => {
 app.put('/api/process/task-records/:id', express.json(), async (req, res) => {
   try {
     const id = req.params.id;
+    const before = taskRecordService.get(id) || null;
     const record = await taskRecordService.upsert(id, req.body || {});
+    try {
+      const keys = ['tier', 'risk', 'pFail', 'doneAt', 'reviewedAt', 'reviewOutcome', 'claimedAt', 'claimedBy'];
+      const changes = {};
+      for (const k of keys) {
+        const from = before?.[k] ?? null;
+        const to = record?.[k] ?? null;
+        if (from !== to) {
+          changes[k] = { from, to };
+        }
+      }
+      if (Object.keys(changes).length > 0) {
+        activityFeed.track('task-record.updated', { id, changes });
+      }
+    } catch {
+      // ignore
+    }
     res.json({ id, record });
   } catch (error) {
     logger.error('Failed to upsert task record', { error: error.message, stack: error.stack });