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
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151

use serde::{Deserialize, Serialize};

use crate::runtime::connection::{ConnectionHandleRef, ResolvedConnectionTarget};
use crate::runtime::geometry::{EdgePosition, HandlePosition};
use crate::runtime::measurement::NodeMeasurement;
use jellyflow_core::core::{CanvasPoint, CanvasSize, EdgeId, NodeId};

use super::ConformanceAction;

pub(super) fn kind(action: &ConformanceAction) -> Option<&'static str> {
    Some(match action {
        ConformanceAction::ReportNodeMeasurement { .. } => "report_node_measurement",
        ConformanceAction::AssertLayoutFacts { .. } => "assert_layout_facts",
        _ => return None,
    })
}

#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
pub struct ConformanceLayoutFactsExpectation {
    #[serde(default, skip_serializing_if = "Vec::is_empty")]
    pub visible_node_ids: Vec<NodeId>,
    #[serde(default, skip_serializing_if = "Vec::is_empty")]
    pub visible_edge_ids: Vec<EdgeId>,
    #[serde(default, skip_serializing_if = "Vec::is_empty")]
    pub edge_positions: Vec<ConformanceLayoutEdgePosition>,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub connection_target: Option<ConformanceLayoutFactsConnectionTargetExpectation>,
}

impl ConformanceLayoutFactsExpectation {
    pub fn new(
        visible_node_ids: impl IntoIterator<Item = NodeId>,
        visible_edge_ids: impl IntoIterator<Item = EdgeId>,
    ) -> Self {
        Self {
            visible_node_ids: visible_node_ids.into_iter().collect(),
            visible_edge_ids: visible_edge_ids.into_iter().collect(),
            edge_positions: Vec::new(),
            connection_target: None,
        }
    }

    pub fn with_edge_positions(
        mut self,
        edge_positions: impl IntoIterator<Item = ConformanceLayoutEdgePosition>,
    ) -> Self {
        self.edge_positions = edge_positions.into_iter().collect();
        self
    }

    pub fn with_connection_target(
        mut self,
        connection_target: ConformanceLayoutFactsConnectionTargetExpectation,
    ) -> Self {
        self.connection_target = Some(connection_target);
        self
    }
}

#[derive(Debug, Clone, Copy, PartialEq, Serialize, Deserialize)]
pub struct ConformanceLayoutEdgePosition {
    pub edge: EdgeId,
    pub source: ConformanceEdgeEndpointPosition,
    pub target: ConformanceEdgeEndpointPosition,
}

impl ConformanceLayoutEdgePosition {
    pub fn new(
        edge: EdgeId,
        source: ConformanceEdgeEndpointPosition,
        target: ConformanceEdgeEndpointPosition,
    ) -> Self {
        Self {
            edge,
            source,
            target,
        }
    }

    pub fn from_edge_position(edge: EdgeId, position: EdgePosition) -> Self {
        Self {
            edge,
            source: ConformanceEdgeEndpointPosition::new(
                position.source.point,
                position.source.position,
            ),
            target: ConformanceEdgeEndpointPosition::new(
                position.target.point,
                position.target.position,
            ),
        }
    }

    pub(crate) fn matches_edge_position(self, position: EdgePosition) -> bool {
        self.source.matches_endpoint(position.source)
            && self.target.matches_endpoint(position.target)
    }
}

#[derive(Debug, Clone, Copy, PartialEq, Serialize, Deserialize)]
pub struct ConformanceEdgeEndpointPosition {
    pub point: CanvasPoint,
    pub position: HandlePosition,
}

impl ConformanceEdgeEndpointPosition {
    pub fn new(point: CanvasPoint, position: HandlePosition) -> Self {
        Self { point, position }
    }

    fn matches_endpoint(self, endpoint: crate::runtime::geometry::EdgeEndpointPosition) -> bool {
        self.point == endpoint.point && self.position == endpoint.position
    }
}

#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
pub struct ConformanceLayoutFactsConnectionTargetExpectation {
    pub pointer: CanvasPoint,
    pub from: ConnectionHandleRef,
    pub expected: ResolvedConnectionTarget,
}

impl ConformanceLayoutFactsConnectionTargetExpectation {
    pub fn new(
        pointer: CanvasPoint,
        from: ConnectionHandleRef,
        expected: ResolvedConnectionTarget,
    ) -> Self {
        Self {
            pointer,
            from,
            expected,
        }
    }
}

impl ConformanceAction {
    pub fn report_node_measurement(measurement: NodeMeasurement) -> Self {
        Self::ReportNodeMeasurement { measurement }
    }

    pub fn assert_layout_facts(
        viewport_size: CanvasSize,
        expected: ConformanceLayoutFactsExpectation,
    ) -> Self {
        Self::AssertLayoutFacts {
            viewport_size,
            expected,
        }
    }
}