agent-berth 2.2.1

Monitor and resume coding agents
Documentation 
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

use super::*;

#[test]
fn request_response_roundtrip() {
    let notify = Request::Notify {
        provider: "claude".into(),
        payload: serde_json::json!({"session_id":"s"}),
    };
    let text = serde_json::to_string(&notify).unwrap();
    let back: Request = serde_json::from_str(&text).unwrap();
    assert!(matches!(back, Request::Notify { provider, .. } if provider == "claude"));

    let list = Request::List {
        resumable: true,
        idle_ms: Some(1200),
    };
    let text = serde_json::to_string(&list).unwrap();
    assert!(text.contains("list"));
    let back: Request = serde_json::from_str(&text).unwrap();
    assert!(matches!(
        back,
        Request::List {
            resumable: true,
            idle_ms: Some(1200)
        }
    ));

    let all = serde_json::to_string(&Request::ListAll).unwrap();
    assert!(all.contains("list_all"));
    assert!(matches!(
        serde_json::from_str(&all).unwrap(),
        Request::ListAll
    ));

    let stats = serde_json::to_string(&Request::Stats).unwrap();
    assert!(stats.contains("stats"));
    assert!(matches!(
        serde_json::from_str(&stats).unwrap(),
        Request::Stats
    ));

    let response = serde_json::to_string(&Response::stats(vec![ProviderStats {
        provider: "claude".into(),
        running: 1,
        waiting: 0,
        idle: 2,
        done: 0,
        total: 3,
    }]))
    .unwrap();
    let parsed: Response = serde_json::from_str(&response).unwrap();
    assert!(matches!(
        parsed,
        Response::Ok {
            stats: Some(stats),
            ..
        } if stats[0].provider == "claude" && stats[0].running == 1 && stats[0].total == 3
    ));

    let remove = Request::Remove {
        provider: "claude".into(),
        session_id: "s".into(),
    };
    let text = serde_json::to_string(&remove).unwrap();
    assert!(matches!(
        serde_json::from_str(&text).unwrap(),
        Request::Remove { provider, session_id }
            if provider == "claude" && session_id == "s"
    ));

    let ok = serde_json::to_string(&Response::ok()).unwrap();
    let parsed: Response = serde_json::from_str(&ok).unwrap();
    assert!(matches!(parsed, Response::Ok { sessions: None, .. }));
}