feat: add txactions

Libplanet.Action/PolicyActionsGetterCollection.cs

@@ -1,4 +1,5 @@
 using Libplanet.Types.Blocks;
+using Libplanet.Types.Tx;
 
 namespace Libplanet.Action
 {
@@ -17,16 +18,32 @@ public class PolicyActionsGetterCollection
         /// evaluate at the end for each <see cref="IPreEvaluationBlock"/> that gets evaluated.
         /// Note the order of the returned list determines the execution order.
         /// </param>
+        /// <param name="beginTxActionsGetter">A delegator to get policy block actions to
+        /// evaluate at the beginning for each <see cref="Transaction"/> that gets evaluated.
+        /// Note the order of the returned list determines the execution order.
+        /// </param>
+        /// <param name="endTxActionsGetter">A delegator to get policy block actions to
+        /// evaluate at the end for each <see cref="Transaction"/> that gets evaluated.
+        /// Note the order of the returned list determines the execution order.
+        /// </param>
         public PolicyActionsGetterCollection(
             PolicyActionsGetter beginBlockActionsGetter,
-            PolicyActionsGetter endBlockActionsGetter)
+            PolicyActionsGetter endBlockActionsGetter,
+            PolicyActionsGetter beginTxActionsGetter,
+            PolicyActionsGetter endTxActionsGetter)
         {
             BeginBlockActionsGetter = beginBlockActionsGetter;
             EndBlockActionsGetter = endBlockActionsGetter;
+            BeginTxActionsGetter = beginTxActionsGetter;
+            EndTxActionsGetter = endTxActionsGetter;
         }
 
         public PolicyActionsGetter BeginBlockActionsGetter { get; }
 
         public PolicyActionsGetter EndBlockActionsGetter { get; }
+
+        public PolicyActionsGetter BeginTxActionsGetter { get; }
+
+        public PolicyActionsGetter EndTxActionsGetter { get; }
     }
 }

Libplanet.Benchmarks/AppendBlock.cs

@@ -31,7 +31,9 @@ public AppendBlock()
                 new ActionEvaluator(
                     policyActionsGetterCollection: new PolicyActionsGetterCollection(
                         beginBlockActionsGetter: _ => ImmutableArray<IAction>.Empty,
-                        endBlockActionsGetter: _ => ImmutableArray<IAction>.Empty),
+                        endBlockActionsGetter: _ => ImmutableArray<IAction>.Empty,
+                        beginTxActionsGetter: _ => ImmutableArray<IAction>.Empty,
+                        endTxActionsGetter: _ => ImmutableArray<IAction>.Empty),
                     stateStore: fx.StateStore,
                     actionTypeLoader: new SingleActionLoader(typeof(DumbAction))));
             _privateKey = new PrivateKey();

Libplanet.Benchmarks/BlockChain.cs

@@ -37,7 +37,9 @@ public void SetupChain()
                 new ActionEvaluator(
                     policyActionsGetterCollection: new PolicyActionsGetterCollection(
                         beginBlockActionsGetter: _ => ImmutableArray<IAction>.Empty,
-                        endBlockActionsGetter: _ => ImmutableArray<IAction>.Empty),
+                        endBlockActionsGetter: _ => ImmutableArray<IAction>.Empty,
+                        beginTxActionsGetter: _ => ImmutableArray<IAction>.Empty,
+                        endTxActionsGetter: _ => ImmutableArray<IAction>.Empty),
                     stateStore: _fx.StateStore,
                     actionTypeLoader: new SingleActionLoader(typeof(DumbAction))));
             var key = new PrivateKey();

Libplanet.Benchmarks/ProposeBlock.cs

@@ -30,7 +30,9 @@ public ProposeBlock()
                 new ActionEvaluator(
                     policyActionsGetterCollection: new PolicyActionsGetterCollection(
                         beginBlockActionsGetter: _ => ImmutableArray<IAction>.Empty,
-                        endBlockActionsGetter: _ => ImmutableArray<IAction>.Empty),
+                        endBlockActionsGetter: _ => ImmutableArray<IAction>.Empty,
+                        beginTxActionsGetter: _ => ImmutableArray<IAction>.Empty,
+                        endTxActionsGetter: _ => ImmutableArray<IAction>.Empty),
                     stateStore: fx.StateStore,
                     actionTypeLoader: new SingleActionLoader(typeof(DumbAction))));
             _privateKey = new PrivateKey();

Libplanet.Explorer.Executable/Program.cs

@@ -202,7 +202,9 @@ If omitted (default) explorer only the local blockchain store.")]
                         new ActionEvaluator(
                             new PolicyActionsGetterCollection(
                                 _ => policy.BeginBlockActions,
-                                _ => policy.EndBlockActions),
+                                _ => policy.EndBlockActions,
+                                _ => policy.BeginTxActions,
+                                _ => policy.EndTxActions),
                             stateStore,
                             new SingleActionLoader(typeof(NullAction))));
                 Startup.PreloadedSingleton = false;
@@ -391,6 +393,10 @@ public DumbBlockPolicy(BlockPolicy blockPolicy)
 
             public ImmutableArray<IAction> EndBlockActions => _impl.EndBlockActions;
 
+            public ImmutableArray<IAction> BeginTxActions => _impl.BeginTxActions;
+
+            public ImmutableArray<IAction> EndTxActions => _impl.EndTxActions;
+
             public int GetMinTransactionsPerBlock(long index) =>
                 _impl.GetMinTransactionsPerBlock(index);
 

Libplanet.Explorer.Tests/GeneratedBlockChainFixture.cs

@@ -73,7 +73,9 @@ public GeneratedBlockChainFixture(
         var actionEvaluator = new ActionEvaluator(
             new PolicyActionsGetterCollection(
                 _ => policy.BeginBlockActions,
-                _ => policy.EndBlockActions),
+                _ => policy.EndBlockActions,
+                _ => policy.BeginTxActions,
+                _ => policy.EndTxActions),
             stateStore,
             TypedActionLoader.Create(typeof(SimpleAction).Assembly, typeof(SimpleAction)));
         Block genesisBlock = BlockChain.ProposeGenesisBlock(

Libplanet.Extensions.Cocona/BlockPolicyParams.cs

@@ -77,6 +77,12 @@ public ImmutableArray<IAction> GetBeginBlockActions() =>
     public ImmutableArray<IAction> GetEndBlockActions() =>
         GetEndBlockActions(LoadAssemblies());
 
+    public ImmutableArray<IAction> GetBeginTxActions() =>
+        GetBeginTxActions(LoadAssemblies());
+
+    public ImmutableArray<IAction> GetEndTxActions() =>
+        GetEndTxActions(LoadAssemblies());
+
     [SuppressMessage(
         "Major Code Smell",
         "S3011:Reflection should not be used to increase accessibility of classes, methods, " +
@@ -180,17 +186,79 @@ internal ImmutableArray<IAction> GetEndBlockActions(Assembly[] assemblies)
         if (propertyInfo is null)
         {
             var message = $"The policy type "
-                + $"'{policy.GetType().FullName}' does not have a "
-                + $"'{nameof(IBlockPolicy.EndBlockActions)}' property.";
+                          + $"'{policy.GetType().FullName}' does not have a "
+                          + $"'{nameof(IBlockPolicy.EndBlockActions)}' property.";
             throw new InvalidOperationException(message);
         }
 
         var value = propertyInfo.GetValue(policy);
         if (value is null)
         {
             var message = $"The value of property "
-                + $"'{nameof(IBlockPolicy.EndBlockActions)}' of type "
-                + $"'{policy.GetType().FullName}' cannot be null.";
+                          + $"'{nameof(IBlockPolicy.EndBlockActions)}' of type "
+                          + $"'{policy.GetType().FullName}' cannot be null.";
+            throw new InvalidOperationException(message);
+        }
+
+        return (ImmutableArray<IAction>)value;
+    }
+
+    internal ImmutableArray<IAction> GetBeginTxActions(Assembly[] assemblies)
+    {
+        object? policy = GetBlockPolicy(assemblies);
+        if (policy is null)
+        {
+            return ImmutableArray<IAction>.Empty;
+        }
+
+        PropertyInfo? propertyInfo = policy
+            .GetType()
+            .GetProperty(nameof(IBlockPolicy.BeginTxActions));
+        if (propertyInfo is null)
+        {
+            var message = $"The policy type "
+                          + $"'{policy.GetType().FullName}' does not have a "
+                          + $"'{nameof(IBlockPolicy.BeginTxActions)}' property.";
+            throw new InvalidOperationException(message);
+        }
+
+        var value = propertyInfo.GetValue(policy);
+        if (value is null)
+        {
+            var message = $"The value of property "
+                          + $"'{nameof(IBlockPolicy.BeginTxActions)}' of type "
+                          + $"'{policy.GetType().FullName}' cannot be null.";
+            throw new InvalidOperationException(message);
+        }
+
+        return (ImmutableArray<IAction>)value;
+    }
+
+    internal ImmutableArray<IAction> GetEndTxActions(Assembly[] assemblies)
+    {
+        object? policy = GetBlockPolicy(assemblies);
+        if (policy is null)
+        {
+            return ImmutableArray<IAction>.Empty;
+        }
+
+        PropertyInfo? propertyInfo = policy
+            .GetType()
+            .GetProperty(nameof(IBlockPolicy.EndTxActions));
+        if (propertyInfo is null)
+        {
+            var message = $"The policy type "
+                          + $"'{policy.GetType().FullName}' does not have a "
+                          + $"'{nameof(IBlockPolicy.EndTxActions)}' property.";
+            throw new InvalidOperationException(message);
+        }
+
+        var value = propertyInfo.GetValue(policy);
+        if (value is null)
+        {
+            var message = $"The value of property "
+                          + $"'{nameof(IBlockPolicy.EndTxActions)}' of type "
+                          + $"'{policy.GetType().FullName}' cannot be null.";
             throw new InvalidOperationException(message);
         }
 

Libplanet.Extensions.Cocona/Commands/BlockCommand.cs

@@ -158,10 +158,14 @@ public void GenerateGenesis(
 
         var beginBlockActions = blockPolicyParams.GetBeginBlockActions();
         var endBlockActions = blockPolicyParams.GetEndBlockActions();
+        var beginTxActions = blockPolicyParams.GetEndBlockActions();
+        var endTxActions = blockPolicyParams.GetEndBlockActions();
         var actionEvaluator = new ActionEvaluator(
             new PolicyActionsGetterCollection(
                 _ => beginBlockActions,
-                _ => endBlockActions),
+                _ => endBlockActions,
+                _ => beginTxActions,
+                _ => endTxActions),
             new TrieStateStore(new DefaultKeyValueStore(null)),
             new SingleActionLoader(typeof(NullAction)));
         Block genesis = BlockChain.ProposeGenesisBlock(

Libplanet.Net.Tests/Consensus/ConsensusReactorTest.cs

@@ -71,7 +71,9 @@ public async void StartAsync()
                     new ActionEvaluator(
                         policyActionsGetterCollection: new PolicyActionsGetterCollection(
                             beginBlockActionsGetter: _ => TestUtils.Policy.BeginBlockActions,
-                            endBlockActionsGetter: _ => TestUtils.Policy.EndBlockActions),
+                            endBlockActionsGetter: _ => TestUtils.Policy.EndBlockActions,
+                            beginTxActionsGetter: _ => TestUtils.Policy.BeginTxActions,
+                            endTxActionsGetter: _ => TestUtils.Policy.EndTxActions),
                         stateStore: stateStore,
                         actionTypeLoader: new SingleActionLoader(typeof(DumbAction))));
             }

Libplanet.Net.Tests/SwarmTest.Broadcast.cs

@@ -472,7 +472,9 @@ public async Task BroadcastTxAsyncMany()
                     new ActionEvaluator(
                         policyActionsGetterCollection: new PolicyActionsGetterCollection(
                             beginBlockActionsGetter: _ => policy.BeginBlockActions,
-                            endBlockActionsGetter_ => policy.EndBlockActions),
+                            endBlockActionsGetter: _ => policy.EndBlockActions,
+                            beginTxActionsGetter: _ => policy.BeginTxActions,
+                            endTxActionsGetter: _ => policy.EndTxActions),
                         stateStore: fxs[i].StateStore,
                         actionTypeLoader: new SingleActionLoader(typeof(DumbAction))));
                 swarms[i] = await CreateSwarm(blockChains[i]).ConfigureAwait(false);

Libplanet.RocksDBStore.Tests/RocksDBStoreTest.cs

@@ -89,7 +89,9 @@ public void ReopenStoreAfterDispose()
                     new ActionEvaluator(
                         policyActionsGetterCollection: new PolicyActionsGetterCollection(
                             beginBlockActionsGetter: _ => ImmutableArray<IAction>.Empty,
-                            endBlockActionsGetter: _ => ImmutableArray<IAction>.Empty),
+                            endBlockActionsGetter: _ => ImmutableArray<IAction>.Empty,
+                            beginTxActionsGetter: _ => ImmutableArray<IAction>.Empty,
+                            endTxActionsGetter: _ => ImmutableArray<IAction>.Empty),
                         stateStore: stateStore,
                         actionTypeLoader: new SingleActionLoader(typeof(DumbAction))));
                 store.Dispose();

Libplanet.Tests/Action/ActionEvaluatorTest.cs

@@ -95,7 +95,9 @@ public void Idempotent()
             var actionEvaluator = new ActionEvaluator(
                 new PolicyActionsGetterCollection(
                     beginBlockActionsGetter: _ => ImmutableArray<IAction>.Empty,
-                    endBlockActionsGetter: _ => ImmutableArray<IAction>.Empty),
+                    endBlockActionsGetter: _ => ImmutableArray<IAction>.Empty,
+                    beginTxActionsGetter: _ => ImmutableArray<IAction>.Empty,
+                    endTxActionsGetter: _ => ImmutableArray<IAction>.Empty),
                 stateStore,
                 new SingleActionLoader(typeof(RandomAction)));
             Block stateRootBlock = noStateRootBlock.Sign(
@@ -300,7 +302,9 @@ DumbAction MakeAction(Address address, char identifier, Address? transferTo = nu
             var actionEvaluator = new ActionEvaluator(
                 new PolicyActionsGetterCollection(
                     beginBlockActionsGetter: _ => ImmutableArray<IAction>.Empty,
-                    endBlockActionsGetter: _ => ImmutableArray<IAction>.Empty),
+                    endBlockActionsGetter: _ => ImmutableArray<IAction>.Empty,
+                    beginTxActionsGetter: _ => ImmutableArray<IAction>.Empty,
+                    endTxActionsGetter: _ => ImmutableArray<IAction>.Empty),
                 stateStore: new TrieStateStore(new MemoryKeyValueStore()),
                 actionTypeLoader: new SingleActionLoader(typeof(DumbAction)));
 
@@ -584,7 +588,9 @@ public void EvaluateTx()
             var actionEvaluator = new ActionEvaluator(
                 new PolicyActionsGetterCollection(
                     beginBlockActionsGetter: _ => ImmutableArray<IAction>.Empty,
-                    endBlockActionsGetter: _ => ImmutableArray<IAction>.Empty),
+                    endBlockActionsGetter: _ => ImmutableArray<IAction>.Empty,
+                    beginTxActionsGetter: _ => ImmutableArray<IAction>.Empty,
+                    endTxActionsGetter: _ => ImmutableArray<IAction>.Empty),
                 stateStore: new TrieStateStore(new MemoryKeyValueStore()),
                 actionTypeLoader: new SingleActionLoader(typeof(DumbAction)));
 
@@ -687,7 +693,9 @@ public void EvaluateTxResultThrowingException()
             var actionEvaluator = new ActionEvaluator(
                 new PolicyActionsGetterCollection(
                     beginBlockActionsGetter: _ => ImmutableArray<IAction>.Empty,
-                    endBlockActionsGetter: _ => ImmutableArray<IAction>.Empty),
+                    endBlockActionsGetter: _ => ImmutableArray<IAction>.Empty,
+                    beginTxActionsGetter: _ => ImmutableArray<IAction>.Empty,
+                    endTxActionsGetter: _ => ImmutableArray<IAction>.Empty),
                 stateStore: new TrieStateStore(new MemoryKeyValueStore()),
                 actionTypeLoader: new SingleActionLoader(typeof(ThrowException))
             );

Libplanet.Tests/Blockchain/BlockChainTest.Append.cs

@@ -464,7 +464,9 @@ TxPolicyViolationException IsSignerValid(
                     new ActionEvaluator(
                         new PolicyActionsGetterCollection(
                             _ => policy.BeginBlockActions,
-                            _ => policy.EndBlockActions),
+                            _ => policy.EndBlockActions,
+                            _ => policy.BeginTxActions,
+                            _ => policy.EndTxActions),
                         stateStore: fx.StateStore,
                         actionTypeLoader: new SingleActionLoader(typeof(DumbAction))));
 
@@ -596,7 +598,9 @@ public void AppendValidatesBlock()
                 new ActionEvaluator(
                     new PolicyActionsGetterCollection(
                         _ => policy.BeginBlockActions,
-                        _ => policy.EndBlockActions),
+                        _ => policy.EndBlockActions,
+                        _ => policy.BeginTxActions,
+                        _ => policy.EndTxActions),
                     _fx.StateStore,
                     new SingleActionLoader(typeof(DumbAction))));
             Assert.Throws<BlockPolicyViolationException>(
@@ -773,7 +777,9 @@ public void DoesNotMigrateStateWithoutAction()
             var actionEvaluator = new ActionEvaluator(
                 new PolicyActionsGetterCollection(
                     _ => policy.BeginBlockActions,
-                    _ => policy.EndBlockActions),
+                    _ => policy.EndBlockActions,
+                    _ => policy.BeginTxActions,
+                    _ => policy.EndTxActions),
                 stateStore: fx.StateStore,
                 actionTypeLoader: new SingleActionLoader(typeof(DumbAction)));
 

Libplanet.Tests/Blockchain/BlockChainTest.ProposeBlock.cs

@@ -143,7 +143,9 @@ public void CanProposeInvalidGenesisBlock()
                 var actionEvaluator = new ActionEvaluator(
                     new PolicyActionsGetterCollection(
                         _ => policy.BeginBlockActions,
-                        _ => policy.EndBlockActions),
+                        _ => policy.EndBlockActions,
+                        _ => policy.BeginTxActions,
+                        _ => policy.EndTxActions),
                     fx.StateStore,
                     new SingleActionLoader(typeof(DumbAction)));
                 var genesis = BlockChain.ProposeGenesisBlock(
@@ -185,7 +187,9 @@ public void CanProposeInvalidBlock()
                     new ActionEvaluator(
                         new PolicyActionsGetterCollection(
                             _ => policy.BeginBlockActions,
-                            _ => policy.EndBlockActions),
+                            _ => policy.EndBlockActions,
+                            _ => policy.BeginTxActions,
+                            _ => policy.EndTxActions),
                         stateStore: fx.StateStore,
                         actionTypeLoader: new SingleActionLoader(typeof(DumbAction))));
                 var txs = new[]
@@ -411,7 +415,9 @@ TxPolicyViolationException IsSignerValid(
                     new ActionEvaluator(
                         new PolicyActionsGetterCollection(
                             _ => policy.BeginBlockActions,
-                            _ => policy.EndBlockActions),
+                            _ => policy.EndBlockActions,
+                            _ => policy.BeginTxActions,
+                            _ => policy.EndTxActions),
                         stateStore: fx.StateStore,
                         actionTypeLoader: new SingleActionLoader(typeof(DumbAction))));
 
@@ -533,7 +539,9 @@ public void ProposeBlockWithBlockAction()
                 new ActionEvaluator(
                     new PolicyActionsGetterCollection(
                         _ => policy.BeginBlockActions,
-                        _ => policy.EndBlockActions),
+                        _ => policy.EndBlockActions,
+                        _ => policy.BeginTxActions,
+                        _ => policy.EndTxActions),
                     _fx.StateStore,
                     new SingleActionLoader(typeof(DumbAction))));