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

use crate::runtime::xyflow::callbacks::DeleteChange;
use jellyflow_core::ops::GraphOp;

use super::removed_edges::visit_removed_edges;

#[derive(Default)]
pub(super) struct DeleteChangeAccumulator {
    change: DeleteChange,
}

impl DeleteChangeAccumulator {
    pub(super) fn push_op(&mut self, op: &GraphOp) {
        match op {
            GraphOp::RemoveNode { id, .. } => {
                self.change.push_node(*id);
                self.push_deleted_edges(op);
            }
            GraphOp::RemoveEdge { .. } | GraphOp::RemovePort { .. } => {
                self.push_deleted_edges(op);
            }
            GraphOp::RemoveGroup { id, .. } => self.change.push_group(*id),
            GraphOp::RemoveStickyNote { id, .. } => self.change.push_sticky_note(*id),
            _ => {}
        }
    }

    fn push_deleted_edges(&mut self, op: &GraphOp) {
        visit_removed_edges(op, |id, _edge| {
            self.change.push_edge(id);
        });
    }

    pub(super) fn finish(mut self) -> DeleteChange {
        self.change.sort_dedup();
        self.change
    }
}