use generic type for message data + cache message ids

examples/gossipsub-chat.rs

@@ -51,7 +51,7 @@ use env_logger::{Builder, Env};
 use futures::prelude::*;
 use libp2p::gossipsub::MessageId;
 use libp2p::gossipsub::{
-    GossipsubEvent, GossipsubMessage, IdentTopic as Topic, MessageAuthenticity, ValidationMode,
+    GossipsubEvent, RawGossipsubMessage, IdentTopic as Topic, MessageAuthenticity, ValidationMode,
 };
 use libp2p::{gossipsub, identity, PeerId};
 use std::collections::hash_map::DefaultHasher;
@@ -79,7 +79,7 @@ fn main() -> Result<(), Box<dyn Error>> {
     // Create a Swarm to manage peers and events
     let mut swarm = {
         // To content-address message, we can take the hash of message and use it as an ID.
-        let message_id_fn = |message: &GossipsubMessage| {
+        let message_id_fn = |message: &RawGossipsubMessage| {
             let mut s = DefaultHasher::new();
             message.data.hash(&mut s);
             MessageId::from(s.finish().to_string())
@@ -154,7 +154,7 @@ fn main() -> Result<(), Box<dyn Error>> {
                         message,
                     } => println!(
                         "Got message: {} with id: {} from peer: {:?}",
-                        String::from_utf8_lossy(&message.data),
+                        String::from_utf8_lossy(message.data()),
                         id,
                         peer_id
                     ),

examples/ipfs-private.rs

@@ -195,7 +195,7 @@ fn main() -> Result<(), Box<dyn Error>> {
                     message,
                 } => println!(
                     "Got message: {} with id: {} from peer: {:?}",
-                    String::from_utf8_lossy(&message.data),
+                    String::from_utf8_lossy(message.data()),
                     id,
                     peer_id
                 ),