diff --git a/packages/taiko-client/driver/chain_syncer/blob/syncer.go b/packages/taiko-client/driver/chain_syncer/blob/syncer.go index 7a0fe0b901d..51c50dccb03 100644 --- a/packages/taiko-client/driver/chain_syncer/blob/syncer.go +++ b/packages/taiko-client/driver/chain_syncer/blob/syncer.go @@ -198,6 +198,7 @@ func (s *Syncer) onBlockProposed( } // Ignore those already inserted blocks. if s.lastInsertedBlockID != nil && meta.GetBlockID().Cmp(s.lastInsertedBlockID) <= 0 { + log.Debug("Skip already inserted block", "blockID", meta.GetBlockID(), "lastInsertedBlockID", s.lastInsertedBlockID) return nil } @@ -224,6 +225,7 @@ func (s *Syncer) onBlockProposed( if s.progressTracker.Triggered() { // Already synced through beacon sync, just skip this event. if meta.GetBlockID().Cmp(s.progressTracker.LastSyncedBlockID()) <= 0 { + log.Debug("Skip already beacon synced block", "blockID", meta.GetBlockID()) return nil } diff --git a/packages/taiko-client/pkg/chain_iterator/block_batch_iterator.go b/packages/taiko-client/pkg/chain_iterator/block_batch_iterator.go index 56242c39d2b..b79debd7a5e 100644 --- a/packages/taiko-client/pkg/chain_iterator/block_batch_iterator.go +++ b/packages/taiko-client/pkg/chain_iterator/block_batch_iterator.go @@ -144,9 +144,16 @@ func (i *BlockBatchIterator) Iter() error { } if err := i.iter(); err != nil { if errors.Is(err, io.EOF) { + log.Debug( + "Block batch iterator finished", + "start", i.startHeight, + "end", i.endHeight, + "current", i.current.Number, + ) break } if errors.Is(err, errContinue) { + log.Debug("Block batch iterator continues", "current", i.current.Number) continue } log.Error("Block batch iterator callback error", "error", err) @@ -212,6 +219,8 @@ func (i *BlockBatchIterator) iter() (err error) { return err } + log.Debug("Iterating blocks", "start", i.current.Number, "end", endHeader.Number) + if err := i.onBlocks(i.ctx, i.current, endHeader, i.updateCurrent, i.end); err != nil { return err } @@ -287,6 +296,8 @@ func (i *BlockBatchIterator) rewindOnReorgDetected() error { return err } + log.Debug("Rewind on reorg detected", "oldCurrent", i.current.Number, "newCurrent", current.Number) + i.current = current return nil } diff --git a/packages/taiko-client/pkg/chain_iterator/event_iterator/block_proposed_iterator.go b/packages/taiko-client/pkg/chain_iterator/event_iterator/block_proposed_iterator.go index 5941ae467e9..5441623c03d 100644 --- a/packages/taiko-client/pkg/chain_iterator/event_iterator/block_proposed_iterator.go +++ b/packages/taiko-client/pkg/chain_iterator/event_iterator/block_proposed_iterator.go @@ -125,6 +125,7 @@ func assembleBlockProposedIteratorCallback( for iterOntake.Next() { event := iterOntake.Event + log.Debug("Processing BlockProposedV2 event", "block", event.BlockId, "l1BlockHeight", event.Raw.BlockNumber) if err := callback(ctx, metadata.NewTaikoDataBlockMetadataOntake(event), eventIter.end); err != nil { log.Warn("Error while processing BlockProposedV2 events, keep retrying", "error", err)