runcycles 0.2.4

Runtime authority for AI agents in Rust — hard limits on agent spend, risky tool actions, and audit gaps. Tokio-native client for the Cycles protocol (reserve-commit lifecycle, RAII guards).
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

//! Tests for ApiResponse wrapper.

use runcycles::models::*;
use runcycles::CyclesClient;
use serde_json::json;
use wiremock::matchers::{method, path};
use wiremock::{Mock, MockServer, ResponseTemplate};

#[tokio::test]
async fn api_response_into_inner() {
    let server = MockServer::start().await;
    let client = CyclesClient::builder("key", server.uri()).build();

    Mock::given(method("POST"))
        .and(path("/v1/reservations"))
        .respond_with(
            ResponseTemplate::new(200)
                .set_body_json(json!({
                    "decision": "ALLOW",
                    "reservation_id": "rsv_inner",
                    "affected_scopes": ["tenant:acme"]
                }))
                .append_header("x-request-id", "req-inner")
                .append_header("x-cycles-tenant", "acme"),
        )
        .mount(&server)
        .await;

    let req = ReservationCreateRequest::builder()
        .subject(Subject {
            tenant: Some("acme".into()),
            ..Default::default()
        })
        .action(Action::new("llm.completion", "gpt-4o"))
        .estimate(Amount::usd_microcents(5000))
        .build();

    let api_resp = client.create_reservation_with_metadata(&req).await.unwrap();

    // Test Deref
    assert_eq!(api_resp.decision, Decision::Allow);

    // Test metadata
    assert_eq!(api_resp.request_id.as_deref(), Some("req-inner"));
    assert_eq!(api_resp.cycles_tenant.as_deref(), Some("acme"));

    // Test into_inner
    let inner = api_resp.into_inner();
    assert_eq!(inner.decision, Decision::Allow);
    assert_eq!(inner.reservation_id.unwrap().as_str(), "rsv_inner");
}

#[tokio::test]
async fn api_response_missing_optional_headers() {
    let server = MockServer::start().await;
    let client = CyclesClient::builder("key", server.uri()).build();

    Mock::given(method("POST"))
        .and(path("/v1/reservations"))
        .respond_with(ResponseTemplate::new(200).set_body_json(json!({
            "decision": "ALLOW",
            "reservation_id": "rsv_no_headers",
            "affected_scopes": []
        })))
        .mount(&server)
        .await;

    let req = ReservationCreateRequest::builder()
        .subject(Subject {
            tenant: Some("acme".into()),
            ..Default::default()
        })
        .action(Action::new("llm.completion", "gpt-4o"))
        .estimate(Amount::usd_microcents(5000))
        .build();

    let api_resp = client.create_reservation_with_metadata(&req).await.unwrap();
    assert!(api_resp.request_id.is_none());
    assert!(api_resp.rate_limit_remaining.is_none());
    assert!(api_resp.rate_limit_reset.is_none());
    assert!(api_resp.cycles_tenant.is_none());
}