merge sync_reset_at and epoch_unannounced into opening

1 files changed, 2 insertions, 3 deletions

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)
             };