Skip to content

Commit edbe6f6

Browse files
author
colinlyguo
committed
add PostL1MessageQueueHash update
1 parent 6a8ef2c commit edbe6f6

File tree

2 files changed

+6
-0
lines changed

2 files changed

+6
-0
lines changed

rollup/internal/controller/watcher/batch_proposer.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -161,6 +161,7 @@ func (p *BatchProposer) updateDBBatchInfo(batch *encoding.Batch, codecVersion en
161161
}
162162

163163
batch.Chunks = batch.Chunks[:len(batch.Chunks)-1]
164+
batch.PostL1MessageQueueHash = batch.Chunks[len(batch.Chunks)-1].PostL1MessageQueueHash
164165

165166
log.Info("Batch not compatible with compressed data, removing last chunk", "batch index", batch.Index, "truncated chunk length", len(batch.Chunks))
166167
}

rollup/internal/controller/watcher/chunk_proposer.go

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -175,6 +175,11 @@ func (p *ChunkProposer) updateDBChunkInfo(chunk *encoding.Chunk, codecVersion en
175175
}
176176

177177
chunk.Blocks = chunk.Blocks[:len(chunk.Blocks)-1]
178+
chunk.PostL1MessageQueueHash, err = encoding.MessageQueueV2ApplyL1MessagesFromBlocks(chunk.PrevL1MessageQueueHash, chunk.Blocks)
179+
if err != nil {
180+
log.Error("Failed to calculate last L1 message queue hash for block", "block number", chunk.Blocks[0].Header.Number, "err", err)
181+
return err
182+
}
178183

179184
log.Info("Chunk not compatible with compressed data, removing last block", "start block number", chunk.Blocks[0].Header.Number, "truncated block length", len(chunk.Blocks))
180185
}

0 commit comments

Comments
 (0)