lsm / neokai / 25468115749

81%

push

github

Add InternalEventBus facade for semantic daemon events (#1806)

* Add InternalEventBus facade for semantic daemon events

Introduces InternalEventBus — a typed pub/sub primitive with explicit
await-vs-fire-and-forget semantics:

- publish(...) awaits all local handlers and throws
  InternalEventBusPublishError with structured HandlerFailure details.
- publishAsync(...) is explicit fire-and-forget.
- Subscriber names are required for diagnostics.
- Session-scoped and global subscriptions supported.

Wraps existing in-process infrastructure; no persistence/replay in v1.
Includes full unit-test coverage.

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

* Defer publishAsync dispatch via queueMicrotask to avoid sync handler stalls

publishAsync now schedules the publish call on the next microtask so
that synchronous handlers never run on the caller's stack. This keeps
the fire-and-forget contract: the method returns immediately regardless
of whether subscribers are sync or async.

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

* Fix double-delivery, generic factory typing, and docs

- publish: skip global handler lookup when sessionId equals the global
  sentinel ('__global__') to prevent double-delivery.
- createInternalEventBus: made generic so callers can preserve their
  event-map type safety.
- File-level doc: corrected publishAsync failure wording from
  "logged at debug level only" to "silently swallowed".

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

* Reject reserved session key and accept keyed interfaces

- subscribe() now throws when sessionId is '__global__', preventing
  ambiguous global subscriptions that could leak cross-session events.
- TEventMap constraint loosened from Record<string, InternalEventPayload>
  to `object` so interface-style event maps compile without requiring a
  string index signature. Internal casts preserve runtime behaviour.
- Added regression tests for reserved-key rejection and keyed-i... (continued)

8198 of 11342 branches covered (72.28%)

Branch coverage included in aggregate %.

128 of 128 new or added lines in 1 file covered. (100.0%)

62898 of 74935 relevant lines covered (83.94%)

288.1 hits per line