Gossipsub 1.1 ammendments (#50)

* Shuffling things around * Further minor ammendments * Misc typos and improvements * Correct tests * Wasm support
sigp · Aug 24, 2020 · 3206da5 · 3206da5
1 parent 5d93c0a
commit 3206da5
Show file tree

Hide file tree

Showing 14 changed files with 532 additions and 318 deletions.
diff --git a/examples/gossipsub-chat.rs b/examples/gossipsub-chat.rs
@@ -93,10 +93,12 @@ fn main() -> Result<(), Box<dyn Error>> {
             .heartbeat_interval(Duration::from_secs(10))
             .message_id_fn(message_id_fn) // content-address messages. No two messages of the
             //same content will be propagated.
-            .build().expect("Valid config");
+            .build()
+            .expect("Valid config");
         // build a gossipsub network behaviour
         let mut gossipsub =
-            gossipsub::Gossipsub::new(MessageAuthenticity::Signed(local_key), gossipsub_config);
+            gossipsub::Gossipsub::new(MessageAuthenticity::Signed(local_key), gossipsub_config)
+                .expect("Correct configuration");
         gossipsub.subscribe(topic.clone());
         if let Some(explicit) = std::env::args().nth(2) {
             let explicit = explicit.clone();
@@ -142,10 +144,10 @@ fn main() -> Result<(), Box<dyn Error>> {
         loop {
             match swarm.poll_next_unpin(cx) {
                 Poll::Ready(Some(gossip_event)) => match gossip_event {
-                    GossipsubEvent::Message{
+                    GossipsubEvent::Message {
                         propagation_source: peer_id,
                         message_id: id,
-                        message
+                        message,
                     } => println!(
                         "Got message: {} with id: {} from peer: {:?}",
                         String::from_utf8_lossy(&message.data),

diff --git a/examples/ipfs-private.rs b/examples/ipfs-private.rs
@@ -192,7 +192,7 @@ fn main() -> Result<(), Box<dyn Error>> {
                 GossipsubEvent::Message {
                     propagation_source: peer_id,
                     message_id: id,
-                    message
+                    message,
                 } => println!(
                     "Got message: {} with id: {} from peer: {:?}",
                     String::from_utf8_lossy(&message.data),
@@ -245,12 +245,14 @@ fn main() -> Result<(), Box<dyn Error>> {
     let mut swarm = {
         let gossipsub_config = GossipsubConfigBuilder::new()
             .max_transmit_size(262144)
-            .build().expect("valid config");
+            .build()
+            .expect("valid config");
         let mut behaviour = MyBehaviour {
             gossipsub: Gossipsub::new(
                 MessageAuthenticity::Signed(local_key.clone()),
                 gossipsub_config,
-            ),
+            )
+            .expect("Valid configuration"),
             identify: Identify::new(
                 "/ipfs/0.1.0".into(),
                 "rust-ipfs-example".into(),