Formatting

packages/ciphernode/net/src/correlation_id.rs

@@ -5,7 +5,7 @@ use std::{
 
 static NEXT_CORRELATION_ID: AtomicUsize = AtomicUsize::new(1);
 
-/// CorrelationId provides a way to correlate commands and the events they create. 
+/// CorrelationId provides a way to correlate commands and the events they create.
 #[derive(Debug, Clone)]
 pub struct CorrelationId {
     id: usize,

packages/ciphernode/net/src/dialer.rs

@@ -6,10 +6,10 @@ use libp2p::{
     swarm::{dial_opts::DialOpts, ConnectionId, DialError},
     Multiaddr,
 };
-use tracing::info;
 use std::net::ToSocketAddrs;
 use tokio::sync::{broadcast, mpsc};
 use tracing::error;
+use tracing::info;
 
 use crate::{
     events::{NetworkPeerCommand, NetworkPeerEvent},
@@ -78,7 +78,7 @@ async fn attempt_connection(
 }
 
 /// Wait for results of a retry based on a given correlation id and return the correct variant of
-/// RetryError depending on the result from the downstream event 
+/// RetryError depending on the result from the downstream event
 async fn wait_for_connection(
     event_rx: &mut broadcast::Receiver<NetworkPeerEvent>,
     dial_connection: ConnectionId,

packages/ciphernode/net/src/events.rs

@@ -35,14 +35,10 @@ pub enum NetworkPeerEvent {
         message_id: MessageId,
     },
     /// There was an error Dialing a peer
-    DialError {
-        error: Arc<DialError>,
-    },
+    DialError { error: Arc<DialError> },
     /// A connection was established to a peer
-    ConnectionEstablished {
-        connection_id: ConnectionId,
-    },
-    /// There was an error creating a connection 
+    ConnectionEstablished { connection_id: ConnectionId },
+    /// There was an error creating a connection
     OutgoingConnectionError {
         connection_id: ConnectionId,
         error: Arc<DialError>,

packages/ciphernode/net/src/network_peer.rs

@@ -40,7 +40,7 @@ pub struct NetworkPeer {
     udp_port: Option<u16>,
     /// The gossipsub topic that the peer should listen on
     topic: gossipsub::IdentTopic,
-    /// Broadcast channel to report NetworkPeerEvents to listeners 
+    /// Broadcast channel to report NetworkPeerEvents to listeners
     event_tx: broadcast::Sender<NetworkPeerEvent>,
     /// Transmission channel to send NetworkPeerCommands to the NetworkPeer
     cmd_tx: mpsc::Sender<NetworkPeerCommand>,

packages/ciphernode/net/src/retry.rs

@@ -1,7 +1,7 @@
 use anyhow::Result;
-use tracing::{error, warn};
 use std::{future::Future, time::Duration};
 use tokio::time::sleep;
+use tracing::{error, warn};
 
 pub enum RetryError {
     Failure(anyhow::Error),