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

use crate::runtime::xyflow::changes::{NodeChange, NodeGraphChanges};
use crate::runtime::xyflow::dialect::node_update_change_from_op;
use jellyflow_core::ops::GraphOp;

use super::edges::push_removed_edge_changes;

pub(super) fn try_push_node_change(op: &GraphOp, out: &mut NodeGraphChanges) -> bool {
    match op {
        GraphOp::AddNode { id, node } => {
            out.push_node(NodeChange::Add {
                id: *id,
                node: node.clone(),
            });
        }
        GraphOp::RemoveNode { id, edges, .. } => {
            out.push_node(NodeChange::Remove { id: *id });
            push_removed_edge_changes(edges, out);
        }
        GraphOp::RemoveGroup { detached, .. } => {
            for (node_id, _previous_parent) in detached {
                out.push_node(NodeChange::Parent {
                    id: *node_id,
                    parent: None,
                });
            }
        }
        _ => {
            let Some(change) = node_update_change_from_op(op) else {
                return false;
            };
            out.push_node(change);
        }
    }
    true
}