Add GetFullBlocks P2P logic (enable fixing #522)

neo/Network/P2P/Message.cs

@@ -74,6 +74,9 @@ private void DecompressPayload()
                 case MessageCommand.GetData:
                     Payload = decompressed.AsSerializable<InvPayload>();
                     break;
+                case MessageCommand.GetBlockData:
+                    Payload = decompressed.AsSerializable<GetBlockDataPayload>();
+                    break;
                 case MessageCommand.Transaction:
                     Payload = decompressed.AsSerializable<Transaction>();
                     break;

neo/Network/P2P/MessageCommand.cs

@@ -19,6 +19,7 @@ public enum MessageCommand : byte
         Mempool = 0x25,
         Inv = 0x27,
         GetData = 0x28,
+        GetBlockData = 0x29,
         NotFound = 0x2a,
         Transaction = 0x2b,
         Block = 0x2c,

neo/Network/P2P/Payloads/GetBlockDataPayload.cs

@@ -0,0 +1,37 @@
+using Neo.IO;
+using System;
+using System.IO;
+
+namespace Neo.Network.P2P.Payloads
+{
+    public class GetBlockDataPayload : ISerializable
+    {
+        private const ushort MaxBlocksCount = 500;
+        public uint IndexStart;
+        public ushort Count;
+
+        public int Size => sizeof(uint) + sizeof(ushort);
+
+        public static GetBlockDataPayload Create(uint index_start, ushort count)
+        {
+            return new GetBlockDataPayload
+            {
+                IndexStart = index_start,
+                Count = count
+            };
+        }
+
+        void ISerializable.Deserialize(BinaryReader reader)
+        {
+            IndexStart = reader.ReadUInt32();
+            Count = reader.ReadUInt16();
+            if (Count == 0 || Count > MaxBlocksCount) throw new FormatException();
+        }
+
+        void ISerializable.Serialize(BinaryWriter writer)
+        {
+            writer.Write(IndexStart);
+            writer.Write(Count);
+        }
+    }
+}

neo/Network/P2P/ProtocolHandler.cs

@@ -80,6 +80,9 @@ protected override void OnReceive(object message)
                 case MessageCommand.GetBlocks:
                     OnGetBlocksMessageReceived((GetBlocksPayload)msg.Payload);
                     break;
+                case MessageCommand.GetBlockData:
+                    OnGetBlockDataMessageReceived((GetBlockDataPayload)msg.Payload);
+                    break;
                 case MessageCommand.GetData:
                     OnGetDataMessageReceived((InvPayload)msg.Payload);
                     break;
@@ -175,6 +178,26 @@ private void OnGetBlocksMessageReceived(GetBlocksPayload payload)
             Context.Parent.Tell(Message.Create(MessageCommand.Inv, InvPayload.Create(InventoryType.Block, hashes.ToArray())));
         }
 
+        private void OnGetBlockDataMessageReceived(GetBlockDataPayload payload)
+        {
+            for (uint i = payload.IndexStart, max = payload.IndexStart + payload.Count; i < max; i++)
+            {
+                Block block = Blockchain.Singleton.Store.GetBlock(i);
+                if (block == null)
+                    break;
+
+                if (bloom_filter == null)
+                {
+                    Context.Parent.Tell(Message.Create(MessageCommand.Block, block));
+                }
+                else
+                {
+                    BitArray flags = new BitArray(block.Transactions.Select(p => bloom_filter.Test(p)).ToArray());
+                    Context.Parent.Tell(Message.Create(MessageCommand.MerkleBlock, MerkleBlockPayload.Create(block, flags)));
+                }
+            }
+        }
+
         private void OnGetDataMessageReceived(InvPayload payload)
         {
             UInt256[] hashes = payload.Hashes.Where(p => sentHashes.Add(p)).ToArray();