From 36eae63e84f22c9973edee699d3388ee2674874e Mon Sep 17 00:00:00 2001
From: hozan23 <hozan23@karyontech.net>
Date: Sat, 1 Jun 2024 21:30:23 +0200
Subject: p2p: fix cargo clippy warnings

---
 Cargo.lock                  | 10 +++++-----
 p2p/src/discovery/lookup.rs |  8 ++++----
 p2p/src/peer/mod.rs         |  2 +-
 3 files changed, 10 insertions(+), 10 deletions(-)

diff --git a/Cargo.lock b/Cargo.lock
index 2c4a741..23f0dd1 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -1231,7 +1231,7 @@ dependencies = [
 
 [[package]]
 name = "karyon_core"
-version = "0.1.0"
+version = "0.1.1"
 dependencies = [
  "async-channel 2.3.1",
  "async-process",
@@ -1251,7 +1251,7 @@ dependencies = [
 
 [[package]]
 name = "karyon_jsonrpc"
-version = "0.1.0"
+version = "0.1.1"
 dependencies = [
  "async-channel 2.3.1",
  "async-trait",
@@ -1275,7 +1275,7 @@ dependencies = [
 
 [[package]]
 name = "karyon_jsonrpc_macro"
-version = "0.1.0"
+version = "0.1.1"
 dependencies = [
  "proc-macro2",
  "quote",
@@ -1285,7 +1285,7 @@ dependencies = [
 
 [[package]]
 name = "karyon_net"
-version = "0.1.0"
+version = "0.1.1"
 dependencies = [
  "async-channel 2.3.1",
  "async-trait",
@@ -1307,7 +1307,7 @@ dependencies = [
 
 [[package]]
 name = "karyon_p2p"
-version = "0.1.0"
+version = "0.1.1"
 dependencies = [
  "async-channel 2.3.1",
  "async-std",
diff --git a/p2p/src/discovery/lookup.rs b/p2p/src/discovery/lookup.rs
index 3beea7e..677bad7 100644
--- a/p2p/src/discovery/lookup.rs
+++ b/p2p/src/discovery/lookup.rs
@@ -345,7 +345,7 @@ impl LookupService {
     /// Sends a Pong msg
     async fn send_pong_msg(&self, nonce: [u8; 32], conn: &Conn<NetMsg>) -> Result<()> {
         trace!("Send Pong msg");
-        conn.send(NetMsg::new(NetMsgCmd::Pong, &PongMsg(nonce))?)
+        conn.send(NetMsg::new(NetMsgCmd::Pong, PongMsg(nonce))?)
             .await?;
         Ok(())
     }
@@ -355,7 +355,7 @@ impl LookupService {
         trace!("Send FindPeer msg");
         conn.send(NetMsg::new(
             NetMsgCmd::FindPeer,
-            &FindPeerMsg(peer_id.clone()),
+            FindPeerMsg(peer_id.clone()),
         )?)
         .await?;
 
@@ -376,7 +376,7 @@ impl LookupService {
             .closest_entries(&peer_id.0, MAX_PEERS_IN_PEERSMSG);
 
         let peers: Vec<PeerMsg> = entries.into_iter().map(|e| e.into()).collect();
-        conn.send(NetMsg::new(NetMsgCmd::Peers, &PeersMsg(peers))?)
+        conn.send(NetMsg::new(NetMsgCmd::Peers, PeersMsg(peers))?)
             .await?;
         Ok(())
     }
@@ -397,7 +397,7 @@ impl LookupService {
     /// Sends a Shutdown msg.
     async fn send_shutdown_msg(&self, conn: &Conn<NetMsg>) -> Result<()> {
         trace!("Send Shutdown msg");
-        conn.send(NetMsg::new(NetMsgCmd::Shutdown, &ShutdownMsg(0))?)
+        conn.send(NetMsg::new(NetMsgCmd::Shutdown, ShutdownMsg(0))?)
             .await?;
         Ok(())
     }
diff --git a/p2p/src/peer/mod.rs b/p2p/src/peer/mod.rs
index b4cfd3a..0d42da3 100644
--- a/p2p/src/peer/mod.rs
+++ b/p2p/src/peer/mod.rs
@@ -124,7 +124,7 @@ impl Peer {
 
         // No need to handle the error here
         let shutdown_msg =
-            NetMsg::new(NetMsgCmd::Shutdown, &ShutdownMsg(0)).expect("pack shutdown message");
+            NetMsg::new(NetMsgCmd::Shutdown, ShutdownMsg(0)).expect("pack shutdown message");
         let _ = self.conn.send(shutdown_msg).await;
 
         // Force shutting down
-- 
cgit v1.2.3