New plugin interface: IStoragePlugin

src/neo/NeoSystem.cs

@@ -4,6 +4,7 @@
 using Neo.Network.P2P;
 using Neo.Network.RPC;
 using Neo.Persistence;
+using Neo.Persistence.Memory;
 using Neo.Plugins;
 using Neo.Wallets;
 using System;
@@ -30,10 +31,10 @@ public class NeoSystem : IDisposable
         private ChannelsConfig start_message = null;
         private bool suspend = false;
 
-        public NeoSystem(IStore store)
+        public NeoSystem(string storageEngine = null)
         {
-            this.store = store;
             Plugin.LoadPlugins(this);
+            this.store = storageEngine is null ? new Store() : Plugin.Storages[storageEngine].GetStore();
             this.Blockchain = ActorSystem.ActorOf(Ledger.Blockchain.Props(this, store));
             this.LocalNode = ActorSystem.ActorOf(Network.P2P.LocalNode.Props(this));
             this.TaskManager = ActorSystem.ActorOf(Network.P2P.TaskManager.Props(this));
@@ -49,6 +50,7 @@ public void Dispose()
             // Dispose will call ActorSystem.Terminate()
             ActorSystem.Dispose();
             ActorSystem.WhenTerminated.Wait();
+            store.Dispose();
         }
 
         public void EnsureStoped(IActorRef actor)

src/neo/Plugins/IStoragePlugin.cs

@@ -0,0 +1,9 @@
+using Neo.Persistence;
+
+namespace Neo.Plugins
+{
+    public interface IStoragePlugin
+    {
+        IStore GetStore();
+    }
+}

src/neo/Plugins/Plugin.cs

@@ -12,6 +12,7 @@ public abstract class Plugin : IDisposable
     {
         public static readonly List<Plugin> Plugins = new List<Plugin>();
         private static readonly List<ILogPlugin> Loggers = new List<ILogPlugin>();
+        internal static readonly Dictionary<string, IStoragePlugin> Storages = new Dictionary<string, IStoragePlugin>();
         internal static readonly List<IRpcPlugin> RpcPlugins = new List<IRpcPlugin>();
         internal static readonly List<IPersistencePlugin> PersistencePlugins = new List<IPersistencePlugin>();
         internal static readonly List<IP2PPlugin> P2PPlugins = new List<IP2PPlugin>();
@@ -48,6 +49,7 @@ protected Plugin()
             Plugins.Add(this);
 
             if (this is ILogPlugin logger) Loggers.Add(logger);
+            if (this is IStoragePlugin storage) Storages.Add(Name, storage);
             if (this is IP2PPlugin p2p) P2PPlugins.Add(p2p);
             if (this is IRpcPlugin rpc) RpcPlugins.Add(rpc);
             if (this is IPersistencePlugin persistence) PersistencePlugins.Add(persistence);

tests/neo.UnitTests/Consensus/UT_Consensus.cs

@@ -41,7 +41,7 @@ public void ConsensusService_Primary_Sends_PrepareRequest_After_OnStart()
             TestProbe subscriber = CreateTestProbe();
             var mockWallet = new Mock<Wallet>();
             mockWallet.Setup(p => p.GetAccount(It.IsAny<UInt160>())).Returns<UInt160>(p => new TestWalletAccount(p));
-            ConsensusContext context = new ConsensusContext(mockWallet.Object, TestBlockchain.Store);
+            ConsensusContext context = new ConsensusContext(mockWallet.Object, Blockchain.Singleton.Store);
 
             int timeIndex = 0;
             var timeValues = new[] {

tests/neo.UnitTests/Consensus/UT_ConsensusContext.cs

@@ -3,6 +3,7 @@
 using Moq;
 using Neo.Consensus;
 using Neo.IO;
+using Neo.Ledger;
 using Neo.Network.P2P.Payloads;
 using Neo.SmartContract.Native;
 using Neo.Wallets;
@@ -38,7 +39,7 @@ public void TestSetup()
                 _validatorKeys[x] = new KeyPair(pk);
             }
 
-            _context = new ConsensusContext(mockWallet.Object, TestBlockchain.Store)
+            _context = new ConsensusContext(mockWallet.Object, Blockchain.Singleton.Store)
             {
                 Validators = _validatorKeys.Select(u => u.PublicKey).ToArray()
             };

tests/neo.UnitTests/Ledger/UT_Blockchain.cs

@@ -37,21 +37,19 @@ public static TestHeader Cast(Header input)
     public class UT_Blockchain
     {
         private NeoSystem system;
-        private IStore store;
         Transaction txSample = Blockchain.GenesisBlock.Transactions[0];
 
         [TestInitialize]
         public void Initialize()
         {
             system = TestBlockchain.TheNeoSystem;
-            store = TestBlockchain.Store;
             Blockchain.Singleton.MemPool.TryAdd(txSample.Hash, txSample);
         }
 
         [TestMethod]
         public void TestConstructor()
         {
-            system.ActorSystem.ActorOf(Blockchain.Props(system, store)).Should().NotBeSameAs(system.Blockchain);
+            system.ActorSystem.ActorOf(Blockchain.Props(system, Blockchain.Singleton.Store)).Should().NotBeSameAs(system.Blockchain);
         }
 
         [TestMethod]

tests/neo.UnitTests/TestBlockchain.cs

@@ -1,21 +1,16 @@
 using Neo.Ledger;
-using Neo.Persistence;
 using System;
-using MemoryStore = Neo.Persistence.Memory.Store;
 
 namespace Neo.UnitTests
 {
     public static class TestBlockchain
     {
-        public static readonly IStore Store;
         public static readonly NeoSystem TheNeoSystem;
 
         static TestBlockchain()
         {
-            Store = new MemoryStore();
-
             Console.WriteLine("initialize NeoSystem");
-            TheNeoSystem = new NeoSystem(Store);
+            TheNeoSystem = new NeoSystem();
 
             // Ensure that blockchain is loaded