Function TestBuildStatsWindowed

internal/stats/report_test.go:79–131

(t *testing.T)

}

func TestBuildStatsWindowed(t *testing.T) {
	root := t.TempDir()
	claudeProj := t.TempDir()

	db, err := flowdb.OpenDB(filepath.Join(root, "flow.db"))
	if err != nil {
		t.Fatal(err)
	}
	defer db.Close()
	work := "/work/app"
	mustExec(t, db, `INSERT INTO tasks (slug,name,status,work_dir,session_id,created_at,updated_at)
		VALUES ('t1','T1','done',?, '00000000-0000-4000-8000-000000000001', '2026-05-01T00:00:00Z','2026-05-01T00:00:00Z')`, work)

	jdir := filepath.Join(claudeProj, claude.EncodeCwd(work))
	os.MkdirAll(jdir, 0o755)
	// (a) lookup BEFORE the cutoff, (b) lookup AFTER the cutoff,
	// (c) lookup with a missing timestamp (zero TS).
	before := `{"type":"assistant","timestamp":"2026-05-01T10:00:00.000Z","message":{"role":"assistant","content":[{"type":"tool_use","name":"Bash","input":{"command":"flow show task"}}]}}`
	after := `{"type":"assistant","timestamp":"2026-06-10T10:00:00.000Z","message":{"role":"assistant","content":[{"type":"tool_use","name":"Bash","input":{"command":"flow show task"}}]}}`
	noTS := `{"type":"assistant","message":{"role":"assistant","content":[{"type":"tool_use","name":"Bash","input":{"command":"flow show task"}}]}}`
	os.WriteFile(filepath.Join(jdir, "00000000-0000-4000-8000-000000000001.jsonl"),
		[]byte(before+"\n"+after+"\n"+noTS+"\n"), 0o644)

	// Brief + updates for t1 — known byte sizes for the windowed token assertion.
	// All three lookups are resumes, so each in-window resume contributes
	// briefBytes + updatesBytes. Only the after-cutoff one is in window.
	briefContent := []byte("# T1 brief\nWindowed test brief.\n") // 32 bytes
	updatesContent := []byte("# update\nWindowed update note.\n")  // 31 bytes
	os.MkdirAll(filepath.Join(root, "tasks", "t1", "updates"), 0o755)
	os.WriteFile(filepath.Join(root, "tasks", "t1", "brief.md"), briefContent, 0o644)
	os.WriteFile(filepath.Join(root, "tasks", "t1", "updates", "u1.md"), updatesContent, 0o644)

	c := LoadCache(filepath.Join(root, "stats-cache.json"))
	since := time.Date(2026, 6, 1, 0, 0, 0, 0, time.UTC) // between (a) and (b)
	s, err := BuildStats(BuildOpts{
		Root: root, ClaudeProjects: claudeProj, DB: db, Cache: c,
		Constants: DefaultConstants(), Since: since, Project: "",
	})
	if err != nil {
		t.Fatal(err)
	}
	// Only the after-cutoff lookup is counted; zero-TS and before-cutoff excluded.
	if s.LookupsTotal != 1 || s.LookupsByKind[LookupResume] != 1 {
		t.Errorf("windowed lookups = %d %v, want 1 resume", s.LookupsTotal, s.LookupsByKind)
	}
	// The window guard must govern byte accumulation too: only the single
	// in-window resume contributes; out-of-window and zero-TS contribute ZERO.
	wantContextTokens := (int64(len(briefContent)) + int64(len(updatesContent))) / 4
	if s.Savings.ContextTokens != wantContextTokens {
		t.Errorf("windowed ContextTokens = %d, want %d (only the 1 in-window resume: (brief=%d + updates=%d)/4)",
			s.Savings.ContextTokens, wantContextTokens, len(briefContent), len(updatesContent))
	}
}

func TestBuildStatsPlaybookRuns(t *testing.T) {
	root := t.TempDir()