jellyflow-core 0.2.0

Headless graph model, IDs, type descriptors, and interaction policy primitives 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

use crate::core::{Binding, BindingId, Graph};
use crate::ops::GraphOp;

use super::ApplyError;

pub(super) fn apply_binding_op(graph: &mut Graph, op: &GraphOp) -> Result<(), ApplyError> {
    match op {
        GraphOp::AddBinding { id, binding } => apply_add_binding(graph, *id, binding)?,
        GraphOp::RemoveBinding { id, binding } => remove_binding_exact(graph, *id, binding)?,
        GraphOp::SetBindingSubject { id, to, .. } => {
            binding_mut(graph, *id)?.subject = to.clone();
        }
        GraphOp::SetBindingTarget { id, to, .. } => {
            binding_mut(graph, *id)?.target = to.clone();
        }
        GraphOp::SetBindingKind { id, to, .. } => {
            binding_mut(graph, *id)?.kind = to.clone();
        }
        GraphOp::SetBindingMeta { id, to, .. } => {
            binding_mut(graph, *id)?.meta = to.clone();
        }
        _ => unreachable!("non-binding op routed to binding apply"),
    }
    Ok(())
}

pub(super) fn remove_binding_exact(
    graph: &mut Graph,
    id: BindingId,
    expected: &Binding,
) -> Result<(), ApplyError> {
    let Some(current) = graph.bindings.get(&id) else {
        return Err(ApplyError::MissingBinding { id });
    };
    if current != expected {
        return Err(ApplyError::RemoveBindingMismatch { id });
    }
    graph.bindings.remove(&id);
    Ok(())
}

fn apply_add_binding(
    graph: &mut Graph,
    id: BindingId,
    binding: &Binding,
) -> Result<(), ApplyError> {
    if graph.bindings.contains_key(&id) {
        return Err(ApplyError::BindingAlreadyExists { id });
    }
    graph.bindings.insert(id, binding.clone());
    Ok(())
}

fn binding_mut(graph: &mut Graph, id: BindingId) -> Result<&mut Binding, ApplyError> {
    graph
        .bindings
        .get_mut(&id)
        .ok_or(ApplyError::MissingBinding { id })
}