Adds rpc method for anvil to drop all pending transactions

crates/anvil/core/src/eth/mod.rs

@@ -371,6 +371,17 @@ pub enum EthRequest {
     )]
     DropTransaction(B256),
 
+    /// Removes transactions from the pool
+    #[cfg_attr(
+        feature = "serde",
+        serde(
+            rename = "anvil_dropAllTransactions",
+            alias = "hardhat_dropAllTransactions",
+            with = "empty_params"
+        )
+    )]
+    DropAllTransactions(),
+
     /// Reset the fork to a fresh forked state, and optionally update the fork config
     #[cfg_attr(feature = "serde", serde(rename = "anvil_reset", alias = "hardhat_reset"))]
     Reset(#[cfg_attr(feature = "serde", serde(default))] Option<Params<Option<Forking>>>),

crates/anvil/src/eth/api.rs

@@ -296,6 +296,9 @@ impl EthApi {
             EthRequest::DropTransaction(tx) => {
                 self.anvil_drop_transaction(tx).await.to_rpc_result()
             }
+            EthRequest::DropAllTransactions() => {
+                self.anvil_drop_all_transactions().await.to_rpc_result()
+            }
             EthRequest::Reset(fork) => {
                 self.anvil_reset(fork.and_then(|p| p.params)).await.to_rpc_result()
             }
@@ -1572,6 +1575,16 @@ impl EthApi {
         Ok(self.pool.drop_transaction(tx_hash).map(|tx| tx.hash()))
     }
 
+
+    /// Removes all transactions from the pool
+    ///
+    /// Handler for RPC call: `anvil_dropAllTransactions`
+    pub async fn anvil_drop_all_transactions(&self) -> Result<()> {
+        node_info!("anvil_dropAllTransactions");
+        self.pool.drop_all_transactions();
+        Ok(())
+    }
+
     /// Reset the fork to a fresh forked state, and optionally update the fork config.
     ///
     /// If `forking` is `None` then this will disable forking entirely.

crates/anvil/src/eth/pool/mod.rs

@@ -166,6 +166,23 @@ impl Pool {
         dropped
     }
 
+    pub fn drop_all_transactions(&self) {
+        let pool = self.inner.write();
+
+        let pending_transactions = pool.pending_transactions.transactions();
+        let ready_transactions = pool.ready_transactions.get_transactions();
+
+        pending_transactions.for_each(|pool_transaction| {
+            let tx_hash = pool_transaction.as_ref().hash();
+            self.drop_transaction(tx_hash);
+        });
+
+        ready_transactions.for_each(|pool_transaction| {
+            let tx_hash = pool_transaction.as_ref().hash();
+            self.drop_transaction(tx_hash);
+        });
+    }
+
     /// notifies all listeners about the transaction
     fn notify_listener(&self, hash: TxHash) {
         let mut listener = self.transaction_listener.lock();