Don't add as an explicit peer if already connected

akildemir · Mar 23, 2024 · 4914420 · 4914420
1 parent f11a08c
commit 4914420
Showing 1 changed file with 11 additions and 11 deletions.
diff --git a/coordinator/src/p2p.rs b/coordinator/src/p2p.rs
@@ -435,18 +435,18 @@ impl LibP2p {
                 Some(SwarmEvent::Dialing { connection_id, .. }) => {
                   log::debug!("dialing to peer in connection ID {}", &connection_id);
                 }
-                  Some(SwarmEvent::ConnectionEstablished { peer_id, connection_id, .. }) => {
-                    if &peer_id == swarm.local_peer_id() {
-                      swarm.close_connection(connection_id);
-                    } else {
-                      log::debug!(
-                        "connection established to peer {} in connection ID {}",
-                        &peer_id,
-                        &connection_id,
-                      );
-                      swarm.behaviour_mut().gossipsub.add_explicit_peer(&peer_id)
-                    }
+                Some(SwarmEvent::ConnectionEstablished { peer_id, connection_id, .. }) => {
+                  if &peer_id == swarm.local_peer_id() {
+                    swarm.close_connection(connection_id);
+                  } else if swarm.is_connected(&peer_id) {} else {
+                    log::debug!(
+                      "connection established to peer {} in connection ID {}",
+                      &peer_id,
+                      &connection_id,
+                    );
+                    swarm.behaviour_mut().gossipsub.add_explicit_peer(&peer_id)
                   }
+                }
                 Some(SwarmEvent::Behaviour(BehaviorEvent::Gossipsub(
                   GsEvent::Message { propagation_source, message, .. },
                 ))) => {