lsm / HyperNeo / 31445655618

80%

Build Type

push

github

Committed by web-flow

Commit Message

feat(daemon): make message-delivery v2 the default, migrate Space injectors (#2431)

* feat(daemon): make message-delivery v2 the default, migrate Space injectors

Flip HYPERNEO_MESSAGE_DELIVERY_V2 to default-on (opt out with =0) and
route the Space-agent, long-term-agent, and injectMessageIntoSession
kickoff paths through the durable deliverMessage chokepoint instead of
the inline ensureQueryStarted+enqueueWithId path. resetContextPerTurn is
gated on no active delivery job to avoid racing a pending v2 turn.
recoverOrphanedConsumedMessages stays as the backstop for the remaining
legacy deferred-replay and rate-limit-retry paths.

* fix(daemon): gate injector delivery on v2 flag + terminalize on enqueue failure

Address review on #2431:
- P1: wrap each migrated deliverMessage call in try/catch and call
  markDeliveryFailedByUuid on failure, mirroring deliverChatMessage, so a
  transient enqueue throw can't strand an ownerless 'enqueued' row.
- P2: gate the three migrated injectors on isMessageDeliveryV2Enabled() so
  HYPERNEO_MESSAGE_DELIVERY_V2=0 is a complete kill-switch (rolls back Space
  and long-term-agent delivery too), not ordinary chat only.
- P3: injectLongTermAgentMessage throws (with a corrected comment) instead of
  silently dropping the message when reactiveDb is absent.
- Add a crash-boundary regression test asserting the row is terminalized when
  durable enqueue throws.

* fix(agent): driveDeliveryTurn awaits turn-end, not query-close

driveDeliveryTurn awaited this.queryPromise, which in streaming-input
mode resolves only on query-CLOSE — never at turn-end. So the turn job
hung `processing` forever: the active-turn index stayed occupied and
every subsequent message misclassified as a steer (pending, undeliverable),
breaking all multi-turn delivery under v2 (rewind/steer/space online tests
failed in CI under the default-on flip).

Await the idle transition (new ProcessingStateManager.waitForIdleTransition)
instead, raced with queryProm... (continued)

Coverage Stats

20492 of 57872 branches covered (35.41%)

Branch coverage included in aggregate %.

101 of 206 new or added lines in 16 files covered. (49.03%)

111 existing lines in 15 files now uncovered.

30486 of 68426 relevant lines covered (44.55%)

280.25 hits per line