agentos-client 0.2.9

High-level Rust client SDK for the Agent OS native sidecar (1:1 port of the TypeScript AgentOs client)
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
75
76
77
78
79
80
81
82
83
84
85

use agentos_client::SessionStreamEntry;
use serde_json::json;

#[test]
fn session_events_use_the_flat_public_json_shape() {
    let cases = [
        json!({
            "durability": "durable",
            "sessionId": "main",
            "sequence": 1,
            "timestamp": "2026-07-18T00:00:00.000Z",
            "type": "agent_message_chunk",
            "content": { "type": "text", "text": "done" }
        }),
        json!({
            "durability": "ephemeral",
            "sessionId": "main",
            "afterSequence": 1,
            "type": "agent_thought_chunk",
            "content": { "type": "text", "text": "thinking" }
        }),
        json!({
            "durability": "durable",
            "sessionId": "main",
            "sequence": 2,
            "timestamp": "2026-07-18T00:00:01.000Z",
            "type": "permission_request",
            "requestId": "permission-1",
            "options": [{
                "optionId": "allow",
                "name": "Allow",
                "kind": "allow_once"
            }],
            "toolCall": { "toolCallId": "tool-1" }
        }),
        json!({
            "durability": "durable",
            "sessionId": "main",
            "sequence": 3,
            "timestamp": "2026-07-18T00:00:02.000Z",
            "type": "permission_response",
            "requestId": "permission-1",
            "outcome": { "outcome": "selected", "optionId": "allow" },
            "status": "accepted"
        }),
    ];

    for expected in cases {
        let event: SessionStreamEntry =
            serde_json::from_value(expected.clone()).expect("deserialize flat session event");
        assert_eq!(
            serde_json::to_value(event).expect("serialize flat session event"),
            expected
        );
    }
}

#[test]
fn session_event_envelopes_reject_invalid_durability_combinations() {
    let ephemeral_permission = json!({
        "durability": "ephemeral",
        "sessionId": "main",
        "afterSequence": 0,
        "type": "permission_request",
        "requestId": "permission-1",
        "options": [],
        "toolCall": { "toolCallId": "tool-1" }
    });
    assert!(serde_json::from_value::<SessionStreamEntry>(ephemeral_permission).is_err());

    let ephemeral_with_timestamp = json!({
        "durability": "ephemeral",
        "sessionId": "main",
        "afterSequence": 0,
        "timestamp": "2026-07-18T00:00:00.000Z",
        "type": "agent_message_chunk",
        "content": { "type": "text", "text": "partial" }
    });
    let normalized = serde_json::to_value(
        serde_json::from_value::<SessionStreamEntry>(ephemeral_with_timestamp)
            .expect("deserialize ephemeral event"),
    )
    .expect("serialize ephemeral event");
    assert!(normalized.get("timestamp").is_none());
}