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

mod edges;
mod nodes;

use crate::runtime::xyflow::changes::NodeGraphChanges;
use jellyflow_core::ops::GraphOp;

#[derive(Debug, Default)]
pub(super) struct NodeGraphChangeAccumulator {
    out: NodeGraphChanges,
}

impl NodeGraphChangeAccumulator {
    pub(super) fn new() -> Self {
        Self::default()
    }

    pub(super) fn push_op(&mut self, op: &GraphOp) {
        push_node_graph_change(op, &mut self.out);
    }

    pub(super) fn finish(self) -> NodeGraphChanges {
        self.out
    }
}

fn push_node_graph_change(op: &GraphOp, out: &mut NodeGraphChanges) {
    if nodes::try_push_node_change(op, out) {
        return;
    }
    edges::try_push_edge_change(op, out);
}