diff --git a/db/db.go b/db/db.go index cb5a6b6..7233ed0 100644 --- a/db/db.go +++ b/db/db.go @@ -79,6 +79,7 @@ func (db *OperationDB) AddOperation(op *pbkv.KVOperation) { } func (db *OperationDB) HandleOperations(ctx context.Context, blockNumber uint64, finalBlockHeight uint64, step bstream.StepType, kvOps *pbkv.KVOperations) error { if step == bstream.StepNew { + db.logger.Info("handling undos", zap.Uint64("block_number", blockNumber), zap.Int("step", int(step))) err := db.PurgeUndoOperations(ctx, finalBlockHeight) if err != nil { return fmt.Errorf("deleting LIB undo operations: %w", err)