aether-agent-cli 0.7.26

CLI and ACP server for the Aether AI coding agent
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

use std::error::Error;
use std::process::{Command, Output};

const INVALID_TRACEPARENT: &str = "00-00000000000000000000000000000000-0123456789abcdef-01";
const VALID_TRACEPARENT: &str = "00-00112233445566778899aabbccddeeff-0123456789abcdef-01";
const TELEMETRY_SETTINGS: &str = r#""telemetry":{"otlp":{"endpoint":"http://127.0.0.1:1"}}"#;

type TestResult = Result<(), Box<dyn Error>>;

#[test]
fn acp_rejects_an_invalid_trace_context_when_telemetry_is_enabled() -> TestResult {
    let options = format!(
        r#"{{"settings":{{"credentialsStore":{{"type":"memory"}},"agents":[],{TELEMETRY_SETTINGS}}},"traceContext":{{"traceparent":"{INVALID_TRACEPARENT}"}}}}"#
    );
    let output = aether(&["acp", "--options-json", &options]).output()?;
    assert_rejected(&output, "traceparent");
    Ok(())
}

#[test]
fn headless_rejects_an_invalid_trace_context_when_telemetry_is_enabled() -> TestResult {
    let options = format!(
        r#"{{"prompt":"hello","settings":{{"agents":[],{TELEMETRY_SETTINGS}}},"traceContext":{{"traceparent":"{INVALID_TRACEPARENT}"}}}}"#
    );
    let output = aether(&["headless", "--options-json", &options]).output()?;
    assert_rejected(&output, "traceparent");
    Ok(())
}

#[test]
fn headless_rejects_an_invalid_tracestate_when_telemetry_is_enabled() -> TestResult {
    let options = format!(
        r#"{{"prompt":"hello","settings":{{"agents":[],{TELEMETRY_SETTINGS}}},"traceContext":{{"traceparent":"{VALID_TRACEPARENT}","tracestate":"not a valid tracestate"}}}}"#
    );
    let output = aether(&["headless", "--options-json", &options]).output()?;
    assert_rejected(&output, "tracestate");
    Ok(())
}

fn aether(args: &[&str]) -> Command {
    let mut command = Command::new(env!("CARGO_BIN_EXE_aether"));
    command.args(args);
    command
}

fn assert_rejected(output: &Output, header: &str) {
    let stderr = String::from_utf8_lossy(&output.stderr);
    assert!(!output.status.success(), "invalid trace context succeeded: {stderr}");
    assert!(stderr.contains(&format!("telemetry trace context has an invalid {header} header")), "stderr: {stderr}");
}