reth/examples/custom-inspector/src/main.rs

//! Example of how to use a custom inspector to trace new pending transactions
//!
//! Run with
//!
//! ```sh
//! cargo run --release -p custom-inspector -- node --http --ws --recipients 0x....,0x....
//! ```
//!
//! If no recipients are specified, all transactions will be inspected.

#![warn(unused_crate_dependencies)]

use alloy_eips::BlockNumberOrTag;
use alloy_evm::Evm;
use alloy_primitives::Address;
use alloy_rpc_types_eth::{state::EvmOverrides, TransactionRequest};
use clap::Parser;
use futures_util::StreamExt;
use reth_ethereum::{
    cli::{chainspec::EthereumChainSpecParser, interface::Cli},
    evm::{
        primitives::ConfigureEvm,
        revm::revm::{
            bytecode::opcode::OpCode,
            context_interface::ContextTr,
            inspector::Inspector,
            interpreter::{interpreter::EthInterpreter, interpreter_types::Jumps, Interpreter},
        },
    },
    node::{builder::NodeHandle, EthereumNode},
    pool::TransactionPool,
    rpc::api::eth::helpers::Call,
};

fn main() {
    Cli::<EthereumChainSpecParser, RethCliTxpoolExt>::parse()
        .run(|builder, args| async move {
            // launch the node
            let NodeHandle { node, node_exit_future } =
                builder.node(EthereumNode::default()).launch().await?;

            // create a new subscription to pending transactions
            let mut pending_transactions = node.pool.new_pending_pool_transactions_listener();

            // get an instance of the `trace_` API handler
            let eth_api = node.rpc_registry.eth_api().clone();

            println!("Spawning trace task!");

            // Spawn an async block to listen for transactions.
            node.task_executor.spawn(Box::pin(async move {
                // Waiting for new transactions
                while let Some(event) = pending_transactions.next().await {
                    let tx = event.transaction;
                    println!("Transaction received: {tx:?}");

                    if let Some(recipient) = tx.to() {
                        if args.is_match(&recipient) {
                            // convert the pool transaction
                            let call_request =
                                TransactionRequest::from_recovered_transaction(tx.to_consensus());

                            let evm_config = node.evm_config.clone();

                            let result = eth_api
                                .spawn_with_call_at(
                                    call_request,
                                    BlockNumberOrTag::Latest.into(),
                                    EvmOverrides::default(),
                                    move |db, evm_env, tx_env| {
                                        let mut dummy_inspector = DummyInspector::default();
                                        let mut evm = evm_config.evm_with_env_and_inspector(
                                            db,
                                            evm_env,
                                            &mut dummy_inspector,
                                        );
                                        // execute the transaction on a blocking task and await
                                        // the
                                        // inspector result
                                        let _ = evm.transact(tx_env)?;
                                        Ok(dummy_inspector)
                                    },
                                )
                                .await;

                            if let Ok(ret_val) = result {
                                let hash = tx.hash();
                                println!(
                                    "Inspector result for transaction {}: \n {}",
                                    hash,
                                    ret_val.ret_val.join("\n")
                                );
                            }
                        }
                    }
                }
            }));

            node_exit_future.await
        })
        .unwrap();
}

/// Our custom cli args extension that adds one flag to reth default CLI.
#[derive(Debug, Clone, Default, clap::Args)]
struct RethCliTxpoolExt {
    /// The addresses of the recipients that we want to trace.
    #[arg(long, value_delimiter = ',')]
    pub recipients: Vec<Address>,
}

impl RethCliTxpoolExt {
    /// Check if the recipient is in the list of recipients to trace.
    pub fn is_match(&self, recipient: &Address) -> bool {
        self.recipients.is_empty() || self.recipients.contains(recipient)
    }
}

/// A dummy inspector that logs the opcodes and their corresponding program counter for a
/// transaction
#[derive(Default, Debug, Clone)]
struct DummyInspector {
    ret_val: Vec<String>,
}

impl<CTX> Inspector<CTX, EthInterpreter> for DummyInspector
where
    CTX: ContextTr,
{
    /// This method is called at each step of the EVM execution.
    /// It checks if the current opcode is valid and if so, it stores the opcode and its
    /// corresponding program counter in the `ret_val` vector.
    fn step(&mut self, interp: &mut Interpreter<EthInterpreter>, _context: &mut CTX) {
        if let Some(opcode) = OpCode::new(interp.bytecode.opcode()) {
            self.ret_val.push(format!("{}: {}", interp.bytecode.pc(), opcode));
        }
    }
}