ahp-types 0.8.0

Wire protocol types for the Agent Host Protocol (AHP).
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

use ahp_types::commands::ChatSource;

#[test]
fn chat_source_routes_by_kind() {
    let fork = serde_json::from_str::<ChatSource>(
        r#"{"kind":"fork","chat":"ahp-chat:/main","turnId":"turn-12"}"#,
    )
    .expect("decode fork source");
    let side_chat = serde_json::from_str::<ChatSource>(
        r#"{"kind":"sideChat","chat":"ahp-chat:/main","turnId":"turn-active","selection":{"text":"const value = compute()","responsePartId":"part-7"}}"#,
    )
    .expect("decode side chat source");

    match fork {
        ChatSource::Fork(value) => {
            assert_eq!(value.chat, "ahp-chat:/main");
            assert_eq!(value.turn_id, "turn-12");
        }
        other => panic!("expected fork variant, got {other:?}"),
    }

    match side_chat {
        ChatSource::SideChat(value) => {
            assert_eq!(value.chat, "ahp-chat:/main");
            assert_eq!(value.turn_id, "turn-active");
            let selection = value.selection.expect("selection should decode");
            assert_eq!(selection.text, "const value = compute()");
            assert_eq!(selection.response_part_id.as_deref(), Some("part-7"));
        }
        other => panic!("expected sideChat variant, got {other:?}"),
    }
}

#[test]
fn chat_source_rejects_missing_or_unknown_kind() {
    for raw in [
        r#"{"chat":"ahp-chat:/main","turnId":"turn-12"}"#,
        r#"{"kind":"future","chat":"ahp-chat:/main","turnId":"turn-12"}"#,
    ] {
        assert!(
            serde_json::from_str::<ChatSource>(raw).is_err(),
            "expected decode failure for {raw}"
        );
    }
}