fix fmt

Author: Asurar0

p2p/p2p/src/inbound_server.rs

@@ -4,26 +4,31 @@
 //! them to the handshaker service and then adds them to the client pool.
 use std::{pin::pin, sync::Arc};
 
-use futures::{StreamExt, SinkExt};
+use futures::{SinkExt, StreamExt};
 use tokio::{
-    sync::Semaphore, task::JoinSet, time::{sleep, timeout}
+    sync::Semaphore,
+    task::JoinSet,
+    time::{sleep, timeout},
 };
 use tower::{Service, ServiceExt};
 use tracing::{instrument, Instrument, Span};
 
-use cuprate_wire::{
-    admin::{PingResponse, PING_OK_RESPONSE_STATUS_TEXT}, 
-    AdminRequestMessage, AdminResponseMessage, BucketError, Message
-};
 use cuprate_p2p_core::{
     client::{Client, DoHandshakeRequest, HandshakeError, InternalPeerID},
     services::{AddressBookRequest, AddressBookResponse},
     AddressBook, ConnectionDirection, NetworkZone,
 };
+use cuprate_wire::{
+    admin::{PingResponse, PING_OK_RESPONSE_STATUS_TEXT},
+    AdminRequestMessage, AdminResponseMessage, BucketError, Message,
+};
 
 use crate::{
     client_pool::ClientPool,
-    constants::{HANDSHAKE_TIMEOUT, INBOUND_CONNECTION_COOL_DOWN, PING_REQUEST_CONCURRENCY, PING_REQUEST_TIMEOUT},
+    constants::{
+        HANDSHAKE_TIMEOUT, INBOUND_CONNECTION_COOL_DOWN, PING_REQUEST_CONCURRENCY,
+        PING_REQUEST_TIMEOUT,
+    },
     P2PConfig,
 };
 
@@ -46,7 +51,7 @@ where
 {
     // Copying the peer_id before borrowing for ping responses (Make us avoid a `clone()`).
     let our_peer_id = config.basic_node_data().peer_id;
-    
+
     // Mandatory. Extract server config from P2PConfig
     let Some(server_config) = config.server_config else {
         tracing::warn!("No inbound server config provided, not listening for inbound connections.");
@@ -61,7 +66,7 @@ where
 
     let mut listener = pin!(listener);
 
-    // Create semaphore for limiting to maximum inbound connections. 
+    // Create semaphore for limiting to maximum inbound connections.
     let semaphore = Arc::new(Semaphore::new(config.max_inbound_connections));
     // Create ping request handling JoinSet
     let mut ping_join_set = JoinSet::new();
@@ -94,7 +99,7 @@ where
             None => InternalPeerID::Unknown(rand::random()),
         };
 
-        // If we're still behind our maximum limit, Initiate handshake. 
+        // If we're still behind our maximum limit, Initiate handshake.
         if let Ok(permit) = semaphore.clone().try_acquire_owned() {
             tracing::debug!("Permit free for incoming connection, attempting handshake.");
 
@@ -119,23 +124,19 @@ where
         } else {
             // Otherwise check if the node is simply pinging us.
             tracing::debug!("No permit free for incoming connection.");
-            
+
             // We only handle 2 ping request conccurently. Otherwise we drop the connection immediately.
             if ping_join_set.len() < PING_REQUEST_CONCURRENCY {
                 ping_join_set.spawn(
                     async move {
                         // Await first message from node. If it is a ping request we respond back, otherwise we drop the connection.
                         let fut = timeout(PING_REQUEST_TIMEOUT, peer_stream.next());
-                        
                         #[allow(clippy::collapsible_match)]
                         // Ok if timeout did not elapsed -> Some if there is a message -> Ok if it has been decoded
                         if let Ok(Some(Result::<Message,BucketError>::Ok(command))) = fut.await {
-                            
                             if let Message::Request(AdminRequestMessage::Ping) = command {
-                                let _ = peer_sink
-                                    .send(Message::Response(AdminResponseMessage::Ping(
-                                        PingResponse {
-                                            status: PING_OK_RESPONSE_STATUS_TEXT, 
+                                let _ = peer_sink.send(Message::Response(AdminResponseMessage::Ping(PingResponse {
+                                            status: PING_OK_RESPONSE_STATUS_TEXT,
                                             peer_id: our_peer_id
                                         }
                                     )).into())