logic-mesh 1.0.0

Control logic engine using event based and reactive blocks written in Rust.
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
152

// Copyright (c) 2022-2023, Radu Racariu.

use libhaystack::val::Value;
use serde::{Deserialize, Serialize};

use crate::base::{
    block::{BlockDesc, BlockPin, desc::BlockImplementation},
    engine::messages::{ChangeSource, WatchMessage},
};

/// Block field properties, inputs or output
#[derive(Default, Clone, Serialize, Deserialize)]
pub struct JsBlockPin {
    pub name: String,
    pub kind: String,
}

/// Block description as a simple struct
#[derive(Default, Clone, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct JsBlockDesc {
    pub name: String,
    pub dis: String,
    pub lib: String,
    pub ver: String,
    pub category: String,
    pub doc: String,
    pub implementation: String,
    pub inputs: Vec<JsBlockPin>,
    pub outputs: Vec<JsBlockPin>,
    pub run_condition: Option<String>,
}

impl From<JsBlockDesc> for BlockDesc {
    fn from(desc: JsBlockDesc) -> Self {
        Self {
            name: desc.name,
            dis: desc.dis,
            library: desc.lib,
            ver: desc.ver,
            category: desc.category,
            doc: desc.doc,
            implementation: BlockImplementation::External,

            inputs: desc
                .inputs
                .into_iter()
                .map(|pin| BlockPin {
                    name: pin.name,
                    kind: pin.kind.as_str().try_into().unwrap_or_default(),
                })
                .collect(),

            outputs: desc
                .outputs
                .into_iter()
                .map(|pin| BlockPin {
                    name: pin.name,
                    kind: pin.kind.as_str().try_into().unwrap_or_default(),
                })
                .collect(),

            run_condition: desc
                .run_condition
                .map(|cond| cond.as_str().try_into().unwrap_or_default()),
        }
    }
}

impl From<BlockDesc> for JsBlockDesc {
    fn from(desc: BlockDesc) -> Self {
        Self {
            name: desc.name,
            dis: desc.dis,
            lib: desc.library,
            ver: desc.ver,
            category: desc.category,
            doc: desc.doc,
            implementation: desc.implementation.to_string(),

            inputs: desc
                .inputs
                .into_iter()
                .map(|pin| JsBlockPin {
                    name: pin.name,
                    kind: pin.kind.to_string(),
                })
                .collect(),

            outputs: desc
                .outputs
                .into_iter()
                .map(|pin| JsBlockPin {
                    name: pin.name,
                    kind: pin.kind.to_string(),
                })
                .collect(),

            run_condition: desc.run_condition.map(|cond| cond.to_string()),
        }
    }
}

#[derive(Default, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct JsWatchNotification {
    pub id: String,
    pub changes: Vec<JsWatchChange>,
    /// Block's operational state at the time of the notification
    /// (`running | fault | disabled | terminated`).
    pub state: String,
    /// Fault reason when `state == "fault"`, else `None`.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub fault_reason: Option<String>,
}

#[derive(Default, Serialize, Deserialize)]
pub struct JsWatchChange {
    pub name: String,
    pub source: String,
    pub value: Value,
}

impl From<WatchMessage> for JsWatchNotification {
    fn from(msg: WatchMessage) -> Self {
        let block_id = msg.block_id.to_string();
        let state = msg.state.label().to_string();
        let fault_reason = msg.state.fault_reason().map(|s| s.to_string());
        let changes = msg
            .changes
            .into_iter()
            .map(|(name, source)| JsWatchChange {
                name,
                source: match source {
                    ChangeSource::Input(_, _) => "input".to_string(),
                    ChangeSource::Output(_, _) => "output".to_string(),
                },
                value: match source {
                    ChangeSource::Input(_, v) => v,
                    ChangeSource::Output(_, v) => v,
                },
            })
            .collect();

        Self {
            id: block_id,
            changes,
            state,
            fault_reason,
        }
    }
}