lsm / neokai / 25478454997

82%

push

github

Add InternalQueryBus facade and preserve Live Query boundary (#1814)

* Add InternalQueryBus facade and preserve Live Query boundary

Implements the daemon InternalQueryBus following the same patterns as
InternalCommandBus and InternalEventBus:

- QueryResult<T> structured success/failure shape
- One-handler-per-query semantics with duplicate rejection
- Missing handlers return structured failures (never throw)
- Handler throws are caught and normalized to ok:false results
- register/execute/hasHandler/unregister/clear/getHandlerCount APIs
- createInternalQueryBus typed factory

Minimal integration:
- Export from daemon package.json
- Instantiate in createDaemonApp and expose via DaemonAppContext
- No broad migration of existing call sites

Live Query boundary is documented in the module header: InternalQueryBus
serves explicit point-in-time reads; LiveQueryEngine/ReactiveDatabase serve
reactive reads. Live Query remains read-model plumbing, not a domain event bus.

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

* Address review feedback: type QueryBus, remove dead metadata, fix test names

- Type queryBus with DaemonQueryMap via createInternalQueryBus<DaemonQueryMap>()
- Remove dead metadata field from QueryResult (handlers return raw TOutput)
- Use conditional-type helpers QueryInput/QueryOutput so constraint stays
  `extends object` and works with interface-style query maps
- Rename misleading test: 'return data on a successful handler result'
- Rename misleading test: 'preserve the original error when handler throws'

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

---------

Co-authored-by: Claude Opus 4.7 <noreply@anthropic.com>

8231 of 11408 branches covered (72.15%)

Branch coverage included in aggregate %.

59 of 59 new or added lines in 2 files covered. (100.0%)

63353 of 75378 relevant lines covered (84.05%)

285.34 hits per line