diff --git a/src/mqtt.rs b/src/mqtt.rs index 2ebedc2..c015621 100644 --- a/src/mqtt.rs +++ b/src/mqtt.rs @@ -13,7 +13,6 @@ use rumqttc::v5::mqttbytes::v5::{ConnectReturnCode, LastWill, Publish}; use rumqttc::v5::{mqttbytes::QoS, AsyncClient, Event, Incoming, MqttOptions}; use rumqttc::Transport; use rustls_pki_types::{CertificateDer, PrivateKeyDer}; -use serde::Serialize; use tokio::sync::mpsc; use tokio::time::sleep; @@ -23,24 +22,6 @@ use crate::config::Configuration; static STATE: OnceCell> = OnceCell::new(); -#[derive(Serialize)] -struct CommandTopicContext { - pub gateway_id: String, - pub command: String, -} - -#[derive(Serialize)] -struct EventTopicContext { - pub gateway_id: String, - pub event: String, -} - -#[derive(Serialize)] -struct StateTopciContext { - pub gateway_id: String, - pub state: String, -} - struct State { client: AsyncClient, qos: QoS,