feat(recv)!: batch the inbound commit pipeline during the offline drain - #961

Merged

jlucaso1 merged 35 commits into

mainfrom

claude/whatsapp-rust-allocator-api-prw9c4

Jul 3, 2026

Commits on Jul 3, 2026

feat(recv)!: batch the inbound commit pipeline during the offline drain
claude
committed
e0dc4a4
fix(bot): keep MessageContext out of the batched on_message future
claude
committed
d114f3a
fix(recv): raceless drain-to-live transition; review fixes from cubic/codex/greptile/coderabbit
claude
committed
66ac89a
fix(recv): commit the drain batch before cleanup's Signal flush; dispatch replayed messages
claude
committed
bbf931d
fix(recv): actually reorder acks before the batch event dispatch
claude
committed
9c9bee7
fix(recv): flush Signal state on empty drain flushes; align docs; keep .text in budget
claude
committed
dcdc148
fix(recv): route redelivery replays through the commit batcher
claude
committed
d1d0019
fix(recv): log the self_weak upgrade failure in cleanup's drain flush
claude
committed
a3accf3
fix(recv): close self-review findings on the inbound commit batcher
claude
committed
8c44cff
fix(recv): report Signal-flush failures as not-durable in drain commits
claude
committed
a178372
fix(recv): close review follow-ups on the drain finisher and lock order
claude
committed
1d95e3f
refactor(recv): consolidate the drain-to-live publication
claude
committed
dacb7b4
fix(recv): defer the drain-to-live transition when the tail commit fails
claude
committed
d8ce860
fix(recv): hold the single permit while a deferred tail commit retries
claude
committed
5ec1970
fix(recv): arm a retry loop when the live transition is deferred
claude
committed
a93f243
fix(recv): route the session-establishment flush through the batch-safe wrapper
claude
committed
9c02601
fix(recv): generation-scope the deferred-transition retry task
claude
committed
cf368ba
fix(recv): bound the timeout-arm wait on an already-running finisher
claude
committed
a5a0fd2
fix(recv): keep hook batches retryable when the Signal flush fails after the rows
claude
committed
9a93e30
fix(recv): settle the teardown Signal cache under the processing permit
claude
committed
3278ae6
fix(recv): don't destroy teardown-retained Signal state at connect
claude
committed
9af8f0c
fix(recv): clear the cache-retention flag only on a successful flush
claude
committed
9e15e3d
fix(recv): quiesce lane workers at teardown instead of patching around them
claude
committed
c4cd5e1
fix(recv): compare stale lane work against the lane's spawn generation
claude
committed
4053f18
fix(recv): gate classification on the lane generation; keep the tracing span in production
claude
committed
a5618bd
fix(recv): hold SKDM receipts through the deferred window; keep the cache on entryless teardown timeouts
claude
committed
371d4c9
test(recv): cover the deferred-window receipt-buffering contract
claude
committed
77cb458
fix(recv): couple the Signal-cache drop to the batcher resets that drop entries
claude
committed
baf3952
fix(recv): re-scope the mode mutation after awaited commits; keep the identity path single-permit
claude
committed
52c8a87
docs(recv): fix stale re-acquire comment at the permit call site
claude
committed
68358c4
fix(recv): drop the dirty Signal cache on a teardown-settle timeout
claude
committed
19eee50
refactor(events): tighten the Messages event API surface (pre-1.0)
claude
committed
19bef0e
fix(recv): close batch-safe flush TOCTOU and log teardown drops
claude
committed
99fe8c7
refactor(recv): make the under-permit commit always flush; drop stale recheck
claude
committed
d82ccea
fix(recv): fail closed on active drain without a live client; fix stale doc
claude
committed
4b672d6