close duplicate connection

Signed-off-by: turuslan <[email protected]>

core/network/impl/peer_manager_impl.cpp

@@ -18,6 +18,7 @@
 #include "scale/libp2p_types.hpp"
 #include "storage/predefined_keys.hpp"
 #include "utils/pool_handler_ready_make.hpp"
+#include "utils/weak_macro.hpp"
 
 namespace {
   /// Reputation value for a node when we get disconnected from it.
@@ -124,6 +125,28 @@ namespace kagome::network {
               }
             });
 
+    peer_connected_sub_ =
+        host_.getBus()
+            .getChannel<libp2p::event::network::OnNewConnectionChannel>()
+            .subscribe(
+                [WEAK_SELF](std::weak_ptr<libp2p::connection::CapableConnection>
+                                weak_conn) {
+                  WEAK_LOCK(self);
+                  WEAK_LOCK(conn);
+                  auto peer_id = conn->remotePeer().value();
+                  for (auto &conn2 : self->host_.getNetwork()
+                                         .getConnectionManager()
+                                         .getConnectionsToPeer(peer_id)) {
+                    if (conn2 == conn) {
+                      continue;
+                    }
+                    if (conn2->isInitiator() != conn->isInitiator()) {
+                      continue;
+                    }
+                    std::ignore = conn->close();
+                  }
+                });
+
     peer_disconnected_handler_ =
         host_.getBus()
             .getChannel<libp2p::event::network::OnPeerDisconnectedChannel>()

core/network/impl/peer_manager_impl.hpp

@@ -187,6 +187,7 @@ namespace kagome::network {
     std::shared_ptr<network::PeerView> peer_view_;
 
     libp2p::event::Handle add_peer_handle_;
+    libp2p::event::Handle peer_connected_sub_;
     libp2p::event::Handle peer_disconnected_handler_;
     std::unordered_set<PeerId> peers_in_queue_;
     std::deque<PeerId> queue_to_connect_;