feat(metering): use pending flashblocks state for bundle metering

bin/node/src/main.rs

@@ -6,8 +6,8 @@
 pub mod cli;
 
 use base_client_node::BaseNodeRunner;
-use base_flashblocks::FlashblocksExtension;
-use base_metering::MeteringExtension;
+use base_flashblocks::{FlashblocksConfig, FlashblocksExtension};
+use base_metering::{MeteringConfig, MeteringExtension};
 use base_txpool::TxPoolExtension;
 
 #[global_allocator]
@@ -26,10 +26,16 @@ fn main() {
     cli.run(|builder, args| async move {
         let mut runner = BaseNodeRunner::new(args.rollup_args.clone());
 
+        // Create flashblocks config first so we can share its state with metering
+        let flashblocks_config: Option<FlashblocksConfig> = args.clone().into();
+
         // Feature extensions (FlashblocksExtension must be last - uses replace_configured)
         runner.install_ext::<TxPoolExtension>(args.clone().into());
-        runner.install_ext::<MeteringExtension>(args.enable_metering);
-        runner.install_ext::<FlashblocksExtension>(args.into());
+        runner.install_ext::<MeteringExtension>(MeteringConfig {
+            enabled: args.enable_metering,
+            flashblocks_config: flashblocks_config.clone(),
+        });
+        runner.install_ext::<FlashblocksExtension>(flashblocks_config);
 
         let handle = runner.run(builder);
         handle.await

crates/client/flashblocks/src/extension.rs

@@ -15,7 +15,7 @@ use crate::{
 };
 
 /// Flashblocks-specific configuration knobs.
-#[derive(Debug)]
+#[derive(Debug, Clone)]
 pub struct FlashblocksConfig {
     /// The websocket endpoint that streams flashblock updates.
     pub websocket_url: Url,

crates/client/flashblocks/src/state.rs

@@ -110,6 +110,12 @@ impl FlashblocksReceiver for FlashblocksState {
     }
 }
 
+impl Default for FlashblocksState {
+    fn default() -> Self {
+        Self::new(10)
+    }
+}
+
 impl FlashblocksAPI for FlashblocksState {
     fn get_pending_blocks(&self) -> Guard<Option<Arc<PendingBlocks>>> {
         self.pending_blocks.load()