chore(all): clippy fix

Author: mempirate

msg-sim/src/dummynet.rs

@@ -52,7 +52,7 @@ impl Pipe {
         cmd.arg("dnctl").arg("pipe").arg(self.id.to_string()).arg("config");
 
         if let Some(bandwidth) = self.bandwidth {
-            let bw = format!("{}Kbit/s", bandwidth);
+            let bw = format!("{bandwidth}Kbit/s");
 
             cmd.args(["bw", &bw]);
         }
@@ -236,7 +236,7 @@ impl PacketFilter {
         let endpoint = self.endpoint.expect("No endpoint set");
         let pipe_id = self.pipe.id();
 
-        let echo_command = format!("dummynet in from any to {} pipe {}", endpoint, pipe_id);
+        let echo_command = format!("dummynet in from any to {endpoint} pipe {pipe_id}");
 
         // Set up the echo command
         let mut echo = Command::new("echo").arg(echo_command).stdout(Stdio::piped()).spawn()?;

msg-socket/src/rep/mod.rs

@@ -146,7 +146,7 @@ mod tests {
     async fn reqrep_durable() {
         let _ = tracing_subscriber::fmt::try_init();
         let random_port = rand::random::<u16>() + 10000;
-        let addr = format!("0.0.0.0:{}", random_port);
+        let addr = format!("0.0.0.0:{random_port}");
 
         // Initialize the request socket (client side) with a transport
         let mut req = ReqSocket::new(Tcp::default());

msg-transport/src/ipc/mod.rs

@@ -110,8 +110,7 @@ impl Transport<PathBuf> for Ipc {
             debug!("Socket file already exists. Attempting to remove.");
             if let Err(e) = std::fs::remove_file(&addr) {
                 return Err(io::Error::other(format!(
-                    "Failed to remove existing socket file, {:?}",
-                    e
+                    "Failed to remove existing socket file, {e:?}"
                 )));
             }
         }

msg-wire/src/compression/lz4.rs

@@ -26,7 +26,7 @@ pub struct Lz4Decompressor;
 impl Decompressor for Lz4Decompressor {
     fn decompress(&self, data: &[u8]) -> Result<Bytes, io::Error> {
         let bytes = decompress_size_prepended(data).map_err(|e| {
-            io::Error::new(io::ErrorKind::InvalidData, format!("Lz4 decompression failed: {}", e))
+            io::Error::new(io::ErrorKind::InvalidData, format!("Lz4 decompression failed: {e}"))
         })?;
 
         Ok(Bytes::from(bytes))

msg-wire/src/compression/mod.rs

@@ -173,37 +173,37 @@ mod tests {
 
         let gzip = GzipCompressor::new(6);
         let (gzip_time, gzip_perf, gzip_comp) = compression_test(&data, gzip);
-        println!("gzip compression shrank the data by {:.2}% in {:?}", gzip_perf, gzip_time);
+        println!("gzip compression shrank the data by {gzip_perf:.2}% in {gzip_time:?}");
 
         let zstd = ZstdCompressor::new(6);
         let (zstd_time, zstd_perf, zstd_comp) = compression_test(&data, zstd);
-        println!("zstd compression shrank the data by {:.2}% in {:?}", zstd_perf, zstd_time);
+        println!("zstd compression shrank the data by {zstd_perf:.2}% in {zstd_time:?}");
 
         let snappy = SnappyCompressor;
         let (snappy_time, snappy_perf, snappy_comp) = compression_test(&data, snappy);
-        println!("snappy compression shrank the data by {:.2}% in {:?}", snappy_perf, snappy_time);
+        println!("snappy compression shrank the data by {snappy_perf:.2}% in {snappy_time:?}");
 
         let lz4 = Lz4Compressor;
         let (lz4_time, lz4_perf, lz4_comp) = compression_test(&data, lz4);
-        println!("lz4 compression shrank the data by {:.2}% in {:?}", lz4_perf, lz4_time);
+        println!("lz4 compression shrank the data by {lz4_perf:.2}% in {lz4_time:?}");
 
         println!("------ SSZ BLOCK -------");
 
         let gzip = GzipDecompressor;
         let gzip_time = decompression_test(&gzip_comp, gzip);
-        println!("gzip decompression took {:?}", gzip_time);
+        println!("gzip decompression took {gzip_time:?}");
 
         let zstd = ZstdDecompressor;
         let zstd_time = decompression_test(&zstd_comp, zstd);
-        println!("zstd decompression took {:?}", zstd_time);
+        println!("zstd decompression took {zstd_time:?}");
 
         let snappy = SnappyDecompressor;
         let snappy_time = decompression_test(&snappy_comp, snappy);
-        println!("snappy decompression took {:?}", snappy_time);
+        println!("snappy decompression took {snappy_time:?}");
 
         let lz4 = Lz4Decompressor;
         let lz4_time = decompression_test(&lz4_comp, lz4);
-        println!("lz4 decompression took {:?}", lz4_time);
+        println!("lz4 decompression took {lz4_time:?}");
     }
 
     #[test]
@@ -216,36 +216,36 @@ mod tests {
 
         let gzip = GzipCompressor::new(6);
         let (gzip_time, gzip_perf, gzip_comp) = compression_test(&data, gzip);
-        println!("gzip compression shrank the data by {:.2}% in {:?}", gzip_perf, gzip_time);
+        println!("gzip compression shrank the data by {gzip_perf:.2}% in {gzip_time:?}");
 
         let zstd = ZstdCompressor::new(6);
         let (zstd_time, zstd_perf, zstd_comp) = compression_test(&data, zstd);
-        println!("zstd compression shrank the data by {:.2}% in {:?}", zstd_perf, zstd_time);
+        println!("zstd compression shrank the data by {zstd_perf:.2}% in {zstd_time:?}");
 
         let snappy = SnappyCompressor;
         let (snappy_time, snappy_perf, snappy_comp) = compression_test(&data, snappy);
-        println!("snappy compression shrank the data by {:.2}% in {:?}", snappy_perf, snappy_time);
+        println!("snappy compression shrank the data by {snappy_perf:.2}% in {snappy_time:?}");
 
         let lz4 = Lz4Compressor;
         let (lz4_time, lz4_perf, lz4_comp) = compression_test(&data, lz4);
-        println!("lz4 compression shrank the data by {:.2}% in {:?}", lz4_perf, lz4_time);
+        println!("lz4 compression shrank the data by {lz4_perf:.2}% in {lz4_time:?}");
 
         println!("------ BLOB TX ------");
 
         let gzip = GzipDecompressor;
         let gzip_time = decompression_test(&gzip_comp, gzip);
-        println!("gzip decompression took {:?}", gzip_time);
+        println!("gzip decompression took {gzip_time:?}");
 
         let zstd = ZstdDecompressor;
         let zstd_time = decompression_test(&zstd_comp, zstd);
-        println!("zstd decompression took {:?}", zstd_time);
+        println!("zstd decompression took {zstd_time:?}");
 
         let snappy = SnappyDecompressor;
         let snappy_time = decompression_test(&snappy_comp, snappy);
-        println!("snappy decompression took {:?}", snappy_time);
+        println!("snappy decompression took {snappy_time:?}");
 
         let lz4 = Lz4Decompressor;
         let lz4_time = decompression_test(&lz4_comp, lz4);
-        println!("lz4 decompression took {:?}", lz4_time);
+        println!("lz4 decompression took {lz4_time:?}");
     }
 }

msg/examples/ipc.rs

@@ -31,7 +31,7 @@ async fn main() {
     });
 
     let res: Bytes = req.request(Bytes::from("helloooo!")).await.unwrap();
-    println!("Response: {:?}", res);
+    println!("Response: {res:?}");
 
     // Access the socket statistics
     let stats = req.stats();

msg/examples/reqrep.rs

@@ -23,7 +23,7 @@ async fn main() {
     });
 
     let res: Bytes = req.request(Bytes::from("helloooo!")).await.unwrap();
-    println!("Response: {:?}", res);
+    println!("Response: {res:?}");
 
     // Access the socket statistics
     let stats = req.stats();

msg/examples/reqrep_auth.rs

@@ -9,7 +9,7 @@ struct Auth;
 
 impl Authenticator for Auth {
     fn authenticate(&self, id: &Bytes) -> bool {
-        println!("Auth request from: {:?}", id);
+        println!("Auth request from: {id:?}");
         // Custom authentication logic
         true
     }
@@ -41,5 +41,5 @@ async fn main() {
     });
 
     let res: Bytes = req.request(Bytes::from("hello")).await.unwrap();
-    println!("Response: {:?}", res);
+    println!("Response: {res:?}");
 }

msg/examples/reqrep_compression.rs

@@ -36,5 +36,5 @@ async fn main() {
     });
 
     let res: Bytes = req.request(Bytes::from("hello")).await.unwrap();
-    println!("Response: {:?}", res);
+    println!("Response: {res:?}");
 }