unify request_sync logic

1 files changed, 2 insertions, 3 deletions

diff --git a/src/swarm/source.rs b/src/swarm/source.rs
index 5e428f2..e098dc1 100644
--- a/src/swarm/source.rs
+++ b/src/swarm/source.rs
@@ -37,7 +37,6 @@ use tracing::{debug, info, warn};
 
 use crate::locks::MutexExt;
 use crate::state::{AppState, CatchUpSource, PeerState};
-use crate::swarm::sync::SyncEvent;
 
 /// How long a clearly closer peer (by round-trip time) gets to claim the source role
 /// before whoever asks next takes it.
@@ -303,7 +302,7 @@ pub(crate) fn finished(state: &AppState, from: &str) {
     tokio::spawn(async move {
         let peers: Vec<String> = state.peer_states.read().await.keys().cloned().collect();
         for other in peers.into_iter().filter(|other| *other != from) {
-            let _ = state.sync_events.send(SyncEvent::PeerNeedsSync(other));
+            state.request_sync(&other);
         }
     });
 }
@@ -314,7 +313,7 @@ pub(crate) fn resync_everyone(state: &AppState) {
     tokio::spawn(async move {
         let peers: Vec<String> = state.peer_states.read().await.keys().cloned().collect();
         for other in peers {
-            let _ = state.sync_events.send(SyncEvent::PeerNeedsSync(other));
+            state.request_sync(&other);
         }
     });
 }