blvm-node 0.1.32

Bitcoin Commons BLVM: Minimal Bitcoin node implementation using blvm-protocol and blvm-consensus
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

//! Module API registry and inter-module router smoke.

use async_trait::async_trait;
use blvm_node::module::inter_module::api::ModuleAPI;
use blvm_node::module::inter_module::registry::ModuleApiRegistry;
use blvm_node::module::inter_module::router::ModuleRouter;
use blvm_node::module::traits::ModuleError;
use std::sync::Arc;

struct EchoApi;

#[async_trait]
impl ModuleAPI for EchoApi {
    async fn handle_request(
        &self,
        method: &str,
        params: &[u8],
        caller_module_id: &str,
    ) -> Result<Vec<u8>, ModuleError> {
        let base = method.rsplit("::").next().unwrap_or(method);
        if base != "echo" {
            return Err(ModuleError::OperationError(format!(
                "unknown method {method}"
            )));
        }
        Ok(format!("{caller_module_id}:{}", String::from_utf8_lossy(params)).into_bytes())
    }

    fn list_methods(&self) -> Vec<String> {
        vec!["echo".into()]
    }

    fn api_version(&self) -> u32 {
        1
    }
}

#[tokio::test]
async fn registry_register_route_and_call() {
    let registry = Arc::new(ModuleApiRegistry::new());
    registry
        .register_api("svc_abc".into(), Arc::new(EchoApi))
        .await
        .unwrap();

    assert_eq!(registry.list_modules().await, vec!["svc_abc".to_string()]);
    assert_eq!(
        registry.get_module_methods("svc_abc").await,
        Some(vec!["echo".to_string()])
    );
    assert_eq!(
        registry.route_method("echo").await,
        Some(("svc_abc".to_string(), "echo".to_string()))
    );
    assert_eq!(
        registry.resolve_module_id("svc").await,
        Some("svc_abc".into())
    );

    let api = registry.get_api("svc_abc").await.unwrap();
    let out = api.handle_request("echo", b"hi", "caller").await.unwrap();
    assert_eq!(out, b"caller:hi");

    registry.unregister_api("svc_abc").await.unwrap();
    assert!(registry.get_api("svc_abc").await.is_none());
}

#[tokio::test]
async fn router_direct_call_and_method_routing() {
    let registry = Arc::new(ModuleApiRegistry::new());
    registry
        .register_api("svc_xyz".into(), Arc::new(EchoApi))
        .await
        .unwrap();
    let router = ModuleRouter::new(Arc::clone(&registry));

    let direct = router
        .route_call("caller", Some("svc_xyz"), "echo", b"one")
        .await
        .unwrap();
    assert_eq!(direct, b"caller:one");

    let routed = router
        .route_call("caller", None, "echo", b"two")
        .await
        .unwrap();
    assert_eq!(routed, b"caller:two");

    let missing = router.route_call("caller", None, "missing", b"").await;
    assert!(missing.is_err());
}