greentic-flow-dev 1.1.27665160846

Generic YGTC flow schema/loader/IR for self-describing component nodes.
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

use greentic_flow::contracts;
use greentic_types::schemas::common::schema_ir::{AdditionalProperties, SchemaIr};
use greentic_types::schemas::component::v0_6_0::{
    ComponentDescribe, ComponentInfo, ComponentOperation, ComponentRunInput, ComponentRunOutput,
    schema_hash,
};
use std::collections::BTreeMap;

#[test]
fn recompute_schema_hash_matches() {
    let config_schema = SchemaIr::Object {
        properties: BTreeMap::new(),
        required: Vec::new(),
        additional: AdditionalProperties::Allow,
    };
    let op_schema = SchemaIr::Object {
        properties: BTreeMap::new(),
        required: Vec::new(),
        additional: AdditionalProperties::Allow,
    };
    let expected = schema_hash(&op_schema, &op_schema, &config_schema).unwrap();
    let op = ComponentOperation {
        id: "run".to_string(),
        display_name: None,
        input: ComponentRunInput {
            schema: op_schema.clone(),
        },
        output: ComponentRunOutput { schema: op_schema },
        defaults: BTreeMap::new(),
        redactions: Vec::new(),
        constraints: BTreeMap::new(),
        schema_hash: expected.clone(),
    };
    let recomputed = contracts::recompute_schema_hash(&op, &config_schema).unwrap();
    assert_eq!(recomputed, expected);
}

#[test]
fn describe_hash_is_deterministic() {
    let describe = ComponentDescribe {
        info: ComponentInfo {
            id: "acme.widget".to_string(),
            version: "0.1.0".to_string(),
            role: "tool".to_string(),
            display_name: None,
        },
        provided_capabilities: Vec::new(),
        required_capabilities: Vec::new(),
        metadata: BTreeMap::new(),
        operations: Vec::new(),
        config_schema: SchemaIr::Object {
            properties: BTreeMap::new(),
            required: Vec::new(),
            additional: AdditionalProperties::Allow,
        },
    };
    let hash1 = contracts::describe_hash(&describe).unwrap();
    let hash2 = contracts::describe_hash(&describe).unwrap();
    assert_eq!(hash1, hash2);
}

#[test]
fn decode_component_describe_rejects_empty_payload() {
    let err = contracts::decode_component_describe(&[]).expect_err("empty payload must fail");
    assert!(format!("{err}").contains("empty payload"));
}

#[test]
fn find_operation_reports_missing_operation_id() {
    let describe = ComponentDescribe {
        info: ComponentInfo {
            id: "acme.widget".to_string(),
            version: "0.1.0".to_string(),
            role: "tool".to_string(),
            display_name: None,
        },
        provided_capabilities: Vec::new(),
        required_capabilities: Vec::new(),
        metadata: BTreeMap::new(),
        operations: Vec::new(),
        config_schema: SchemaIr::Object {
            properties: BTreeMap::new(),
            required: Vec::new(),
            additional: AdditionalProperties::Allow,
        },
    };

    let err = contracts::find_operation(&describe, "missing").expect_err("missing op must fail");
    assert!(format!("{err}").contains("operation 'missing' not found"));
}