unify request_sync logic

1 files changed, 1 insertions, 4 deletions

diff --git a/src/swarm/peer/epoch.rs b/src/swarm/peer/epoch.rs
index 56711b1..d97db0f 100644
--- a/src/swarm/peer/epoch.rs
+++ b/src/swarm/peer/epoch.rs
@@ -6,7 +6,6 @@ use tracing::{debug, info, warn};
 
 use crate::document::replica::{Epoch, EpochRelation};
 use crate::state::AppState;
-use crate::swarm::sync::SyncEvent;
 use crate::transport;
 
 /// Records the epoch a peer advertised and compares it with ours. Returns true when the
@@ -66,9 +65,7 @@ pub(super) async fn observe_peer_epoch(
             EpochRelation::Same => {
                 if previous.is_some() {
                     info!(peer = %peer, epoch = %remote, "Peer is on our epoch again; resuming sync");
-                    let _ = state
-                        .sync_events
-                        .send(SyncEvent::PeerNeedsSync(peer.to_owned()));
+                    state.request_sync(peer);
                 }
             }
             // Expected after a remake: either side switches or catches up.