Refactor L1Watcher to return PipelineEvent(u64)

crates/indexer/src/lib.rs

@@ -12,11 +12,11 @@ impl Indexer {
     /// Handles an event from the L1.
     pub async fn handle_l1_event(&mut self, event: L1Event) {
         match event {
-            L1Event::CommitBatch(batch_input) => self.handle_batch_input(batch_input).await,
             L1Event::Reorg(block_number) => self.handle_reorg(block_number).await,
             L1Event::NewBlock(block_number) => todo!(),
             L1Event::Finalized(block_number) => self.handle_finalized(block_number).await,
             L1Event::L1Message(l1_message) => self.handle_l1_message(l1_message).await,
+            L1Event::PipelineEvent(block_number) => (),
         }
     }
 

crates/l1/src/event.rs

@@ -1,12 +1,12 @@
-use scroll_primitives::{BatchInput, L1Message};
+use scroll_primitives::L1Message;
 use std::sync::Arc;
 
 /// An observation from the L1.
 #[derive(Debug)]
 pub enum L1Event {
-    /// A new batch input has been committed to L1 with the given [`BatchInput`].
-    CommitBatch(Arc<BatchInput>),
-    /// A new [`L1Message`] has been added to the L1 message queue.
+    /// A block containing a pipeline event has been added to the L1.
+    PipelineEvent(u64),
+    /// A new L1 message has been added to the L1.
     L1Message(Arc<L1Message>),
     /// A new block has been added to the L1.
     NewBlock(u64),