store

Cargo.toml

@@ -5,21 +5,23 @@ edition = "2021"
 
 [features]
 default = []
-socket = ["rmp", "rmp-serde", "bytes", "flate2", "event"]
+socket = ["rmp", "rmp-serde", "bytes", "flate2"]
 paidui = []
 login = []
-event = []
 
 [dependencies]
 anyhow = { version = "1", features = ["std"], default-features = false }
-serde_json = { version = "1", default-features = false }
+serde_json = { version = "1", features = ["std"], default-features = false }
 serde_repr = { version = "0.1", default-features = false }
 serde = { version = "1", features = ["derive"], default-features = false }
 chrono = "0.4"
 chrono-tz = "0.9.0"
 tracing = { version = "0.1", default-features = false }
+rs-snowflake = { version = "0.6", default-features = false }
+uuid = { version = "1", features = ["v4"], default-features = false }
+once_cell = { version = "1", features = ["std"], default-features = false }
 
-bytes = { version = "1", default-features = false, optional = true }
+bytes = { version = "1", features = ["std"], default-features = false, optional = true }
 rmp = { version = "0.8", default-features = false, optional = true }
 rmp-serde = { version = "1", default-features = false, optional = true }
 flate2 = { version = "1", features = ["rust_backend"], default-features = false, optional = true }

src/lib.rs

-#[cfg(feature = "event")]
 pub mod event;
 pub mod id;
 #[cfg(feature = "login")]

src/serde/mod.rs

-use anyhow::Result;
 use serde::Deserialize;
 use serde_json::Value;
 

src/socket/protocol/mod.rs

@@ -5,14 +5,15 @@ use crate::socket::protocol::{
         connect::ConnectHeader, message_id::MessageIdHeader, pub_ack::PubAckHeader, VariableHeader,
     },
 };
+use crate::id;
 use anyhow::{anyhow, Result};
 use bytes::Buf;
 use payload::{disconnect::DisConnectPayload, sub_ack::SubAckPayload};
 use rmp::encode::RmpWrite;
 use serde::{Deserialize, Serialize};
 use serde_repr::{Deserialize_repr, Serialize_repr};
-use tracing::error;
 use std::{io::Read, mem::ManuallyDrop, ptr};
+use tracing::error;
 use variable::{conn_ack::ConnAckHeader, disconnect::DisconnectHeader, publish::PublishHeader};
 
 pub mod fixed;
@@ -45,7 +46,7 @@ impl Protocol {
         let payload = ConnectPayload::new(device_id, username, password, client_type);
 
         Ok(Self {
-            trace_id: crate::id::uuid(),
+            trace_id: id::uuid(),
             fixed,
             variable: Self::create_variable(variable)?,
             payload: Self::create_payload(Some(payload))?,