lsm / neokai / 22561074815 / 7
84%
dev: 84%

DEFAULT BRANCH: dev
Ran
Files 139
Run time 4s
Badge
Embed ▾
README BADGES
x

If you need to use a raster PNG badge, change the '.svg' to '.png' in the link

Markdown

Textile

RDoc

HTML

Rst
coverage: 24.54% (-0.1%) from 24.67%
22561074815.7

push

github

web-flow 
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)

6081 of 24780 relevant lines covered (24.54%)

12.03 hits per line

Source Files on job daemon-online-features-2 - 22561074815.7