feat(chat): cache timer for Claude Code subscription models

Per-step and per-turn timers for the gaps between model requests (the
Claude prompt cache expires after 5 min idle). A step gap runs live under
the executing tools from step-complete until its last tool result (or the
next step's output), then is stamped on that step's metrics line beside
its cache badge. A turn gap runs live on the turn's metrics line from
done/error until the next message is sent, then is stamped there. Counts
m:ss up to 10 min, then '10+ min'; colour tracks the 5-min TTL.

Gated on claude/<model>. Pure reducer in core/metrics/cache-timer.ts;
the turn gap is seeded from an idle conversation's lastActivityAt so it
survives a reload. Stamps are in-memory only.

3 files changed, 644 insertions, 0 deletions

diff --git a/src/core/metrics/cache-timer.test.ts b/src/core/metrics/cache-timer.test.ts
new file mode 100644
index 0000000..e55eff4
--- /dev/null
+++ b/src/core/metrics/cache-timer.test.ts
@@ -0,0 +1,344 @@
+import type { AgentEvent, StepId, TurnMetrics } from "@dispatch/wire";
+import { describe, expect, it } from "vitest";
+import type { RenderGroup } from "../chunks";
+import {
+  CACHE_TIMER_MAX_MS,
+  CACHE_TTL_MS,
+  type CacheTimerState,
+  foldCacheTimerEvent,
+  initialCacheTimerState,
+  lastTurnRowIndex,
+  seedTurnGap,
+  stopTurnGap,
+  viewCacheTimer,
+} from "./cache-timer";
+import type { MetricsRow } from "./types";
+
+const SEC = 1000;
+const MIN = 60 * SEC;
+const C = "conv";
+
+const ev = {
+  turnStart: (turnId: string): AgentEvent => ({ type: "turn-start", conversationId: C, turnId }),
+  userMessage: (turnId: string): AgentEvent => ({
+    type: "user-message",
+    conversationId: C,
+    turnId,
+    text: "hi",
+  }),
+  text: (turnId: string): AgentEvent => ({
+    type: "text-delta",
+    conversationId: C,
+    turnId,
+    delta: "x",
+  }),
+  call: (turnId: string, stepId: string, toolCallId: string): AgentEvent => ({
+    type: "tool-call",
+    conversationId: C,
+    turnId,
+    stepId: stepId as StepId,
+    toolCallId,
+    toolName: "t",
+    input: {},
+  }),
+  result: (
+    turnId: string,
+    stepId: string,
+    toolCallId: string,
+    durationMs?: number,
+  ): AgentEvent => ({
+    type: "tool-result",
+    conversationId: C,
+    turnId,
+    stepId: stepId as StepId,
+    toolCallId,
+    toolName: "t",
+    content: "ok",
+    isError: false,
+    ...(durationMs !== undefined ? { durationMs } : {}),
+  }),
+  stepComplete: (turnId: string, stepId: string): AgentEvent => ({
+    type: "step-complete",
+    conversationId: C,
+    turnId,
+    stepId: stepId as StepId,
+  }),
+  usage: (turnId: string, stepId: string): AgentEvent => ({
+    type: "usage",
+    conversationId: C,
+    turnId,
+    stepId: stepId as StepId,
+    usage: { inputTokens: 1, outputTokens: 1 },
+  }),
+  done: (turnId: string): AgentEvent => ({
+    type: "done",
+    conversationId: C,
+    turnId,
+    reason: "end-turn",
+  }),
+  error: (turnId: string): AgentEvent => ({
+    type: "error",
+    conversationId: C,
+    turnId,
+    message: "boom",
+  }),
+};
+
+const noTurn = () => undefined;
+
+/** Fold `[time, event]` pairs from the initial state. */
+function run(
+  steps: readonly (readonly [number, AgentEvent])[],
+  start: CacheTimerState = initialCacheTimerState(),
+  lastTurnId: () => string | undefined = noTurn,
+): CacheTimerState {
+  return steps.reduce((s, [at, e]) => foldCacheTimerEvent(s, e, at, lastTurnId), start);
+}
+
+describe("foldCacheTimerEvent — step gaps", () => {
+  it("runs from step-complete while tools execute, and stamps when the last result returns", () => {
+    const s1 = run([
+      [0, ev.turnStart("t1")],
+      [100, ev.call("t1", "t1#0", "a")],
+      [110, ev.call("t1", "t1#0", "b")],
+      [1_000, ev.stepComplete("t1", "t1#0")],
+    ]);
+    expect(s1.running).toMatchObject({
+      kind: "step",
+      stepId: "t1#0",
+      startedAt: 1_000,
+      toolCount: 2,
+    });
+
+    const s2 = run([[4_000, ev.result("t1", "t1#0", "a")]], s1);
+    expect(s2.running?.kind).toBe("step"); // still waiting on "b"
+    expect(s2.stepStamps.size).toBe(0);
+
+    const s3 = run([[13_000, ev.result("t1", "t1#0", "b")]], s2);
+    expect(s3.running).toBeNull();
+    expect(s3.stepStamps.get("t1#0")).toBe(12_000);
+  });
+
+  it("stamps each step of a multi-step turn separately", () => {
+    const s = run([
+      [0, ev.call("t1", "t1#0", "a")],
+      [1_000, ev.stepComplete("t1", "t1#0")],
+      [3_000, ev.result("t1", "t1#0", "a")],
+      [5_000, ev.call("t1", "t1#1", "b")],
+      [6_000, ev.stepComplete("t1", "t1#1")],
+      [66_000, ev.result("t1", "t1#1", "b")],
+    ]);
+    expect(s.stepStamps.get("t1#0")).toBe(2_000);
+    expect(s.stepStamps.get("t1#1")).toBe(60_000);
+  });
+
+  it("uses the backend tool duration when it exceeds the wall clock (late-join replay burst)", () => {
+    const s = run([
+      [5_000, ev.call("t1", "t1#0", "a")],
+      [5_000, ev.stepComplete("t1", "t1#0")],
+      [5_000, ev.result("t1", "t1#0", "a", 42_000)],
+    ]);
+    expect(s.stepStamps.get("t1#0")).toBe(42_000);
+  });
+
+  it("stops at the next step's output when a result never matched (fallback)", () => {
+    const s = run([
+      [0, ev.call("t1", "t1#0", "a")],
+      [1_000, ev.stepComplete("t1", "t1#0")],
+      [9_000, ev.text("t1")],
+    ]);
+    expect(s.running).toBeNull();
+    expect(s.stepStamps.get("t1#0")).toBe(8_000);
+  });
+
+  it("stops on a tool-call or usage from a DIFFERENT step, not its own", () => {
+    const base = run([
+      [0, ev.call("t1", "t1#0", "a")],
+      [1_000, ev.stepComplete("t1", "t1#0")],
+    ]);
+    expect(run([[2_000, ev.usage("t1", "t1#0")]], base).running?.kind).toBe("step");
+    expect(run([[3_000, ev.usage("t1", "t1#1")]], base).stepStamps.get("t1#0")).toBe(2_000);
+    expect(run([[4_000, ev.call("t1", "t1#1", "z")]], base).stepStamps.get("t1#0")).toBe(3_000);
+  });
+
+  it("discards a step with no tool calls (the final step of a turn)", () => {
+    const s = run([
+      [1_000, ev.stepComplete("t1", "t1#0")],
+      [1_050, ev.done("t1")],
+    ]);
+    expect(s.stepStamps.size).toBe(0);
+    expect(s.running).toEqual({ kind: "turn", turnId: "t1", startedAt: 1_050 });
+  });
+
+  it("stamps a step whose tools were still running when the turn ended (stopped)", () => {
+    const s = run([
+      [0, ev.call("t1", "t1#0", "a")],
+      [1_000, ev.stepComplete("t1", "t1#0")],
+      [21_000, ev.done("t1")],
+    ]);
+    expect(s.stepStamps.get("t1#0")).toBe(20_000);
+    expect(s.running?.kind).toBe("turn");
+  });
+});
+
+describe("foldCacheTimerEvent — turn gaps", () => {
+  it("starts at done and is stamped on that turn when the next turn starts", () => {
+    const s = run([
+      [1_000, ev.done("t1")],
+      [91_000, ev.userMessage("t2")],
+      [91_500, ev.turnStart("t2")],
+    ]);
+    expect(s.running).toBeNull();
+    expect(s.turnStamps.get("t1")).toBe(90_000);
+  });
+
+  it("an error also ends the turn", () => {
+    expect(run([[7, ev.error("t1")]]).running).toEqual({
+      kind: "turn",
+      turnId: "t1",
+      startedAt: 7,
+    });
+  });
+
+  it("stopTurnGap stamps on a local send", () => {
+    const s = stopTurnGap(run([[1_000, ev.done("t1")]]), 4_000, noTurn);
+    expect(s.running).toBeNull();
+    expect(s.turnStamps.get("t1")).toBe(3_000);
+  });
+
+  it("stopTurnGap is a no-op while a step gap runs", () => {
+    const base = run([
+      [0, ev.call("t1", "t1#0", "a")],
+      [1_000, ev.stepComplete("t1", "t1#0")],
+    ]);
+    expect(stopTurnGap(base, 2_000, noTurn)).toBe(base);
+  });
+});
+
+describe("seedTurnGap", () => {
+  it("seeds a turn gap with no turnId, stamped on the most recent turn when stopped", () => {
+    const seeded = seedTurnGap(initialCacheTimerState(), 1_000);
+    expect(seeded.running).toEqual({ kind: "turn", turnId: null, startedAt: 1_000 });
+    const s = stopTurnGap(seeded, 61_000, () => "t9");
+    expect(s.turnStamps.get("t9")).toBe(60_000);
+  });
+
+  it("drops a seeded gap when the most recent turn is unknown", () => {
+    const s = stopTurnGap(seedTurnGap(initialCacheTimerState(), 1_000), 2_000, noTurn);
+    expect(s.running).toBeNull();
+    expect(s.turnStamps.size).toBe(0);
+  });
+
+  it("keeps the later start, never overrides a step gap, ignores non-finite", () => {
+    const live = run([[5_000, ev.done("t1")]]);
+    expect(seedTurnGap(live, 4_000).running).toEqual({
+      kind: "turn",
+      turnId: "t1",
+      startedAt: 5_000,
+    });
+    expect(seedTurnGap(live, 6_000).running).toEqual({
+      kind: "turn",
+      turnId: "t1",
+      startedAt: 6_000,
+    });
+    const step = run([
+      [0, ev.call("t1", "t1#0", "a")],
+      [1_000, ev.stepComplete("t1", "t1#0")],
+    ]);
+    expect(seedTurnGap(step, 9_000)).toBe(step);
+    expect(seedTurnGap(initialCacheTimerState(), Number.NaN).running).toBeNull();
+  });
+});
+
+describe("viewCacheTimer", () => {
+  it("formats m:ss up to 10 minutes", () => {
+    expect(viewCacheTimer(0).label).toBe("0:00");
+    expect(viewCacheTimer(9 * SEC + 999).label).toBe("0:09");
+    expect(viewCacheTimer(MIN + 5 * SEC).label).toBe("1:05");
+    expect(viewCacheTimer(5 * MIN + 30 * SEC).label).toBe("5:30");
+    expect(viewCacheTimer(9 * MIN + 59 * SEC).label).toBe("9:59");
+    expect(viewCacheTimer(9 * MIN + 59 * SEC).capped).toBe(false);
+  });
+
+  it("reads '10+ min' and is capped at and past 10 minutes", () => {
+    expect(viewCacheTimer(CACHE_TIMER_MAX_MS)).toEqual({
+      label: "10+ min",
+      level: "error",
+      capped: true,
+    });
+    expect(viewCacheTimer(3 * 60 * MIN).label).toBe("10+ min");
+  });
+
+  it("colours by the 5-minute cache TTL", () => {
+    expect(viewCacheTimer(3 * MIN + 59 * SEC).level).toBe("success");
+    expect(viewCacheTimer(4 * MIN).level).toBe("warning");
+    expect(viewCacheTimer(CACHE_TTL_MS).level).toBe("error");
+    expect(viewCacheTimer(7 * MIN).level).toBe("error");
+  });
+
+  it("clamps negative / non-finite elapsed (clock skew) to 0:00", () => {
+    expect(viewCacheTimer(-5 * SEC).label).toBe("0:00");
+    expect(viewCacheTimer(Number.NaN).label).toBe("0:00");
+  });
+});
+
+function userRow(text = "hi"): MetricsRow {
+  const group: RenderGroup = {
+    kind: "single",
+    chunk: { seq: null, role: "user", chunk: { type: "text", text }, provisional: true },
+  };
+  return { kind: "group", group };
+}
+
+function assistantRow(turnId: string): MetricsRow {
+  const group: RenderGroup = {
+    kind: "single",
+    chunk: {
+      seq: 1,
+      role: "assistant",
+      chunk: { type: "text", text: "ok" },
+      provisional: false,
+      turnId,
+    },
+  };
+  return { kind: "group", group };
+}
+
+function turnRow(turnId: string, turnNumber: number): MetricsRow {
+  const usage = { inputTokens: 10, outputTokens: 5 };
+  const turn: TurnMetrics = { turnId, usage, steps: [{ stepId: `${turnId}#0` as StepId, usage }] };
+  return {
+    kind: "turn-metrics",
+    turn,
+    turnNumber,
+    cumulativeUsage: usage,
+    prevLastStepUsage: null,
+  };
+}
+
+describe("lastTurnRowIndex", () => {
+  it("picks the LAST turn-metrics row", () => {
+    const rows = [
+      userRow(),
+      assistantRow("t1"),
+      turnRow("t1", 1),
+      userRow(),
+      assistantRow("t2"),
+      turnRow("t2", 2),
+    ];
+    expect(lastTurnRowIndex(rows)).toBe(5);
+  });
+
+  it("is null once a user message follows the last turn", () => {
+    expect(lastTurnRowIndex([userRow(), turnRow("t1", 1), userRow("next")])).toBeNull();
+  });
+
+  it("skips trailing non-user rows after the turn row", () => {
+    expect(lastTurnRowIndex([userRow(), turnRow("t1", 1), assistantRow("t1")])).toBe(1);
+  });
+
+  it("is null with no turn-metrics rows", () => {
+    expect(lastTurnRowIndex([])).toBeNull();
+    expect(lastTurnRowIndex([userRow(), assistantRow("t1")])).toBeNull();
+  });
+});
diff --git a/src/core/metrics/cache-timer.ts b/src/core/metrics/cache-timer.ts
new file mode 100644
index 0000000..66d5fac
--- /dev/null
+++ b/src/core/metrics/cache-timer.ts
@@ -0,0 +1,285 @@
+import type { AgentEvent } from "@dispatch/wire";
+import type { MetricsRow } from "./types";
+
+/**
+ * Pure core for the **cache timer** — how long the prompt cache has sat idle
+ * between model requests. Anthropic's prompt cache (as used by the Claude Code
+ * subscription) expires 5 minutes after its last hit, so the gaps BETWEEN
+ * requests decide whether the next request reads from cache:
+ *
+ * - **step gap**: a step (one LLM round-trip) finished and its tools are
+ *   executing. Starts at `step-complete`; stops when the step's last tool
+ *   result arrives (the next request fires right after) or, failing that, when
+ *   anything from the next step shows up. Its final value is **stamped** on
+ *   that step (keyed by `stepId`).
+ * - **turn gap**: the turn ended (`done` / `error`) and the conversation is
+ *   waiting on the user. Stops when a new message is sent (locally, or a
+ *   `user-message` / `turn-start` from another client) and is stamped on that
+ *   turn (keyed by `turnId`).
+ *
+ * At most ONE gap runs at a time (`running`). Zero DOM, zero clock: every fold
+ * takes the current time as an argument.
+ */
+
+/** Prompt-cache time-to-live: 5 minutes (drives the badge colour). */
+export const CACHE_TTL_MS = 5 * 60 * 1000;
+
+/** The timer counts up to this, then reads "10+ min". */
+export const CACHE_TIMER_MAX_MS = 10 * 60 * 1000;
+
+/** Within this much of the TTL the timer warns (colour only). */
+const WARN_AT_MS = CACHE_TTL_MS - 60 * 1000;
+
+/** A step gap in progress: the step's tools are executing. */
+export interface RunningStepGap {
+  readonly kind: "step";
+  readonly turnId: string;
+  readonly stepId: string;
+  /** Epoch ms the step completed. */
+  readonly startedAt: number;
+  /** How many tool calls the step made (`0` → nothing to show; never stamped). */
+  readonly toolCount: number;
+  /** Tool calls still awaiting their result. */
+  readonly pending: ReadonlySet<string>;
+  /** Longest backend-reported tool `durationMs` seen so far for this step. */
+  readonly maxToolMs: number;
+}
+
+/** A turn gap in progress: the turn ended and nothing has been sent since. */
+export interface RunningTurnGap {
+  readonly kind: "turn";
+  /**
+   * The turn that ended, or `null` when seeded from the backend's
+   * `lastActivityAt` after a reload (no live `done` seen) — then it belongs to
+   * the most recent turn, resolved positionally / via `lastTurnId` on stop.
+   */
+  readonly turnId: string | null;
+  /** Epoch ms the turn ended. */
+  readonly startedAt: number;
+}
+
+export type RunningGap = RunningStepGap | RunningTurnGap;
+
+export interface CacheTimerState {
+  readonly running: RunningGap | null;
+  /** Stamped step gaps: `stepId` → elapsed ms. */
+  readonly stepStamps: ReadonlyMap<string, number>;
+  /** Stamped turn gaps: `turnId` → elapsed ms. */
+  readonly turnStamps: ReadonlyMap<string, number>;
+  /** Tool calls seen per step in the CURRENT turn (`stepId` → call ids). */
+  readonly calls: ReadonlyMap<string, ReadonlySet<string>>;
+  /** Tool results seen per step in the CURRENT turn (`stepId` → call ids). */
+  readonly results: ReadonlyMap<string, ReadonlySet<string>>;
+  /** Longest tool `durationMs` per step in the CURRENT turn. */
+  readonly toolMs: ReadonlyMap<string, number>;
+}
+
+export function initialCacheTimerState(): CacheTimerState {
+  return {
+    running: null,
+    stepStamps: new Map(),
+    turnStamps: new Map(),
+    calls: new Map(),
+    results: new Map(),
+    toolMs: new Map(),
+  };
+}
+
+function addTo(
+  map: ReadonlyMap<string, ReadonlySet<string>>,
+  key: string,
+  value: string,
+): ReadonlyMap<string, ReadonlySet<string>> {
+  const next = new Map(map);
+  next.set(key, new Set([...(map.get(key) ?? []), value]));
+  return next;
+}
+
+function withEntry(map: ReadonlyMap<string, number>, key: string, value: number) {
+  const next = new Map(map);
+  next.set(key, value);
+  return next;
+}
+
+/**
+ * Stop the running STEP gap (if any). A step that made tool calls is stamped
+ * with `max(wall-clock elapsed, longest backend tool duration)` — the backend
+ * figure keeps a late-join replay (whole step delivered in one burst, ~0
+ * elapsed) honest. A step with no tool calls is discarded.
+ */
+function stopStep(state: CacheTimerState, now: number): CacheTimerState {
+  const r = state.running;
+  if (r === null || r.kind !== "step") return state;
+  if (r.toolCount === 0) return { ...state, running: null };
+  const elapsed = Math.max(0, now - r.startedAt, r.maxToolMs);
+  return { ...state, running: null, stepStamps: withEntry(state.stepStamps, r.stepId, elapsed) };
+}
+
+/**
+ * Stop the running TURN gap (if any) and stamp it on its turn. A seeded gap
+ * (`turnId === null`) is stamped on `lastTurnId()` — the most recent turn's
+ * id — or dropped when that is unknown.
+ */
+export function stopTurnGap(
+  state: CacheTimerState,
+  now: number,
+  lastTurnId: () => string | undefined,
+): CacheTimerState {
+  const r = state.running;
+  if (r === null || r.kind !== "turn") return state;
+  const turnId = r.turnId ?? lastTurnId();
+  if (turnId === undefined) return { ...state, running: null };
+  const elapsed = Math.max(0, now - r.startedAt);
+  return { ...state, running: null, turnStamps: withEntry(state.turnStamps, turnId, elapsed) };
+}
+
+/** A turn ended: close any step gap, forget the turn's tool bookkeeping, start the turn gap. */
+function endTurn(state: CacheTimerState, turnId: string, now: number): CacheTimerState {
+  const s = stopStep(state, now);
+  return {
+    ...s,
+    running: { kind: "turn", turnId, startedAt: now },
+    calls: new Map(),
+    results: new Map(),
+    toolMs: new Map(),
+  };
+}
+
+/**
+ * Fold one live event into the cache-timer state at time `now`. `lastTurnId`
+ * resolves a seeded turn gap's turn when a new turn starts (see
+ * `stopTurnGap`); it is only called in that case.
+ */
+export function foldCacheTimerEvent(
+  state: CacheTimerState,
+  event: AgentEvent,
+  now: number,
+  lastTurnId: () => string | undefined,
+): CacheTimerState {
+  const r = state.running;
+  switch (event.type) {
+    case "user-message":
+    case "turn-start":
+      // A new turn is starting — the user (here or elsewhere) sent a message.
+      return stopTurnGap(state, now, lastTurnId);
+
+    case "tool-call": {
+      // A call from a DIFFERENT step means the next step is already streaming.
+      const s = r?.kind === "step" && r.stepId !== event.stepId ? stopStep(state, now) : state;
+      return { ...s, calls: addTo(s.calls, event.stepId, event.toolCallId) };
+    }
+
+    case "tool-result": {
+      const results = addTo(state.results, event.stepId, event.toolCallId);
+      const dur = event.durationMs ?? 0;
+      const toolMs =
+        dur > (state.toolMs.get(event.stepId) ?? 0)
+          ? withEntry(state.toolMs, event.stepId, dur)
+          : state.toolMs;
+      let s: CacheTimerState = { ...state, results, toolMs };
+      if (r?.kind === "step" && r.stepId === event.stepId) {
+        const pending = new Set(r.pending);
+        pending.delete(event.toolCallId);
+        s = { ...s, running: { ...r, pending, maxToolMs: Math.max(r.maxToolMs, dur) } };
+        // Every tool of the step has returned → the next request fires now.
+        if (pending.size === 0) s = stopStep(s, now);
+      }
+      return s;
+    }
+
+    case "step-complete": {
+      const s = stopStep(stopTurnGap(state, now, lastTurnId), now);
+      const calls = s.calls.get(event.stepId) ?? new Set<string>();
+      const done = s.results.get(event.stepId) ?? new Set<string>();
+      const pending = new Set([...calls].filter((id) => !done.has(id)));
+      return {
+        ...s,
+        running: {
+          kind: "step",
+          turnId: event.turnId,
+          stepId: event.stepId,
+          startedAt: now,
+          toolCount: calls.size,
+          pending,
+          maxToolMs: s.toolMs.get(event.stepId) ?? 0,
+        },
+      };
+    }
+
+    case "text-delta":
+    case "reasoning-delta":
+    case "provider-retry":
+      // Output (or a retry) from the next request: the gap is over.
+      return r?.kind === "step" ? stopStep(state, now) : state;
+
+    case "usage":
+      return r?.kind === "step" && event.stepId !== undefined && event.stepId !== r.stepId
+        ? stopStep(state, now)
+        : state;
+
+    case "done":
+    case "error":
+      return endTurn(state, event.turnId, now);
+
+    default:
+      return state;
+  }
+}
+
+/**
+ * Seed a turn gap from an authoritative "last activity" timestamp (the
+ * backend's `lastActivityAt`, for a conversation that is idle — e.g. after a
+ * reload, when no live `done` was seen). Never overrides a running step gap;
+ * a running turn gap keeps the LATER start. Non-finite input is ignored.
+ */
+export function seedTurnGap(state: CacheTimerState, at: number): CacheTimerState {
+  if (!Number.isFinite(at)) return state;
+  const r = state.running;
+  if (r === null) return { ...state, running: { kind: "turn", turnId: null, startedAt: at } };
+  if (r.kind === "turn" && at > r.startedAt) return { ...state, running: { ...r, startedAt: at } };
+  return state;
+}
+
+// ── View ──────────────────────────────────────────────────────────────────────
+
+/** Formatted cache-timer view: label + colour severity + capped flag. */
+export interface CacheTimerView {
+  /** `"m:ss"` up to 10 minutes, then `"10+ min"`. */
+  readonly label: string;
+  /** Colour by the 5-minute cache TTL (maps to DaisyUI `badge-{level}`). */
+  readonly level: "success" | "warning" | "error";
+  /** Whether the 10-minute display cap was reached (a live timer may stop ticking). */
+  readonly capped: boolean;
+}
+
+/**
+ * Build the view for `elapsedMs`. Colour tracks the cache TTL: success under
+ * 4 min, warning in the last minute, error once the cache has likely expired.
+ * Negative / non-finite elapsed (clock skew) clamps to `0:00`.
+ */
+export function viewCacheTimer(elapsedMs: number): CacheTimerView {
+  const ms = Number.isFinite(elapsedMs) && elapsedMs > 0 ? elapsedMs : 0;
+  const level = ms >= CACHE_TTL_MS ? "error" : ms >= WARN_AT_MS ? "warning" : "success";
+  if (ms >= CACHE_TIMER_MAX_MS) return { label: "10+ min", level, capped: true };
+  const totalSeconds = Math.floor(ms / 1000);
+  const minutes = Math.floor(totalSeconds / 60);
+  const seconds = totalSeconds % 60;
+  return { label: `${minutes}:${seconds.toString().padStart(2, "0")}`, level, capped: false };
+}
+
+/**
+ * Index of the most recent turn's metrics row — the LAST `turn-metrics` row,
+ * provided no user message follows it. Where a SEEDED turn gap (no `turnId`)
+ * renders. `null` when there is no such row.
+ */
+export function lastTurnRowIndex(rows: readonly MetricsRow[]): number | null {
+  for (let i = rows.length - 1; i >= 0; i--) {
+    const row = rows[i];
+    if (row === undefined) continue;
+    if (row.kind === "turn-metrics") return i;
+    if (row.kind === "group" && row.group.kind === "single" && row.group.chunk.role === "user") {
+      return null;
+    }
+  }
+  return null;
+}
diff --git a/src/core/metrics/index.ts b/src/core/metrics/index.ts
index d3c9669..d9df7f5 100644
--- a/src/core/metrics/index.ts
+++ b/src/core/metrics/index.ts
@@ -1,4 +1,19 @@
 export {
+  CACHE_TIMER_MAX_MS,
+  CACHE_TTL_MS,
+  type CacheTimerState,
+  type CacheTimerView,
+  foldCacheTimerEvent,
+  initialCacheTimerState,
+  lastTurnRowIndex,
+  type RunningGap,
+  type RunningStepGap,
+  type RunningTurnGap,
+  seedTurnGap,
+  stopTurnGap,
+  viewCacheTimer,
+} from "./cache-timer";
+export {
   type ContextUsage,
   computeCachePct,
   computeContextUsage,