loop over multiple signatures for address

pkg/solana/logpoller/loader.go

@@ -90,29 +90,54 @@ func (c *EncodedLogCollector) BackfillForAddress(ctx context.Context, address st
 		return err
 	}
 
-	sigs, err := c.client.GetSignaturesForAddressWithOpts(ctx, pubKey, &rpc.GetSignaturesForAddressOpts{
-		Commitment:     rpc.CommitmentFinalized,
-		MinContextSlot: &fromSlot,
-	})
-	if err != nil {
-		return err
-	}
+	var (
+		lowestSlotRead uint64
+		lowestSlotSig  solana.Signature
+	)
 
-	slots := make(map[uint64]struct{})
+	for lowestSlotRead > fromSlot {
+		opts := rpc.GetSignaturesForAddressOpts{
+			Commitment:     rpc.CommitmentFinalized,
+			MinContextSlot: &fromSlot,
+		}
 
-	for _, sig := range sigs {
-		_, ok := slots[sig.Slot]
-		if !ok {
-			if err := c.workers.Do(ctx, &getTransactionsFromBlockJob{
-				slotNumber: sig.Slot,
-				client:     c.client,
-				parser:     c.parser,
-				chJobs:     c.chJobs,
-			}); err != nil {
-				return err
+		if lowestSlotRead > 0 {
+			opts.Before = lowestSlotSig
+		}
+
+		sigs, err := c.client.GetSignaturesForAddressWithOpts(ctx, pubKey, &opts)
+		if err != nil {
+			return err
+		}
+
+		slots := make(map[uint64]struct{})
+
+		var newSigsFound bool
+
+		for _, sig := range sigs {
+			if sig.Slot < lowestSlotRead {
+				lowestSlotRead = sig.Slot
+				lowestSlotSig = sig.Signature
 			}
 
-			slots[sig.Slot] = struct{}{}
+			_, ok := slots[sig.Slot]
+			if !ok {
+				if err := c.workers.Do(ctx, &getTransactionsFromBlockJob{
+					slotNumber: sig.Slot,
+					client:     c.client,
+					parser:     c.parser,
+					chJobs:     c.chJobs,
+				}); err != nil {
+					return err
+				}
+
+				slots[sig.Slot] = struct{}{}
+				newSigsFound = true
+			}
+		}
+
+		if !newSigsFound {
+			break
 		}
 	}