chore(rpc): Connect Peer RPC Request

crates/node/p2p/src/rpc/request.rs

@@ -40,6 +40,12 @@
         /// Whether to only return connected peers.
         connected: bool,
     },
+
+    /// Request to connect the specified peer.
+    ConnectPeer {
+        /// The peer id to connect.
+        peer_id: PeerId,
+    },
     /// Request to disconnect the specified peer.
     DisconnectPeer {
         /// The peer id to disconnect.
@@ -63,6 +69,7 @@
             Self::PeerInfo(s) => Self::handle_peer_info(s, gossip, disc),
             Self::Peers { out, connected } => Self::handle_peers(out, connected, gossip, disc),
             Self::DisconnectPeer { peer_id } => Self::disconnect_peer(peer_id, gossip),
+            Self::ConnectPeer { peer_id } => Self::connect_peer(peer_id, gossip),
             Self::PeerStats(s) => Self::handle_peer_stats(s, gossip, disc),
         }
     }
@@ -74,6 +81,14 @@
             info!(target: "p2p::rpc", "Disconnected peer {}", peer_id);
         }
     }
+
+    fn connect_peer(peer_id: PeerId, gossip: &mut GossipDriver) {
+        if let Err(e) = gossip.swarm.dial(peer_id) {
+            warn!(target: "p2p::rpc", "Failed to connect to peer {}: {:?}", peer_id, e);
+        } else {
+            info!(target: "p2p::rpc", "Connected peer {}", peer_id);
+        }
+    }
 
     fn handle_discovery_table(sender: Sender<Vec<String>>, disc: &Discv5Handler) {
         let enrs = disc.table_enrs();

crates/node/rpc/src/p2p.rs

@@ -142,10 +142,21 @@
         Err(ErrorObject::from(ErrorCode::MethodNotFound))
     }
 
-    async fn opp2p_connect_peer(&self, _peer: String) -> RpcResult<()> {
+    async fn opp2p_connect_peer(&self, peer_id: String) -> RpcResult<()> {
         kona_macros::inc!(gauge, kona_p2p::Metrics::RPC_CALLS, "method" => "opp2p_connectPeer");
-        // Method not supported yet.
-        Err(ErrorObject::from(ErrorCode::MethodNotFound))
+
+        let peer_id = match peer_id.parse() {
+            Ok(id) => id,
+            Err(err) => {
+                warn!(target: "rpc", ?err, ?peer_id, "Failed to parse peer ID");
+                return Err(ErrorObject::from(ErrorCode::InvalidParams))
+            }
+        };
+
+        self.sender
+            .send(P2pRpcRequest::ConnectPeer { peer_id })
+            .await
+            .map_err(|_| ErrorObject::from(ErrorCode::InternalError))
     }
 
     async fn opp2p_disconnect_peer(&self, peer_id: String) -> RpcResult<()> {