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
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70

use crate::io::{NodeGraphEditorConfig, NodeGraphViewState};
use crate::runtime::lookups::NodeGraphLookups;
use jellyflow_core::core::Graph;
use jellyflow_core::ops::GraphHistory;

use super::super::NodeGraphStore;

impl NodeGraphStore {
    pub fn graph(&self) -> &Graph {
        &self.graph
    }

    pub fn graph_revision(&self) -> u64 {
        self.graph_revision
    }

    pub fn layout_facts_revision(&self) -> u64 {
        self.layout_facts_revision
    }

    pub fn lookups(&self) -> &NodeGraphLookups {
        &self.lookups
    }

    pub(crate) fn lookups_mut(&mut self) -> &mut NodeGraphLookups {
        &mut self.lookups
    }

    /// Replaces the entire graph document.
    ///
    /// This is a controlled-mode helper: callers that own graph state can swap the document
    /// without going through transactions (e.g. loading a file, switching tabs).
    ///
    /// This emits a document replacement event, not a graph commit. Selection is sanitized against
    /// the new graph.
    pub fn replace_graph(&mut self, graph: Graph) {
        let before = self.capture_document_snapshot();

        self.graph = graph;
        self.bump_graph_revision();
        self.view_state.sanitize_for_graph(&self.graph);
        self.lookups.rebuild_from(&self.graph);
        self.bump_layout_facts_revision();
        self.publish_document_replaced(before);
    }

    /// Replaces the entire document snapshot in one atomic store update.
    ///
    /// This is the full document reset path: graph, view state, editor config, lookups, revision,
    /// and undo/redo history are updated together, then one `DocumentReplaced` event is emitted.
    pub fn replace_document(
        &mut self,
        graph: Graph,
        mut view_state: NodeGraphViewState,
        editor_config: NodeGraphEditorConfig,
    ) {
        let before = self.capture_document_snapshot();

        view_state.sanitize_for_graph(&graph);
        self.graph = graph;
        self.bump_graph_revision();
        self.view_state = view_state;
        self.interaction = editor_config.interaction;
        self.runtime_tuning = editor_config.runtime_tuning;
        self.history = GraphHistory::default();
        self.lookups.rebuild_from(&self.graph);
        self.bump_layout_facts_revision();
        self.publish_document_replaced(before);
    }
}