Add Transaction Permissioning Hook to PermissioningService Interface

besu/src/main/java/org/hyperledger/besu/services/PermissionServiceImpl.java

@@ -0,0 +1,45 @@
+package org.hyperledger.besu.services;
+
+import org.hyperledger.besu.ethereum.permissioning.account.TransactionPermissioningProvider;
+import org.hyperledger.besu.plugin.services.PermissioningService;
+import org.hyperledger.besu.plugin.services.permissioning.NodeConnectionPermissioningProvider;
+import org.hyperledger.besu.plugin.services.permissioning.NodeMessagePermissioningProvider;
+import org.hyperledger.besu.ethereum.core.Transaction;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class PermissionServiceImpl implements PermissioningService {
+    private static final Logger log = LoggerFactory.getLogger(PermissionServiceImpl.class);
+    private final List<TransactionPermissioningProvider> transactionPermissioningProviders = new ArrayList<>();
+
+    @Override
+    public void registerNodePermissioningProvider(NodeConnectionPermissioningProvider provider) {
+
+    }
+
+    @Override
+    public void registerTransactionPermissioningProvider(TransactionPermissioningProvider provider) {
+        transactionPermissioningProviders.add(provider);
+        log.info("Registered new transaction permissioning provider.");
+    }
+
+    @Override
+    public void registerNodeMessagePermissioningProvider(NodeMessagePermissioningProvider provider) {
+
+    }
+
+    public boolean isTransactionPermitted(Transaction transaction) {
+        for (TransactionPermissioningProvider provider : transactionPermissioningProviders) {
+            if (!provider.isPermitted(transaction)) {
+                log.info("Transaction {} not permitted by one of the providers.", transaction.getHash());
+                return false;
+            }
+        }
+        log.info("Transaction {} permitted.", transaction.getHash());
+        return true;
+    }
+}
+

plugin-api/src/main/java/org/hyperledger/besu/plugin/services/PermissioningService.java

@@ -14,6 +14,7 @@
  */
 package org.hyperledger.besu.plugin.services;
 
+import org.hyperledger.besu.ethereum.permissioning.account.TransactionPermissioningProvider;
 import org.hyperledger.besu.plugin.services.permissioning.NodeConnectionPermissioningProvider;
 import org.hyperledger.besu.plugin.services.permissioning.NodeMessagePermissioningProvider;
 
@@ -38,6 +39,13 @@ public interface PermissioningService extends BesuService {
    */
   void registerNodePermissioningProvider(NodeConnectionPermissioningProvider provider);
 
+  /**
+   * Registers a callback for transaction permission.
+   *
+   * @param provider The provider to register
+   */
+  void registerTransactionPermissioningProvider(TransactionPermissioningProvider provider);
+
   /**
    * Registers a callback to allow the interception of a devp2p message sending request
    *