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

//! Store helpers for XyFlow-style change arrays.

use crate::runtime::store::{DispatchError, DispatchOutcome, NodeGraphStore};
use crate::runtime::xyflow::changes::{ChangesToTransactionError, NodeGraphChanges};

#[derive(Debug, thiserror::Error)]
pub enum DispatchChangesError {
    #[error(transparent)]
    Changes(#[from] ChangesToTransactionError),
    #[error(transparent)]
    Dispatch(#[from] DispatchError),
}

impl NodeGraphStore {
    /// Applies XyFlow-style changes by converting them to a reversible transaction.
    pub fn dispatch_changes(
        &mut self,
        changes: &NodeGraphChanges,
    ) -> Result<DispatchOutcome, DispatchChangesError> {
        let tx = changes.to_transaction(self.graph())?;
        Ok(self.dispatch_transaction(&tx)?)
    }
}