harn_vm/agent_events/agent.rs
1use serde::{Deserialize, Serialize};
2
3use crate::composition::{CompositionChildCall, CompositionChildResult, CompositionRunEnvelope};
4use crate::llm::receipts::ToolCallReceipt;
5use crate::orchestration::{HandoffArtifact, MutationSessionRecord};
6use crate::tool_annotations::ToolKind;
7
8use super::tool::{ToolCallErrorCategory, ToolCallStatus, ToolExecutor};
9use super::worker::{FsWatchEvent, WorkerEvent};
10
11/// Events emitted by the agent loop. Some variants map 1:1 to ACP
12/// `sessionUpdate` variants; Harn-specific lifecycle events ride on the
13/// extension stream.
14#[derive(Clone, Debug, Serialize, Deserialize)]
15#[serde(tag = "type", rename_all = "snake_case")]
16pub enum AgentEvent {
17 AgentMessageChunk {
18 session_id: String,
19 content: String,
20 },
21 AgentThoughtChunk {
22 session_id: String,
23 content: String,
24 },
25 UserMessage {
26 session_id: String,
27 message_id: String,
28 content: Vec<serde_json::Value>,
29 },
30 ToolCall {
31 session_id: String,
32 tool_call_id: String,
33 tool_name: String,
34 kind: Option<ToolKind>,
35 status: ToolCallStatus,
36 raw_input: serde_json::Value,
37 /// Set to `Some(true)` by the streaming candidate detector
38 /// (harn#692) when this event represents a tool-call shape
39 /// detected in the model's in-flight assistant text but whose
40 /// arguments have not finished parsing yet. Clients can render a
41 /// spinner / placeholder while the model writes the body. The
42 /// detector follows up with a `ToolCallUpdate { parsing: false,
43 /// .. }` carrying either `status: pending` (promoted) or
44 /// `status: failed` with `error_category: parse_aborted`.
45 /// `None` (the default) means "this is a normal post-parse tool
46 /// call, no candidate phase was active" so the on-disk shape
47 /// stays compatible with replays recorded before this field
48 /// existed.
49 #[serde(default, skip_serializing_if = "Option::is_none")]
50 parsing: Option<bool>,
51 /// Mutation-session audit context active when the tool was
52 /// dispatched (see harn#699). Hosts use it to group every tool
53 /// emission belonging to the same write-capable session.
54 #[serde(default, skip_serializing_if = "Option::is_none")]
55 audit: Option<MutationSessionRecord>,
56 },
57 ToolCallUpdate {
58 session_id: String,
59 tool_call_id: String,
60 tool_name: String,
61 status: ToolCallStatus,
62 raw_output: Option<serde_json::Value>,
63 error: Option<String>,
64 /// Wall-clock milliseconds from the parse-to-execution boundary
65 /// to the terminal `Completed`/`Failed` update. Includes the
66 /// time spent in any wrapping orchestration logic (loop checks,
67 /// post-tool hooks, microcompaction). Populated only on the
68 /// terminal update — `None` on intermediate `Pending` /
69 /// `InProgress` updates so clients can ignore the field until
70 /// it shows up.
71 #[serde(default, skip_serializing_if = "Option::is_none")]
72 duration_ms: Option<u64>,
73 /// Milliseconds spent in the actual host/builtin/MCP dispatch
74 /// call only (the inner `dispatch_tool_execution` window).
75 /// Populated only on the terminal update; `None` otherwise.
76 #[serde(default, skip_serializing_if = "Option::is_none")]
77 execution_duration_ms: Option<u64>,
78 /// Structured classification of the failure (when `status` is
79 /// `Failed`). Paired with `error` so clients can render each
80 /// category distinctly without parsing free-form strings. Always
81 /// `None` for non-Failed updates and serialized as
82 /// `errorCategory` in the ACP wire format.
83 #[serde(default, skip_serializing_if = "Option::is_none")]
84 error_category: Option<ToolCallErrorCategory>,
85 /// Where the tool actually ran. `None` only for events emitted
86 /// from sites that pre-date the dispatch decision (e.g. the
87 /// pending → in-progress transition the loop emits before the
88 /// dispatcher picks a backend).
89 #[serde(default, skip_serializing_if = "Option::is_none")]
90 executor: Option<ToolExecutor>,
91 /// Companion to `ToolCall.parsing` (harn#692). The streaming
92 /// candidate detector emits the *terminal* candidate event as a
93 /// `ToolCallUpdate` with `parsing: Some(false)` to retract the
94 /// in-flight `parsing: true` chip — either by promoting the
95 /// candidate (`status: pending`, populated `raw_output: None`,
96 /// `error: None`) or aborting it (`status: failed`,
97 /// `error_category: parse_aborted`). `None` means this update is
98 /// not part of a candidate-phase transition.
99 #[serde(default, skip_serializing_if = "Option::is_none")]
100 parsing: Option<bool>,
101 /// Best-effort partial parse of the streamed tool-call arguments.
102 /// Populated by the SSE transport on `Pending` updates as the
103 /// model streams `input_json_delta` (Anthropic) or
104 /// `tool_calls[].function.arguments` deltas (OpenAI). `None` on
105 /// terminal updates and on emissions from non-streaming paths
106 /// (#693). When the partial bytes are not yet parseable as JSON
107 /// the transport falls back to `raw_input_partial`.
108 #[serde(default, skip_serializing_if = "Option::is_none")]
109 raw_input: Option<serde_json::Value>,
110 /// Raw concatenated bytes of the streamed tool-call arguments
111 /// when a permissive parse failed (#693). Mutually exclusive
112 /// with `raw_input`: clients render whichever is present.
113 #[serde(default, skip_serializing_if = "Option::is_none")]
114 raw_input_partial: Option<String>,
115 /// Mutation-session audit context for the tool call. Carries the
116 /// same payload as on the paired `ToolCall` event so a host
117 /// processing a single update doesn't have to correlate against
118 /// the prior pending event.
119 #[serde(default, skip_serializing_if = "Option::is_none")]
120 audit: Option<MutationSessionRecord>,
121 },
122 Plan {
123 session_id: String,
124 plan: serde_json::Value,
125 },
126 ProgressReported {
127 session_id: String,
128 message: Option<String>,
129 entries: serde_json::Value,
130 replace: bool,
131 metadata: serde_json::Value,
132 },
133 /// Emitted when the compass observes a freeform edit and either
134 /// suggests a structural primitive, rewrites the tool call, or falls
135 /// back because rewrite mode could not prove equivalence.
136 CompassRoutingDecision {
137 session_id: String,
138 tool_call_id: String,
139 mode: String,
140 action: String,
141 persona: String,
142 original_tool: String,
143 routed_tool: String,
144 target_tool: String,
145 #[serde(default, skip_serializing_if = "Option::is_none")]
146 path: Option<String>,
147 },
148 /// Emitted after an agent scratchpad reorganization attempt. The
149 /// scratchpad body itself stays in session state; this event carries
150 /// status and count/error metadata so live UIs and eval harnesses can
151 /// audit whether reorganization helped or damaged the working set.
152 AgentScratchpadReorganization {
153 session_id: String,
154 iteration: usize,
155 status: String,
156 details: serde_json::Value,
157 },
158 /// A renderable, declarative artifact spec emitted by an agent. Harn
159 /// validates the payload and transports it; host surfaces own rendering
160 /// and may fall back to the plain-text representation.
161 Artifact {
162 session_id: String,
163 artifact_id: String,
164 kind: String,
165 #[serde(default, skip_serializing_if = "Option::is_none")]
166 title: Option<String>,
167 mime_type: String,
168 spec: serde_json::Value,
169 fallback: String,
170 size_bytes: u64,
171 provenance: serde_json::Value,
172 metadata: serde_json::Value,
173 },
174 /// Fires at the top of every model round-trip inside an
175 /// `agent_loop` invocation. Maps to the `iteration_start` steering
176 /// seam. Not the same as ACP's outer `prompt_turn` boundary; an
177 /// `agent_turn`/`prompt_turn` cycle contains many of these.
178 IterationStart {
179 session_id: String,
180 iteration: usize,
181 /// Configured provider for the impending LLM call. Empty when the
182 /// caller defers provider selection to the routing layer.
183 /// Surfaces here so observers can show "about to call X/Y" before
184 /// the call returns — previously this only landed in the
185 /// transcript after the response, leaving live pulse-check
186 /// consumers without a model attribution for in-flight iterations.
187 #[serde(default, skip_serializing_if = "String::is_empty")]
188 provider: String,
189 /// Configured model id. Same semantics as `provider`.
190 #[serde(default, skip_serializing_if = "String::is_empty")]
191 model: String,
192 },
193 /// Fires at the bottom of every model round-trip, after tool
194 /// dispatch (or after the dispatch was skipped). Sibling of
195 /// `IterationStart`.
196 IterationEnd {
197 session_id: String,
198 iteration: usize,
199 /// Free-form dict carrying the post-call snapshot. Stable keys
200 /// emitted by the agent loop: `tool_count`, `text`, plus the
201 /// LLM-result projection — `provider`, `model`, `response_ms`,
202 /// `input_tokens`, `output_tokens`, `thinking_chars`. Hosts that
203 /// surface latency/cost panes key off these without re-parsing
204 /// the transcript JSONL.
205 iteration_info: serde_json::Value,
206 },
207 /// Emitted when a first-class agent session is explicitly closed by
208 /// `agent_session_close`. This gives event-log consumers a typed
209 /// terminal marker even when no final model turn runs.
210 SessionClosed {
211 session_id: String,
212 reason: String,
213 status: String,
214 metadata: serde_json::Value,
215 },
216 /// Emitted when `agent_session_reanchor` swaps the primary workspace
217 /// anchor (#2218). Hosts use this to drive cross-project handoff UX.
218 /// Carries the previous and current anchors so consumers can diff
219 /// without re-fetching session state.
220 AnchorChanged {
221 session_id: String,
222 previous: Option<serde_json::Value>,
223 current: serde_json::Value,
224 carry_transcript: bool,
225 compacted: bool,
226 reason: Option<String>,
227 },
228 JudgeDecision {
229 session_id: String,
230 iteration: usize,
231 verdict: String,
232 reasoning: String,
233 next_step: Option<String>,
234 judge_duration_ms: u64,
235 #[serde(default, skip_serializing_if = "Option::is_none")]
236 trigger: Option<String>,
237 #[serde(default, skip_serializing_if = "Option::is_none")]
238 reason: Option<String>,
239 #[serde(default, skip_serializing_if = "Option::is_none")]
240 confirm: Option<bool>,
241 #[serde(default, skip_serializing_if = "Option::is_none")]
242 converted_from: Option<String>,
243 },
244 /// Per-step critique decision emitted by `agent_step_judge`.
245 /// Sibling of [`JudgeDecision`] but fired BEFORE tool dispatch on
246 /// every assistant turn (when configured), not just at completion.
247 /// `on_veto` carries the configured remediation shape
248 /// (`"replace"` or `"retain"`); `cost_usd` is best-effort from the
249 /// stdlib economics estimator and may be 0 when pricing is unknown.
250 /// `skipped` marks configured short-circuits that did not call the
251 /// judge model.
252 StepJudgeDecision {
253 session_id: String,
254 iteration: usize,
255 verdict: String,
256 reasoning: String,
257 critique: String,
258 confidence: f64,
259 judge_duration_ms: u64,
260 vetoed: bool,
261 #[serde(default, skip_serializing_if = "std::ops::Not::not")]
262 skipped: bool,
263 #[serde(default, skip_serializing_if = "Option::is_none")]
264 reason: Option<String>,
265 /// True when this `verdict: "pass"` is the result of the step-judge
266 /// model itself erroring and `fail_open` swallowing the error — the
267 /// turn proceeded, but the adversarial-review surface was UNAVAILABLE
268 /// (not a genuine approval). Lets telemetry tell an inert reviewer
269 /// apart from a real pass. Mirrors `reason: "judge_unavailable"`.
270 #[serde(default, skip_serializing_if = "std::ops::Not::not")]
271 judge_error: bool,
272 on_veto: String,
273 input_tokens: u64,
274 output_tokens: u64,
275 cost_usd: f64,
276 provider: String,
277 model: String,
278 },
279 /// Deterministic pre-dispatch critique emitted by the structural
280 /// validator middleware. Fires before any LLM-backed judge so hosts
281 /// can distinguish "$0 structural retry" from semantic critique.
282 StructuralValidatorDecision {
283 session_id: String,
284 iteration: usize,
285 rule: String,
286 diagnostic: String,
287 recommended_action: String,
288 vetoed: bool,
289 #[serde(default, skip_serializing_if = "std::ops::Not::not")]
290 skipped: bool,
291 #[serde(default, skip_serializing_if = "Option::is_none")]
292 reason: Option<String>,
293 on_failure: String,
294 attempts: usize,
295 max_attempts: usize,
296 },
297 ScopeClassifierVerdict {
298 session_id: String,
299 iteration: usize,
300 label: String,
301 original_label: String,
302 confidence: f64,
303 confidence_threshold: f64,
304 evidence: String,
305 skip_main_turn: bool,
306 #[serde(default, skip_serializing_if = "Option::is_none")]
307 classifier_kind: Option<String>,
308 #[serde(default, skip_serializing_if = "Option::is_none")]
309 model: Option<String>,
310 #[serde(default, skip_serializing_if = "Option::is_none")]
311 error: Option<String>,
312 },
313 MissingToolCallVerdict {
314 session_id: String,
315 iteration: usize,
316 action: String,
317 original_action: String,
318 tool_name: String,
319 confidence: f64,
320 confidence_threshold: f64,
321 evidence: String,
322 #[serde(default, skip_serializing_if = "Option::is_none")]
323 language: Option<String>,
324 #[serde(default, skip_serializing_if = "Option::is_none")]
325 classifier_kind: Option<String>,
326 #[serde(default, skip_serializing_if = "Option::is_none")]
327 model: Option<String>,
328 #[serde(default, skip_serializing_if = "Option::is_none")]
329 error: Option<String>,
330 },
331 TypedCheckpoint {
332 session_id: String,
333 checkpoint: serde_json::Value,
334 },
335 FeedbackInjected {
336 session_id: String,
337 kind: String,
338 content: String,
339 },
340 /// Emitted when the agent loop exhausts `max_iterations` without any
341 /// explicit break condition firing. Distinct from a natural "done" or
342 /// a "stuck" nudge-exhaustion: this is strictly a budget cap.
343 BudgetExhausted {
344 session_id: String,
345 max_iterations: usize,
346 #[serde(default, skip_serializing_if = "Option::is_none")]
347 kind: Option<String>,
348 #[serde(default, skip_serializing_if = "Option::is_none")]
349 cost_usd: Option<f64>,
350 #[serde(default, skip_serializing_if = "Option::is_none")]
351 wall_clock_ms: Option<u64>,
352 },
353 /// Emitted when a loop-level budget circuit breaker trips after N
354 /// consecutive retryable failures. `paused_for_ms` is the mock-time-aware
355 /// backoff already honored before the terminal budget event.
356 BudgetCircuitBreaker {
357 session_id: String,
358 kind: String,
359 consecutive_count: usize,
360 paused_for_ms: u64,
361 },
362 /// Emitted when the loop breaks because consecutive text-only turns
363 /// hit `max_nudges`. Parity with `BudgetExhausted` / `IterationEnd` for
364 /// hosts that key off agent-terminal events.
365 LoopStuck {
366 session_id: String,
367 max_nudges: usize,
368 last_iteration: usize,
369 tail_excerpt: String,
370 },
371 /// Pipeline-authored stuck/escalation signal emitted through
372 /// `agent_emit_event("loop_stuck", payload)`. The runtime-level
373 /// `LoopStuck` variant above remains the built-in max-nudge terminal event;
374 /// this variant preserves the pipeline payload so hosts can surface richer
375 /// handoff/escalation details without inventing another wire kind.
376 LoopStuckSignal {
377 session_id: String,
378 payload: serde_json::Value,
379 },
380 /// Emitted by the reserved-budget terminal-verify guard
381 /// (`agent_emit_event("reserved_terminal_verify", payload)`). The guard
382 /// holds back a small iteration reserve the main loop cannot consume; when
383 /// the loop would otherwise terminate on a budget/stuck boundary with an
384 /// unverified source write, it spends the reserve on a final verify(+repair)
385 /// instead of ending blind on a red build. The payload's `phase` field tags
386 /// the step (`grant` / `verify_passed` / `verify_failed`) so replayers and
387 /// operators can see the guard fire and its outcome. Payload-preserving like
388 /// `LoopStuckSignal` so the guard can carry richer detail without inventing
389 /// another wire kind.
390 ReservedTerminalVerify {
391 session_id: String,
392 payload: serde_json::Value,
393 },
394 /// Emitted when the daemon idle-wait loop trips its watchdog because
395 /// every configured wake source returned `None` for N consecutive
396 /// attempts. Exists so a broken daemon doesn't hang the session
397 /// silently.
398 DaemonWatchdogTripped {
399 session_id: String,
400 attempts: usize,
401 elapsed_ms: u64,
402 },
403 /// Emitted when a skill is activated. Carries the match reason so
404 /// replayers can reconstruct *why* a given skill took effect at
405 /// this iteration.
406 SkillActivated {
407 session_id: String,
408 skill_name: String,
409 iteration: usize,
410 reason: String,
411 },
412 /// Emitted when a previously-active skill is deactivated because
413 /// the reassess phase no longer matches it.
414 SkillDeactivated {
415 session_id: String,
416 skill_name: String,
417 iteration: usize,
418 },
419 /// Emitted once per activation when the skill's `allowed_tools` filter
420 /// narrows the effective tool surface exposed to the model.
421 SkillScopeTools {
422 session_id: String,
423 skill_name: String,
424 allowed_tools: Vec<String>,
425 },
426 /// Emitted when the agent loop ratchets the model-visible tool
427 /// surface narrower after observing recent tool-call usage. Unlike
428 /// `SkillScopeTools`, this is session-local and can only remove
429 /// tools from the currently-effective surface.
430 SkillNarrow {
431 session_id: String,
432 reason: String,
433 removed_tools: Vec<String>,
434 remaining_tools: Vec<String>,
435 #[serde(default, skip_serializing_if = "serde_json::Value::is_null")]
436 policy: serde_json::Value,
437 #[serde(default, skip_serializing_if = "serde_json::Value::is_null")]
438 removed_tool_details: serde_json::Value,
439 #[serde(default, skip_serializing_if = "serde_json::Value::is_null")]
440 kept_tool_details: serde_json::Value,
441 },
442 /// Read-only stance lifecycle (std/agent/stance): `phase` is one of
443 /// `armed`, `write_access_granted`, `write_access_denied`,
444 /// `disarmed`. Arming carries the permitted tool window; the
445 /// grant/deny phases carry the escape-hatch justification and the
446 /// consent verdict so a trace viewer can explain every elevation.
447 StanceTransition {
448 session_id: String,
449 phase: String,
450 escape_tool: String,
451 #[serde(default, skip_serializing_if = "Vec::is_empty")]
452 allowed_tools: Vec<String>,
453 #[serde(default, skip_serializing_if = "String::is_empty")]
454 justification: String,
455 #[serde(default, skip_serializing_if = "String::is_empty")]
456 consent: String,
457 #[serde(default, skip_serializing_if = "String::is_empty")]
458 reason: String,
459 },
460 /// Emitted when a `tool_search` query is issued by the model. Carries
461 /// the raw query args, the configured strategy, and a `mode` tag
462 /// distinguishing the client-executed fallback (`"client"`) from
463 /// provider-native paths (`"anthropic"` / `"openai"`). Mirrors the
464 /// transcript event shape so hosts can render a search-in-progress
465 /// chip in real time — the replay path walks the transcript after
466 /// the turn, which is too late for live UX.
467 ToolSearchQuery {
468 session_id: String,
469 tool_use_id: String,
470 name: String,
471 query: serde_json::Value,
472 strategy: String,
473 mode: String,
474 },
475 /// Emitted when `tool_search` resolves — carries the list of tool
476 /// names newly promoted into the model's effective surface for the
477 /// next turn. Pair-emitted with `ToolSearchQuery` on every search.
478 ToolSearchResult {
479 session_id: String,
480 tool_use_id: String,
481 promoted: Vec<String>,
482 strategy: String,
483 mode: String,
484 },
485 TranscriptCompacted {
486 session_id: String,
487 mode: String,
488 reason: String,
489 strategy: String,
490 archived_messages: usize,
491 estimated_tokens_before: usize,
492 estimated_tokens_after: usize,
493 snapshot_asset_id: Option<String>,
494 #[serde(default, skip_serializing_if = "Option::is_none")]
495 instruction_mode: Option<String>,
496 #[serde(default, skip_serializing_if = "Option::is_none")]
497 instruction_source: Option<String>,
498 #[serde(default, skip_serializing_if = "Option::is_none")]
499 compaction_policy: Option<serde_json::Value>,
500 },
501 /// Emitted whenever `transcript_project` derives a model-visible
502 /// prefix from the immutable raw transcript. Hosts that render a
503 /// side-by-side raw/projected view subscribe to this — the typed
504 /// payload mirrors the metadata on the persisted
505 /// `transcript.projection` transcript event so clients don't have to
506 /// re-parse the transcript to sync UI state.
507 TranscriptProjected {
508 session_id: String,
509 policy: String,
510 reason: String,
511 prefix_hash: String,
512 kept_count: usize,
513 dropped_count: usize,
514 provider_safety_blocked: bool,
515 #[serde(default, skip_serializing_if = "is_zero_usize")]
516 redacted_count: usize,
517 #[serde(default, skip_serializing_if = "is_zero_usize")]
518 reclaimed_tokens: usize,
519 #[serde(default, skip_serializing_if = "Vec::is_empty")]
520 roots_consulted: Vec<String>,
521 #[serde(default, skip_serializing_if = "Vec::is_empty")]
522 redaction_pointers: Vec<serde_json::Value>,
523 },
524 /// Emitted when a pending `system_reminder` is rendered into the
525 /// next provider request. ACP clients show these in a reminder lane
526 /// instead of mixing them into assistant text chunks.
527 ReminderEmitted {
528 session_id: String,
529 reminder_id: String,
530 tags: Vec<String>,
531 body: String,
532 role_hint: String,
533 rendered_role: String,
534 source: String,
535 ttl_turns: Option<i64>,
536 },
537 Handoff {
538 session_id: String,
539 artifact_id: String,
540 handoff: Box<HandoffArtifact>,
541 },
542 FsWatch {
543 session_id: String,
544 subscription_id: String,
545 events: Vec<FsWatchEvent>,
546 },
547 /// Emitted when hostlib staged filesystem state changes for a session.
548 /// The ACP adapter maps this to the existing `progress` extension so
549 /// clients can update rollup-diff badges without waiting for a prompt
550 /// turn boundary.
551 StagedWritesPending {
552 session_id: String,
553 pending_count: usize,
554 total_bytes: u64,
555 },
556 /// Per-call outcome of `hostlib_fs_safe_text_patch`. Hosts subscribe to
557 /// this to roll up stale-base / hunk-conflict rates and average
558 /// hunks-per-patch without scraping result dicts out of pipeline logs.
559 /// Fired from both the staged-overlay and direct-disk code paths so
560 /// the rollup is comprehensive.
561 SafeTextPatchResult {
562 session_id: String,
563 path: String,
564 result: String,
565 hunks_count: usize,
566 bytes_written: u64,
567 #[serde(default, skip_serializing_if = "Option::is_none")]
568 failed_hunk_index: Option<usize>,
569 },
570 /// ACP control-plane arbitration outcome. Emitted for accepted,
571 /// idempotent, and rejected controls so replay/audit consumers can show
572 /// who acted and why a late or unauthorized action lost.
573 ControlOutcome {
574 session_id: String,
575 control_id: String,
576 method: String,
577 outcome: String,
578 status: String,
579 actor: serde_json::Value,
580 target: serde_json::Value,
581 #[serde(default, skip_serializing_if = "Option::is_none")]
582 reason: Option<String>,
583 #[serde(default, skip_serializing_if = "serde_json::Value::is_null")]
584 metadata: serde_json::Value,
585 },
586 /// Lifecycle update for a delegated/background worker. Carries the
587 /// canonical typed `event` variant alongside the worker's current
588 /// `status` string and the structured `metadata` payload that
589 /// `worker_bridge_metadata` builds (task, mode, timing, child
590 /// run/snapshot paths, audit-session, etc.). The `audit` field is
591 /// the same `MutationSessionRecord` JSON serialization carried on
592 /// the bridge wire so ACP/A2A consumers don't need to re-derive it.
593 ///
594 /// One-to-one with the bridge-side `worker_update` session-update
595 /// notification: ACP and A2A adapters subscribe to this variant
596 /// and translate it into their respective wire formats. The
597 /// `session_id` is the parent agent session that owns the worker
598 /// (i.e. the session whose VM spawned the worker), so a single
599 /// host stays subscribed to the same sink for both message and
600 /// worker traffic.
601 WorkerUpdate {
602 session_id: String,
603 worker_id: String,
604 worker_name: String,
605 worker_task: String,
606 worker_mode: String,
607 event: WorkerEvent,
608 status: String,
609 metadata: serde_json::Value,
610 audit: Option<serde_json::Value>,
611 },
612 /// A human-in-the-loop primitive (`ask_user`, `request_approval`,
613 /// `dual_control`, `escalate`) has just suspended the script and is
614 /// waiting on a response. Hosts that bridge the VM onto a remote
615 /// transport (ACP, A2A) translate this into a "paused / awaiting
616 /// input" wire signal so the client knows the task isn't stuck —
617 /// it's blocked on the human side. Pair-emitted with `HitlResolved`
618 /// when the waitpoint completes/cancels/times out.
619 HitlRequested {
620 session_id: String,
621 request_id: String,
622 kind: String,
623 payload: serde_json::Value,
624 },
625 /// Companion to `HitlRequested`: the waitpoint has resolved (either
626 /// a response arrived, the deadline elapsed, or the request was
627 /// cancelled). `outcome` is one of `"answered"`, `"timeout"`,
628 /// `"cancelled"`. Hosts use this to flip task state back to
629 /// `working` after an `input-required` pause.
630 HitlResolved {
631 session_id: String,
632 request_id: String,
633 kind: String,
634 outcome: String,
635 },
636 /// Emitted by the agent loop's adaptive iteration budget /
637 /// `loop_control` policy when a budget extension or early stop fires.
638 /// Generic enough to cover both shapes — `action` distinguishes them.
639 /// Carries the iteration the decision applied to, the previous /
640 /// resulting iteration limit, the policy reason string, and (for
641 /// stops) the loop status.
642 LoopControlDecision {
643 session_id: String,
644 iteration: usize,
645 action: String,
646 old_limit: usize,
647 new_limit: usize,
648 reason: String,
649 status: String,
650 },
651 /// Emitted when `agent_loop` detects adjacent repeated tool calls with
652 /// identical arguments. The warning payload avoids raw arguments by
653 /// default and carries digests so hosts can correlate repeats without
654 /// exposing potentially sensitive tool inputs.
655 AgentLoopStallWarning {
656 session_id: String,
657 warning: serde_json::Value,
658 },
659 /// Emitted when a concrete provider/model pair lacks a catalog
660 /// recommendation for a capability and the runtime chooses a fallback.
661 CapabilityGap {
662 session_id: String,
663 level: String,
664 capability: String,
665 provider: String,
666 model: String,
667 fallback_tool_format: String,
668 #[serde(default, skip_serializing_if = "Option::is_none")]
669 requested_tool_format: Option<String>,
670 message: String,
671 },
672 /// Emitted when a caller explicitly forces a tool format that
673 /// differs from the capability catalog's recommendation or known
674 /// native/text parity guidance.
675 ToolFormatOverride {
676 session_id: String,
677 provider: String,
678 model: String,
679 requested_format: String,
680 recommended_format: String,
681 catalog_parity: String,
682 #[serde(default, skip_serializing_if = "Option::is_none")]
683 override_reason: Option<String>,
684 },
685 /// Emitted when a `tool_caller` middleware (see std/llm/tool_middleware)
686 /// attaches structured audit metadata to a tool call — typically a
687 /// user-facing `summary`, a `description`, an ACP-style `kind`, an MCP
688 /// `hints` block, a `consent` decision, the per-layer `layers` log, or
689 /// free-form `metadata` keys (A2A-style extension slot).
690 ///
691 /// One-to-one with the underlying tool-call: hosts can join on
692 /// `tool_call_id` to render middleware-attached chips alongside the
693 /// existing `ToolCall` / `ToolCallUpdate` stream. The `audit` payload
694 /// is intentionally free-form JSON so middleware can carry whatever
695 /// shape the harness author chooses without needing protocol-level
696 /// changes per new middleware. When present, `receipt` carries the
697 /// stable typed, privacy-preserving record hosts can persist or mirror.
698 ToolCallAudit {
699 session_id: String,
700 tool_call_id: String,
701 tool_name: String,
702 audit: serde_json::Value,
703 #[serde(default, skip_serializing_if = "Option::is_none")]
704 receipt: Option<ToolCallReceipt>,
705 },
706 /// Emitted by `std/cache::with_cache` (both the generic and LLM
707 /// forms) when a cached lookup returns a hit. Carries the
708 /// content-addressed key, the backend that served the value, and a
709 /// `metrics` block with the cost-moat receipts the persona value
710 /// ledger (a cloud platform) and crystallization receipts read:
711 /// `model_calls_avoided`, plus `tokens_saved` / `latency_saved_ms`
712 /// when the cached envelope carried `usage` / `latency_ms`.
713 CacheHit {
714 session_id: String,
715 key: String,
716 backend: String,
717 namespace: String,
718 payload: serde_json::Value,
719 },
720 /// Paired with `CacheHit`. Emitted on the miss path when the
721 /// fresh result is stored. `payload.metrics.compute_ms` carries
722 /// the wall-clock cost of the underlying computation, which
723 /// callers can feed back as `estimate.latency_saved_ms` on the
724 /// next hit.
725 CacheMiss {
726 session_id: String,
727 key: String,
728 backend: String,
729 namespace: String,
730 payload: serde_json::Value,
731 },
732 /// A language-neutral tool-composition snippet has started. The envelope
733 /// identifies the snippet and binding manifest hashes plus the side-effect
734 /// ceiling requested for the whole parent run.
735 CompositionStart {
736 session_id: String,
737 run: CompositionRunEnvelope,
738 },
739 /// A composition snippet is dispatching a child binding call. The child
740 /// remains visible as its own operation with annotations and policy context
741 /// instead of being hidden inside the parent composition blob.
742 CompositionChildCall {
743 session_id: String,
744 call: CompositionChildCall,
745 },
746 /// A child binding operation emitted a status/result update.
747 CompositionChildResult {
748 session_id: String,
749 result: CompositionChildResult,
750 },
751 /// A composition run finished successfully and carries stdout/stderr,
752 /// artifacts, and the structured result in the terminal envelope.
753 CompositionFinish {
754 session_id: String,
755 run: CompositionRunEnvelope,
756 },
757 /// A composition run failed before producing a successful terminal result.
758 /// The terminal envelope carries the failure category and optional error.
759 CompositionError {
760 session_id: String,
761 run: CompositionRunEnvelope,
762 },
763 /// Emitted once per `__agent_loop_checkpoint(...)` pass. The single
764 /// named seam through which the agent loop drains queued bridge
765 /// injections and inbox feedback. Hosts use it to debug "did the
766 /// loop check for steering at the expected boundary" without having
767 /// to grep the loop body for inline drain calls.
768 ///
769 /// `kind` is one of the documented seam names: `iteration_start`,
770 /// `pre_tool_dispatch`, `post_tool_dispatch`, `iteration_end`,
771 /// `pre_compact`, `post_compact`, `daemon_idle_pre`,
772 /// `daemon_idle_post`, `loop_exit`. `delivered` is the count of
773 /// bridge injections drained at this seam (inbox drains are
774 /// reported separately under `inbox_delivered`). `dispatch_skipped`
775 /// is true only when an `interrupt_immediate` injection arrived at
776 /// `pre_tool_dispatch` and the pending tool batch was skipped.
777 LoopCheckpoint {
778 session_id: String,
779 iteration: usize,
780 kind: String,
781 delivered: usize,
782 #[serde(default, skip_serializing_if = "is_zero_usize")]
783 inbox_delivered: usize,
784 #[serde(default, skip_serializing_if = "std::ops::Not::not")]
785 dispatch_skipped: bool,
786 },
787 /// Surfaced when Harn is acting as an MCP **client** and a peer
788 /// server sends a server-to-client message during an agent session:
789 /// a `notifications/progress` / `notifications/message` /
790 /// `notifications/*/list_changed` notification, or an inbound
791 /// `elicitation/create` / `sampling/createMessage` request.
792 ///
793 /// Emitted alongside (not in place of) the existing agent-inbox
794 /// relay so a thin ACP client can render a live progress bar, log
795 /// line, elicitation prompt, or sampling affordance without parsing
796 /// the inbox transcript. `direction` is `"notification"` for
797 /// fire-and-forget server notifications and `"request"` for inbound
798 /// requests that still resolve through the existing client-role
799 /// dispatch path (this event does not change that response). `method`
800 /// is the raw MCP JSON-RPC method; `params` is its untouched payload.
801 McpNotification {
802 session_id: String,
803 server: String,
804 method: String,
805 direction: String,
806 params: serde_json::Value,
807 },
808 /// Surfaced when the effective MCP catalog changes — either because a
809 /// server emitted a `notifications/tools/list_changed` (or the
810 /// resource/prompt equivalents), or because the persisted enable/disable
811 /// allowlist was edited. A thin ACP client (an IDE host's TUI / GUI)
812 /// treats this as a cue to re-fetch the catalog (e.g. via the
813 /// `mcp/catalog` request) and re-render its toggle UI, rather than
814 /// reconciling any local state. `server` is the server whose list
815 /// changed, or `None` when the change is allowlist-wide. `reason` is a
816 /// short tag (`"list_changed"` or `"allowlist_updated"`).
817 McpCatalogChanged {
818 session_id: String,
819 #[serde(default, skip_serializing_if = "Option::is_none")]
820 server: Option<String>,
821 reason: String,
822 },
823 /// Surfaced when an MCP server harn is acting as a client for answers a
824 /// request with `401 Unauthorized` mid-session, meaning its OAuth token is
825 /// missing or expired. This is a cue for a thin ACP client (an IDE host's
826 /// TUI / GUI) to start an authorization: call `mcp/authorize` to mint a
827 /// browser URL, open it, and forward the redirect's `code`+`state` back via
828 /// `mcp/oauth_callback`. Token exchange and storage stay in harn. `server`
829 /// is the configured server name; `resource` is its canonical RFC 8707
830 /// resource indicator; `scope` is the `scope` parameter from the
831 /// `WWW-Authenticate` challenge, when present.
832 McpAuthRequired {
833 session_id: String,
834 server: String,
835 resource: String,
836 #[serde(default, skip_serializing_if = "Option::is_none")]
837 scope: Option<String>,
838 },
839}
840
841fn is_zero_usize(value: &usize) -> bool {
842 *value == 0
843}
844
845impl AgentEvent {
846 pub fn session_id(&self) -> &str {
847 match self {
848 Self::AgentMessageChunk { session_id, .. }
849 | Self::AgentThoughtChunk { session_id, .. }
850 | Self::UserMessage { session_id, .. }
851 | Self::ToolCall { session_id, .. }
852 | Self::ToolCallUpdate { session_id, .. }
853 | Self::Plan { session_id, .. }
854 | Self::ProgressReported { session_id, .. }
855 | Self::CompassRoutingDecision { session_id, .. }
856 | Self::AgentScratchpadReorganization { session_id, .. }
857 | Self::Artifact { session_id, .. }
858 | Self::IterationStart { session_id, .. }
859 | Self::IterationEnd { session_id, .. }
860 | Self::SessionClosed { session_id, .. }
861 | Self::AnchorChanged { session_id, .. }
862 | Self::JudgeDecision { session_id, .. }
863 | Self::StepJudgeDecision { session_id, .. }
864 | Self::StructuralValidatorDecision { session_id, .. }
865 | Self::ScopeClassifierVerdict { session_id, .. }
866 | Self::MissingToolCallVerdict { session_id, .. }
867 | Self::TypedCheckpoint { session_id, .. }
868 | Self::FeedbackInjected { session_id, .. }
869 | Self::BudgetExhausted { session_id, .. }
870 | Self::BudgetCircuitBreaker { session_id, .. }
871 | Self::LoopStuck { session_id, .. }
872 | Self::LoopStuckSignal { session_id, .. }
873 | Self::ReservedTerminalVerify { session_id, .. }
874 | Self::DaemonWatchdogTripped { session_id, .. }
875 | Self::SkillActivated { session_id, .. }
876 | Self::SkillDeactivated { session_id, .. }
877 | Self::SkillScopeTools { session_id, .. }
878 | Self::SkillNarrow { session_id, .. }
879 | Self::StanceTransition { session_id, .. }
880 | Self::ToolSearchQuery { session_id, .. }
881 | Self::ToolSearchResult { session_id, .. }
882 | Self::TranscriptCompacted { session_id, .. }
883 | Self::TranscriptProjected { session_id, .. }
884 | Self::ReminderEmitted { session_id, .. }
885 | Self::Handoff { session_id, .. }
886 | Self::FsWatch { session_id, .. }
887 | Self::StagedWritesPending { session_id, .. }
888 | Self::SafeTextPatchResult { session_id, .. }
889 | Self::ControlOutcome { session_id, .. }
890 | Self::WorkerUpdate { session_id, .. }
891 | Self::HitlRequested { session_id, .. }
892 | Self::HitlResolved { session_id, .. }
893 | Self::LoopControlDecision { session_id, .. }
894 | Self::AgentLoopStallWarning { session_id, .. }
895 | Self::CapabilityGap { session_id, .. }
896 | Self::ToolFormatOverride { session_id, .. }
897 | Self::ToolCallAudit { session_id, .. }
898 | Self::CacheHit { session_id, .. }
899 | Self::CacheMiss { session_id, .. }
900 | Self::CompositionStart { session_id, .. }
901 | Self::CompositionChildCall { session_id, .. }
902 | Self::CompositionChildResult { session_id, .. }
903 | Self::CompositionFinish { session_id, .. }
904 | Self::CompositionError { session_id, .. }
905 | Self::LoopCheckpoint { session_id, .. }
906 | Self::McpNotification { session_id, .. }
907 | Self::McpCatalogChanged { session_id, .. }
908 | Self::McpAuthRequired { session_id, .. } => session_id,
909 }
910 }
911}