Flashblocks

Cargo.toml

@@ -6,6 +6,8 @@ edition = "2024"
 [dependencies]
 op-alloy-rpc-types-engine = "0.12.0"
 alloy-rpc-types-engine = "0.13.0"
+alloy-rpc-types-eth = "0.13.0"
+alloy-serde = "0.13.0"
 alloy-eips = { version = "0.13.0", features = ["serde"], optional = true }
 alloy-primitives = { version = "0.8.10", features = ["rand"] }
 tokio = { version = "1", features = ["full"] }
@@ -39,6 +41,8 @@ tracing-opentelemetry = "0.29.0"
 futures = "0.3.31"
 metrics = "0.24.0"
 metrics-exporter-prometheus = "0.16.0"
+tokio-tungstenite = { version = "0.26.2", features = ["native-tls"] }
+url = "2.5"
 metrics-util = "0.19.0"
 eyre = "0.6.12"
 paste = "1.0.15"
@@ -50,7 +54,6 @@ lazy_static = {version = "1.5.0", optional = true }
 
 [dev-dependencies]
 op-alloy-consensus = "0.12.0"
-alloy-rpc-types-eth = "0.13.0"
 anyhow = "1.0"
 assert_cmd = "2.0.10"
 predicates = "3.1.2"

src/bin/main.rs

@@ -2,8 +2,8 @@
 use ::tracing::info;
 use clap::Parser;
 use rollup_boost::{
-    Args, Commands, DebugClient, DebugCommands, PayloadSource, ProxyLayer, RollupBoostServer,
-    RpcClient, init_metrics, init_tracing,
+    Args, Commands, DebugClient, DebugCommands, Flashblocks, PayloadSource, ProxyLayer,
+    RollupBoostServer, RpcClient, init_metrics, init_tracing,
 };
 use std::net::SocketAddr;
 
@@ -90,11 +90,21 @@ async fn main() -> eyre::Result<()> {
         info!("Boost sync enabled");
     }
 
+    let flashblocks_client = if args.flashblocks.flashblocks {
+        let inbound_url = args.flashblocks.flashblocks_url;
+        let outbound_url = args.flashblocks.flashblocks_outbound_url;
+
+        Some(Flashblocks::run(inbound_url, outbound_url).unwrap())
+    } else {
+        None
+    };
+
     let rollup_boost = RollupBoostServer::new(
         l2_client,
         builder_client,
         boost_sync_enabled,
         args.execution_mode,
+        flashblocks_client,
     );
 
     // Spawn the debug server

src/cli.rs

@@ -69,6 +69,25 @@ pub struct Args {
     /// Execution mode to start rollup boost with
     #[arg(long, env, default_value = "enabled")]
     pub execution_mode: ExecutionMode,
+
+    /// Enable Flashblocks client
+    #[clap(flatten)]
+    pub flashblocks: FlashblocksArgs,
+}
+
+#[derive(Parser, Debug)]
+pub struct FlashblocksArgs {
+    /// Enable Flashblocks client
+    #[arg(long, env, default_value = "false")]
+    pub flashblocks: bool,
+
+    /// Flashblocks WebSocket URL
+    #[arg(long, env, default_value = "ws://localhost:1111")]
+    pub flashblocks_url: String,
+
+    /// Flashblocks outbound WebSocket URL
+    #[arg(long, env, default_value = "127.0.0.1:1112")]
+    pub flashblocks_outbound_url: String,
 }
 
 #[derive(Clone, Debug)]