api: add NetDisconnect api

filecoin-project · Jul 7, 2022 · a4ac2e5 · a4ac2e5
1 parent 56fa2ae
commit a4ac2e5
Show file tree

Hide file tree

Showing 12 changed files with 79 additions and 2 deletions.
diff --git a/app/submodule/network/network_api.go b/app/submodule/network/network_api.go
@@ -87,3 +87,8 @@ func (na *networkAPI) NetAddrsListen(context.Context) (peer.AddrInfo, error) {
 		Addrs: na.network.Host.Addrs(),
 	}, nil
 }
+
+// NetDisconnect disconnect to peer at the given address
+func (na *networkAPI) NetDisconnect(_ context.Context, p peer.ID) error {
+	return na.network.Network.Disconnect(p)
+}
diff --git a/pkg/net/network.go b/pkg/net/network.go
@@ -130,3 +130,8 @@ func (network *Network) Peers(ctx context.Context, verbose, latency, streams boo
 	sort.Sort(&out)
 	return &out, nil
 }
+
+// Disconnect disconnect to peer at the given address
+func (network *Network) Disconnect(p peer.ID) error {
+	return network.host.Network().ClosePeer(p)
+}
diff --git a/venus-shared/api/chain/v0/method.md b/venus-shared/api/chain/v0/method.md
@@ -127,6 +127,7 @@
   * [MsigSwapPropose](#MsigSwapPropose)
 * [Network](#Network)
   * [NetAddrsListen](#NetAddrsListen)
+  * [NetDisconnect](#NetDisconnect)
   * [NetworkConnect](#NetworkConnect)
   * [NetworkFindPeer](#NetworkFindPeer)
   * [NetworkFindProvidersAsync](#NetworkFindProvidersAsync)
@@ -4018,6 +4019,20 @@ Response:
 }
 ```
 
+### NetDisconnect
+
+
+Perms: write
+
+Inputs:
+```json
+[
+  "12D3KooWGzxzKZYveHXtpG6AsrUJBcWxHBFS2HsEoGTxrMLvKXtf"
+]
+```
+
+Response: `{}`
+
 ### NetworkConnect
 
 

diff --git a/venus-shared/api/chain/v0/mock/mock_fullnode.go b/venus-shared/api/chain/v0/mock/mock_fullnode.go
diff --git a/venus-shared/api/chain/v0/network.go b/venus-shared/api/chain/v0/network.go
@@ -24,4 +24,5 @@ type INetwork interface {
 	NetworkPing(context.Context, peer.ID) (time.Duration, error)                                     //perm:read
 	Version(context.Context) (types.Version, error)                                                  //perm:read
 	NetAddrsListen(context.Context) (peer.AddrInfo, error)                                           //perm:read
+	NetDisconnect(context.Context, peer.ID) error                                                    //perm:write
 }
diff --git a/venus-shared/api/chain/v0/proxy_gen.go b/venus-shared/api/chain/v0/proxy_gen.go
diff --git a/venus-shared/api/chain/v1/method.md b/venus-shared/api/chain/v1/method.md
@@ -132,6 +132,7 @@
   * [MsigSwapPropose](#MsigSwapPropose)
 * [Network](#Network)
   * [NetAddrsListen](#NetAddrsListen)
+  * [NetDisconnect](#NetDisconnect)
   * [NetworkConnect](#NetworkConnect)
   * [NetworkFindPeer](#NetworkFindPeer)
   * [NetworkFindProvidersAsync](#NetworkFindProvidersAsync)
@@ -4409,6 +4410,20 @@ Response:
 }
 ```
 
+### NetDisconnect
+
+
+Perms: write
+
+Inputs:
+```json
+[
+  "12D3KooWGzxzKZYveHXtpG6AsrUJBcWxHBFS2HsEoGTxrMLvKXtf"
+]
+```
+
+Response: `{}`
+
 ### NetworkConnect
 
 

diff --git a/venus-shared/api/chain/v1/mock/mock_fullnode.go b/venus-shared/api/chain/v1/mock/mock_fullnode.go
diff --git a/venus-shared/api/chain/v1/network.go b/venus-shared/api/chain/v1/network.go
@@ -24,4 +24,5 @@ type INetwork interface {
 	NetworkPing(context.Context, peer.ID) (time.Duration, error)                                     //perm:read
 	Version(context.Context) (types.Version, error)                                                  //perm:read
 	NetAddrsListen(context.Context) (peer.AddrInfo, error)                                           //perm:read
+	NetDisconnect(context.Context, peer.ID) error                                                    //perm:write
 }
diff --git a/venus-shared/api/chain/v1/proxy_gen.go b/venus-shared/api/chain/v1/proxy_gen.go
diff --git a/venus-shared/compatible-checks/api-diff.txt b/venus-shared/compatible-checks/api-diff.txt
@@ -95,7 +95,6 @@ github.com/filecoin-project/venus/venus-shared/api/chain/v0.FullNode <> github.c
 	- NetBlockRemove
 	- NetConnect
 	- NetConnectedness
-	- NetDisconnect
 	- NetFindPeer
 	- NetLimit
 	- NetPeerInfo
@@ -296,7 +295,6 @@ github.com/filecoin-project/venus/venus-shared/api/chain/v1.FullNode <> github.c
 	- NetBlockRemove
 	- NetConnect
 	- NetConnectedness
-	- NetDisconnect
 	- NetFindPeer
 	- NetLimit
 	- NetPeerInfo

diff --git a/venus-shared/compatible-checks/api-perm.txt b/venus-shared/compatible-checks/api-perm.txt
@@ -21,6 +21,7 @@ v0: github.com/filecoin-project/venus/venus-shared/api/chain/v0 <> github.com/fi
 	- IMessagePool.MpoolSelects
 	- IMultiSig.MsigCancelTxnHash
 	- INetwork.NetAddrsListen
+	- INetwork.NetDisconnect
 	- INetwork.NetworkConnect
 	- INetwork.NetworkFindPeer
 	- INetwork.NetworkFindProvidersAsync