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
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96

//! Store event publication internals.

use crate::io::{NodeGraphEditorConfig, NodeGraphViewState};
use crate::runtime::commit::NodeGraphPatch;
use crate::runtime::events::{
    NodeGraphDocumentSnapshot, NodeGraphGestureEvent, NodeGraphStoreEvent, ViewChange,
};
use jellyflow_core::core::Graph;

use super::NodeGraphStore;

pub(super) struct DocumentSnapshotParts {
    graph: Graph,
    graph_revision: u64,
    view_state: NodeGraphViewState,
    editor_config: NodeGraphEditorConfig,
}

impl DocumentSnapshotParts {
    fn from_store(store: &NodeGraphStore) -> Self {
        Self {
            graph: store.graph.clone(),
            graph_revision: store.graph_revision,
            view_state: store.view_state.clone(),
            editor_config: store.editor_config(),
        }
    }

    fn event_snapshot(&self) -> NodeGraphDocumentSnapshot<'_> {
        NodeGraphDocumentSnapshot {
            graph: &self.graph,
            graph_revision: self.graph_revision,
            view_state: &self.view_state,
            editor_config: &self.editor_config,
        }
    }
}

impl NodeGraphStore {
    pub(super) fn bump_graph_revision(&mut self) {
        self.graph_revision = self.graph_revision.saturating_add(1);
    }

    pub(super) fn bump_layout_facts_revision(&mut self) {
        self.layout_facts_revision = self.layout_facts_revision.saturating_add(1);
    }

    pub(crate) fn publish_layout_facts_changed(&mut self) {
        self.bump_layout_facts_revision();
        self.notify_selectors();
    }

    pub(super) fn capture_document_snapshot(&self) -> DocumentSnapshotParts {
        DocumentSnapshotParts::from_store(self)
    }

    pub(super) fn publish_document_replaced(&mut self, before: DocumentSnapshotParts) {
        let after = self.capture_document_snapshot();

        self.emit(NodeGraphStoreEvent::DocumentReplaced {
            before: before.event_snapshot(),
            after: after.event_snapshot(),
        });
        self.notify_selectors();
    }

    pub(super) fn publish_graph_commit(&mut self, patch: &NodeGraphPatch) {
        self.emit(NodeGraphStoreEvent::GraphCommitted { patch });
        self.notify_selectors();
    }

    pub(super) fn publish_view_changed(
        &mut self,
        before: &NodeGraphViewState,
        after: &NodeGraphViewState,
        changes: &[ViewChange],
    ) {
        if !changes.is_empty() {
            self.emit(NodeGraphStoreEvent::ViewChanged {
                before,
                after,
                changes,
            });
        }
        self.notify_selectors();
    }

    pub(super) fn emit(&mut self, event: NodeGraphStoreEvent<'_>) {
        self.subscriptions.emit_event(event);
    }

    /// Emits a transient gesture event for adapter layers that own pointer/keyboard gestures.
    pub fn emit_gesture(&mut self, event: NodeGraphGestureEvent) {
        self.subscriptions.emit_gesture(event);
    }
}