feat: Add IStoreService

sdk/node/Libplanet.Node.Extensions/LibplanetServicesExtensions.cs

@@ -41,6 +41,8 @@ public static ILibplanetNodeBuilder AddLibplanetNode(
         services.AddSingleton<IConfigureOptions<SoloOptions>, SoloOptionsConfigurator>();
 
         services.AddSingleton<PolicyService>();
+        services.AddSingleton<StoreService>();
+        services.AddSingleton(s => (IStoreService)s.GetRequiredService<StoreService>());
         services.AddSingleton<IBlockChainService, BlockChainService>();
         services.AddSingleton<IReadChainService, ReadChainService>();
         services.AddSingleton<TransactionService>();

sdk/node/Libplanet.Node.Tests/Services/BlockChainServiceTest.cs

@@ -25,12 +25,15 @@ public void Create_Test()
 
         var serviceProvider = services.BuildServiceProvider();
         var policyService = new PolicyService();
-        var logger = new NullLoggerFactory().CreateLogger<BlockChainService>();
+        var loggerFactory = new NullLoggerFactory();
+        var logger = loggerFactory.CreateLogger<BlockChainService>();
         var genesisOptions = serviceProvider.GetRequiredService<IOptions<GenesisOptions>>();
         var storeOptions = serviceProvider.GetRequiredService<IOptions<StoreOptions>>();
+        var storeService = new StoreService(
+            storeOptions, loggerFactory.CreateLogger<StoreService>());
         var blockChainService = new BlockChainService(
             genesisOptions: genesisOptions,
-            storeOptions: storeOptions,
+            storeService: storeService,
             policyService: policyService,
             actionLoaderProviders: [],
             logger: logger);

sdk/node/Libplanet.Node/Services/BlockChainService.cs

@@ -36,7 +36,7 @@ internal sealed class BlockChainService : IBlockChainService, IActionRenderer
 
     public BlockChainService(
         IOptions<GenesisOptions> genesisOptions,
-        IOptions<StoreOptions> storeOptions,
+        IStoreService storeService,
         PolicyService policyService,
         IEnumerable<IActionLoaderProvider> actionLoaderProviders,
         ILogger<BlockChainService> logger)
@@ -45,7 +45,8 @@ public BlockChainService(
         _logger = logger;
         _blockChain = CreateBlockChain(
             genesisOptions: genesisOptions.Value,
-            storeOptions: storeOptions.Value,
+            store: storeService.Store,
+            stateStore: storeService.StateStore,
             stagePolicy: policyService.StagePolicy,
             renderers: [this],
             actionLoaders: [.. actionLoaderProviders.Select(item => item.GetActionLoader())]);
@@ -91,12 +92,12 @@ void Action(object? state)
 
     private static BlockChain CreateBlockChain(
         GenesisOptions genesisOptions,
-        StoreOptions storeOptions,
+        IStore store,
+        IStateStore stateStore,
         IStagePolicy stagePolicy,
         IRenderer[] renderers,
         IActionLoader[] actionLoaders)
     {
-        var (store, stateStore) = CreateStore(storeOptions);
         var actionLoader = new AggregateTypedActionLoader(actionLoaders);
         var actionEvaluator = new ActionEvaluator(
             policyActionsRegistry: new(),

sdk/node/Libplanet.Node/Services/IStoreService.cs

@@ -0,0 +1,10 @@
+using Libplanet.Store;
+
+namespace Libplanet.Node.Services;
+
+public interface IStoreService
+{
+    IStore Store { get; }
+
+    IStateStore StateStore { get; }
+}

sdk/node/Libplanet.Node/Services/StoreService.cs

@@ -0,0 +1,50 @@
+using Libplanet.Node.Options;
+using Libplanet.RocksDBStore;
+using Libplanet.Store;
+using Libplanet.Store.Trie;
+using Microsoft.Extensions.Logging;
+using Microsoft.Extensions.Options;
+
+namespace Libplanet.Node.Services;
+
+internal sealed class StoreService : IStoreService
+{
+    public StoreService(
+        IOptions<StoreOptions> storeOptions,
+        ILogger<StoreService> logger)
+    {
+        (Store, KeyValueStore) = CreateStore(storeOptions.Value);
+        StateStore = new TrieStateStore(KeyValueStore);
+    }
+
+    public IStore Store { get; }
+
+    public IKeyValueStore KeyValueStore { get; }
+
+    public IStateStore StateStore { get; }
+
+    private static (IStore, IKeyValueStore) CreateStore(StoreOptions storeOptions)
+    {
+        return storeOptions.Type switch
+        {
+            StoreType.RocksDB => CreateRocksDBStore(storeOptions),
+            StoreType.InMemory => CreateMemoryStore(),
+            _ => throw new NotSupportedException($"Unsupported store type: {storeOptions.Type}"),
+        };
+    }
+
+    private static (MemoryStore, MemoryKeyValueStore) CreateMemoryStore()
+    {
+        var store = new MemoryStore();
+        var keyValueStore = new MemoryKeyValueStore();
+        return (store, keyValueStore);
+    }
+
+    private static (RocksDBStore.RocksDBStore, RocksDBKeyValueStore) CreateRocksDBStore(
+        StoreOptions storeOptions)
+    {
+        var store = new RocksDBStore.RocksDBStore(storeOptions.StoreName);
+        var keyValueStore = new RocksDBKeyValueStore(storeOptions.StateStoreName);
+        return (store, keyValueStore);
+    }
+}