r402-extensions 0.21.0

Protocol extension implementations for the x402 payment protocol.
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

//! Advertise-only bazaar discovery declarations.

#![allow(unused_crate_dependencies, reason = "sibling tests consume them")]
#![allow(
    clippy::tests_outside_test_module,
    reason = "integration test binaries put #[test] fns at file scope"
)]
#![allow(
    clippy::indexing_slicing,
    clippy::unwrap_used,
    clippy::panic,
    reason = "idiomatic test-code patterns"
)]

use r402_extensions::{BazaarBodyMethod, BazaarBodyType, BazaarExtension, BazaarQueryMethod};
use r402_protocol::extension::{AdvertiseContext, Extension};
use serde_json::json;

#[test]
fn advertise_http_query_shape() {
    let ext = BazaarExtension::http_query(BazaarQueryMethod::Get, json!({"city": "San Francisco"}))
        .with_output(json!({"weather": "foggy"}));
    assert_eq!(ext.id(), "bazaar");
    let entry = ext.advertise(&AdvertiseContext::new(None)).unwrap();
    let info = entry.as_info().unwrap();
    assert_eq!(info["input"]["type"], "http");
    assert_eq!(info["input"]["method"], "GET");
    assert_eq!(info["input"]["queryParams"]["city"], "San Francisco");
    assert_eq!(info["output"]["example"]["weather"], "foggy");
    let schema = entry.as_schema().unwrap();
    assert_eq!(
        schema["properties"]["input"]["properties"]["method"]["enum"],
        json!(["GET"])
    );
}

#[test]
fn advertise_http_head_and_patch_methods() {
    let head = BazaarExtension::http_query(BazaarQueryMethod::Head, json!({}));
    let head_info = head
        .advertise(&AdvertiseContext::new(None))
        .unwrap()
        .as_info()
        .unwrap()
        .clone();
    assert_eq!(head_info["input"]["method"], "HEAD");

    let patch = BazaarExtension::http_body(
        BazaarBodyMethod::Patch,
        BazaarBodyType::Json,
        json!({"status": "active"}),
    );
    let patch_info = patch
        .advertise(&AdvertiseContext::new(None))
        .unwrap()
        .as_info()
        .unwrap()
        .clone();
    assert_eq!(patch_info["input"]["method"], "PATCH");
}

#[test]
fn advertise_http_body_shape() {
    let ext = BazaarExtension::http_body(
        BazaarBodyMethod::Post,
        BazaarBodyType::Json,
        json!({"query": "example"}),
    );
    let entry = ext.advertise(&AdvertiseContext::new(None)).unwrap();
    let info = entry.as_info().unwrap();
    assert_eq!(info["input"]["type"], "http");
    assert_eq!(info["input"]["method"], "POST");
    assert_eq!(info["input"]["bodyType"], "json");
    assert_eq!(info["input"]["body"]["query"], "example");
}

#[test]
fn advertise_mcp_shape() {
    let ext = BazaarExtension::mcp(
        "financial_analysis",
        json!({"type": "object", "properties": {"ticker": {"type": "string"}}}),
    );
    let entry = ext.advertise(&AdvertiseContext::new(None)).unwrap();
    let info = entry.as_info().unwrap();
    assert_eq!(info["input"]["type"], "mcp");
    assert_eq!(info["input"]["toolName"], "financial_analysis");
    assert!(info["input"].get("inputSchema").is_some());
}

#[test]
fn advertise_is_not_legacy_catalog() {
    let ext = BazaarExtension::http_query(BazaarQueryMethod::Get, json!({}));
    let entry = ext.advertise(&AdvertiseContext::new(None)).unwrap();
    let info = entry.as_info().unwrap();
    assert!(info.get("catalog").is_none());
    assert!(info.get("categories").is_none());
    assert!(info.get("registered").is_none());
}