Phase 9: Faster Write-Back (CAL-15) — event-driven outbox drain #14

Merged

luckberg merged 26 commits from gsd/phase-09-faster-write-back into main 2026-06-12 21:19:17 -04:00

Conversation 0 Commits 26 Files Changed 21

+2634 -94

26 Commits

Author	SHA1	Message	Date
Lucas Berger	89411ce44b	style(09): prettier-format outboxWorker.test.ts (fix CI format check)	2026-06-12 21:12:17 -04:00
Lucas Berger	777910c86a	docs(09): add code review fix report + refresh review after fixes	2026-06-12 21:01:55 -04:00
Lucas Berger	b7767af825	fix(09): IN-01 guard __resetDrainState against production use	2026-06-12 20:59:53 -04:00
Lucas Berger	b724b3e932	fix(09): WR-03/IN-03/IN-04 add drain-listener teardown, test-only __resetDrainState, and remove stale RED @ts-ignore	2026-06-12 20:51:49 -04:00
Lucas Berger	e1ffddf8dc	fix(09): WR-02 make initOutboxTrigger idempotent and retain the unsubscribe handle via stopOutboxTrigger	2026-06-12 20:51:32 -04:00
Lucas Berger	d3163f2281	fix(09): IN-02 extract shared resolveFinalRrule helper to deduplicate the update/create RRULE decision tree	2026-06-12 20:50:52 -04:00
Lucas Berger	b8bb6e7671	fix(09): IN-01 add ordering comments cementing signalOutboxDrain() stays after the enqueue commit	2026-06-12 20:50:26 -04:00
Lucas Berger	8307a7b713	fix(09): WR-01 defer outbox drain emit to a microtask so a throwing listener cannot corrupt the enqueue route response	2026-06-12 20:50:21 -04:00
Lucas Berger	1bc1f134a7	docs(09): refresh code review report	2026-06-12 17:24:08 -04:00
Lucas Berger	ffc1f52f2b	docs(phase-09): evolve PROJECT.md after phase completion	2026-06-12 17:09:34 -04:00
Lucas Berger	03f02a1207	docs(phase-09): complete phase execution	2026-06-12 17:08:54 -04:00
Lucas Berger	551b751b81	docs(09): add code review report	2026-06-12 17:04:55 -04:00
Lucas Berger	fff5789a5f	docs(09-02): complete enqueue-site signal wiring plan ... - 09-02-SUMMARY.md: 4 signalOutboxDrain() sites + initOutboxTrigger() startup wiring - STATE.md: plan position advanced, metrics recorded - ROADMAP.md: plan progress updated - REQUIREMENTS.md: CAL-15 marked complete	2026-06-12 16:59:27 -04:00
Lucas Berger	0ebdf4864d	feat(09-02): wire initOutboxTrigger() at startup under isMainModule() in index.ts ... - extend outboxWorker import to include initOutboxTrigger alongside startOutboxWorker - call initOutboxTrigger() immediately after startOutboxWorker() inside isMainModule() guard - gated by isMainModule() so tests importing app never register the drain listener (Pitfall 4)	2026-06-12 16:57:52 -04:00
Lucas Berger	30eff3dcdb	feat(09-02): add signalOutboxDrain() after each of four enqueue sites in events.ts ... - import signalOutboxDrain from '../lib/outboxTrigger.js' - Site 1 (POST /create): fire-and-forget signal after outbox insert, before 202 - Site 2 (PATCH edit-as-move): signal after await db.transaction() resolves, not inside callback (D-03) - Site 3 (PATCH same-calendar update): signal after outbox insert, before 202 - Site 4 (DELETE): signal after outbox insert, before 202	2026-06-12 16:57:21 -04:00
Lucas Berger	9164619ccd	docs(09-01): complete outbox drain trigger wiring plan	2026-06-12 16:54:20 -04:00
Lucas Berger	2b113045f7	feat(09-01): add scheduleOutboxDrain, drainRequested, initOutboxTrigger; route setInterval through wrapper ... - Add import { onOutboxDrain } from outboxTrigger.js - Add let drainRequested = false (D-05 trailing-re-drain flag) - Export scheduleOutboxDrain(): void — isDraining guard + drainRequested loop (D-05/T-09-01) drainRequested=false reset precedes recursive call (Pitfall 3) errors caught via .catch to prevent crash (D-02/T-09-03) - Export initOutboxTrigger(): void — registers onOutboxDrain(() => scheduleOutboxDrain()) - startOutboxWorker setInterval body: scheduleOutboxDrain() replaces runOutboxDrain().catch() 15 * 1000 interval unchanged (D-08) - runOutboxDrain body/isDraining guard/finally unchanged (D-02/D-07) - Fix trigger-wiring tests: add beforeAll(initOutboxTrigger) to wire EventEmitter listener; fix Test C mock to return empty rows on trailing drain (correct D-07 behaviour) - 30/30 outboxWorker tests GREEN; tsc --noEmit clean	2026-06-12 16:52:36 -04:00
Lucas Berger	bcde073729	test(09-01): add failing trigger-wiring tests for SC-1, D-05, D-07 ... - Import scheduleOutboxDrain (not yet exported — causes RED) - Import signalOutboxDrain from outboxTrigger.ts - Add describe block 'scheduleOutboxDrain — trigger wiring (D-09)' with 3 tests: Test A SC-1: signalOutboxDrain() fires drain promptly without timer advance Test B D-05: two mid-drain signals collapse to exactly one trailing re-drain Test C D-07: concurrent scheduleOutboxDrain() calls dispatch exactly once via isDraining guard - 27 pre-existing tests unmodified and passing; 3 new tests failing (RED)	2026-06-12 16:48:41 -04:00
Lucas Berger	1e12d702a1	feat(09-01): create outboxTrigger.ts zero-dependency EventEmitter signal module ... - Module-level singleton EventEmitter, single subscriber, no setMaxListeners - Export signalOutboxDrain(): void — fire-and-forget drain signal (D-04) - Export onOutboxDrain(handler): () => void — register/unsubscribe listener - Only imports node:events; zero internal dependencies (no circular import risk)	2026-06-12 16:47:39 -04:00
Lucas Berger	a78c7241d6	docs(09): add pattern map	2026-06-12 14:28:32 -04:00
Lucas Berger	5fdbd11475	docs(09): create phase plan	2026-06-12 14:28:09 -04:00
Lucas Berger	b22c92ae92	docs(09): create phase plan (2 plans, 2 waves) — outboxTrigger + drain signal wiring	2026-06-12 14:21:37 -04:00
Lucas Berger	555f4c80f8	docs(phase-9): add validation strategy	2026-06-12 14:11:10 -04:00
Lucas Berger	106574df1d	docs(09): research phase — faster write-back trigger wiring	2026-06-12 14:09:26 -04:00
Lucas Berger	b104d73cb5	docs(state): record phase 9 context session	2026-06-12 14:02:28 -04:00
Lucas Berger	2a11e86bca	docs(09): capture phase context	2026-06-12 14:02:21 -04:00