feat: Implement TempoTransactionValidator

Cargo.toml

@@ -174,3 +174,4 @@ prost-build = "0.13"
 protox = "0.7"
 criterion = "0.7.0"
 jsonrpsee = { version = "0.26.0", features = ["server", "client", "macros"] }
+futures = "0.3"

crates/node/src/node.rs

@@ -37,13 +37,15 @@ use reth_rpc_eth_api::FromEvmError;
 use reth_rpc_eth_types::EthApiError;
 use reth_tracing::tracing::{debug, info};
 use reth_transaction_pool::{
-    EthPoolTransaction, EthTransactionPool, PoolTransaction, TransactionValidationTaskExecutor,
+    EthPoolTransaction, PoolTransaction, TransactionValidationTaskExecutor,
     blobstore::DiskFileBlobStore,
 };
 use std::{default::Default, sync::Arc, time::SystemTime};
 use tempo_chainspec::spec::{TEMPO_BASE_FEE, TempoChainSpec};
 use tempo_evm::evm::TempoEvmFactory;
-use tempo_transaction_pool::transaction::TempoPooledTransaction;
+use tempo_transaction_pool::{
+    TempoTransactionPool, transaction::TempoPooledTransaction, validator::TempoTransactionValidator,
+};
 
 /// Type configuration for a regular Ethereum node.
 #[derive(Debug, Default, Clone)]
@@ -358,7 +360,7 @@ where
     Node: FullNodeTypes<Types: NodeTypes<ChainSpec: EthereumHardforks>>,
     T: EthPoolTransaction<Consensus = TxTy<Node::Types>> + PoolTransaction,
 {
-    type Pool = EthTransactionPool<Node::Provider, DiskFileBlobStore, T>;
+    type Pool = TempoTransactionPool<Node::Provider, DiskFileBlobStore, T>;
 
     async fn build_pool(self, ctx: &BuilderContext<Node>) -> eyre::Result<Self::Pool> {
         let mut pool_config = ctx.pool_config().clone();
@@ -408,7 +410,7 @@ where
             });
         }
 
-        // TODO: custom tempo tx validation
+        let validator = validator.map(|validator| TempoTransactionValidator::new(validator));
         let transaction_pool = TxPoolBuilder::new(ctx)
             .with_validator(validator)
             .build_and_spawn_maintenance_task(blob_store, pool_config)?;

crates/precompiles/Cargo.toml

@@ -10,6 +10,7 @@ description = "TODO:"
 
 [dependencies]
 reth-evm.workspace = true
+reth-storage-api.workspace = true
 alloy = { workspace = true, features = ["contract", "sol-types", "rpc"] }
 alloy-evm.workspace = true
 alloy-consensus.workspace = true

crates/precompiles/src/contracts/mod.rs

@@ -1,3 +1,4 @@
+pub mod provider;
 pub mod roles;
 pub mod storage;
 pub mod tip20;

crates/precompiles/src/contracts/provider.rs

@@ -0,0 +1,42 @@
+use alloy_primitives::{Address, U256};
+use reth_evm::revm::interpreter::instructions::utility::IntoAddress;
+use reth_storage_api::{StateProvider, errors::ProviderResult};
+
+use crate::{
+    TIP_FEE_MANAGER_ADDRESS,
+    contracts::{storage::slots::mapping_slot, tip_fee_manager, tip20},
+};
+
+/// Provides access to TIPFeeManager storage to fetch fee token data and balances
+pub trait TIPFeeStorageProvider {
+    /// Get fee token balance for a user.
+    ///
+    /// Returns the user's balance in their configured fee token. Falls back to
+    /// validator token if user has no token set.
+    fn get_fee_token_balance(&self, user: Address) -> ProviderResult<U256>;
+}
+
+/// Implementation of TIPFeeManager storage operations for generic [`StateProvider`]
+impl<T: StateProvider> TIPFeeStorageProvider for T {
+    fn get_fee_token_balance(&self, user: Address) -> ProviderResult<U256> {
+        // Look up user's configured fee token in TIPFeeManager storage
+        let user_token_slot = mapping_slot(user, tip_fee_manager::slots::USER_TOKENS);
+        let fee_token = self
+            .storage(TIP_FEE_MANAGER_ADDRESS, user_token_slot.into())?
+            .unwrap_or_default()
+            .into_address();
+
+        if fee_token.is_zero() {
+            // TODO: how to handle getting validator fee token? Should we get the next validator or
+            // default to some token?
+        }
+
+        // Query the user's balance in the determined fee token's TIP20 contract
+        let balance_slot = mapping_slot(user, tip20::slots::BALANCES);
+        let balance = self
+            .storage(fee_token, balance_slot.into())?
+            .unwrap_or_default();
+
+        Ok(balance)
+    }
+}

crates/transaction-pool/Cargo.toml

@@ -9,11 +9,21 @@ rust-version.workspace = true
 # workspace = true
 
 [dependencies]
+tempo-precompiles.workspace = true
 reth-transaction-pool.workspace = true
 reth-chainspec.workspace = true
 reth-ethereum-primitives.workspace = true
+reth-evm.workspace = true
 reth-primitives-traits.workspace = true
 reth-storage-api.workspace = true
+alloy.workspace = true
 alloy-consensus.workspace = true
 alloy-primitives.workspace = true
 alloy-eips.workspace = true
+futures.workspace = true
+
+[dev-dependencies]
+reth-transaction-pool.workspace = true
+alloy-eips.workspace = true
+reth-provider = { workspace = true, features = ["test-utils"] }
+tokio.workspace = true

crates/transaction-pool/src/lib.rs

@@ -1,2 +1,14 @@
+use reth_transaction_pool::{
+    CoinbaseTipOrdering, EthPooledTransaction, Pool, TransactionValidationTaskExecutor,
+};
+
+use crate::validator::TempoTransactionValidator;
+
 pub mod transaction;
 pub mod validator;
+
+pub type TempoTransactionPool<Client, S, T = EthPooledTransaction> = Pool<
+    TransactionValidationTaskExecutor<TempoTransactionValidator<Client, T>>,
+    CoinbaseTipOrdering<T>,
+    S,
+>;