cal_core/device/
message_plugin.rs

1use crate::device::device::Connector;
2use crate::{ConnectState, FlowState};
3use serde::{Deserialize, Serialize};
4use std::fmt::{Debug, Formatter};
5
6#[derive(Serialize, Deserialize, Clone)]
7#[serde(rename_all = "camelCase")]
8pub struct MessagePlugin {
9    #[serde(default = "crate::device::shared::build_connect_to")]
10    pub connect_to: String,
11}
12
13impl Connector for MessagePlugin {
14    fn get_connect_to(&mut self, _state: &mut FlowState) -> ConnectState {
15        ConnectState::default(&self.connect_to, None)
16    }
17}
18
19impl Debug for MessagePlugin {
20    fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
21        f.debug_struct("MessagePlugin")
22            .field("connect_to", &self.connect_to)
23            .finish()
24    }
25}