chore: small changes to the gossip

blueprint-test-utils/src/test_ext.rs

@@ -309,10 +309,12 @@ pub async fn new_test_ext_blueprint_manager<
 pub fn find_open_tcp_bind_port() -> u16 {
     let listener = std::net::TcpListener::bind(format!("{LOCAL_BIND_ADDR}:0"))
         .expect("Should bind to localhost");
-    listener
+    let port = listener
         .local_addr()
         .expect("Should have a local address")
-        .port()
+        .port();
+    drop(listener);
+    port
 }
 
 pub struct LocalhostTestExt {

sdk/src/network/mod.rs

@@ -1,6 +1,5 @@
 use crate::error::Error;
 use async_trait::async_trait;
-use auto_impl::auto_impl;
 use core::fmt::Display;
 use dashmap::DashMap;
 use futures::{Stream, StreamExt};
@@ -87,7 +86,7 @@ impl Display for ProtocolMessage {
 }
 
 #[async_trait]
-#[auto_impl(&, Arc)]
+#[auto_impl::auto_impl(&, Box, Arc)]
 pub trait Network: Send + Sync + 'static {
     async fn next_message(&self) -> Option<ProtocolMessage>;
     async fn send_message(&self, message: ProtocolMessage) -> Result<(), Error>;
@@ -753,6 +752,7 @@ mod tests {
 
             let received_msg = subnetwork0.recv().await.unwrap();
             assert_eq!(received_msg.payload, msg.payload);
+            tracing::info!("Done nested depth = {cur_depth}/{max_depth}");
 
             Box::pin(nested_multiplex(
                 cur_depth + 1,

sdk/src/network/setup.rs

@@ -277,10 +277,8 @@ pub fn multiplexed_libp2p_network(config: NetworkConfig) -> NetworkResult {
     }
 
     let ips_to_bind_to = vec![
-        IpAddr::from_str("127.0.0.1").unwrap(),
         IpAddr::from_str("0.0.0.0").unwrap(),
         IpAddr::from_str("::1").unwrap(),
-        IpAddr::from_str("::").unwrap(),
     ];
 
     for addr in ips_to_bind_to {