lsm / neokai / 22561074815

84%

push

github

ADR: Live Query and Job Queue Architecture (#176)

* feat(daemon): add ReactiveDatabase wrapper for change event emission

Proxy wrapper around BunDatabase that intercepts write operations (run/exec)
and emits per-table change events. Supports transaction batching (events
deferred until commit, suppressed on rollback) and a public notifyChange()
API for code that bypasses the Database facade.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* feat(daemon): add LiveQueryEngine for reactive SQL queries

Subscribe to parameterized SQL queries and receive callbacks when results
change. Uses content-hash diffing to detect actual data changes (not just
table writes). Supports snapshot + delta modes, configurable debounce,
and automatic cleanup via dispose().

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* feat(daemon): wire ReactiveDatabase and LiveQueryEngine into app lifecycle

Create ReactiveDatabase and LiveQueryEngine during app initialization,
expose them on DaemonAppContext, and dispose LiveQueryEngine on shutdown.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* feat(daemon): add job_queue table schema and indexes

Generic DB-backed queue table with status state machine (pending →
processing → completed/failed/dead), priority, scheduled execution,
retry tracking, and optimized dequeue index.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* feat(daemon): add JobQueueRepository for generic DB-backed queue

Atomic enqueue/dequeue with priority ordering, scheduled execution,
exponential backoff retries, dead-letter queue, stale job reclaim,
and cleanup. Exposed via Database facade.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* feat(daemon): add JobQueueProcessor for polling-based job execution

Register per-queue handlers, poll with configurable interval, respect
maxConcurrent limits, periodically reclaim stale jobs, and support
reactive change notification to skip unnecessary polls.

Co-Authored-... (continued)

2561 of 3019 branches covered (84.83%)

Branch coverage included in aggregate %.

518 of 519 new or added lines in 7 files covered. (99.81%)

20884 of 24512 relevant lines covered (85.2%)

266.22 hits per line