Send client quitting on network shutdown (#253)

ethereum/p2p/src/main/java/tech/pegasys/pantheon/ethereum/p2p/netty/NettyP2PNetwork.java

@@ -361,6 +361,7 @@ public final class NettyP2PNetwork implements P2PNetwork {
 
   @Override
   public void stop() {
+    sendClientQuittingToPeers();
     peerDiscoveryAgent.stop().join();
     peerBondedObserverId.ifPresent(peerDiscoveryAgent::removePeerBondedObserver);
     peerBondedObserverId = OptionalLong.empty();
@@ -369,6 +370,10 @@ public final class NettyP2PNetwork implements P2PNetwork {
     boss.shutdownGracefully();
   }
 
+  private void sendClientQuittingToPeers() {
+    connections.getPeerConnections().forEach(p -> p.disconnect(DisconnectReason.CLIENT_QUITTING));
+  }
+
   @Override
   public void awaitStop() {
     try {

ethereum/p2p/src/test/java/tech/pegasys/pantheon/ethereum/p2p/NettyP2PNetworkTest.java

@@ -15,6 +15,10 @@ package tech.pegasys.pantheon.ethereum.p2p;
 import static java.util.Collections.singletonList;
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.assertj.core.api.Assertions.assertThatThrownBy;
+import static org.mockito.ArgumentMatchers.eq;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
 
 import tech.pegasys.pantheon.crypto.SECP256K1;
 import tech.pegasys.pantheon.ethereum.p2p.api.P2PNetwork;
@@ -29,6 +33,7 @@ import tech.pegasys.pantheon.ethereum.p2p.peers.Endpoint;
 import tech.pegasys.pantheon.ethereum.p2p.peers.Peer;
 import tech.pegasys.pantheon.ethereum.p2p.peers.PeerBlacklist;
 import tech.pegasys.pantheon.ethereum.p2p.wire.Capability;
+import tech.pegasys.pantheon.ethereum.p2p.wire.PeerInfo;
 import tech.pegasys.pantheon.ethereum.p2p.wire.SubProtocol;
 import tech.pegasys.pantheon.ethereum.p2p.wire.messages.DisconnectMessage.DisconnectReason;
 import tech.pegasys.pantheon.util.bytes.BytesValue;
@@ -402,4 +407,53 @@ public final class NettyP2PNetworkTest {
       }
     };
   }
+
+  @Test
+  public void shouldSendClientQuittingWhenNetworkStops() {
+    NettyP2PNetwork nettyP2PNetwork = mockNettyP2PNetwork();
+    Peer peer = mockPeer();
+    PeerConnection peerConnection = mockPeerConnection();
+
+    nettyP2PNetwork.connect(peer).complete(peerConnection);
+    nettyP2PNetwork.stop();
+
+    verify(peerConnection).disconnect(eq(DisconnectReason.CLIENT_QUITTING));
+  }
+
+  private PeerConnection mockPeerConnection() {
+    PeerInfo peerInfo = mock(PeerInfo.class);
+    when(peerInfo.getNodeId()).thenReturn(BytesValue.fromHexString("0x00"));
+    PeerConnection peerConnection = mock(PeerConnection.class);
+    when(peerConnection.getPeer()).thenReturn(peerInfo);
+    return peerConnection;
+  }
+
+  private NettyP2PNetwork mockNettyP2PNetwork() {
+    final DiscoveryConfiguration noDiscovery = DiscoveryConfiguration.create().setActive(false);
+    final SECP256K1.KeyPair keyPair = SECP256K1.KeyPair.generate();
+    final Capability cap = Capability.create("eth", 63);
+    final NetworkingConfiguration networkingConfiguration =
+        NetworkingConfiguration.create()
+            .setDiscovery(noDiscovery)
+            .setSupportedProtocols(subProtocol())
+            .setRlpx(RlpxConfiguration.create().setBindPort(0));
+
+    return new NettyP2PNetwork(
+        mock(Vertx.class),
+        keyPair,
+        networkingConfiguration,
+        singletonList(cap),
+        () -> false,
+        new PeerBlacklist());
+  }
+
+  private Peer mockPeer() {
+    Peer peer = mock(Peer.class);
+    when(peer.getId())
+        .thenReturn(
+            BytesValue.fromHexString(
+                "0x00000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000"));
+    when(peer.getEndpoint()).thenReturn(new Endpoint("127.0.0.1", 30303, OptionalInt.of(30303)));
+    return peer;
+  }
 }