phoxal 0.54.0

Phoxal - production-oriented autonomous robot framework: the runtime engine and model (the api contract tree lives in phoxal-api, the typed bus in phoxal-bus).
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

//! The composed form of a protocol key, proven end to end across two slices.
//!
//! `phoxal_api_tree!`'s protocol mode emits *relative* keys whose leading
//! segment is the protocol name, and the bus session mounts everything under
//! `phoxal/<execution-id>`. Each half is unit tested in its own crate; nothing
//! previously pinned the two together, so a change to either root convention
//! could drift the composed key that the macro rustdoc advertises. This test
//! opens a real in-process session and asserts the final key.

use phoxal_bus::{Bus, BusConfig, ContractBody};
use phoxal_macros::phoxal_api_tree;

phoxal_api_tree! {
    protocol supervisor {
        connect {
            #[serde(tag = "schema")]
            enum Hello {
                #[serde(rename = "supervisor.hello/v0")]
                V0 { token: String },
            }

            topic hello: command Hello;
        }
    }
}

#[tokio::test(flavor = "multi_thread", worker_threads = 1)]
async fn a_protocol_topic_composes_under_the_execution_scoped_root() {
    let config = BusConfig::in_process("composition");
    let execution = config.execution;
    let bus = Bus::open(config).await.expect("open in-process bus");

    // The macro's half: relative, protocol-led, no revision segment.
    assert_eq!(
        <supervisor::connect::Hello as ContractBody>::TOPIC,
        "supervisor/connect/hello"
    );
    // The session's half: the execution is the whole root.
    assert_eq!(bus.root(), format!("phoxal/{execution}"));
    // Composed, this is the key a supervisor protocol actually speaks on.
    assert_eq!(
        bus.full_key(<supervisor::connect::Hello as ContractBody>::TOPIC),
        format!("phoxal/{execution}/supervisor/connect/hello")
    );

    bus.close().await.expect("close in-process bus");
}