add logs when receiving and sending Rpcs

Author: jxs

protocols/gossipsub/src/behaviour.rs

@@ -3133,11 +3133,12 @@ where
 
         // Try sending the message to the connection handler,
         // High priority messages should not fail.
+        tracing::debug!(%peer_id, ?rpc, "Sending Rpc");
         match peer.messages.try_push(rpc) {
             Ok(()) => true,
             Err(rpc) => {
                 // Sending failed because the channel is full.
-                tracing::warn!(peer=%peer_id, "Send Queue full. Could not send {:?}.", rpc);
+                tracing::warn!(%peer_id, ?rpc, "Send Queue full. Could not send Rpc.");
 
                 // Update failed message counter.
                 let failed_messages = self.failed_messages.entry(peer_id).or_default();
@@ -3521,6 +3522,7 @@ where
                 invalid_messages,
             } => {
                 // Handle the gossipsub RPC
+                tracing::debug!(rpc = ?rpc, "Received RPC");
 
                 // Handle subscriptions
                 // Update connected peers topics

protocols/gossipsub/src/types.rs

@@ -127,7 +127,7 @@ pub enum PeerKind {
 }
 
 /// A message received by the gossipsub system and stored locally in caches..
-#[derive(Clone, PartialEq, Eq, Hash, Debug)]
+#[derive(Clone, PartialEq, Eq, Hash)]
 pub struct RawMessage {
     /// Id of the peer that published this message.
     pub source: Option<PeerId>,
@@ -151,6 +151,20 @@ pub struct RawMessage {
     pub validated: bool,
 }
 
+impl std::fmt::Debug for RawMessage {
+    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
+        f.debug_struct("RawMessage")
+            .field("source", &self.source)
+            .field("data length", &self.data.len())
+            .field("sequence_number", &self.sequence_number)
+            .field("topic", &self.topic)
+            .field("signature", &self.signature)
+            .field("key", &self.key)
+            .field("validated", &self.validated)
+            .finish()
+    }
+}
+
 impl PeerKind {
     /// Returns true if peer speaks any gossipsub version.
     pub(crate) fn is_gossipsub(&self) -> bool {