Bohan Jiang 170fa2102b fix(agent/hermes): wire streamingCurrentTurn gate to drop history replay (#2024) ...

Hermes ACP can flush queued session updates from the previous turn
before the current turn actually starts — both as session/resume
history replay and as chunks queued before our session/prompt response
streams. Without a gate those updates were appended to output and
re-emitted to the UI, so the previous answer appeared duplicated next
to the new one. Closes #1997.

PR #1789 added the acceptNotification hook field to hermesClient and
the call site in handleNotification, but never assigned it for Hermes,
so the guard short-circuited and every notification was processed.
This change mirrors the working Kiro pattern (kiro.go:87/97/240):

  - declare a streamingCurrentTurn atomic.Bool in the backend.
  - assign acceptNotification, onMessage, onPromptDone gates that all
    return early when the flag is false.
  - flip the flag to true immediately before c.request("session/prompt").

Adds TestHermesClientAcceptNotificationGate as a regression test that
exercises the gate directly on hermesClient.

Verified with `go test ./pkg/agent`.

Co-authored-by: multica-agent <github@multica.ai>

2026-05-03 11:43:36 +08:00

..

agent

fix(agent/hermes): wire streamingCurrentTurn gate to drop history replay (#2024)

2026-05-03 11:43:36 +08:00

db

fix: guard session resume by runtime (#1905)

2026-05-03 10:51:31 +08:00

protocol

feat(projects): typed project resources + agent runtime injection (#1926)

2026-04-30 14:00:43 +08:00

redact

feat(security): redact sensitive information in agent live output

2026-03-30 23:38:49 +08:00