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
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

use jellyflow_core::core::{Node, NodeId, NodeKindKey};
use jellyflow_core::ops::{GraphOp, GraphTransaction};
use serde_json::Value;

pub(super) struct NodeKindTxWriter {
    tx: GraphTransaction,
}

impl NodeKindTxWriter {
    pub(super) fn new(label: &str) -> Self {
        Self {
            tx: GraphTransaction::new().with_label(label),
        }
    }

    pub(super) fn rewrite_node_kind(
        &mut self,
        id: NodeId,
        node: &Node,
        canonical: &NodeKindKey,
    ) -> bool {
        if canonical == &node.kind {
            return false;
        }

        self.tx.push(GraphOp::SetNodeKind {
            id,
            from: node.kind.clone(),
            to: canonical.clone(),
        });
        true
    }

    pub(super) fn update_node_data(&mut self, id: NodeId, node: &Node, new_data: Value) {
        if node.data == new_data {
            return;
        }

        self.tx.push(GraphOp::SetNodeData {
            id,
            from: node.data.clone(),
            to: new_data,
        });
    }

    pub(super) fn update_node_kind_version(
        &mut self,
        id: NodeId,
        node: &Node,
        latest_kind_version: u32,
    ) {
        self.tx.push(GraphOp::SetNodeKindVersion {
            id,
            from: node.kind_version,
            to: latest_kind_version,
        });
    }

    pub(super) fn into_tx(self) -> GraphTransaction {
        self.tx
    }
}