feat(cast): add cast txpool (#10104)

* feat(cast): txpool inspection utils

* fix: typo

* chore: cleanup

* clippy

---------

Co-authored-by: Matthias Seitz <[email protected]>

Author: 0xOsiris

crates/cast/Cargo.toml

@@ -42,6 +42,7 @@ alloy-provider = { workspace = true, features = [
     "ws",
     "ipc",
     "trace-api",
+    "txpool-api"
 ] }
 alloy-rlp.workspace = true
 alloy-rpc-types = { workspace = true, features = ["eth", "trace"] }

crates/cast/src/args.rs

@@ -704,6 +704,7 @@ pub async fn run_command(args: CastArgs) -> Result<()> {
             let eof = stdin::unwrap_line(eof)?;
             sh_println!("{}", SimpleCast::decode_eof(&eof)?)?
         }
+        CastSubcommand::TxPool { command } => command.run().await?,
     };
 
     /// Prints slice of tokens using [`format_tokens`] or [`format_tokens_raw`] depending whether

crates/cast/src/cmd/mod.rs

@@ -21,4 +21,5 @@ pub mod rpc;
 pub mod run;
 pub mod send;
 pub mod storage;
+pub mod txpool;
 pub mod wallet;

crates/cast/src/cmd/txpool.rs

@@ -0,0 +1,64 @@
+use alloy_primitives::Address;
+use alloy_provider::ext::TxPoolApi;
+use clap::Parser;
+use foundry_cli::{
+    opts::RpcOpts,
+    utils::{self, LoadConfig},
+};
+
+/// CLI arguments for `cast tx-pool`.
+#[derive(Debug, Parser, Clone)]
+pub enum TxPoolSubcommands {
+    /// Fetches the content of the transaction pool.
+    Content {
+        #[command(flatten)]
+        args: RpcOpts,
+    },
+    /// Fetches the content of the transaction pool filtered by a specific address.
+    ContentFrom {
+        /// The Signer to filter the transactions by.
+        #[arg(short, long)]
+        from: Address,
+        #[command(flatten)]
+        args: RpcOpts,
+    },
+    /// Fetches a textual summary of each transaction in the pool.
+    Inspect {
+        #[command(flatten)]
+        args: RpcOpts,
+    },
+    /// Fetches the current status of the transaction pool.
+    Status {
+        #[command(flatten)]
+        args: RpcOpts,
+    },
+}
+
+impl TxPoolSubcommands {
+    pub async fn run(self) -> eyre::Result<()> {
+        match self {
+            Self::Content { args } => {
+                let config = args.load_config()?;
+                let provider = utils::get_provider(&config)?;
+                sh_println!("{:#?}", provider.txpool_content().await?)?;
+            }
+            Self::ContentFrom { from, args } => {
+                let config = args.load_config()?;
+                let provider = utils::get_provider(&config)?;
+                sh_println!("{:#?}", provider.txpool_content_from(from).await?)?;
+            }
+            Self::Inspect { args } => {
+                let config = args.load_config()?;
+                let provider = utils::get_provider(&config)?;
+                sh_println!("{:#?}", provider.txpool_inspect().await?)?;
+            }
+            Self::Status { args } => {
+                let config = args.load_config()?;
+                let provider = utils::get_provider(&config)?;
+                sh_println!("{:#?}", provider.txpool_status().await?)?;
+            }
+        };
+
+        Ok(())
+    }
+}

crates/cast/src/opts.rs

@@ -3,7 +3,7 @@ use crate::cmd::{
     constructor_args::ConstructorArgsArgs, create2::Create2Args, creation_code::CreationCodeArgs,
     estimate::EstimateArgs, find_block::FindBlockArgs, interface::InterfaceArgs, logs::LogsArgs,
     mktx::MakeTxArgs, rpc::RpcArgs, run::RunArgs, send::SendTxArgs, storage::StorageArgs,
-    wallet::WalletSubcommands,
+    txpool::TxPoolSubcommands, wallet::WalletSubcommands,
 };
 use alloy_primitives::{Address, B256, U256};
 use alloy_rpc_types::BlockId;
@@ -1052,6 +1052,13 @@ pub enum CastSubcommand {
     /// Decodes EOF container bytes
     #[command()]
     DecodeEof { eof: Option<String> },
+
+    /// Inspect the TxPool of a node.
+    #[command(visible_alias = "tp")]
+    TxPool {
+        #[command(subcommand)]
+        command: TxPoolSubcommands,
+    },
 }
 
 /// CLI arguments for `cast --to-base`.