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

mod connection;
mod delete;

use super::super::traits::NodeGraphCallbacks;
use crate::runtime::commit::NodeGraphPatch;
use crate::runtime::xyflow::projection::XyFlowCommitProjection;

pub(super) fn dispatch_graph_commit_callbacks(
    callbacks: &mut dyn NodeGraphCallbacks,
    patch: &NodeGraphPatch,
) {
    let projection = XyFlowCommitProjection::from_patch(patch);
    let node_edge_changes = projection.node_edge_changes();
    callbacks.on_graph_commit(patch);
    callbacks.on_node_edge_changes(node_edge_changes);
    if !node_edge_changes.nodes().is_empty() {
        callbacks.on_nodes_change(node_edge_changes.nodes());
    }
    if !node_edge_changes.edges().is_empty() {
        callbacks.on_edges_change(node_edge_changes.edges());
    }

    connection::dispatch_connection_callbacks(callbacks, projection.connection_changes());
    delete::dispatch_delete_callbacks(callbacks, projection.delete_change());
}