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

use super::apply::{
    ApplyChangesReport, apply_edge_changes, apply_graph_changes, apply_node_changes,
};
use super::changes::{EdgeChange, NodeChange, NodeGraphChanges, NodeGraphPatch};
use super::projection::XyFlowCommitProjection;
use jellyflow_core::core::Graph;

/// XyFlow-style controlled graph state for adapter-owned node/edge arrays.
#[derive(Debug, Clone)]
pub struct ControlledGraph {
    graph: Graph,
}

impl ControlledGraph {
    pub fn new(graph: Graph) -> Self {
        Self { graph }
    }

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

    pub fn graph_mut(&mut self) -> &mut Graph {
        &mut self.graph
    }

    pub fn into_graph(self) -> Graph {
        self.graph
    }

    pub fn apply_changes(&mut self, changes: &NodeGraphChanges) -> ApplyChangesReport {
        apply_graph_changes(&mut self.graph, changes)
    }

    pub fn apply_patch_changes(&mut self, patch: &NodeGraphPatch) -> ApplyChangesReport {
        let projection = XyFlowCommitProjection::from_patch(patch);
        self.apply_changes(projection.node_edge_changes())
    }

    pub fn apply_node_changes(&mut self, changes: &[NodeChange]) -> ApplyChangesReport {
        apply_node_changes(&mut self.graph, changes)
    }

    pub fn apply_edge_changes(&mut self, changes: &[EdgeChange]) -> ApplyChangesReport {
        apply_edge_changes(&mut self.graph, changes)
    }
}