agentcarousel 0.2.3

Evaluate agents and skills with YAML fixtures, run cases (mock or live), and keep run rows in SQLite for reports and evidence export.
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
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125

use assert_cmd::Command;
use std::io::{Read, Write};
use std::net::TcpListener;
use std::sync::mpsc;
use std::thread;

fn workspace_root() -> std::path::PathBuf {
    std::path::PathBuf::from(env!("CARGO_MANIFEST_DIR"))
        .parent()
        .and_then(|path| path.parent())
        .map(std::path::PathBuf::from)
        .expect("workspace root")
}

fn spawn_json_server(status_line: &str, body: &str) -> (String, mpsc::Receiver<String>) {
    let listener = TcpListener::bind("127.0.0.1:0").expect("bind test server");
    let addr = listener.local_addr().expect("local addr");
    let (tx, rx) = mpsc::channel::<String>();
    let status = status_line.to_string();
    let payload = body.to_string();
    thread::spawn(move || {
        let (mut stream, _) = listener.accept().expect("accept");
        let mut req = [0u8; 2048];
        let n = stream.read(&mut req).expect("read");
        let request = String::from_utf8_lossy(&req[..n]).to_string();
        let first_line = request.lines().next().unwrap_or_default().to_string();
        let _ = tx.send(first_line);

        let response = format!(
            "HTTP/1.1 {status}\r\ncontent-type: application/json\r\ncontent-length: {}\r\nconnection: close\r\n\r\n{}",
            payload.len(),
            payload
        );
        stream
            .write_all(response.as_bytes())
            .expect("write response");
    });
    (format!("http://{}", addr), rx)
}

#[test]
fn trust_check_fails_without_registry_url() {
    std::env::remove_var("REGISTRY_API_BASE_URL");
    std::env::remove_var("REGISTRY_URL");
    let root = workspace_root();
    let assert = Command::cargo_bin("agentcarousel")
        .unwrap()
        .current_dir(&root)
        .args(["trust-check", "cmmc-assessor@1.0.0"])
        .assert()
        .failure();
    let stderr = String::from_utf8_lossy(&assert.get_output().stderr);
    assert!(
        stderr.contains("registry URL is required"),
        "expected missing URL guidance, got: {stderr:?}"
    );
}

#[test]
fn trust_check_parses_bundle_version_and_enforces_threshold() {
    let (url, rx) = spawn_json_server(
        "200 OK",
        r#"{"bundle_id":"cmmc-assessor-1.0.0","trust_state":"Experimental"}"#,
    );
    let root = workspace_root();
    let assert = Command::cargo_bin("agentcarousel")
        .unwrap()
        .current_dir(&root)
        .args([
            "trust-check",
            "cmmc-assessor@1.0.0",
            "--url",
            &url,
            "--min-trust",
            "trusted",
        ])
        .assert()
        .failure();
    let stderr = String::from_utf8_lossy(&assert.get_output().stderr);
    assert!(
        stderr.contains("below required threshold"),
        "expected threshold failure, got: {stderr:?}"
    );

    let first_line = rx.recv().expect("request first line");
    assert!(
        first_line.contains("GET /v1/bundles/cmmc-assessor-1.0.0/trust-state"),
        "unexpected request path: {first_line:?}"
    );
}

#[test]
fn trust_check_reports_missing_minisign_binary() {
    let (url, _rx) = spawn_json_server("200 OK", r#"{"trust_state":"Trusted"}"#);
    let root = workspace_root();
    let temp_dir = tempfile::tempdir().expect("temp dir");
    let attestation = temp_dir.path().join("attestation.json");
    let pubkey = temp_dir.path().join("minisign.pub");
    std::fs::write(&attestation, "{}").expect("write attestation");
    std::fs::write(&pubkey, "untrusted comment: minisign public key\nRWQ...")
        .expect("write pubkey");

    let assert = Command::cargo_bin("agentcarousel")
        .unwrap()
        .current_dir(&root)
        .args([
            "trust-check",
            "cmmc-assessor@1.0.0",
            "--url",
            &url,
            "--attestation",
            attestation.to_str().expect("attestation path"),
            "--minisign-pubkey",
            pubkey.to_str().expect("pubkey path"),
            "--minisign-bin",
            "definitely-not-a-real-minisign-binary",
        ])
        .assert()
        .failure();
    let stderr = String::from_utf8_lossy(&assert.get_output().stderr);
    assert!(
        stderr.contains("failed to run `definitely-not-a-real-minisign-binary`"),
        "expected minisign error, got: {stderr:?}"
    );
}