Skip to content

Commit 559735b

Browse files
committed
feat: answer comments
1 parent 6108026 commit 559735b

File tree

2 files changed

+6
-1
lines changed

2 files changed

+6
-1
lines changed

crates/manager/src/manager/mod.rs

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -492,6 +492,9 @@ where
492492
}
493493
EngineDriverEvent::ChainImportOutcome(outcome) => {
494494
if let Some(block) = outcome.outcome.block() {
495+
if let Some(sequencer) = self.sequencer.as_mut() {
496+
sequencer.handle_new_payload(&block);
497+
}
495498
if let Some(event_sender) = self.event_sender.as_ref() {
496499
event_sender.notify(RollupManagerEvent::BlockImported(block));
497500
}

crates/sequencer/src/lib.rs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -197,6 +197,8 @@ where
197197
if queue_index + 1 > self.l1_messages_queue_index {
198198
tracing::trace!(target: "rollup_node::sequencer", "Advancing L1 messages queue index from {} to {}", self.l1_messages_queue_index, queue_index + 1);
199199
self.l1_messages_queue_index = queue_index + 1;
200+
} else {
201+
tracing::warn!(target: "rollup_node::sequencer", "Skipping L1 messages queue index update, current index is {}, new payload has max index {}", self.l1_messages_queue_index, queue_index);
200202
}
201203
}
202204
}
@@ -248,7 +250,7 @@ async fn build_payload_attributes<P: L1MessageProvider + Unpin + Send + Sync + '
248250

249251
// Collect L1 messages to include in payload.
250252
let db_l1_messages = provider
251-
.take_n_messages_from_index(l1_messages_queue_index, max_l1_messages)
253+
.get_n_messages(l1_messages_queue_index.into(), max_l1_messages)
252254
.await
253255
.map_err(Into::<L1ProviderError>::into)?;
254256

0 commit comments

Comments
 (0)