add debug logging and format tcp server actor

mycognosist · May 15, 2023 · 5d35c02 · 5d35c02
1 parent 456f563
commit 5d35c02
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/src/actors/tcp_server.rs b/src/actors/tcp_server.rs
@@ -4,6 +4,7 @@ use async_std::{
 };
 use futures::{select_biased, FutureExt};
 use kuska_ssb::keystore::OwnedIdentity;
+use log::debug;
 
 use crate::{broker::*, Result};
 
@@ -18,14 +19,22 @@ pub async fn actor(
 
     let listener = TcpListener::bind(addr).await?;
     let mut incoming = listener.incoming();
+    debug!("Listening for inbound TCP connection...");
 
     loop {
         select_biased! {
             _ = ch_terminate => break,
             stream = incoming.next().fuse() => {
                 if let Some(stream) = stream {
                     if let Ok(stream) = stream {
-                        Broker::spawn(super::peer::actor(server_id.clone(), super::peer::Connect::ClientStream{stream}, selective_replication));
+                        debug!("Received inbound TCP connection");
+                        Broker::spawn(
+                            super::peer::actor(
+                                server_id.clone(),
+                                super::peer::Connect::ClientStream{stream},
+                                selective_replication
+                            )
+                        );
                     }
                 } else {
                     break;