malvin 0.2.5

Non-interactive research and coding agent
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
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102

#[test]
fn heartbeat_phases_follow_runtime_signals() {
    use crate::tool_summary::ToolSummaryDetail;
    use serde_json::json;

    let _guard = crate::agent_phase::AGENT_PHASE_TEST_LOCK
        .lock()
        .unwrap_or_else(std::sync::PoisonError::into_inner);
    crate::agent_phase::reset_phase_state_for_test();
    assert_eq!(crate::agent_phase::heartbeat_label(), "Orienting");
    crate::agent_phase::reset_for_run();
    crate::agent_phase::enter_verifying();
    crate::agent_phase::leave_verifying();
    let mut tracker = crate::tool_summary::ToolSummaryTracker::default();
    let observe = |update: serde_json::Value,
                   tracker: &mut crate::tool_summary::ToolSummaryTracker| {
        let v = json!({"method": "session/update", "params": {"update": update}});
        crate::tool_summary::tool_summary_lines(&v, tracker, ToolSummaryDetail::Log).unwrap();
    };
    observe(
        json!({"sessionUpdate":"tool_call","toolCallId":"1","kind":"execute","status":"pending","rawInput":{"command":"sleep 9"}}),
        &mut tracker,
    );
    observe(
        json!({"sessionUpdate":"tool_call_update","toolCallId":"1","status":"completed","rawOutput":{"exitCode":0}}),
        &mut tracker,
    );
    observe(
        json!({"sessionUpdate":"tool_call","toolCallId":"r1","kind":"read","status":"pending","rawInput":{"path":"a.rs"}}),
        &mut tracker,
    );
    assert_eq!(
        crate::agent_phase::current_phase_for_test(),
        crate::agent_phase::AgentPhase::Researching
    );
    observe(
        json!({"sessionUpdate":"tool_call","toolCallId":"x1","kind":"execute","status":"pending","rawInput":{"command":"kiss check"}}),
        &mut tracker,
    );
    observe(
        json!({"sessionUpdate":"tool_call_update","toolCallId":"x1","status":"completed","rawOutput":{"exitCode":1}}),
        &mut tracker,
    );
    assert_eq!(
        crate::agent_phase::current_phase_for_test(),
        crate::agent_phase::AgentPhase::Debugging
    );
    crate::agent_phase::set_reporting(true);
    assert_eq!(crate::agent_phase::heartbeat_label(), "Reporting");
}

#[test]
fn kiss_cov_edit_and_search_tool_phases() {
    use crate::tool_summary::ToolSummaryDetail;
    use serde_json::json;

    let _guard = crate::agent_phase::AGENT_PHASE_TEST_LOCK
        .lock()
        .unwrap_or_else(std::sync::PoisonError::into_inner);
    crate::agent_phase::reset_phase_state_for_test();
    let mut tracker = crate::tool_summary::ToolSummaryTracker::default();
    let observe = |update: serde_json::Value,
                   tracker: &mut crate::tool_summary::ToolSummaryTracker| {
        let v = json!({"method": "session/update", "params": {"update": update}});
        crate::tool_summary::tool_summary_lines(&v, tracker, ToolSummaryDetail::Log).unwrap();
    };
    observe(
        json!({"sessionUpdate":"tool_call","toolCallId":"e1","kind":"edit","status":"pending","rawInput":{"path":"a.rs"}}),
        &mut tracker,
    );
    assert_eq!(
        crate::agent_phase::current_phase_for_test(),
        crate::agent_phase::AgentPhase::Implementing
    );
    observe(
        json!({"sessionUpdate":"tool_call","toolCallId":"s1","kind":"search","status":"pending","rawInput":{"query":"foo"}}),
        &mut tracker,
    );
    assert_eq!(
        crate::agent_phase::current_phase_for_test(),
        crate::agent_phase::AgentPhase::Researching
    );
}

#[test]
fn kiss_cov_agent_phase_private_symbol_names() {
    use crate::agent_phase::kiss_cov::{
        ToolKind, witness_active_tool_phase, witness_phase_if, witness_tool_kinds,
    };
    let _ = stringify!(phase_if);
    let _ = stringify!(active_tool_phase);
    assert_eq!(witness_tool_kinds().len(), 4);
    assert_eq!(
        witness_phase_if(true),
        Some(crate::agent_phase::AgentPhase::Waiting)
    );
    assert_eq!(witness_phase_if(false), None);
    assert_eq!(
        witness_active_tool_phase(ToolKind::Edit),
        crate::agent_phase::AgentPhase::Implementing
    );
}