tigrbl_rs_kernel 0.1.13-dev.1

Rust kernel compiler, packed plan model, and optimizer passes for Tigrbl.
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

use tigrbl_rs_kernel::{build_parity_snapshot, KernelCompiler};
use tigrbl_rs_spec::{
    AppSpec, BindingSpec, Exchange, HookPhase, HookSpec, OpKind, OpSpec, TxScope,
};

#[test]
fn kernel_parity_snapshot_covers_routes_opviews_phases_packed_and_docs() {
    let mut app = AppSpec {
        name: "phase4-demo".to_string(),
        ..AppSpec::default()
    };
    app.bindings.push(BindingSpec {
        alias: "create_widget".to_string(),
        transport: "rest".to_string(),
        path: Some("/widgets".to_string()),
        op: OpSpec {
            kind: OpKind::Create,
            name: "create".to_string(),
            route: Some("/widgets".to_string()),
            exchange: Exchange::RequestResponse,
            tx_scope: TxScope::ReadWrite,
            subevents: vec![],
        },
        hooks: vec![HookSpec {
            name: "pre".to_string(),
            phase: HookPhase::PreHandler,
            ..HookSpec::default()
        }],
        ..BindingSpec::default()
    });
    app.bindings.push(BindingSpec {
        alias: "events".to_string(),
        transport: "sse".to_string(),
        path: Some("/events".to_string()),
        op: OpSpec {
            kind: OpKind::Subscribe,
            name: "subscribe".to_string(),
            route: Some("/events".to_string()),
            exchange: Exchange::ServerStream,
            tx_scope: TxScope::None,
            subevents: vec!["chunk".to_string()],
        },
        ..BindingSpec::default()
    });

    let plan = KernelCompiler.compile(&app);
    let snapshot = build_parity_snapshot(&app, &plan);

    assert_eq!(snapshot.app_name, "phase4-demo");
    assert_eq!(snapshot.routes.len(), 2);
    assert_eq!(snapshot.opviews[0].hook_count, 1);
    assert_eq!(
        snapshot.phase_plans.get("create_widget").unwrap(),
        &vec![
            "INGRESS_BEGIN",
            "INGRESS_DISPATCH",
            "START_TX",
            "PRE_HANDLER",
            "HANDLER",
            "POST_HANDLER",
            "TX_COMMIT",
            "POST_RESPONSE",
        ]
    );
    assert_eq!(
        snapshot.phase_plans.get("events").unwrap(),
        &vec![
            "INGRESS_BEGIN",
            "INGRESS_DISPATCH",
            "PRE_HANDLER",
            "HANDLER",
            "POST_HANDLER",
            "POST_EMIT",
            "POST_RESPONSE",
        ]
    );
    assert_eq!(snapshot.packed_plan.segments, 3);
    assert_eq!(snapshot.docs.openapi_paths, vec!["/widgets".to_string()]);
    assert_eq!(snapshot.docs.asyncapi_channels, vec!["/events".to_string()]);
}