jellyflow-runtime 0.1.0

Headless store, rules, schema, profile, and change pipeline for Jellyflow.
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

use super::fixtures::{insert_node, insert_typed_data_input, insert_typed_data_output};

use crate::rules::plan_connect_typed;
use jellyflow_core::core::{Graph, NodeId, PortCapacity, PortId};
use jellyflow_core::types::{DefaultTypeCompatibility, TypeDesc};

#[test]
fn plan_connect_typed_rejects_incompatible_data_types() {
    let mut graph = Graph::default();

    let a = NodeId::new();
    let b = NodeId::new();
    insert_node(&mut graph, a, "core.a");
    insert_node(&mut graph, b, "core.b");

    let out = PortId::new();
    let inn = PortId::new();
    insert_typed_data_output(
        &mut graph,
        out,
        a,
        "out",
        PortCapacity::Multi,
        TypeDesc::Int,
    );
    insert_typed_data_input(
        &mut graph,
        inn,
        b,
        "in",
        PortCapacity::Single,
        TypeDesc::String,
    );

    let mut compat = DefaultTypeCompatibility::default();
    let plan = plan_connect_typed(
        &graph,
        out,
        inn,
        |g, p| g.ports.get(&p).and_then(|p| p.ty.clone()),
        &mut compat,
    );
    assert!(plan.is_reject());
    assert!(plan.ops().is_empty());
}

#[test]
fn plan_connect_typed_accepts_int_to_float() {
    let mut graph = Graph::default();

    let a = NodeId::new();
    let b = NodeId::new();
    insert_node(&mut graph, a, "core.a");
    insert_node(&mut graph, b, "core.b");

    let out = PortId::new();
    let inn = PortId::new();
    insert_typed_data_output(
        &mut graph,
        out,
        a,
        "out",
        PortCapacity::Multi,
        TypeDesc::Int,
    );
    insert_typed_data_input(
        &mut graph,
        inn,
        b,
        "in",
        PortCapacity::Single,
        TypeDesc::Float,
    );

    let mut compat = DefaultTypeCompatibility::default();
    let plan = plan_connect_typed(
        &graph,
        out,
        inn,
        |g, p| g.ports.get(&p).and_then(|p| p.ty.clone()),
        &mut compat,
    );
    assert!(plan.is_accept());
    assert!(!plan.ops().is_empty());
}