test: add test_l1_sync_batch_finalized

Author: yiweichi

crates/node/src/args.rs

@@ -356,19 +356,15 @@ impl ScrollRollupNodeConfig {
                 .filter(|_| !self.test_args.test || self.blob_provider_args.anvil_url.is_some())
             {
                 tracing::info!(target: "scroll::node::args", ?l1_block_startup_info, "Starting L1 watcher");
-                (
-                    None,
-                    Some(
-                        L1Watcher::spawn(
-                            provider,
-                            l1_block_startup_info,
-                            node_config,
-                            self.l1_provider_args.logs_query_block_range,
-                            self.test_args.test && self.test_args.skip_l1_synced,
-                        )
-                        .await,
-                    ),
-                )
+                    let (tx, rx) = L1Watcher::spawn(
+                        provider,
+                        l1_block_startup_info,
+                        node_config,
+                        self.l1_provider_args.logs_query_block_range,
+                        self.test_args.test && self.test_args.skip_l1_synced,
+                    )
+                    .await;
+                    (Some(tx), Some(rx))
             } else {
                 // Create a channel for L1 notifications that we can use to inject L1 messages for
                 // testing

crates/node/src/test_utils/event_utils.rs

@@ -143,6 +143,15 @@ impl<'a> EventWaiter<'a> {
         Ok(())
     }
 
+    /// Wait for batch finalized event on all specified nodes.
+    pub async fn batch_finalized(self) -> eyre::Result<()> {
+        self.wait_for_event_on_all(|e| {
+            matches!(e, ChainOrchestratorEvent::BatchFinalized { .. }).then_some(())
+        })
+        .await?;
+        Ok(())
+    }
+
     /// Wait for batch reverted event on all specified nodes.
     pub async fn batch_reverted(self) -> eyre::Result<()> {
         self.wait_for_event_on_all(|e| {