Rotorsoft / act-root / 25994999549

100%

push

github

feat(act): add Store.query_stats — batched per-stream aggregates (#752)

* feat(act): add Store.query_stats port + in-mem + TCK (#639 slice 1+2)

Adds Store.query_stats(input, options): per-stream aggregated stats in
a single round trip per adapter. Heads-only default stays index-friendly;
opt-in count/tail/names/before share one full scan when requested.

Surface (libs/act/src/types/ports.ts):
  - StreamStats<E>:        { head, tail?, count?, names? }
  - QueryStatsOptions<E>:  { tail?, count?, names?, exclude?, before? }
  - EventName<E> + FrameworkEventName: typed exclude lists keep
    "__snapshot__"/"__tombstone__" in the type system without
    inducing a types/ -> ports.ts cycle.
  - Store.query_stats: input is string[] | StreamFilter (mirrors
    reset / unblock / prioritize convention).

Naming: head = latest event, tail = earliest — git-log convention,
opposite of Unix head/tail; flagged in JSDoc.

Snapshot count: derivable from names[SNAP_EVENT] when names: true and
SNAP_EVENT not in exclude. No separate field needed.

Time travel: before?: number filters events with id < cutoff. Cheap on
both code paths.

InMemoryStore: full impl with single forward-scan accumulator, scope
predicate caching per stream, source/blocked filters require
subscription lookup, before-cutoff handled inline.

PostgresStore + SqliteStore: stubs that throw with a clear ACT-639
slice pointer until real impls land in slices 3 and 4.

TCK (libs/act-tck/src/store-tck.ts): new describe("query_stats") block
with 6 conformance cases — array input + empty input, tail, count+names
(including snapshot count via names map), exclude (head shifts, full
filter, framework markers), before (time travel), filter form (regex /
exact / source / blocked via subscriptions).

All 58 InMemoryStore TCK tests pass.

Refs #639 (design ticket updated with full query_stats shape)
Refs #708 (Inspector schema-evolution tab — updated to consume
query_stats instead of the originally proposed count_... (continued)

2572 of 2572 branches covered (100.0%)

Branch coverage included in aggregate %.

295 of 295 new or added lines in 5 files covered. (100.0%)

4880 of 4880 relevant lines covered (100.0%)

396.5 hits per line