Merge pull request #2258 from greymistcube/bump/libplanet-to-3.4.0

⬆️ Bump libplanet to 3.4.0
planetarium · Oct 4, 2023 · 4ff2d48 · 4ff2d48
2 parents 01dda24 + f1a3919
commit 4ff2d48
Show file tree

Hide file tree

Showing 18 changed files with 113 additions and 336 deletions.
diff --git a/Lib9c b/Lib9c
diff --git a/Libplanet.Headless/Hosting/LibplanetNodeService.cs b/Libplanet.Headless/Hosting/LibplanetNodeService.cs
@@ -98,8 +98,7 @@ public LibplanetNodeService(
             (Store, StateStore) = LoadStore(
                 Properties.StorePath,
                 Properties.StoreType,
-                Properties.StoreStatesCacheSize,
-                Properties.NoReduceStore);
+                Properties.StoreStatesCacheSize);
 
             var chainIds = Store.ListChainIds().ToList();
             Log.Debug($"Number of chain ids: {chainIds.Count()}");
@@ -303,7 +302,7 @@ public override async Task StopAsync(CancellationToken cancellationToken)
             }
         }
 
-        protected (IStore, IStateStore) LoadStore(string path, string type, int statesCacheSize, bool noReduceStore = false)
+        protected (IStore, IStateStore) LoadStore(string path, string type, int statesCacheSize)
         {
             IStore store = null;
             if (type == "rocksdb")
@@ -344,10 +343,6 @@ public override async Task StopAsync(CancellationToken cancellationToken)
             }
 
             store ??= new DefaultStore(path, flush: false);
-            if (!noReduceStore)
-            {
-                store = new ReducedStore(store);
-            }
 
             IKeyValueStore stateKeyValueStore = new RocksDBKeyValueStore(Path.Combine(path, "states"));
             IStateStore stateStore = new TrieStateStore(stateKeyValueStore);

diff --git a/Libplanet.Headless/ReducedStore.cs b/Libplanet.Headless/ReducedStore.cs
diff --git a/NineChronicles.Headless.Executable/Commands/MarketCommand.cs b/NineChronicles.Headless.Executable/Commands/MarketCommand.cs
@@ -108,8 +108,8 @@ public void Query(
                 IEnumerable<(Transaction, ActionBase)> actions = block.Transactions
                     .Reverse()
                     .Where(tx => includeFails ||
-                                 !(chain.GetTxExecution(block.Hash, tx.Id) is { } e) ||
-                                 e is TxSuccess)
+                        !(chain.GetTxExecution(block.Hash, tx.Id) is { } e) ||
+                        !e.Fail)
                     .SelectMany(tx => tx.Actions is { } ca
                         ? ca.Reverse().Select(a => (tx, ToAction(a)))
                         : Enumerable.Empty<(Transaction, ActionBase)>());

diff --git a/NineChronicles.Headless.Executable/Commands/ReplayCommand.Privates.cs b/NineChronicles.Headless.Executable/Commands/ReplayCommand.Privates.cs
@@ -70,11 +70,6 @@ public ActionContext(
 
             public bool BlockAction => TxId is null;
 
-            public void PutLog(string log)
-            {
-                // NOTE: Not implemented yet. See also Lib9c.Tests.Action.ActionContext.PutLog().
-            }
-
             public void UseGas(long gas)
             {
             }
@@ -145,8 +140,14 @@ public ValidatorSet GetValidatorSet(BlockHash? offset)
 
             public IAccountState GetAccountState(BlockHash? offset)
             {
-                return new LocalCacheAccountState(_rocksDb, _source.GetAccountState, offset);
+                return new LocalCacheAccountState(
+                    _rocksDb,
+                    _source.GetAccountState,
+                    offset);
             }
+
+            public IAccountState GetAccountState(HashDigest<SHA256>? hash)
+                => _source.GetAccountState(hash);
         }
 
         private sealed class LocalCacheAccountState : IAccountState
@@ -158,11 +159,11 @@ private sealed class LocalCacheAccountState : IAccountState
 
             public LocalCacheAccountState(
                 RocksDb rocksDb,
-                Func<BlockHash?, IAccountState> sourceAccountStateGetter,
+                Func<BlockHash?, IAccountState> sourceAccountStateGetterWithBlockHash,
                 BlockHash? offset)
             {
                 _rocksDb = rocksDb;
-                _sourceAccountStateGetter = sourceAccountStateGetter;
+                _sourceAccountStateGetter = sourceAccountStateGetterWithBlockHash;
                 _offset = offset;
             }
 

diff --git a/NineChronicles.Headless.Executable/Commands/ReplayCommand.cs b/NineChronicles.Headless.Executable/Commands/ReplayCommand.cs
@@ -271,7 +271,7 @@ public int Blocks(
                         try
                         {
                             var rootHash = blockChain.DetermineBlockStateRootHash(block,
-                                out IReadOnlyList<IActionEvaluation> actionEvaluations);
+                                out IReadOnlyList<ICommittedActionEvaluation> actionEvaluations);
 
                             if (verbose)
                             {
@@ -301,8 +301,9 @@ public int Blocks(
                             outputSw?.WriteLine(msg);
 
                             var actionEvaluator = GetActionEvaluator(blockChain);
-                            var actionEvaluations = actionEvaluator.Evaluate(block);
-                            LoggingActionEvaluations(actionEvaluations, outputSw);
+                            var actionEvaluations = blockChain.DetermineBlockStateRootHash(block,
+                                out IReadOnlyList<ICommittedActionEvaluation> failedActionEvaluations);
+                            LoggingActionEvaluations(failedActionEvaluations, outputSw);
 
                             msg = $"- block #{block.Index} evaluating failed with ";
                             _console.Out.Write(msg);
@@ -558,7 +559,7 @@ private void LoggingAboutIncompleteBlockStatesException(
         }
 
         private void LoggingActionEvaluations(
-            IReadOnlyList<IActionEvaluation> actionEvaluations,
+            IReadOnlyList<ICommittedActionEvaluation> actionEvaluations,
             TextWriter? textWriter)
         {
             var count = actionEvaluations.Count;

diff --git a/NineChronicles.Headless.Executable/Commands/StateCommand.cs b/NineChronicles.Headless.Executable/Commands/StateCommand.cs
@@ -132,31 +132,20 @@ IStateStore stateStore
                     block.Index,
                     block.Hash
                 );
-                IReadOnlyList<IActionEvaluation> delta;
                 HashDigest<SHA256> stateRootHash = block.Index < 1
                     ? BlockChain.DetermineGenesisStateRootHash(
                         actionEvaluator,
                         preEvalBlock,
-                        out delta)
+                        out _)
                     : chain.DetermineBlockStateRootHash(
                         preEvalBlock,
-                        out delta);
+                        out _);
                 DateTimeOffset now = DateTimeOffset.Now;
                 if (invalidStateRootHashBlock is null && !stateRootHash.Equals(block.StateRootHash))
                 {
-                    string blockDump = DumpBencodexToFile(
-                        block.MarshalBlock(),
-                        $"block_{block.Index}_{block.Hash}"
-                    );
-                    string deltaDump = DumpBencodexToFile(
-                        new Dictionary(
-                            GetTotalDelta(delta, ToStateKey, ToFungibleAssetKey, ToTotalSupplyKey, ValidatorSetKey)),
-                        $"delta_{block.Index}_{block.Hash}"
-                    );
                     string message =
                         $"Unexpected state root hash for block #{block.Index} {block.Hash}.\n" +
-                        $"  Expected: {block.StateRootHash}\n  Actual:   {stateRootHash}\n" +
-                        $"  Block file: {blockDump}\n  Evaluated delta file: {deltaDump}\n";
+                        $"  Expected: {block.StateRootHash}\n  Actual:   {stateRootHash}\n";
                     if (!bypassStateRootHashCheck)
                     {
                         throw new CommandExitedException(message, 1);

diff --git a/NineChronicles.Headless.Executable/Program.cs b/NineChronicles.Headless.Executable/Program.cs
@@ -480,6 +480,7 @@ IActionLoader MakeSingleActionLoader()
                         standaloneContext.NineChroniclesNodeService!.ActionRenderer,
                         standaloneContext.NineChroniclesNodeService!.ExceptionRenderer,
                         standaloneContext.NineChroniclesNodeService!.NodeStatusRenderer,
+                        standaloneContext.NineChroniclesNodeService!.BlockChain,
                         IPAddress.Loopback.ToString(),
                         rpcProperties.RpcListenPort,
                         context,
@@ -509,6 +510,7 @@ IActionLoader MakeSingleActionLoader()
                         standaloneContext.NineChroniclesNodeService!.ActionRenderer,
                         standaloneContext.NineChroniclesNodeService!.ExceptionRenderer,
                         standaloneContext.NineChroniclesNodeService!.NodeStatusRenderer,
+                        standaloneContext.NineChroniclesNodeService!.BlockChain,
                         IPAddress.Loopback.ToString(),
                         0,
                         context,

diff --git a/NineChronicles.Headless.Tests/GraphQLStartupTest.cs b/NineChronicles.Headless.Tests/GraphQLStartupTest.cs
@@ -23,6 +23,7 @@ public GraphQLStartupTest()
                 new ActionRenderer(),
                 new ExceptionRenderer(),
                 new NodeStatusRenderer(),
+                standaloneContext!.BlockChain,
                 "",
                 0,
                 new RpcContext(),

diff --git a/NineChronicles.Headless.Tests/GraphTypes/GraphQLTestBase.cs b/NineChronicles.Headless.Tests/GraphTypes/GraphQLTestBase.cs
@@ -115,6 +115,7 @@ public GraphQLTestBase(ITestOutputHelper output)
                 ncService.ActionRenderer,
                 ncService.ExceptionRenderer,
                 ncService.NodeStatusRenderer,
+                ncService.BlockChain,
                 "",
                 0,
                 new RpcContext(),
+1 −9		.Lib9c.Benchmarks/Program.cs
+4 −5		.Lib9c.Tests/Action/ActionEvaluationTest.cs
+218 −0		.Lib9c.Tests/Action/ClaimItemsTest.cs
+1 −1		.Lib9c.Tests/Action/MockStateDelta.cs
+3 −0		.Lib9c.Tests/Action/Snapshot/TransferAsset0SnapshotTest.cs
+4 −4		.Lib9c.Tests/Action/TransferAssetTest.cs
+402 −0		.Lib9c.Tests/Action/TransferAssets2Test.cs
+78 −1		.Lib9c.Tests/Action/TransferAssetsTest.cs
+1 −1		.Lib9c.Tools/SubCommand/Market.cs
+4 −18		.Lib9c.Tools/SubCommand/State.cs
+1 −1		.Libplanet
+9 −1		.Libplanet.Extensions.RemoteBlockChainStates/RemoteBlockChainStates.cs
+8 −7		Lib9c.MessagePack/Action/NCActionEvaluation.cs
+35 −0		Lib9c.MessagePack/Formatters/HashDigestFormatter.cs
+4 −3		Lib9c.Renderers/ActionEvaluation.cs
+5 −26		Lib9c.Renderers/Renderers/ActionRenderer.cs
+109 −0		Lib9c/Action/ClaimItems.cs
+11 −0		Lib9c/Action/IClaimItems.cs
+1 −1		Lib9c/Action/Stake.cs
+14 −9		Lib9c/Action/TransferAsset.cs
+2 −1		Lib9c/Action/TransferAssets.cs
+168 −0		Lib9c/Action/TransferAssets2.cs
+2 −0		Lib9c/ActionObsoleteConfig.cs
+3 −0		Lib9c/SerializeKeys.cs