jellyflow-runtime 0.2.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

use crate::runtime::xyflow::changes::{EdgeChange, NodeGraphChanges};
use crate::runtime::xyflow::dialect::edge_update_change_from_op;
use jellyflow_core::core::{Edge, EdgeId};
use jellyflow_core::ops::GraphOp;

pub(super) fn try_push_edge_change(op: &GraphOp, out: &mut NodeGraphChanges) -> bool {
    match op {
        GraphOp::RemovePort { edges, .. } => {
            push_removed_edge_changes(edges, out);
        }
        GraphOp::AddEdge { id, edge } => {
            out.push_edge(EdgeChange::Add {
                id: *id,
                edge: edge.clone(),
            });
        }
        GraphOp::RemoveEdge { id, .. } => push_edge_remove(*id, out),
        _ => {
            let Some(change) = edge_update_change_from_op(op) else {
                return false;
            };
            out.push_edge(change);
        }
    }
    true
}

pub(super) fn push_removed_edge_changes(edges: &[(EdgeId, Edge)], out: &mut NodeGraphChanges) {
    for (id, _edge) in edges {
        push_edge_remove(*id, out);
    }
}

fn push_edge_remove(id: EdgeId, out: &mut NodeGraphChanges) {
    if has_pending_edge_remove_since_last_add(out.edges(), id) {
        return;
    }
    out.push_edge(EdgeChange::Remove { id });
}

fn has_pending_edge_remove_since_last_add(changes: &[EdgeChange], id: EdgeId) -> bool {
    let mut removed = false;
    for change in changes {
        match change {
            EdgeChange::Add { id: added, .. } if *added == id => removed = false,
            EdgeChange::Remove { id: removed_id } if *removed_id == id => removed = true,
            _ => {}
        }
    }
    removed
}