PoC obtaining TXs from auction running on pod

Author: poszu

Cargo.lock

@@ -69,6 +69,7 @@ alloy-network.workspace = true
 alloy-provider.workspace = true
 alloy-serde.workspace = true
 alloy-json-rpc.workspace = true
+alloy-rlp.workspace = true
 
 # op
 alloy-op-evm.workspace = true
@@ -132,6 +133,10 @@ tar = { version = "0.4", optional = true }
 ctor = { version = "0.4.2", optional = true }
 rlimit = { version = "0.10", optional = true }
 macros = { path = "src/tests/framework/macros", optional = true }
+# pod-sdk = { git = "https://github.com/podnetwork/pod-sdk", rev = "faeab8c02e4d1b117362b25027969e85006c5515", version = "0.1.0" }
+pod-sdk = { path = "../../../pod-sdk/rust-sdk/" }
+pod-auction = { package = "optimism-tx-auction", path = "../../../pod-sdk/examples/optimism-tx-auction" }
+itertools = "0.14.0"
 
 [target.'cfg(unix)'.dependencies]
 tikv-jemallocator = { version = "0.6", optional = true }
@@ -142,7 +147,7 @@ vergen-git2.workspace = true
 
 [dev-dependencies]
 alloy-provider = { workspace = true, default-features = true, features = [
-	"txpool-api",
+    "txpool-api",
 ] }
 tempfile = "3.8"
 macros = { path = "src/tests/framework/macros" }
@@ -158,15 +163,15 @@ rlimit = { version = "0.10" }
 default = ["jemalloc"]
 
 jemalloc = [
-	"dep:tikv-jemallocator",
-	"reth-cli-util/jemalloc",
-	"reth-optimism-cli/jemalloc",
+    "dep:tikv-jemallocator",
+    "reth-cli-util/jemalloc",
+    "reth-optimism-cli/jemalloc",
 ]
 jemalloc-prof = [
-	"jemalloc",
-	"tikv-jemallocator?/profiling",
-	"reth/jemalloc-prof",
-	"reth-cli-util/jemalloc-prof",
+    "jemalloc",
+    "tikv-jemallocator?/profiling",
+    "reth/jemalloc-prof",
+    "reth-cli-util/jemalloc-prof",
 ]
 
 min-error-logs = ["tracing/release_max_level_error"]
@@ -176,14 +181,14 @@ min-debug-logs = ["tracing/release_max_level_debug"]
 min-trace-logs = ["tracing/release_max_level_trace"]
 
 testing = [
-	"dashmap",
-	"nanoid",
-	"reth-ipc",
-	"reth-node-builder/test-utils",
-	"bollard",
-	"ctor",
-	"macros",
-	"rlimit",
+    "dashmap",
+    "nanoid",
+    "reth-ipc",
+    "reth-node-builder/test-utils",
+    "bollard",
+    "ctor",
+    "macros",
+    "rlimit",
 ]
 
 interop = []
@@ -202,10 +207,10 @@ ci-features = [
     "min-info-logs",
     "min-debug-logs",
     "min-trace-logs",
-	"testing",
-	"interop",
-	"telemetry",
-	"custom-engine-api",
+    "testing",
+    "interop",
+    "telemetry",
+    "custom-engine-api",
 ]
 
 [[bin]]

crates/op-rbuilder/Cargo.toml

@@ -75,6 +75,9 @@ impl CliExt for Cli {
             if node_command.ext.flashblocks.enabled {
                 return BuilderMode::Flashblocks;
             }
+            if node_command.ext.pod.is_enabled {
+                return BuilderMode::Pod;
+            }
         }
         BuilderMode::Standard
     }

crates/op-rbuilder/src/args/mod.rs

@@ -5,6 +5,7 @@
 //! clap [Args](clap::Args) for optimism rollup configuration
 
 use crate::{flashtestations::args::FlashtestationsArgs, tx_signer::Signer};
+use alloy_primitives::Address;
 use anyhow::{anyhow, Result};
 use clap::Parser;
 use reth_optimism_cli::commands::Commands;
@@ -51,6 +52,8 @@ pub struct OpRbuilderArgs {
     )]
     pub playground: Option<PathBuf>,
     #[command(flatten)]
+    pub pod: PodArgs,
+    #[command(flatten)]
     pub flashblocks: FlashblocksArgs,
     #[command(flatten)]
     pub telemetry: TelemetryArgs,
@@ -149,6 +152,26 @@ impl Default for FlashblocksArgs {
     }
 }
 
+#[derive(Debug, Clone, PartialEq, Eq, clap::Args)]
+pub struct PodArgs {
+    #[arg(long = "pod.enabled", default_value = "false", env = "ENABLE_POD")]
+    pub is_enabled: bool,
+
+    #[arg(
+        long = "pod.rpc-url",
+        env = "POD_RPC_URL",
+        default_value = "ws://127.0.0.1:8545"
+    )]
+    pub pod_rpc_url: String,
+
+    #[arg(
+        long = "pod.contract-address",
+        env = "POD_CONTRACT_ADDRESS",
+        default_value = "0x12296f2D128530a834460DF6c36a2895B793F26d"
+    )]
+    pub pod_contract_address: Address,
+}
+
 /// Parameters for telemetry configuration
 #[derive(Debug, Clone, Default, PartialEq, Eq, clap::Args)]
 pub struct TelemetryArgs {

crates/op-rbuilder/src/args/op.rs

@@ -18,10 +18,12 @@ mod builder_tx;
 mod context;
 mod flashblocks;
 mod generator;
+mod pod;
 mod standard;
 
 pub use builder_tx::BuilderTx;
 pub use flashblocks::FlashblocksBuilder;
+pub use pod::PodBuilder;
 pub use standard::StandardBuilder;
 
 /// Defines the payload building mode for the OP builder.
@@ -34,6 +36,10 @@ pub enum BuilderMode {
     /// block every short interval and makes it available through a websocket update
     /// then merges them into a full block every chain block time.
     Flashblocks,
+    /// Uses the pod payload builder that builds blocks every chain block time
+    /// but picks transactions from an auction running on pod, selecting the highest
+    /// bidding transactions.
+    Pod,
 }
 
 /// Defines the interface for any block builder implementation API entry point.

crates/op-rbuilder/src/builders/mod.rs

@@ -0,0 +1,20 @@
+use crate::args::OpRbuilderArgs;
+use alloy_primitives::Address;
+
+/// Configuration values that are specific to the flashblocks builder.
+#[derive(Debug, Clone)]
+pub struct Config {
+    pub rpc_url: String,
+    pub contract_address: Address,
+}
+
+impl TryFrom<OpRbuilderArgs> for Config {
+    type Error = eyre::Report;
+
+    fn try_from(args: OpRbuilderArgs) -> Result<Self, Self::Error> {
+        Ok(Self {
+            rpc_url: args.pod.pod_rpc_url,
+            contract_address: args.pod.pod_contract_address,
+        })
+    }
+}

crates/op-rbuilder/src/builders/pod/config.rs

@@ -1,21 +1,24 @@
-use payload::StandardPayloadBuilderBuilder;
+use config::Config;
+use payload::PodPayloadBuilderBuilder;
 use reth_node_builder::components::BasicPayloadServiceBuilder;
 
 use crate::traits::{NodeBounds, PoolBounds};
 
 use super::BuilderConfig;
 
+mod config;
 mod payload;
+mod pod_client;
 
-/// Block building strategy that builds blocks using the standard approach by
+/// Block building strategy that builds blocks using auction running on pod by
 /// producing blocks every chain block time.
-pub struct StandardBuilder;
+pub struct PodBuilder;
 
-impl super::PayloadBuilder for StandardBuilder {
-    type Config = ();
+impl super::PayloadBuilder for PodBuilder {
+    type Config = Config;
 
     type ServiceBuilder<Node, Pool>
-        = BasicPayloadServiceBuilder<StandardPayloadBuilderBuilder>
+        = BasicPayloadServiceBuilder<PodPayloadBuilderBuilder>
     where
         Node: NodeBounds,
         Pool: PoolBounds;
@@ -27,8 +30,8 @@ impl super::PayloadBuilder for StandardBuilder {
         Node: NodeBounds,
         Pool: PoolBounds,
     {
-        Ok(BasicPayloadServiceBuilder::new(
-            StandardPayloadBuilderBuilder(config),
-        ))
+        Ok(BasicPayloadServiceBuilder::new(PodPayloadBuilderBuilder(
+            config,
+        )))
     }
 }