greentic-types 0.4.60

Shared primitives for Greentic: TenantCtx, InvocationEnvelope, NodeError, ids.
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

use std::collections::BTreeMap;
use std::path::Path;

use greentic_types::{
    ComponentSourceRefV1, FLOW_RESOLVE_SCHEMA_VERSION, FlowResolveV1, NodeResolveV1, ResolveModeV1,
    sidecar_path_for_flow, validate_flow_resolve,
};

fn roundtrip(source: ComponentSourceRefV1) {
    let doc = FlowResolveV1 {
        schema_version: FLOW_RESOLVE_SCHEMA_VERSION,
        flow: "main.ygtc".into(),
        nodes: BTreeMap::from([(
            "node".to_string(),
            NodeResolveV1 {
                source,
                mode: Some(ResolveModeV1::Pinned),
            },
        )]),
    };

    let json = serde_json::to_string_pretty(&doc).expect("serialize");
    let decoded: FlowResolveV1 = serde_json::from_str(&json).expect("deserialize");
    assert_eq!(decoded, doc);
}

#[test]
fn flow_resolve_roundtrip_local() {
    roundtrip(ComponentSourceRefV1::Local {
        path: "components/demo.wasm".into(),
        digest: Some("sha256:deadbeef".into()),
    });
}

#[test]
fn flow_resolve_roundtrip_oci() {
    roundtrip(ComponentSourceRefV1::Oci {
        r#ref: "ghcr.io/greentic/demo/component:1.2.3".into(),
        digest: Some("sha256:deadbeef".into()),
    });
}

#[test]
fn flow_resolve_roundtrip_repo() {
    roundtrip(ComponentSourceRefV1::Repo {
        r#ref: "repo.example.com/greentic/demo/component@1.2.3".into(),
        digest: Some("sha256:deadbeef".into()),
    });
}

#[test]
fn flow_resolve_roundtrip_store() {
    roundtrip(ComponentSourceRefV1::Store {
        r#ref: "store://greentic/demo/component".into(),
        digest: Some("sha256:deadbeef".into()),
        license_hint: Some("team-license".into()),
        meter: Some(true),
    });
}

#[test]
fn flow_resolve_rejects_absolute_local_paths() {
    let doc = FlowResolveV1 {
        schema_version: FLOW_RESOLVE_SCHEMA_VERSION,
        flow: "main.ygtc".into(),
        nodes: BTreeMap::from([(
            "node".to_string(),
            NodeResolveV1 {
                source: ComponentSourceRefV1::Local {
                    path: "/abs/component.wasm".into(),
                    digest: None,
                },
                mode: None,
            },
        )]),
    };

    let err = validate_flow_resolve(&doc).expect_err("should reject absolute path");
    assert_eq!(err.code, greentic_types::ErrorCode::InvalidInput);
}

#[test]
fn sidecar_path_helper_uses_resolve_suffix() {
    let flow_path = Path::new("flows/main.ygtc");
    let sidecar = sidecar_path_for_flow(flow_path);
    assert_eq!(sidecar, Path::new("flows/main.ygtc.resolve.json"));
}