1 files changed, 21 insertions, 3 deletions
diff --git a/src/swarm/sync.rs b/src/swarm/sync.rs
index 47c3b7f..d82238e 100644
--- a/src/swarm/sync.rs
+++ b/src/swarm/sync.rs
@@ -58,10 +58,28 @@ async fn deliver_sync_to_peer(state: &AppState, peer: &str, retry_delivery: bool
             return Ok(());
         }
 
-        match &peer_state.membership {
-            PeerMembership::Unknown => return Ok(()),
-            PeerMembership::Member { swarm_id } => swarm_id.clone(),
+        let PeerMembership::Member { swarm_id } = &peer_state.membership else {
+            return Ok(());
+        };
+
+        if !retry_delivery {
+            let we_open = state.local_id() < peer;
+            if let Some(wait) = peer_state.opening_wait(we_open, Instant::now()) {
+                trace!(
+                    wait_ms = wait.as_millis(),
+                    "Leaving the opening sync message to the peer"
+                );
+                let tx = state.sync_events.clone();
+                let peer = peer.to_owned();
+                tokio::spawn(async move {
+                    tokio::time::sleep(wait).await;
+                    let _ = tx.send(SyncEvent::PeerNeedsSync(peer));
+                });
+                return Ok(());
+            }
         }
+
+        swarm_id.clone()
     };
 
     let swarm_id = state