chore(taiko-client): more logs for BlockBatchIterator (#18774)

Author: davidtaikocha

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
 		}
 

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
 }

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)