harn-serve 0.10.141

Shared outbound workflow server core for Harn adapters
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72

use harn_vm::agent_events::{
    AgentEvent, FinalWrapupToolCallParseStatus, FinalWrapupUnconsumedToolCall,
};

pub(super) fn events() -> Vec<AgentEvent> {
    vec![
        AgentEvent::RequireSuccessfulToolsViolation {
            session_id: "session-1".to_string(),
            kind: "tool_gap".to_string(),
            source: "agent_loop.require_successful_tools".to_string(),
            actor: Some("implementer".to_string()),
            run_id: Some("run-1".to_string()),
            redacted_summary: "agent_loop completed without invoking edit".to_string(),
            recurrence_hints: vec!["missing_required_tools=1".to_string()],
            metadata: serde_json::json!({
                "missing_required_tools": ["edit"],
                "successful_tool_names": [],
                "iterations": 2,
            }),
        },
        AgentEvent::FinalWrapup {
            session_id: "session-1".to_string(),
            final_status: "max_iterations".to_string(),
            stop_reason: "iteration_limit".to_string(),
            iteration: 4,
            host_directive: false,
            terminal_kind: "max_iterations".to_string(),
            unconsumed_tool_call: Some(FinalWrapupUnconsumedToolCall {
                parse_status: FinalWrapupToolCallParseStatus::Parsed,
                parsed_call_count: 1,
                tool_names: vec!["edit".to_string()],
                diagnostics: Vec::new(),
                evidence_line: "the final summary contained an unconsumed tool call".to_string(),
            }),
        },
        AgentEvent::PackThinkingStripped {
            session_id: "session-1".to_string(),
            model: "claude-opus-adaptive".to_string(),
            requested: "high".to_string(),
            reason: "claude_opus_adaptive".to_string(),
        },
        AgentEvent::SelfConsistencyTie {
            session_id: "session-1".to_string(),
            answer: "alpha".to_string(),
            total: 4,
            distribution: serde_json::json!([
                {"answer": "alpha", "count": 2},
                {"answer": "beta", "count": 2},
            ]),
        },
        AgentEvent::CodeLibrarianQueryNlFallback {
            session_id: "session-1".to_string(),
            attempted_cypher: None,
            mcts_depth: 3,
            mcts_expansions: 9,
            result_count: 2,
            text: "where is session recovery implemented?".to_string(),
        },
        AgentEvent::ModelJob {
            session_id: "session-1".to_string(),
            event: serde_json::json!({
                "schema": "harn.model_job_event.v1",
                "kind": "state_changed",
                "job_id": "job-1",
                "request_id": "logo-1",
                "backend": "fixture",
                "state": "running",
                "at_ms": 12
            }),
        },
    ]
}