Fix akka warning

src/neo/Network/P2P/LocalNode.cs

@@ -1,6 +1,5 @@
 using Akka.Actor;
 using Neo.IO;
-using Neo.Ledger;
 using Neo.Network.P2P.Payloads;
 using System;
 using System.Collections.Concurrent;
@@ -214,6 +213,11 @@ private void OnRelayDirectly(IInventory inventory)
 
         private void OnSendDirectly(IInventory inventory) => SendToRemoteNodes(inventory);
 
+        protected override void OnTcpConnected(IActorRef connection)
+        {
+            connection.Tell(new RemoteNode.SendVersion());
+        }
+
         public static Props Props(NeoSystem system)
         {
             return Akka.Actor.Props.Create(() => new LocalNode(system));

src/neo/Network/P2P/Peer.cs

@@ -226,9 +226,14 @@ private void OnTcpConnected(IPEndPoint remote, IPEndPoint local)
                 Context.Watch(connection);
                 Sender.Tell(new Tcp.Register(connection));
                 ConnectedPeers.TryAdd(connection, remote);
+                OnTcpConnected(connection);
             }
         }
 
+        protected virtual void OnTcpConnected(IActorRef connection)
+        {
+        }
+
         /// <summary>
         /// Will be triggered when a Tcp.CommandFailed message is received.
         /// If it's a Tcp.Connect command, remove the related endpoint from ConnectingPeers.

src/neo/Network/P2P/RemoteNode.cs

@@ -16,6 +16,7 @@ namespace Neo.Network.P2P
     public class RemoteNode : Connection
     {
         internal class Relay { public IInventory Inventory; }
+        internal class SendVersion { }
 
         private readonly NeoSystem system;
         private readonly IActorRef protocol;
@@ -38,16 +39,6 @@ public RemoteNode(NeoSystem system, object connection, IPEndPoint remote, IPEndP
             this.system = system;
             this.protocol = Context.ActorOf(ProtocolHandler.Props(system));
             LocalNode.Singleton.RemoteNodes.TryAdd(Self, this);
-
-            var capabilities = new List<NodeCapability>
-            {
-                new FullNodeCapability(Blockchain.Singleton.Height)
-            };
-
-            if (LocalNode.Singleton.ListenerTcpPort > 0) capabilities.Add(new ServerCapability(NodeCapabilityType.TcpServer, (ushort)LocalNode.Singleton.ListenerTcpPort));
-            if (LocalNode.Singleton.ListenerWsPort > 0) capabilities.Add(new ServerCapability(NodeCapabilityType.WsServer, (ushort)LocalNode.Singleton.ListenerWsPort));
-
-            SendMessage(Message.Create(MessageCommand.Version, VersionPayload.Create(LocalNode.Nonce, LocalNode.UserAgent, capabilities.ToArray())));
         }
 
         /// <summary>
@@ -153,9 +144,25 @@ protected override void OnReceive(object message)
                 case PingPayload payload:
                     OnPingPayload(payload);
                     break;
+                case SendVersion _:
+                    OnSendVersion();
+                    break;
             }
         }
 
+        private void OnSendVersion()
+        {
+            var capabilities = new List<NodeCapability>
+            {
+                new FullNodeCapability(Blockchain.Singleton.Height)
+            };
+
+            if (LocalNode.Singleton.ListenerTcpPort > 0) capabilities.Add(new ServerCapability(NodeCapabilityType.TcpServer, (ushort)LocalNode.Singleton.ListenerTcpPort));
+            if (LocalNode.Singleton.ListenerWsPort > 0) capabilities.Add(new ServerCapability(NodeCapabilityType.WsServer, (ushort)LocalNode.Singleton.ListenerWsPort));
+
+            SendMessage(Message.Create(MessageCommand.Version, VersionPayload.Create(LocalNode.Nonce, LocalNode.UserAgent, capabilities.ToArray())));
+        }
+
         private void OnPingPayload(PingPayload payload)
         {
             if (payload.LastBlockIndex > LastBlockIndex)

tests/neo.UnitTests/Network/P2P/UT_RemoteNode.cs

@@ -31,8 +31,6 @@ public void RemoteNode_Test_Abort_DifferentMagic()
             var connectionTestProbe = CreateTestProbe();
             var remoteNodeActor = ActorOfAsTestActorRef(() => new RemoteNode(testBlockchain, connectionTestProbe, null, null));
 
-            connectionTestProbe.ExpectMsg<Tcp.Write>();
-
             var payload = new VersionPayload()
             {
                 UserAgent = "".PadLeft(1024, '0'),
@@ -58,8 +56,6 @@ public void RemoteNode_Test_Accept_IfSameMagic()
             var connectionTestProbe = CreateTestProbe();
             var remoteNodeActor = ActorOfAsTestActorRef(() => new RemoteNode(testBlockchain, connectionTestProbe, null, null));
 
-            connectionTestProbe.ExpectMsg<Tcp.Write>();
-
             var payload = new VersionPayload()
             {
                 UserAgent = "Unit Test".PadLeft(1024, '0'),