diff --git a/crates/indexer/src/lib.rs b/crates/indexer/src/lib.rs index 17401f98..13a3349f 100644 --- a/crates/indexer/src/lib.rs +++ b/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) => (), } } diff --git a/crates/l1/src/event.rs b/crates/l1/src/event.rs index c4e1b324..b5b9599c 100644 --- a/crates/l1/src/event.rs +++ b/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), - /// 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), /// A new block has been added to the L1. NewBlock(u64),