ActionEvaluator 상세 - planetarium/libplanet GitHub Wiki

        public IReadOnlyList<ICommittedActionEvaluation> Evaluate(
            IPreEvaluationBlock block,
            HashDigest<SHA256>? baseStateRootHash)
        {
            if (block.ProtocolVersion < BlockMetadata.PBFTProtocolVersion)
            {
                throw new BlockProtocolVersionNotSupportedException(
                    $"The native implementation does not support an evaluation of a block " +
                    $"#{block.Index} pre-evaluation hash {block.PreEvaluationHash} " +
                    $"with protocol version less than {BlockMetadata.PBFTProtocolVersion}: " +
                    $"{block.ProtocolVersion}",
                    block.ProtocolVersion);
            }

            _logger.Information(
                "Evaluating actions in the block #{BlockIndex} " +
                "pre-evaluation hash {PreEvaluationHash}...",
                block.Index,
                ByteUtil.Hex(block.PreEvaluationHash.ByteArray)
            );
            Stopwatch stopwatch = new Stopwatch();
            stopwatch.Start();
            try
            {
                IWorld previousState = _stateStore.GetWorld(baseStateRootHash);
                previousState = _stateStore.MigrateWorld(previousState, block.ProtocolVersion);

                var evaluations = ImmutableList<ActionEvaluation>.Empty;
                if (_policyActionsRegistry.BeginBlockActions.Length > 0)
                {
                    evaluations = evaluations.AddRange(EvaluatePolicyBeginBlockActions(
                        block, previousState
                    ));
                    previousState = evaluations.Last().OutputState;
                }

                evaluations = evaluations.AddRange(
                    EvaluateBlock(block, previousState).ToImmutableList()
                );

                if (_policyActionsRegistry.EndBlockActions.Length > 0)
                {
                    previousState = evaluations.Count > 0
                        ? evaluations.Last().OutputState
                        : previousState;
                    evaluations = evaluations.AddRange(EvaluatePolicyEndBlockActions(
                        block, previousState
                    ));
                }

                var committed = ToCommittedEvaluation(block, evaluations, baseStateRootHash);
                return committed;
            }
            catch (Exception e)
            {
                const string errorMessage =
                    "Failed to evaluate block #{BlockIndex} pre-evaluation hash " +
                    "pre-evaluation has {PreEvaluationHash}";
                _logger.Error(
                    e,
                    errorMessage,
                    block.Index,
                    ByteUtil.Hex(block.PreEvaluationHash.ByteArray));
                throw;
            }
            finally
            {
                _logger
                    .ForContext("Tag", "Metric")
                    .ForContext("Subtag", "BlockEvaluationDuration")
                    .Information(
                        "Actions in {TxCount} transactions for block #{BlockIndex} " +
                        "pre-evaluation hash {PreEvaluationHash} evaluated in {DurationMs} ms",
                        block.Transactions.Count,
                        block.Index,
                        ByteUtil.Hex(block.PreEvaluationHash.ByteArray),
                        stopwatch.ElapsedMilliseconds);
            }
        }