ALL-945: MonitorTransitionOutbox publisher daemon (drain to Kafka)
blockedAgent: seph-engineer
Priority: 1
Branch:
wintermute/all-945-monitor-outbox-publisherLinear: ALL-945
Implement ALL-945: BullMQ recurring outbox publisher for monitor.transition events. Branch wintermute/all-945-monitor-outbox-publisher. Drain MonitorTransitionOutbox rows, publish monitor.transition, retry failures, DLQ after 5 attempts to monitor.transition.dlq, preserve (monitorId, entityId) sequence ordering, add unit/integration tests, open PR.
Event Timeline
created
progress
ALL-945 started. Confirmed receipt to Seph, fetched Linear ticket, branch/worktree ready at /home/agent/agents/wintermute/mono-all-945-monitor-outbox-publisher, spawned implementation sub-agent for drain loop + BullMQ worker + tests.
progress
ALL-945 implementation branch pushed and PR #10991 opened/assigned. Drain loop unit tests pass; domains/device lint passes; full typecheck still has unrelated existing test/type failures outside ALL-945. CI watch started for PR #10991.
progress
PR #10991: pushed f278f2af to address CodeRabbit/Cursor feedback. Changes: worker uses autorun:false and starts only after scheduler registration succeeds without blocking server startup; drain query now orders by (monitorId, entityId, sequence); removed new DeepSource exclusions and added queue/worker tests. Local targeted tests 12/12 pass; device lint/typecheck subset clean. CI watch restarted.
progress
PR #10991: pushed e0ab47e0ec to resolve DeepSource JS findings (JS-W1042/JS-0116/JS-C1003) by tightening test mocks and worker job handler. Local device lint passes; targeted publisher tests 12/12 pass. CI watch restarted.
progress
PR #10991: pushed e0ab47e to clear remaining Cursor/CodeRabbit/DeepSource feedback. Cursor review threads are outdated/resolved; CodeRabbit approved latest head; DeepSource latest PR issues list currently empty while analysis completes. CI still pending; watch continues.
progress
PR #10991: pushed 3276c02b0b to address Cursor Bugbot false-DLQ finding. Change separates Kafka publish failures from DB ack failures so attempts are not incremented/DLQed after a successful Kafka publish; added regression test. Local device lint passes; targeted publisher tests 19/19 pass with 97.6% line coverage over new publisher files. CI watch restarted.
progress
PR #10991: pushed dbea06d346 to address DeepSource test-coverage TCV-001 false positive on queue.ts closing object line. Local domains/device lint passes; targeted monitor outbox publisher tests 19/19 pass. CI watch restarted.
status_change
in_progress → blocked