custom url + additional metadata

crates/op-rbuilder/src/args.rs

@@ -17,4 +17,11 @@ pub struct OpRbuilderArgs {
     /// Builder secret key for signing last transaction in block
     #[arg(long = "rollup.builder-secret-key", env = "BUILDER_SECRET_KEY")]
     pub builder_signer: Option<Signer>,
+    /// Websocket port for flashblock payload builder
+    #[arg(
+        long = "rollup.flashblocks-ws-url",
+        env = "FLASHBLOCKS_WS_URL",
+        default_value = "127.0.0.1:1111"
+    )]
+    pub flashblocks_ws_url: String,
 }

crates/op-rbuilder/src/main.rs

@@ -33,11 +33,10 @@ fn main() {
             let op_node = OpNode::new(rollup_args.clone());
             let handle = builder
                 .with_types::<OpNode>()
-                .with_components(
-                    op_node
-                        .components()
-                        .payload(CustomOpPayloadBuilder::new(builder_args.builder_signer)),
-                )
+                .with_components(op_node.components().payload(CustomOpPayloadBuilder::new(
+                    builder_args.builder_signer,
+                    builder_args.flashblocks_ws_url,
+                )))
                 .with_add_ons(
                     OpAddOnsBuilder::default()
                         .with_sequencer(rollup_args.sequencer_http.clone())

crates/op-rbuilder/src/payload_builder.rs

@@ -6,7 +6,7 @@ use crate::tx_signer::Signer;
 use alloy_consensus::{Eip658Value, Header, Transaction, Typed2718, EMPTY_OMMER_ROOT_HASH};
 use alloy_eips::merge::BEACON_NONCE;
 use alloy_eips::Encodable2718;
-use alloy_primitives::{Address, Bytes, B256, U256};
+use alloy_primitives::{map::HashMap, Address, Bytes, B256, U256};
 use alloy_rpc_types_engine::PayloadId;
 use alloy_rpc_types_eth::Withdrawals;
 use op_alloy_consensus::OpDepositReceipt;
@@ -45,6 +45,7 @@ use reth_payload_util::PayloadTransactions;
 use reth_primitives::{transaction::SignedTransactionIntoRecoveredExt, BlockBody, SealedHeader};
 use reth_primitives_traits::proofs;
 use reth_primitives_traits::Block as _;
+use reth_primitives_traits::SignedTransaction;
 use reth_provider::CanonStateSubscriptions;
 use reth_provider::StorageRootProvider;
 use reth_provider::{
@@ -62,7 +63,6 @@ use revm::{
 use rollup_boost::{
     ExecutionPayloadBaseV1, ExecutionPayloadFlashblockDeltaV1, FlashblocksPayloadV1,
 };
-use serde_json::Value;
 use std::error::Error as StdError;
 use tokio_util::sync::CancellationToken;
 use tracing::{debug, trace, warn};
@@ -74,16 +74,20 @@ use tokio::sync::mpsc;
 use tokio_tungstenite::accept_async;
 use tokio_tungstenite::WebSocketStream;
 
-#[derive(Debug, Clone, Copy, Default)]
+#[derive(Debug, Clone, Default)]
 #[non_exhaustive]
 pub struct CustomOpPayloadBuilder {
     #[allow(dead_code)]
     builder_signer: Option<Signer>,
+    flashblocks_ws_url: String,
 }
 
 impl CustomOpPayloadBuilder {
-    pub fn new(builder_signer: Option<Signer>) -> Self {
-        Self { builder_signer }
+    pub fn new(builder_signer: Option<Signer>, flashblocks_ws_url: String) -> Self {
+        Self {
+            builder_signer,
+            flashblocks_ws_url,
+        }
     }
 }
 
@@ -112,6 +116,7 @@ where
             pool,
             ctx.provider().clone(),
             Arc::new(BasicOpReceiptBuilder::default()),
+            self.flashblocks_ws_url.clone(),
         ))
     }
 
@@ -194,14 +199,15 @@ impl<Pool, Client, EvmConfig, N: NodePrimitives> OpPayloadBuilder<Pool, Client,
         pool: Pool,
         client: Client,
         receipt_builder: Arc<dyn OpReceiptBuilder<N::SignedTx, Receipt = N::Receipt>>,
+        flashblocks_ws_url: String,
     ) -> Self {
         let (tx, rx) = mpsc::unbounded_channel();
         let subscribers = Arc::new(Mutex::new(Vec::new()));
 
         Self::publish_task(rx, subscribers.clone());
 
         tokio::spawn(async move {
-            Self::start_ws(subscribers, "127.0.0.1:1111").await;
+            Self::start_ws(subscribers, &flashblocks_ws_url).await;
         });
 
         Self {
@@ -548,10 +554,30 @@ where
     info.last_flashblock_index = info.executed_transactions.len();
 
     let new_transactions_encoded = new_transactions
+        .clone()
         .into_iter()
         .map(|tx| tx.encoded_2718().into())
         .collect::<Vec<_>>();
 
+    let new_receipts = info.receipts[info.last_flashblock_index..].to_vec();
+
+    let receipts_with_hash = new_transactions
+        .iter()
+        .zip(new_receipts.iter())
+        .map(|(tx, receipt)| (*tx.tx_hash(), receipt.clone()))
+        .collect::<HashMap<B256, N::Receipt>>();
+    let new_account_balances = new_bundle
+        .state
+        .iter()
+        .filter_map(|(address, account)| account.info.as_ref().map(|info| (*address, info.balance)))
+        .collect::<HashMap<Address, U256>>();
+
+    let metadata = serde_json::json!({
+        "receipts": receipts_with_hash,
+        "new_account_balances": new_account_balances,
+        "block_number": ctx.parent().number + 1,
+    });
+
     // Prepare the flashblocks message
     let fb_payload = FlashblocksPayloadV1 {
         payload_id: ctx.payload_id(),
@@ -580,7 +606,7 @@ where
             transactions: new_transactions_encoded,
             withdrawals: ctx.withdrawals().cloned().unwrap_or_default().to_vec(),
         },
-        metadata: Value::Null,
+        metadata,
     };
 
     Ok((