unified-agent-api 0.3.5

Agent-agnostic facade and registry for wrapper backends
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

use super::support::*;
use serde_json::{json, Value};

#[test]
fn app_server_agent_message_delta_maps_to_text_output_without_data() {
    let event =
        fork::map_app_server_notification("agentMessage/delta", &json!("hello")).expect("mapped");
    assert_eq!(event.kind, AgentWrapperEventKind::TextOutput);
    assert_eq!(event.channel.as_deref(), Some("assistant"));
    assert_eq!(event.text.as_deref(), Some("hello"));
    assert_eq!(event.data, None);
}

#[test]
fn app_server_reasoning_delta_prefers_content_text_field_when_present() {
    let params = json!({"content": {"text": "hi"}});
    let event = fork::map_app_server_notification("reasoning/text/delta", &params).expect("mapped");
    assert_eq!(event.kind, AgentWrapperEventKind::TextOutput);
    assert_eq!(event.channel.as_deref(), Some("assistant"));
    assert_eq!(event.text.as_deref(), Some("hi"));
    assert_eq!(event.data, None);
}

#[test]
fn app_server_item_started_maps_to_tool_call_with_metadata_only_facet() {
    let params = json!({
        "item_id": "item-1",
        "thread_id": "thread-1",
        "turn_id": "turn-1",
        "item_type": "command_execution"
    });
    let event = fork::map_app_server_notification("item/started", &params).expect("mapped");
    assert_eq!(event.kind, AgentWrapperEventKind::ToolCall);
    assert_eq!(tool_schema(&event), Some(TOOLS_FACET_SCHEMA));
    assert_eq!(
        tool_field(&event, "phase").and_then(Value::as_str),
        Some("start")
    );
    assert_eq!(
        tool_field(&event, "status").and_then(Value::as_str),
        Some("running")
    );
    assert_eq!(
        tool_field(&event, "kind").and_then(Value::as_str),
        Some("command_execution")
    );
}

#[test]
fn app_server_error_maps_to_error_event_with_safe_message_and_no_data() {
    let secret = "SECRET_SHOULD_NOT_LEAK";
    let params = json!({
        "error": {"message": "boom", "additionalDetails": {"secret": secret}},
        "message": secret
    });
    let event = fork::map_app_server_notification("error", &params).expect("mapped");
    assert_eq!(event.kind, AgentWrapperEventKind::Error);
    assert_eq!(event.message.as_deref(), Some("boom"));
    assert!(!event.message.as_deref().unwrap().contains(secret));
    assert_eq!(event.data, None);
}

#[test]
fn approval_request_detector_matches_direct_and_wrapped_payloads() {
    assert!(fork::is_approval_request_notification(
        "codex/event",
        &json!({"type": "approval_required", "approval_id": "ap-1", "kind": "exec"}),
    ));
    assert!(fork::is_approval_request_notification(
        "codex/event",
        &json!({"msg": {"type": "approval", "id": "ap-1", "approval_kind": "exec"}}),
    ));
    assert!(!fork::is_approval_request_notification(
        "codex/event",
        &json!({"type": "task_complete"}),
    ));
    assert!(!fork::is_approval_request_notification(
        "agentMessage/delta",
        &json!({"type": "approval_required"}),
    ));
}