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
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

use serde::{Deserialize, Serialize};

use crate::runtime::connection::{
    ConnectEdgeRequest, ConnectionTargetCandidate, ConnectionTargetFromHandlesInput,
    ConnectionTargetInput, ReconnectEdgeRequest, ResolvedConnectionTarget,
};
use crate::runtime::events::ConnectStart;
use jellyflow_core::core::CanvasPoint;
use jellyflow_core::interaction::NodeGraphConnectionMode;

use super::ConformanceAction;

pub(super) fn kind(action: &ConformanceAction) -> Option<&'static str> {
    Some(match action {
        ConformanceAction::AssertConnectionTarget { .. } => "assert_connection_target",
        ConformanceAction::AssertConnectionTargetFromHandles { .. } => {
            "assert_connection_target_from_handles"
        }
        ConformanceAction::ApplyConnectEdge { .. } => "apply_connect_edge",
        ConformanceAction::ApplyConnectEdgeSession { .. } => "apply_connect_edge_session",
        ConformanceAction::ApplyReconnectEdge { .. } => "apply_reconnect_edge",
        _ => return None,
    })
}

#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
pub struct ConformanceConnectionTargetFromHandlesInput {
    pub pointer: CanvasPoint,
    pub radius: f32,
    pub from: crate::runtime::connection::ConnectionHandleRef,
    pub candidates: Vec<ConnectionTargetCandidate>,
    pub mode: NodeGraphConnectionMode,
    #[serde(default = "default_connection_validity")]
    pub is_valid_connection: bool,
}

impl ConformanceConnectionTargetFromHandlesInput {
    pub(crate) fn as_runtime(&self) -> ConnectionTargetFromHandlesInput<'_> {
        ConnectionTargetFromHandlesInput::new(
            self.pointer,
            self.radius,
            self.from,
            &self.candidates,
            self.mode,
        )
        .with_connection_validity(self.is_valid_connection)
    }

    fn from_runtime(input: ConnectionTargetFromHandlesInput<'_>) -> Self {
        Self {
            pointer: input.pointer,
            radius: input.radius,
            from: input.from,
            candidates: input.candidates.to_vec(),
            mode: input.mode,
            is_valid_connection: input.is_valid_connection,
        }
    }
}

fn default_connection_validity() -> bool {
    true
}

impl ConformanceAction {
    pub fn assert_connection_target(
        input: ConnectionTargetInput,
        expected: ResolvedConnectionTarget,
    ) -> Self {
        Self::AssertConnectionTarget { input, expected }
    }

    pub fn assert_connection_target_from_handles(
        input: ConnectionTargetFromHandlesInput<'_>,
        expected: ResolvedConnectionTarget,
    ) -> Self {
        Self::AssertConnectionTargetFromHandles {
            input: ConformanceConnectionTargetFromHandlesInput::from_runtime(input),
            expected,
        }
    }

    pub fn apply_connect_edge(request: ConnectEdgeRequest) -> Self {
        Self::ApplyConnectEdge { request }
    }

    pub fn apply_connect_edge_session(start: ConnectStart, request: ConnectEdgeRequest) -> Self {
        Self::ApplyConnectEdgeSession { start, request }
    }

    pub fn apply_reconnect_edge(request: ReconnectEdgeRequest) -> Self {
        Self::ApplyReconnectEdge { request }
    }
}