fix p2p test

gnosisguild · Jan 3, 2025 · 9cdf56c · 9cdf56c
1 parent 5e77979
commit 9cdf56c
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/packages/ciphernode/net/src/bin/p2p_test.rs b/packages/ciphernode/net/src/bin/p2p_test.rs
@@ -93,14 +93,14 @@ async fn main() -> Result<()> {
     .into_iter()
     .filter(|n| *n != name)
     .collect();
+
     println!("{} waiting for messages from: {:?}", name, expected);
 
     // Then wait to receive from others with a timeout
     let mut received = HashSet::new();
     let receive_result = timeout(Duration::from_secs(10), async {
-        let history = net_bus.send(GetHistory::<NetworkPeerEvent>::new()).await?;
-        println!("{} history: {:?}", name, history);
         while received != expected {
+            let history = net_bus.send(GetHistory::<NetworkPeerEvent>::new()).await?;
             for event in history.clone() {
                 match event {
                     NetworkPeerEvent::GossipData(msg) => {
@@ -114,6 +114,7 @@ async fn main() -> Result<()> {
                     _ => (),
                 }
             }
+            tokio::time::sleep(Duration::from_secs(1)).await;
         }
         Ok::<(), anyhow::Error>(())
     })

diff --git a/packages/ciphernode/net/src/network_peer.rs b/packages/ciphernode/net/src/network_peer.rs
@@ -92,7 +92,6 @@ impl NetworkPeer {
                 }
             }
             NetworkPeerCommand::Dial(multi) => {
-                info!("DIAL: {:?}", multi);
                 let connection_id = multi.connection_id();
                 match self.swarm.dial(multi) {
                     Ok(v) => {