make broadcast poll duration configurable

bin/strata-client/src/main.rs

@@ -140,6 +140,7 @@ fn main_inner(args: Args) -> anyhow::Result<()> {
                 &executor,
                 ctx.bitcoin_client.clone(),
                 params.clone(),
+                config.btcio.broadcaster.poll_interval_ms,
             );
             let writer_db = init_writer_database(rbdb.clone(), ops_config);
 
@@ -477,15 +478,21 @@ fn start_broadcaster_tasks(
     executor: &TaskExecutor,
     bitcoin_client: Arc<BitcoinClient>,
     params: Arc<Params>,
+    broadcast_poll_interval: u64,
 ) -> Arc<L1BroadcastHandle> {
     // Set up L1 broadcaster.
     let broadcast_ctx = strata_storage::ops::l1tx_broadcast::Context::new(
         broadcast_database.l1_broadcast_db().clone(),
     );
     let broadcast_ops = Arc::new(broadcast_ctx.into_ops(pool));
     // start broadcast task
-    let broadcast_handle =
-        spawn_broadcaster_task(executor, bitcoin_client.clone(), broadcast_ops, params);
+    let broadcast_handle = spawn_broadcaster_task(
+        executor,
+        bitcoin_client.clone(),
+        broadcast_ops,
+        params,
+        broadcast_poll_interval,
+    );
     Arc::new(broadcast_handle)
 }
 

crates/btcio/src/broadcaster/handle.rs

@@ -70,16 +70,23 @@ pub fn spawn_broadcaster_task<T>(
     l1_rpc_client: Arc<T>,
     broadcast_ops: Arc<BroadcastDbOps>,
     params: Arc<Params>,
+    broadcast_poll_interval: u64,
 ) -> L1BroadcastHandle
 where
     T: ReaderRpc + BroadcasterRpc + WalletRpc + SignerRpc + Send + Sync + 'static,
 {
     let (broadcast_entry_tx, broadcast_entry_rx) = mpsc::channel::<(u64, L1TxEntry)>(64);
     let ops = broadcast_ops.clone();
     executor.spawn_critical_async("l1_broadcaster_task", async move {
-        broadcaster_task(l1_rpc_client, ops, broadcast_entry_rx, params)
-            .await
-            .map_err(Into::into)
+        broadcaster_task(
+            l1_rpc_client,
+            ops,
+            broadcast_entry_rx,
+            params,
+            broadcast_poll_interval,
+        )
+        .await
+        .map_err(Into::into)
     });
     L1BroadcastHandle::new(broadcast_entry_tx, broadcast_ops)
 }

crates/btcio/src/broadcaster/task.rs

@@ -15,17 +15,16 @@ use crate::{
     rpc::traits::{BroadcasterRpc, WalletRpc},
 };
 
-const BROADCAST_POLL_INTERVAL: u64 = 1_000; // millis
-
 /// Broadcasts the next blob to be sent
 pub async fn broadcaster_task(
     rpc_client: Arc<impl BroadcasterRpc + WalletRpc>,
     ops: Arc<l1tx_broadcast::BroadcastDbOps>,
     mut entry_receiver: Receiver<(u64, L1TxEntry)>,
     params: Arc<Params>,
+    broadcast_poll_interval: u64,
 ) -> BroadcasterResult<()> {
     info!("Starting Broadcaster task");
-    let interval = tokio::time::interval(Duration::from_millis(BROADCAST_POLL_INTERVAL));
+    let interval = tokio::time::interval(Duration::from_millis(broadcast_poll_interval));
     tokio::pin!(interval);
 
     let mut state = BroadcasterState::initialize(&ops).await?;

crates/config/src/btcio.rs

@@ -5,6 +5,7 @@ use serde::Deserialize;
 pub struct BtcioConfig {
     pub reader: ReaderConfig,
     pub writer: WriterConfig,
+    pub broadcaster: BroadcasterConfig,
 }
 
 /// Configuration for btcio reader.
@@ -38,6 +39,13 @@ pub enum FeePolicy {
     Fixed(u64),
 }
 
+/// Configuration for btcio broadcaster.
+#[derive(Debug, Clone, Deserialize)]
+pub struct BroadcasterConfig {
+    /// How often to invoke the broadcaster, in ms.
+    pub poll_interval_ms: u64,
+}
+
 impl Default for WriterConfig {
     fn default() -> Self {
         Self {
@@ -56,3 +64,11 @@ impl Default for ReaderConfig {
         }
     }
 }
+
+impl Default for BroadcasterConfig {
+    fn default() -> Self {
+        Self {
+            poll_interval_ms: 1_000,
+        }
+    }
+}

crates/config/src/config.rs

@@ -113,6 +113,9 @@ mod test {
             reveal_amount = 100
             bundle_interval_ms = 1000
 
+            [btcio.broadcaster]
+            poll_interval_ms = 1000
+
             [relayer]
             refresh_interval = 10
             stale_duration = 120
@@ -161,6 +164,9 @@ mod test {
             reveal_amount = 100
             bundle_interval_ms = 1000
 
+            [btcio.broadcaster]
+            poll_interval_ms = 1000
+
             [exec.reth]
             rpc_url = "http://localhost:8551"
             secret = "1234567890abcdef"