chore: clippy suggestions https://github.com/bytebeamio/rumqtt/action…

…s/runs/9028175682/job/24808221311?pr=862
bytebeamio · May 10, 2024 · 47a55b6 · 47a55b6
1 parent dd28353
commit 47a55b6
Show file tree

Hide file tree

Showing 8 changed files with 17 additions and 18 deletions.
diff --git a/rumqttc/Cargo.toml b/rumqttc/Cargo.toml
@@ -23,7 +23,7 @@ websocket = ["dep:async-tungstenite", "dep:ws_stream_tungstenite", "dep:http"]
 proxy = ["dep:async-http-proxy"]
 
 [dependencies]
-futures-util = { version = "0.3", default_features = false, features = ["std", "sink"] }
+futures-util = { version = "0.3", default-features = false, features = ["std", "sink"] }
 tokio = { version = "1.36", features = ["rt", "macros", "io-util", "net", "time"] }
 tokio-util = { version = "0.7", features = ["codec"] }
 bytes = "1.5"

diff --git a/rumqttc/src/state.rs b/rumqttc/src/state.rs
@@ -90,7 +90,7 @@ impl MqttState {
             // index 0 is wasted as 0 is not a valid packet id
             outgoing_pub: vec![None; max_inflight as usize + 1],
             outgoing_rel: vec![None; max_inflight as usize + 1],
-            incoming_pub: vec![None; std::u16::MAX as usize + 1],
+            incoming_pub: vec![None; u16::MAX as usize + 1],
             collision: None,
             // TODO: Optimize these sizes later
             events: VecDeque::with_capacity(100),

diff --git a/rumqttc/src/v5/state.rs b/rumqttc/src/v5/state.rs
@@ -138,7 +138,7 @@ impl MqttState {
             // index 0 is wasted as 0 is not a valid packet id
             outgoing_pub: vec![None; max_inflight as usize + 1],
             outgoing_rel: vec![None; max_inflight as usize + 1],
-            incoming_pub: vec![None; std::u16::MAX as usize + 1],
+            incoming_pub: vec![None; u16::MAX as usize + 1],
             collision: None,
             // TODO: Optimize these sizes later
             events: VecDeque::with_capacity(100),

diff --git a/rumqttd/src/router/alertlog.rs b/rumqttd/src/router/alertlog.rs
@@ -71,14 +71,14 @@ pub mod alert {
 pub use alert::*;
 
 pub struct AlertLog {
-    pub config: RouterConfig,
+    pub _config: RouterConfig,
     pub alerts: VecDeque<Alert>,
 }
 
 impl AlertLog {
-    pub fn new(config: RouterConfig) -> AlertLog {
+    pub fn new(_config: RouterConfig) -> AlertLog {
         AlertLog {
-            config,
+            _config,
             alerts: VecDeque::with_capacity(100),
         }
     }

diff --git a/rumqttd/src/router/mod.rs b/rumqttd/src/router/mod.rs
@@ -212,7 +212,7 @@ pub struct Message {
     /// Log to sweep
     pub topic: String,
     /// Qos of the topic
-    pub qos: u8,
+    pub _qos: u8,
     /// Reply data chain
     pub payload: Bytes,
 }
@@ -250,12 +250,12 @@ impl fmt::Debug for Data {
     }
 }
 
-#[derive(Debug, Clone)]
-pub struct Disconnection {
-    pub id: String,
-    pub execute_will: bool,
-    pub pending: Vec<Notification>,
-}
+// #[derive(Debug, Clone)]
+// pub struct Disconnection {
+//     pub id: String,
+//     pub execute_will: bool,
+//     pub pending: Vec<Notification>,
+// }
 
 #[derive(Debug, Clone)]
 pub struct ShadowRequest {

diff --git a/rumqttd/src/router/routing.rs b/rumqttd/src/router/routing.rs
@@ -322,7 +322,7 @@ impl Router {
                 |session_state| {
                     connection.subscriptions = session_state.subscriptions;
                     // for using in acklog
-                    pending_acks = session_state.unacked_pubrels.clone();
+                    pending_acks.clone_from(&session_state.unacked_pubrels);
                     outgoing.unacked_pubrels = session_state.unacked_pubrels;
                     session_state.tracker
                 },

diff --git a/rumqttd/src/segments/mod.rs b/rumqttd/src/segments/mod.rs
@@ -1,5 +1,4 @@
 use crate::Offset;
-use std::usize;
 use std::{collections::VecDeque, io};
 
 mod segment;

diff --git a/rumqttd/src/server/mod.rs b/rumqttd/src/server/mod.rs
@@ -1,10 +1,10 @@
-use tokio::io::{AsyncRead, AsyncWrite};
+// use tokio::io::{AsyncRead, AsyncWrite};
 
 mod broker;
 #[cfg(any(feature = "use-rustls", feature = "use-native-tls"))]
 mod tls;
 
 pub use broker::Broker;
 
-pub trait IO: AsyncRead + AsyncWrite + Send + Sync + Unpin {}
-impl<T: AsyncRead + AsyncWrite + Send + Sync + Unpin> IO for T {}
+// pub trait IO: AsyncRead + AsyncWrite + Send + Sync + Unpin {}
+// impl<T: AsyncRead + AsyncWrite + Send + Sync + Unpin> IO for T {}