Restore transactions from saved consensus context

neo/Consensus/ConsensusService.cs

@@ -430,13 +430,21 @@ private void OnStart(Start options)
         {
             Log("OnStart");
             started = true;
-            bool loadedState = !options.IgnoreRecoveryLogs && context.Load(store);
-            if (loadedState && context.State.HasFlag(ConsensusState.CommitSent))
+            if (!options.IgnoreRecoveryLogs && context.Load(store))
             {
-                CheckPreparations();
-                return;
+                if (context.Transactions != null)
+                {
+                    Sender.Ask<Blockchain.FillCompleted>(new Blockchain.FillMemoryPool
+                    {
+                        Transactions = context.Transactions.Values
+                    }).Wait();
+                }
+                if (context.State.HasFlag(ConsensusState.CommitSent))
+                {
+                    CheckPreparations();
+                    return;
+                }
             }
-
             InitializeConsensus(0);
             // Issue a ChangeView with NewViewNumber of 0 to request recovery messages on start-up.
             if (context.BlockIndex == Blockchain.Singleton.HeaderHeight + 1)

neo/Ledger/Blockchain.cs

@@ -24,6 +24,8 @@ public class ApplicationExecuted { public Transaction Transaction; public Applic
         public class PersistCompleted { public Block Block; }
         public class Import { public IEnumerable<Block> Blocks; }
         public class ImportCompleted { }
+        public class FillMemoryPool { public IEnumerable<Transaction> Transactions; }
+        public class FillCompleted { }
 
         public static readonly uint SecondsPerBlock = ProtocolSettings.Default.SecondsPerBlock;
         public const uint DecrementInterval = 2000000;
@@ -253,6 +255,15 @@ private void AddUnverifiedBlockToCache(Block block)
             blocks.AddLast(block);
         }
 
+        private void OnFillMemoryPool(IEnumerable<Transaction> transactions)
+        {
+            //TODO: Fill the memory pool with the transactions from the consensus context
+            // Step 1: Remove all the transactions in the memory pool
+            // Step 2: Add the transactions from the consensus context to the memory pool
+            // Step 3: Add the original transactions to the memory pool
+            Sender.Tell(new FillCompleted());
+        }
+
         private RelayResultReason OnNewBlock(Block block)
         {
             if (block.Index <= Height)
@@ -406,6 +417,9 @@ protected override void OnReceive(object message)
                 case Import import:
                     OnImport(import.Blocks);
                     break;
+                case FillMemoryPool fill:
+                    OnFillMemoryPool(fill.Transactions);
+                    break;
                 case Header[] headers:
                     OnNewHeaders(headers);
                     break;

neo/NeoSystem.cs

@@ -68,7 +68,7 @@ internal void ResumeNodeStartup()
         public void StartConsensus(Wallet wallet, Store consensus_store = null, bool ignoreRecoveryLogs = false)
         {
             Consensus = ActorSystem.ActorOf(ConsensusService.Props(this.LocalNode, this.TaskManager, consensus_store ?? store, wallet));
-            Consensus.Tell(new ConsensusService.Start { IgnoreRecoveryLogs = ignoreRecoveryLogs });
+            Consensus.Tell(new ConsensusService.Start { IgnoreRecoveryLogs = ignoreRecoveryLogs }, Blockchain);
         }
 
         public void StartNode(int port = 0, int wsPort = 0, int minDesiredConnections = Peer.DefaultMinDesiredConnections,