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
103
104
105
106
107
108
109
110
111
112

#[must_use]
pub fn timestamp_now_string() -> String {
    let now = chrono::Local::now();
    format!(
        "{}.{:03}",
        now.format("%Y%m%d.%H%M%S"),
        now.timestamp_subsec_millis()
    )
}

#[must_use]
pub fn heartbeat_payload_now() -> String {
    let now = chrono::Local::now();
    let ts = now.format("%Y%m%d.%H%M%S");
    let mut payload = format!("{ts} {}", crate::agent_phase::heartbeat_label());
    if let Some(stats) = crate::active_agent_heartbeat::active_agent_heartbeat_stats() {
        payload.push_str(", ");
        payload.push_str(&stats);
    }
    if let Some(id) = crate::run_id::active_run_dir()
        .as_deref()
        .and_then(crate::run_id::short_malvin_log_id)
    {
        payload.push_str(" · ");
        payload.push_str(&id);
    }
    payload
}

#[must_use]
pub fn heartbeat_payload_has_wall_clock_prefix(payload: &str) -> bool {
    let Some(ts) = payload.get(..15) else {
        return false;
    };
    if ts.len() != 15 || ts.as_bytes().get(8) != Some(&b'.') {
        return false;
    }
    ts.chars().all(|c| c.is_ascii_digit() || c == '.') && payload.get(15..16) == Some(" ")
}

#[cfg(test)]
mod tests {
    #[test]
    fn kiss_cov_timestamp_now_string() {
        let _ = super::timestamp_now_string;
        let _ = super::heartbeat_payload_now;
    }

    #[test]
    fn heartbeat_payload_now_starts_with_wall_clock_timestamp() {
        let payload = super::heartbeat_payload_now();
        assert!(super::heartbeat_payload_has_wall_clock_prefix(&payload));
    }

    #[cfg(unix)]
    #[test]
    fn heartbeat_payload_now_includes_agent_stats_when_session_registered() {
        crate::active_agent_heartbeat::clear_active_agent_process_groups_for_test();
        let pgid = std::process::id();
        let baseline = crate::acp::snapshot_pids();
        crate::active_agent_heartbeat::register_active_agent_process_group(Some(pgid), baseline);
        let payload = super::heartbeat_payload_now();
        assert!(payload.contains("sandbox: "));
        assert!(payload.contains("USS"));
        assert!(payload.contains("procs"));
        crate::active_agent_heartbeat::unregister_active_agent_process_group(Some(pgid));
        crate::active_agent_heartbeat::clear_active_agent_process_groups_for_test();
    }

    #[test]
    fn heartbeat_payload_uses_agent_phase_label() {
        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 payload = super::heartbeat_payload_now();
        assert!(payload.contains("Orienting"));
    }

    #[test]
    fn heartbeat_payload_has_wall_clock_prefix_accepts_new_shape() {
        assert!(super::heartbeat_payload_has_wall_clock_prefix(
            "20260524.000000 Still alive."
        ));
        assert!(!super::heartbeat_payload_has_wall_clock_prefix("HB: old"));
    }

    #[test]
    fn heartbeat_payload_now_appends_short_malvin_log_id() {
        let _guard = crate::run_id::ACTIVE_RUN_DIR_TEST_LOCK
            .lock()
            .unwrap_or_else(std::sync::PoisonError::into_inner);
        crate::run_id::set_active_run_dir(None);
        let bare = super::heartbeat_payload_now();
        assert!(
            !bare.contains('·'),
            "no run dir ⇒ no center-dot suffix: {bare}"
        );

        let run = std::path::PathBuf::from(
            "/home/dsweet/.malvin_home/logs/eb7ef333a92a6d41/20260830_024330_estp91hf",
        );
        crate::run_id::set_active_run_dir(Some(run));
        let payload = super::heartbeat_payload_now();
        crate::run_id::set_active_run_dir(None);
        assert!(
            payload.ends_with(" · eb7ef333a92a6d41/20260830_024330_estp91hf"),
            "expected short log id suffix, got {payload}"
        );
        assert!(super::heartbeat_payload_has_wall_clock_prefix(&payload));
    }
}