From 6e0a3fc86fcd3df3d0b26469f132602c7dce9c24 Mon Sep 17 00:00:00 2001
From: tv <tv@krebsco.de>
Date: Sat, 31 Oct 2026 04:48:00 +0100
Subject: unify request_sync logic

---
 src/swarm/peer/epoch.rs | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

(limited to 'src/swarm/peer/epoch.rs')

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.
-- 
cgit v1.3.1