From 2e0b05c39138e79c49e17a52a01db82237d2a9e2 Mon Sep 17 00:00:00 2001
From: tv <tv@krebsco.de>
Date: Fri, 23 Oct 2026 20:12:25 +0200
Subject: merge sync_reset_at and epoch_unannounced into opening

---
 src/swarm/peer.rs | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

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

diff --git a/src/swarm/peer.rs b/src/swarm/peer.rs
index adde444..836a967 100644
--- a/src/swarm/peer.rs
+++ b/src/swarm/peer.rs
@@ -171,7 +171,7 @@ pub(crate) async fn remember_peer(state: &AppState, peer: &str) {
     let mut peer_states = state.peer_states.write().await;
 
     if !peer_states.contains_key(peer) {
-        peer_states.entry(peer.to_owned()).or_default();
+        peer_states.insert(peer.to_owned(), state.new_peer_state(peer));
         info!(
             peer = %peer,
             peer_count = peer_states.len(),
@@ -410,8 +410,7 @@ pub(crate) async fn run_peer_worker(state: AppState) {
             let (became_dormant, ping_due, unanswered) = {
                 let mut peer_state = peer_state_mutex.lock().await;
                 let became_dormant = ready && peer_state.check_dormancy(&state.timing, now);
-                let we_ping = crate::swarm::pair::leads(state.local_id(), peer);
-                let ping_due = peer_state.take_keepalive_due(&state.timing, we_ping, now);
+                let ping_due = peer_state.take_keepalive_due(&state.timing, now);
                 let unanswered = peer_state.take_overdue_sync_reply(now);
                 (became_dormant, ping_due, unanswered)
             };
-- 
cgit v1.3.1