From 88abca65c66ad03a5c0cc9b44d5a2bffb59f4c94 Mon Sep 17 00:00:00 2001
From: danwt <30197399+danwt@users.noreply.github.com>
Date: Mon, 13 May 2024 14:38:11 +0100
Subject: [PATCH] fix retrieve loop

---
 block/retriever.go | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/block/retriever.go b/block/retriever.go
index e885e7255..bcefd4f34 100644
--- a/block/retriever.go
+++ b/block/retriever.go
@@ -15,16 +15,18 @@ import (
 // fetching batches from the settlement layer and then fetching the actual blocks
 // from the DA.
 func (m *Manager) RetrieveLoop(ctx context.Context) {
-	m.logger.Info("started retrieve loop")
-	targetSyncHeightPoller := diodes.NewPoller(m.targetSyncHeight, diodes.WithPollingContext(ctx))
+	m.logger.Info("Started retrieve loop.")
+	p := diodes.NewPoller(m.targetSyncHeight, diodes.WithPollingContext(ctx))
 
 	for {
 		select {
 		case <-ctx.Done():
 			return
 		default:
-			// Get only the latest sync target
-			targetHeight := targetSyncHeightPoller.Next()
+			/*
+				We only care about the latest one
+			*/
+			targetHeight := p.Next()
 			err := m.syncToTargetHeight(*(*uint64)(targetHeight))
 			if err != nil {
 				panic(fmt.Errorf("sync until target: %w", err))