summaryrefslogtreecommitdiff
path: root/internal/storage/dashboard_test.go
diff options
context:
space:
mode:
authorClaude Sonnet 5 <noreply@anthropic.com>2026-07-04 08:50:46 +0000
committerClaude Sonnet 5 <noreply@anthropic.com>2026-07-04 08:50:46 +0000
commitf8ae821240f33d615a9e91cdfeb6c026b7970782 (patch)
tree458ce067db47a92248f163c26ce5fcf71299f3b0 /internal/storage/dashboard_test.go
parentd105eca610b0e737c3313e4978d6a917b4f55d10 (diff)
feat(web,api): add Budget/Roles dashboard -- final phase of the harness redesign (Phase 9b)
Two new tabs, matching Phase 9a's conventions: Budget (per-provider spend meters, escalation funnel, spend-over-time) and Roles (version history, draft activation, readable escalation-ladder view) -- the human-facing surface for the token-husbanding value proposition and the Phase 5/8 versioned role-config system. New backend (minimal, additive, matching existing endpoint conventions -- unauthenticated like /api/budget and /api/roles/*): - internal/storage/dashboard.go: QueryEscalationFunnel (executions grouped by escalation_rung + agent, count + cost) and QuerySpendTimeseries (cost per provider bucketed hourly/daily, mirroring QueryDashboardStats' existing bucketing expressions). Documented honestly: rung 0 is not exclusively "resolved locally" -- escalation_rung defaults to 0 uniformly, so non-role-typed executions (which never climb a ladder) land there too, alongside role-typed tasks genuinely resolved at tier 0. A role-only variant would need a join against tasks.config_json with no queryable role column on executions -- intentionally out of scope. - internal/api/dashboard.go: GET /api/escalation-funnel, GET /api/spend-timeseries (both ?window=5h|24h|7d|<duration>, default 24h). - internal/storage.ListRoleNames + GET /api/roles: the "which roles exist" gap -- there was no way to discover role names before this, only to list versions for a role you already knew the name of. Chart-form decisions (dataviz skill, invoked before writing chart code): horizontal stacked bar for the escalation funnel (rung order already encodes the funnel shape positionally; color only needed for per-provider segments within each rung); multi-line for spend-over-time; a fixed-order categorical palette from the skill's validated palette.md slots for provider identity (re-validated against this app's dark surface, passing); a separate status (good/warning/critical) palette for budget meters, deliberately distinct from both --state-* and the provider palette. Caught and fixed a real bug during visual QA: converging near-zero end-labels on the spend chart were overlapping (an anti-pattern the skill explicitly flags) -- fixed with a 14px minimum-gap check before direct-labeling an endpoint, leaning on the legend/tooltip otherwise. Verified with a real running server, real seeded data (65 executions across rungs 0-2 with a realistic provider mix, 2 roles with active/draft/retired role_configs versions written directly via internal/storage), and a real headless-browser session (reusing Phase 9a's Chromium/proxy scaffinding): confirmed correct rung totals/percentages, provider legends, a 3-line spend chart, live window-selector re-render, correct active-version highlighting on the role panel, and a real Activate click on a draft version -- verified via both DOM re-render and a direct backend GET that it truly persisted. go build/vet/test -race -count=1 all pass, full suite. node --test web/test/*.mjs: 291/291 passing (16 new). Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com> Claude-Session: https://claude.ai/code/session_01V1moSNCJRcP6kykA4tyUSs
Diffstat (limited to 'internal/storage/dashboard_test.go')
-rw-r--r--internal/storage/dashboard_test.go151
1 files changed, 151 insertions, 0 deletions
diff --git a/internal/storage/dashboard_test.go b/internal/storage/dashboard_test.go
new file mode 100644
index 0000000..b7e425d
--- /dev/null
+++ b/internal/storage/dashboard_test.go
@@ -0,0 +1,151 @@
+package storage
+
+import (
+ "strconv"
+ "testing"
+ "time"
+
+ "github.com/thepeterstone/claudomator/internal/task"
+)
+
+// mustCreateTask is a small helper mirroring the pattern used in db_test.go
+// (TestCreateTask_AndGetTask) — a minimal valid task row so executions can
+// reference a real task_id.
+func mustCreateTask(t *testing.T, db *DB, id string) {
+ t.Helper()
+ now := time.Now().UTC().Truncate(time.Second)
+ tk := &task.Task{
+ ID: id,
+ Name: "dashboard-test-" + id,
+ State: task.StatePending,
+ DependsOn: []string{},
+ CreatedAt: now,
+ UpdatedAt: now,
+ }
+ if err := db.CreateTask(tk); err != nil {
+ t.Fatalf("CreateTask(%s): %v", id, err)
+ }
+}
+
+func mustCreateExecution(t *testing.T, db *DB, id, taskID, agent string, rung int, cost float64, start time.Time, status string) {
+ t.Helper()
+ exec := &Execution{
+ ID: id,
+ TaskID: taskID,
+ StartTime: start,
+ EndTime: start.Add(time.Minute),
+ Status: status,
+ CostUSD: cost,
+ Agent: agent,
+ EscalationRung: rung,
+ }
+ if err := db.CreateExecution(exec); err != nil {
+ t.Fatalf("CreateExecution(%s): %v", id, err)
+ }
+}
+
+func TestQueryEscalationFunnel_AggregatesByRungAndAgent(t *testing.T) {
+ db := testDB(t)
+ mustCreateTask(t, db, "t1")
+
+ now := time.Now().UTC()
+ // Rung 0: 2 local executions.
+ mustCreateExecution(t, db, "e1", "t1", "local", 0, 0, now.Add(-3*time.Hour), "COMPLETED")
+ mustCreateExecution(t, db, "e2", "t1", "local", 0, 0, now.Add(-2*time.Hour), "COMPLETED")
+ // Rung 1: 1 anthropic execution.
+ mustCreateExecution(t, db, "e3", "t1", "anthropic", 1, 0.05, now.Add(-1*time.Hour), "COMPLETED")
+ // Still in flight — must be excluded.
+ mustCreateExecution(t, db, "e4", "t1", "anthropic", 1, 0, now, "RUNNING")
+ // Too old — outside the window.
+ mustCreateExecution(t, db, "e5", "t1", "local", 0, 0, now.Add(-48*time.Hour), "COMPLETED")
+
+ buckets, err := db.QueryEscalationFunnel(now.Add(-24 * time.Hour))
+ if err != nil {
+ t.Fatalf("QueryEscalationFunnel: %v", err)
+ }
+
+ want := map[string]struct {
+ count int
+ cost float64
+ }{
+ "0|local": {2, 0},
+ "1|anthropic": {1, 0.05},
+ }
+ if len(buckets) != len(want) {
+ t.Fatalf("expected %d buckets, got %d: %+v", len(want), len(buckets), buckets)
+ }
+ for _, b := range buckets {
+ key := strconv.Itoa(b.Rung) + "|" + b.Agent
+ w, ok := want[key]
+ if !ok {
+ t.Errorf("unexpected bucket %+v", b)
+ continue
+ }
+ if b.Count != w.count {
+ t.Errorf("bucket %s: count = %d, want %d", key, b.Count, w.count)
+ }
+ if b.CostUSD != w.cost {
+ t.Errorf("bucket %s: cost = %v, want %v", key, b.CostUSD, w.cost)
+ }
+ }
+}
+
+func TestQueryEscalationFunnel_Empty_ReturnsEmptySlice(t *testing.T) {
+ db := testDB(t)
+ buckets, err := db.QueryEscalationFunnel(time.Now().Add(-24 * time.Hour))
+ if err != nil {
+ t.Fatalf("QueryEscalationFunnel: %v", err)
+ }
+ if buckets == nil || len(buckets) != 0 {
+ t.Errorf("expected empty non-nil slice, got %v", buckets)
+ }
+}
+
+func TestQuerySpendTimeseries_HourlyBucketsByProvider(t *testing.T) {
+ db := testDB(t)
+ mustCreateTask(t, db, "t1")
+
+ // Pin two executions to the exact same hour bucket for two providers.
+ hourStart := time.Now().UTC().Truncate(time.Hour)
+ mustCreateExecution(t, db, "e1", "t1", "local", 0, 0.10, hourStart.Add(5*time.Minute), "COMPLETED")
+ mustCreateExecution(t, db, "e2", "t1", "anthropic", 0, 0.20, hourStart.Add(10*time.Minute), "COMPLETED")
+ mustCreateExecution(t, db, "e3", "t1", "anthropic", 0, 0.05, hourStart.Add(40*time.Minute), "COMPLETED")
+
+ points, err := db.QuerySpendTimeseries(hourStart.Add(-time.Hour), true)
+ if err != nil {
+ t.Fatalf("QuerySpendTimeseries: %v", err)
+ }
+
+ totals := map[string]float64{}
+ for _, p := range points {
+ totals[p.Agent] += p.CostUSD
+ }
+ if totals["local"] != 0.10 {
+ t.Errorf("local total = %v, want 0.10", totals["local"])
+ }
+ if got, want := totals["anthropic"], 0.25; got < want-1e-9 || got > want+1e-9 {
+ t.Errorf("anthropic total = %v, want %v", got, want)
+ }
+}
+
+func TestQuerySpendTimeseries_DailyBucketing(t *testing.T) {
+ db := testDB(t)
+ mustCreateTask(t, db, "t1")
+
+ today := time.Now().UTC()
+ mustCreateExecution(t, db, "e1", "t1", "local", 0, 1.5, today, "COMPLETED")
+
+ points, err := db.QuerySpendTimeseries(today.Add(-24*time.Hour), false)
+ if err != nil {
+ t.Fatalf("QuerySpendTimeseries: %v", err)
+ }
+ if len(points) != 1 {
+ t.Fatalf("expected 1 point, got %d: %+v", len(points), points)
+ }
+ if points[0].Bucket != today.Format("2006-01-02") {
+ t.Errorf("bucket = %q, want %q", points[0].Bucket, today.Format("2006-01-02"))
+ }
+ if points[0].CostUSD != 1.5 {
+ t.Errorf("cost = %v, want 1.5", points[0].CostUSD)
+ }
+}