fix: Handle phase0

ethpandaops · Dec 6, 2024 · 8bae0b0 · 8bae0b0
1 parent 27bd1fd
commit 8bae0b0
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/pkg/cannon/iterator/backfilling_checkpoint_iterator.go b/pkg/cannon/iterator/backfilling_checkpoint_iterator.go
@@ -2,7 +2,7 @@ package iterator
 
 import (
 	"context"
-	"strings"
+	"fmt"
 	"time"
 
 	"github.com/attestantio/go-eth2-client/spec"
@@ -215,9 +215,9 @@ func (c *BackfillingCheckpoint) Next(ctx context.Context) (rsp *BackFillingCheck
 			}
 		}
 
-		forkEpoch, errr := c.beaconNode.Metadata().Spec.ForkEpochs.GetByName(strings.ToUpper(c.activationFork.String()))
+		forkEpoch, errr := c.beaconNode.Metadata().Spec.ForkEpochs.GetByName(c.activationFork.String())
 		if errr != nil {
-			return nil, errors.Wrap(errr, "failed to get fork epoch")
+			return nil, errors.Wrap(errr, fmt.Sprintf("failed to get epoch for fork: %s", c.activationFork))
 		}
 
 		if checkpoint.Epoch < forkEpoch.Epoch {
@@ -435,7 +435,11 @@ func (c *BackfillingCheckpoint) GetMarker(location *xatu.CannonLocation) (*xatu.
 func (c *BackfillingCheckpoint) getEarliestPossibleBackfillEpoch() (phase0.Epoch, error) {
 	// earliestEpochForType is the earliest epoch for the type based on the fork epochs.
 	// For example, the blob_sidecar cannon type will have an earliest epoch of the DENEB fork.
-	forkEpoch, err := c.beaconNode.Metadata().Spec.ForkEpochs.GetByName(strings.ToUpper(c.activationFork.String()))
+	if c.activationFork == spec.DataVersionPhase0 {
+		return 0, nil
+	}
+
+	forkEpoch, err := c.beaconNode.Metadata().Spec.ForkEpochs.GetByName(c.activationFork.String())
 	if err != nil {
 		return 0, errors.Wrap(err, "failed to get fork epoch")
 	}