arcp 2.0.0

Reference implementation of the Agent Runtime Control Protocol (ARCP) v1.1 — umbrella crate that re-exports arcp-core, arcp-client, and arcp-runtime.
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

//! Shared helpers for integration tests.

#![allow(
    clippy::expect_used,
    clippy::unwrap_used,
    clippy::panic,
    clippy::missing_panics_doc,
    dead_code,
    unreachable_pub
)]

use arcp::auth::{BearerAuthenticator, NoneAuthenticator};
use arcp::messages::{Capabilities, ClientIdentity, Credentials};
use arcp::runtime::ARCPRuntime;
use arcp::transport::{paired, MemoryTransport};
use arcp::{ARCPClient, IMPL_KIND, IMPL_VERSION};

/// Construct a runtime with a bearer authenticator pre-loaded with one
/// `(token, principal)` pair, optional anonymous capability, and a paired
/// in-memory transport for the client.
pub async fn spawn_runtime_with_bearer(
    token: &str,
    principal: &str,
    anonymous: bool,
) -> (ARCPRuntime, ARCPClient<MemoryTransport>) {
    let mut caps = Capabilities {
        streaming: Some(true),
        artifacts: Some(true),
        ..Default::default()
    };
    if anonymous {
        caps.anonymous = Some(true);
    }
    let runtime = ARCPRuntime::builder()
        .with_authenticator(Box::new(
            BearerAuthenticator::new().with_token(token, principal),
        ))
        .with_authenticator(Box::new(NoneAuthenticator::new()))
        .with_capabilities(caps)
        .build()
        .await
        .expect("build runtime");
    let (server_t, client_t) = paired();
    let _handle = runtime.serve_connection(server_t);
    let client = ARCPClient::new(client_t);
    (runtime, client)
}

/// A canonical client identity block for tests.
pub fn test_client_identity() -> ClientIdentity {
    ClientIdentity {
        kind: format!("{IMPL_KIND}-test"),
        version: IMPL_VERSION.into(),
        fingerprint: None,
        principal: Some("test-user".into()),
    }
}

/// Bearer credentials with the given token.
pub fn bearer(token: &str) -> Credentials {
    Credentials {
        scheme: arcp::messages::AuthScheme::Bearer,
        token: Some(token.into()),
    }
}

/// `none`-scheme credentials.
pub const fn none_creds() -> Credentials {
    Credentials {
        scheme: arcp::messages::AuthScheme::None,
        token: None,
    }
}