fix: Prevent dialing connected peers

anchor/network/src/peer_manager/connection.rs

@@ -120,6 +120,11 @@ impl ConnectionManager {
             return false;
         }
 
+        // Don't dial connected peers
+        if self.connected.contains(peer_id) {
+            return false;
+        }
+
         self.connected.len() < self.target_peers
             || self.qualifies_for_priority_connection(peer_id, peer_store, needed_subnets)
     }

anchor/network/src/peer_manager/discovery.rs

@@ -67,13 +67,10 @@ impl PeerDiscovery {
     /// Track a subnet as needed and return actions to find peers for it
     pub fn track_subnet_peers(
         subnet_id: SubnetId,
-        needed_subnets: &mut HashSet<SubnetId>,
         peer_store: &MemoryStore<Enr>,
         connection_manager: &ConnectionManager,
         blocked_peers: &HashSet<PeerId>,
     ) -> ConnectActions {
-        needed_subnets.insert(subnet_id);
-
         Self::determine_actions_for_subnets(
             &[subnet_id],
             peer_store,

anchor/network/src/peer_manager/mod.rs

@@ -71,9 +71,10 @@ impl PeerManager {
 
     /// Join subnet and dial peers for it
     pub fn join_subnet(&mut self, subnet_id: SubnetId) -> ConnectActions {
+        self.needed_subnets.insert(subnet_id);
+
         PeerDiscovery::track_subnet_peers(
             subnet_id,
-            &mut self.needed_subnets,
             self.peer_store.store(),
             &self.connection_manager,
             self.blocking_manager.blocked_peers(),