feat: decode activity SSE events and expose tracker total

2026-08-14 12:53:40 -06:00
parent ce372568e4
commit e961ed35aa
4 changed files with 30 additions and 0 deletions
@@ -63,3 +63,13 @@ test("modelStatus normalizes states", () => {
  assert.equal(tracker.state("D"), "stopped");
  assert.equal(tracker.state("missing"), undefined);
 });
+
+test("total sums in-flight requests across all models", () => {
+  const tracker = new InflightTracker();
+  assert.equal(tracker.total(), 0);
+  tracker.apply({ type: "inflight", operation: "add", requests: [{ model: "A", id: "1" }, { model: "B", id: "2" }] });
+  tracker.apply({ type: "inflight", operation: "add", requests: [{ model: "A", id: "3" }] });
+  assert.equal(tracker.total(), 3);
+  tracker.apply({ type: "inflight", operation: "remove", id: "1" });
+  assert.equal(tracker.total(), 2);
+});