implement NetDisconnect (#1531)

ChainSafe · Apr 11, 2022 · 6f5d900 · 6f5d900
1 parent ebed40a
commit 6f5d900
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/forest/src/cli/net_cmd.rs b/forest/src/cli/net_cmd.rs
@@ -115,7 +115,7 @@ impl NetCommands {
             }
             Self::Disconnect { id } => match net_disconnect((id.to_owned(),)).await {
                 Ok(_) => {
-                    todo!();
+                    println!("disconnect {}: success", id);
                 }
                 Err(e) => handle_rpc_err(e),
             },

diff --git a/node/forest_libp2p/src/service.rs b/node/forest_libp2p/src/service.rs
@@ -364,8 +364,8 @@ where
                                         warn!("Failed to connect to a peer");
                                     }
                                 }
-                                NetRPCMethods::NetDisconnect(response_channel, _peer_id) => {
-                                    warn!("NetDisconnect API not yet implmeneted"); // TODO: implement NetDisconnect - See #1181
+                                NetRPCMethods::NetDisconnect(response_channel, peer_id) => {
+                                    let _ = Swarm::disconnect_peer_id(swarm_stream.get_mut(), peer_id);
 
                                     if response_channel.send(()).is_err() {
                                         warn!("Failed to disconnect from a peer");