fix: L1 message L1MessageKey::BlockNumber lookup edge case

yiweichi · yiweichi · commit db8932c4ed45 · 2025-10-30T04:00:09.000+08:00
diff --git a/crates/database/db/src/operations.rs b/crates/database/db/src/operations.rs
@@ -855,11 +855,13 @@ impl<T: ReadConnectionProvider + Sync + ?Sized> DatabaseReadOperations for T {
                     .await?
                 {
                     // Yield n messages starting from the found queue index + 1.
+                    // Only return messages that haven't been skipped (skipped = false).
                     Ok(models::l1_message::Entity::find()
                         .filter(
                             // We add 1 to the queue index to constrain across block boundaries
                             models::l1_message::Column::QueueIndex.gte(record.queue_index + 1),
                         )
+                        .filter(models::l1_message::Column::Skipped.eq(false))
                         .order_by_asc(models::l1_message::Column::QueueIndex)
                         .limit(Some(n as u64))
                         .all(self.get_connection())

Original file line number	Diff line number	Diff line change
`@@ -855,11 +855,13 @@ impl<T: ReadConnectionProvider + Sync + ?Sized> DatabaseReadOperations for T {`
`855`	`855`	`.await?`
`856`	`856`	`{`
`857`	`857`	`// Yield n messages starting from the found queue index + 1.`
	`858`	`+ // Only return messages that haven't been skipped (skipped = false).`
`858`	`859`	`Ok(models::l1_message::Entity::find()`
`859`	`860`	`.filter(`
`860`	`861`	`// We add 1 to the queue index to constrain across block boundaries`
`861`	`862`	`models::l1_message::Column::QueueIndex.gte(record.queue_index + 1),`
`862`	`863`	`)`
	`864`	`+ .filter(models::l1_message::Column::Skipped.eq(false))`
`863`	`865`	`.order_by_asc(models::l1_message::Column::QueueIndex)`
`864`	`866`	`.limit(Some(n as u64))`
`865`	`867`	`.all(self.get_connection())`