Agent throughput: jobs per dag stacked bar + KPI-strip (#49)

* feat(insights): add getJobsPerDay helper — agent throughput per day + KPIs Raw SQL aggregation of claude_jobs by day and status over 14 days with zero-fill for missing days. KPIs: todayCount, successRate7d, avgDurationSeconds7d. Optional productId filter. Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com> * feat(insights): add AgentThroughputCard — stacked BarChart + KPI-strip + product filter KPI strip (jobs today, 7d success rate, 7d avg duration), 14-day stacked BarChart with JOB_STATUS_COLORS, and URL-bookmarkable product dropdown via useTransition + router.replace. Empty-state when no activity. Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com> --------- Co-authored-by: Claude Sonnet 4.6 <noreply@anthropic.com>
2026-05-02 16:30:06 +02:00 · 2026-05-02 16:30:06 +02:00 · 739037a60b
commit 739037a60b
parent af77553407
3 changed files with 333 additions and 0 deletions
--- a/lib/insights/agent-throughput.ts
+++ b/lib/insights/agent-throughput.ts
@ -0,0 +1,118 @@
+import { prisma } from '@/lib/prisma'
+
+export interface DayCount {
+  day: string
+  queued: number
+  claimed: number
+  running: number
+  done: number
+  failed: number
+  cancelled: number
+}
+
+export interface ThroughputKpi {
+  todayCount: number
+  successRate7d: number
+  avgDurationSeconds7d: number | null
+}
+
+export interface JobsPerDayResult {
+  perDay: DayCount[]
+  kpi: ThroughputKpi
+}
+
+const STATUSES = ['queued', 'claimed', 'running', 'done', 'failed', 'cancelled'] as const
+
+type RawDayRow = { day: Date; status: string; count: bigint }
+type RawKpiRow = { today_count: bigint; done_7d: bigint; terminal_7d: bigint; avg_seconds: number | null }
+
+function toDateStr(d: Date): string {
+  return d.toISOString().slice(0, 10)
+}
+
+export async function getJobsPerDay(
+  userId: string,
+  days = 14,
+  productId?: string,
+): Promise<JobsPerDayResult> {
+  const [dayRows, kpiRows] = await Promise.all([
+    productId
+      ? prisma.$queryRaw<RawDayRow[]>`
+          SELECT DATE(created_at) AS day, LOWER(status::text) AS status, COUNT(*) AS count
+          FROM claude_jobs
+          WHERE user_id = ${userId}
+            AND product_id = ${productId}
+            AND created_at > NOW() - (${days} || ' days')::INTERVAL
+          GROUP BY DATE(created_at), status
+          ORDER BY day ASC
+        `
+      : prisma.$queryRaw<RawDayRow[]>`
+          SELECT DATE(created_at) AS day, LOWER(status::text) AS status, COUNT(*) AS count
+          FROM claude_jobs
+          WHERE user_id = ${userId}
+            AND created_at > NOW() - (${days} || ' days')::INTERVAL
+          GROUP BY DATE(created_at), status
+          ORDER BY day ASC
+        `,
+    productId
+      ? prisma.$queryRaw<RawKpiRow[]>`
+          SELECT
+            COUNT(*) FILTER (WHERE DATE(created_at) = CURRENT_DATE) AS today_count,
+            COUNT(*) FILTER (WHERE status = 'DONE' AND created_at > NOW() - INTERVAL '7 days') AS done_7d,
+            COUNT(*) FILTER (WHERE status IN ('DONE','FAILED','CANCELLED') AND created_at > NOW() - INTERVAL '7 days') AS terminal_7d,
+            AVG(EXTRACT(EPOCH FROM (finished_at - claimed_at))) FILTER (WHERE status = 'DONE' AND created_at > NOW() - INTERVAL '7 days') AS avg_seconds
+          FROM claude_jobs
+          WHERE user_id = ${userId}
+            AND product_id = ${productId}
+        `
+      : prisma.$queryRaw<RawKpiRow[]>`
+          SELECT
+            COUNT(*) FILTER (WHERE DATE(created_at) = CURRENT_DATE) AS today_count,
+            COUNT(*) FILTER (WHERE status = 'DONE' AND created_at > NOW() - INTERVAL '7 days') AS done_7d,
+            COUNT(*) FILTER (WHERE status IN ('DONE','FAILED','CANCELLED') AND created_at > NOW() - INTERVAL '7 days') AS terminal_7d,
+            AVG(EXTRACT(EPOCH FROM (finished_at - claimed_at))) FILTER (WHERE status = 'DONE' AND created_at > NOW() - INTERVAL '7 days') AS avg_seconds
+          FROM claude_jobs
+          WHERE user_id = ${userId}
+        `,
+  ])
+
+  // Build lookup: dayStr → status → count
+  const lookup = new Map<string, Map<string, number>>()
+  for (const row of dayRows) {
+    const d = toDateStr(row.day)
+    if (!lookup.has(d)) lookup.set(d, new Map())
+    lookup.get(d)!.set(row.status, Number(row.count))
+  }
+
+  // Generate full date range with zero-fills
+  const now = new Date()
+  const perDay: DayCount[] = []
+  for (let i = days - 1; i >= 0; i--) {
+    const d = new Date(now)
+    d.setUTCDate(d.getUTCDate() - i)
+    const key = toDateStr(d)
+    const statusMap = lookup.get(key) ?? new Map()
+    perDay.push({
+      day: key,
+      queued: statusMap.get('queued') ?? 0,
+      claimed: statusMap.get('claimed') ?? 0,
+      running: statusMap.get('running') ?? 0,
+      done: statusMap.get('done') ?? 0,
+      failed: statusMap.get('failed') ?? 0,
+      cancelled: statusMap.get('cancelled') ?? 0,
+    })
+  }
+
+  const kpiRow = kpiRows[0]
+  const done7d = Number(kpiRow?.done_7d ?? 0)
+  const terminal7d = Number(kpiRow?.terminal_7d ?? 0)
+
+  return {
+    perDay,
+    kpi: {
+      todayCount: Number(kpiRow?.today_count ?? 0),
+      successRate7d: terminal7d === 0 ? 0 : Math.round((done7d / terminal7d) * 100) / 100,
+      avgDurationSeconds7d: kpiRow?.avg_seconds != null ? Math.round(Number(kpiRow.avg_seconds)) : null,
+    },
+  }
+}