feat: use batch tx validation in eth validator

crates/transaction-pool/src/validate/eth.rs

@@ -25,7 +25,7 @@ use alloy_eips::{
 use reth_chainspec::{ChainSpec, EthereumHardforks};
 use reth_primitives::{InvalidTransactionError, SealedBlock};
 use reth_primitives_traits::{BlockBody, GotExpected};
-use reth_storage_api::{AccountReader, StateProviderFactory};
+use reth_storage_api::{AccountReader, StateProvider, StateProviderFactory};
 use reth_tasks::TaskSpawner;
 use std::{
     marker::PhantomData,
@@ -80,7 +80,7 @@ where
         &self,
         transactions: Vec<(TransactionOrigin, Tx)>,
     ) -> Vec<TransactionValidationOutcome<Tx>> {
-        transactions.into_iter().map(|(origin, tx)| self.validate_one(origin, tx)).collect()
+        self.inner.validate_batch(transactions)
     }
 }
 
@@ -176,10 +176,11 @@ where
     Tx: EthPoolTransaction,
 {
     /// Validates a single transaction.
-    fn validate_one(
+    fn validate_one_with_provider(
         &self,
         origin: TransactionOrigin,
         mut transaction: Tx,
+        provider: &mut Option<Box<dyn StateProvider>>,
     ) -> TransactionValidationOutcome<Tx> {
         // Checks for tx_type
         match transaction.tx_type() {
@@ -349,11 +350,23 @@ where
             }
         }
 
-        let account = match self
-            .client
-            .latest()
-            .and_then(|state| state.basic_account(transaction.sender()))
-        {
+        // Get or create provider
+        let state = if let Some(provider) = provider {
+            provider
+        } else {
+            match self.client.latest() {
+                Ok(new_provider) => {
+                    *provider = Some(new_provider);
+                    provider.as_ref().unwrap()
+                }
+                Err(err) => {
+                    return TransactionValidationOutcome::Error(*transaction.hash(), Box::new(err))
+                }
+            }
+        };
+
+        // Use provider to get account info
+        let account = match state.basic_account(transaction.sender()) {
             Ok(account) => account.unwrap_or_default(),
             Err(err) => {
                 return TransactionValidationOutcome::Error(*transaction.hash(), Box::new(err))
@@ -479,6 +492,28 @@ where
         }
     }
 
+    /// Validates a single transaction.
+    fn validate_one(
+        &self,
+        origin: TransactionOrigin,
+        transaction: Tx,
+    ) -> TransactionValidationOutcome<Tx> {
+        let mut provider = None;
+        self.validate_one_with_provider(origin, transaction, &mut provider)
+    }
+
+    /// Validates all given transactions.
+    fn validate_batch(
+        &self,
+        transactions: Vec<(TransactionOrigin, Tx)>,
+    ) -> Vec<TransactionValidationOutcome<Tx>> {
+        let mut provider = None;
+        transactions
+            .into_iter()
+            .map(|(origin, tx)| self.validate_one_with_provider(origin, tx, &mut provider))
+            .collect()
+    }
+
     fn on_new_head_block<T: BlockHeader>(&self, new_tip_block: &T) {
         // update all forks
         if self.chain_spec.is_cancun_active_at_timestamp(new_tip_block.timestamp()) {