fix format

Author: cceliks

p2p/src/behaviour.rs

@@ -2,11 +2,11 @@ use std::collections::hash_map;
 use std::hash::{Hash, Hasher};
 use std::time::Duration;
 
+use eyre::{eyre, Result};
 use libp2p::identity::{Keypair, PeerId, PublicKey};
 use libp2p::kad::store::MemoryStore;
 use libp2p::StreamProtocol;
 use libp2p::{autonat, dcutr, gossipsub, identify, kad, relay};
-use eyre::{eyre, Result};
 
 #[derive(libp2p::swarm::NetworkBehaviour)]
 pub struct DriaBehaviour {
@@ -43,7 +43,7 @@ impl DriaBehaviour {
 fn create_kademlia_behavior(
     local_peer_id: PeerId,
     protocol_name: StreamProtocol,
-) -> kad::Behaviour<MemoryStore>{
+) -> kad::Behaviour<MemoryStore> {
     use kad::{Behaviour, Config};
 
     const QUERY_TIMEOUT_SECS: u64 = 5 * 60;
@@ -140,29 +140,27 @@ fn create_gossipsub_behavior(author: PeerId) -> Result<gossipsub::Behaviour> {
 
     // TODO: add data transform here later
     let config = match ConfigBuilder::default()
-    .heartbeat_interval(Duration::from_secs(HEARTBEAT_INTERVAL_SECS))
-    .max_transmit_size(MAX_TRANSMIT_SIZE)
-    .message_id_fn(message_id_fn)
-    .message_capacity(MESSAGE_CAPACITY)
-    .message_ttl(Duration::from_secs(MESSAGE_TTL_SECS))
-    .gossip_ttl(Duration::from_secs(GOSSIP_TTL_SECS))
-    .duplicate_cache_time(Duration::from_secs(DUPLICATE_CACHE_TIME_SECS))
-    .max_ihave_length(MAX_IHAVE_LENGTH)
-    .send_queue_size(MAX_SEND_QUEUE_SIZE)
-    .validation_mode(VALIDATION_MODE)
-    .validate_messages()
-    .build() {
+        .heartbeat_interval(Duration::from_secs(HEARTBEAT_INTERVAL_SECS))
+        .max_transmit_size(MAX_TRANSMIT_SIZE)
+        .message_id_fn(message_id_fn)
+        .message_capacity(MESSAGE_CAPACITY)
+        .message_ttl(Duration::from_secs(MESSAGE_TTL_SECS))
+        .gossip_ttl(Duration::from_secs(GOSSIP_TTL_SECS))
+        .duplicate_cache_time(Duration::from_secs(DUPLICATE_CACHE_TIME_SECS))
+        .max_ihave_length(MAX_IHAVE_LENGTH)
+        .send_queue_size(MAX_SEND_QUEUE_SIZE)
+        .validation_mode(VALIDATION_MODE)
+        .validate_messages()
+        .build()
+    {
         Ok(config) => config,
         Err(e) => {
             return Err(eyre!("Failed to create gossipsub config: {}", e));
         }
     };
 
-    match Behaviour::new(
-        MessageAuthenticity::Author(author),
-        config
-        ) {
-            Ok(behaviour) => Ok(behaviour),
-            Err(e) => Err(eyre!("Failed to create gossipsub behaviour: {}", e)),
-        }
+    match Behaviour::new(MessageAuthenticity::Author(author), config) {
+        Ok(behaviour) => Ok(behaviour),
+        Err(e) => Err(eyre!("Failed to create gossipsub behaviour: {}", e)),
+    }
 }

p2p/src/client.rs

@@ -1,5 +1,5 @@
 use super::*;
-use eyre::{eyre, Result};
+use eyre::Result;
 use libp2p::futures::StreamExt;
 use libp2p::gossipsub::{
     Message, MessageAcceptance, MessageId, PublishError, SubscriptionError, TopicHash,
@@ -78,7 +78,8 @@ impl DriaP2PClient {
                     relay_behavior,
                     identity_protocol.clone(),
                     kademlia_protocol.clone(),
-                ).unwrap()
+                )
+                .unwrap()
             })?
             .with_swarm_config(|c| {
                 c.with_idle_connection_timeout(Duration::from_secs(IDLE_CONNECTION_TIMEOUT_SECS))
@@ -135,7 +136,8 @@ impl DriaP2PClient {
             identity_protocol,
             kademlia_protocol,
         })
-    }    /// Subscribe to a topic.        
+    }
+    /// Subscribe to a topic.        
     pub fn subscribe(&mut self, topic_name: &str) -> Result<bool, SubscriptionError> {
         log::debug!("Subscribing to {}", topic_name);