aether-acp-utils 0.3.21

Agent Client Protocol (ACP) utilities for the Aether AI agent framework
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

use acp_utils::client::TokioAcpAgent;
use agent_client_protocol::{Client, ConnectTo};
use std::path::Path;
use std::str::FromStr;
use tokio::task::LocalSet;

#[test]
fn parses_shell_command() {
    let agent = TokioAcpAgent::from_str("aether acp --foo bar").expect("parses");
    let server = agent.stdio();
    assert_eq!(server.command.as_path(), Path::new("aether"));
    assert_eq!(server.args.as_slice(), &["acp", "--foo", "bar"]);
}

#[test]
fn parses_quoted_shell_command() {
    let agent = TokioAcpAgent::from_str(r#"python "my agent.py" --name "Test Agent""#).expect("parses");
    let server = agent.stdio();
    assert_eq!(server.command.as_path(), Path::new("python"));
    assert_eq!(server.args.as_slice(), &["my agent.py", "--name", "Test Agent"]);
}

#[test]
fn parses_leading_environment_variables() {
    let agent = TokioAcpAgent::from_str("RUST_LOG=debug aether acp").expect("parses");
    let server = agent.stdio();
    assert_eq!(server.command.as_path(), Path::new("aether"));
    assert_eq!(server.args.as_slice(), &["acp"]);
    assert_eq!(server.env[0].name, "RUST_LOG");
    assert_eq!(server.env[0].value, "debug");
}

#[test]
fn parses_json_stdio_agent_config() {
    let agent = TokioAcpAgent::from_str(
        r#"{"type":"stdio","name":"test-agent","command":"/usr/bin/python","args":["agent.py","--verbose"],"env":[{"name":"RUST_LOG","value":"debug"}]}"#,
    )
    .expect("parses");

    let server = agent.stdio();
    assert_eq!(server.command.as_path(), Path::new("/usr/bin/python"));
    assert_eq!(server.args.as_slice(), &["agent.py", "--verbose"]);
    assert_eq!(server.env[0].name, "RUST_LOG");
    assert_eq!(server.env[0].value, "debug");
}

#[test]
fn rejects_empty_command() {
    assert!(TokioAcpAgent::from_str("").is_err());
    assert!(TokioAcpAgent::from_str("   ").is_err());
}

#[test]
fn rejects_non_stdio_transport_at_parse_time() {
    let json = r#"{"type":"http","name":"remote","url":"https://example.com/agent","headers":[]}"#;
    assert!(TokioAcpAgent::from_str(json).is_err());
}

#[tokio::test(flavor = "current_thread")]
async fn agent_exited_message_includes_stderr_and_status() {
    LocalSet::new()
        .run_until(async {
            let agent = TokioAcpAgent::from_str("/bin/ls /nonexistent-aether-test-path-12345").expect("parses");
            let result = ConnectTo::<Client>::connect_to(agent, Client.builder()).await;

            let err = result.expect_err("child exited with non-zero status");
            let msg = format!("{err}");
            assert!(msg.contains("exited"), "expected exit info in error: {msg}");
            assert!(msg.contains("No such file"), "expected stderr in error: {msg}");
        })
        .await;
}