jellyflow-runtime 0.3.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
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112

use jellyflow_core::{
    CanvasPoint, CanvasSize, Edge, EdgeId, EdgeKind, Graph, GraphBuilder, GraphId, GraphOp,
    GraphTransaction, Node, NodeId, NodeKindKey, Port, PortCapacity, PortDirection, PortId,
    PortKey, PortKind,
};
use jellyflow_runtime::NodeGraphStore;
use jellyflow_runtime::io::{NodeGraphEditorConfig, NodeGraphViewState};
use jellyflow_runtime::runtime::layout::{LayoutRequest, LayoutScope};

fn make_node(kind: &str, x: f32, ports: Vec<PortId>) -> Node {
    Node {
        kind: NodeKindKey::new(kind),
        kind_version: 1,
        pos: CanvasPoint { x, y: 0.0 },
        origin: None,
        selectable: None,
        focusable: None,
        draggable: None,
        connectable: None,
        deletable: None,
        parent: None,
        extent: None,
        expand_parent: None,
        size: Some(CanvasSize {
            width: 160.0,
            height: 72.0,
        }),
        hidden: false,
        collapsed: false,
        ports,
        data: serde_json::json!({ "label": kind }),
    }
}

fn make_port(node: NodeId, key: &str, dir: PortDirection) -> Port {
    Port {
        node,
        key: PortKey::new(key),
        dir,
        kind: PortKind::Data,
        capacity: PortCapacity::Multi,
        connectable: None,
        connectable_start: None,
        connectable_end: None,
        ty: None,
        data: serde_json::Value::Null,
    }
}

fn make_graph() -> (Graph, NodeId, NodeId, NodeId, PortId, PortId) {
    let source = NodeId::from_u128(2);
    let target = NodeId::from_u128(3);
    let unrelated = NodeId::from_u128(4);
    let source_port = PortId::from_u128(10);
    let target_port = PortId::from_u128(11);

    let mut graph = GraphBuilder::new(GraphId::from_u128(1));
    graph.insert_node(source, make_node("demo.source", 0.0, vec![source_port]));
    graph.insert_node(target, make_node("demo.target", 320.0, vec![target_port]));
    graph.insert_node(unrelated, make_node("demo.unrelated", 640.0, Vec::new()));
    graph.insert_port(source_port, make_port(source, "out", PortDirection::Out));
    graph.insert_port(target_port, make_port(target, "in", PortDirection::In));

    (
        graph.build_unchecked(),
        source,
        target,
        unrelated,
        source_port,
        target_port,
    )
}

fn main() -> Result<(), Box<dyn std::error::Error>> {
    let (graph, source, target, unrelated, source_port, target_port) = make_graph();
    let mut store = NodeGraphStore::new(
        graph,
        NodeGraphViewState::default(),
        NodeGraphEditorConfig::default(),
    );

    let edge = EdgeId::from_u128(20);
    let tx = GraphTransaction::from_ops([GraphOp::AddEdge {
        id: edge,
        edge: Edge::new(EdgeKind::Data, source_port, target_port),
    }])
    .with_label("connect source to target");

    let outcome = store.dispatch_transaction(&tx)?;
    let request =
        LayoutRequest::all().with_dirty_scope_from_footprint(store.graph(), outcome.footprint());

    let Some(nodes) = request.scope.nodes() else {
        panic!("dirty scope should be node-limited");
    };
    assert!(nodes.contains(&source));
    assert!(nodes.contains(&target));
    assert!(!nodes.contains(&unrelated));

    let layout_tx = store.dugong_layout_transaction(&request)?;
    assert!(layout_tx.ops().len() <= 2);

    if let LayoutScope::Nodes { nodes } = request.scope {
        println!(
            "dirty layout scope contains {} node(s); planned {} move op(s)",
            nodes.len(),
            layout_tx.ops().len()
        );
    }

    Ok(())
}