Add sync start block number config parameter

Author: jannikluhn

rolling-shutter/keyperimpl/gnosis/config.go

@@ -106,6 +106,7 @@ type GnosisConfig struct {
 	SecondsPerSlot       uint64                       `shconfig:",required"`
 	SlotsPerEpoch        uint64                       `shconfig:",required"`
 	GenesisSlotTimestamp uint64                       `shconfig:",required"`
+	SyncStartBlockNumber uint64                       `shconfig:",required"`
 }
 
 func NewGnosisConfig() *GnosisConfig {
@@ -118,6 +119,7 @@ func NewGnosisConfig() *GnosisConfig {
 		SecondsPerSlot:       0,
 		SlotsPerEpoch:        0,
 		GenesisSlotTimestamp: 0,
+		SyncStartBlockNumber: 0,
 	}
 	c.Init()
 	return c
@@ -153,6 +155,7 @@ func (c *GnosisConfig) SetExampleValues() error {
 	c.SecondsPerSlot = 5
 	c.SlotsPerEpoch = 16
 	c.GenesisSlotTimestamp = 1665410700
+	c.SyncStartBlockNumber = 0
 	return nil
 }
 

rolling-shutter/keyperimpl/gnosis/keyper.go

@@ -201,6 +201,7 @@ func (kpr *Keyper) initSequencerSyncer(ctx context.Context) error {
 		ExecutionClient:      client,
 		GenesisSlotTimestamp: kpr.config.Gnosis.GenesisSlotTimestamp,
 		SecondsPerSlot:       kpr.config.Gnosis.SecondsPerSlot,
+		SyncStartBlockNumber: kpr.config.Gnosis.SyncStartBlockNumber,
 	}
 
 	// Perform an initial sync now because it might take some time and doing so during regular
@@ -234,11 +235,12 @@ func (kpr *Keyper) initValidatorSyncer(ctx context.Context) error {
 		return errors.Wrap(err, "failed to instantiate validator registry contract")
 	}
 	kpr.validatorSyncer = &ValidatorSyncer{
-		Contract:        validatorRegistryContract,
-		DBPool:          kpr.dbpool,
-		BeaconAPIClient: kpr.beaconAPIClient,
-		ExecutionClient: validatorSyncerClient,
-		ChainID:         chainID.Uint64(),
+		Contract:             validatorRegistryContract,
+		DBPool:               kpr.dbpool,
+		BeaconAPIClient:      kpr.beaconAPIClient,
+		ExecutionClient:      validatorSyncerClient,
+		ChainID:              chainID.Uint64(),
+		SyncStartBlockNumber: kpr.config.Gnosis.SyncStartBlockNumber,
 	}
 
 	// Perform an initial sync now because it might take some time and doing so during regular

rolling-shutter/keyperimpl/gnosis/sequencersyncer.go

@@ -26,6 +26,7 @@ type SequencerSyncer struct {
 	ExecutionClient      *ethclient.Client
 	GenesisSlotTimestamp uint64
 	SecondsPerSlot       uint64
+	SyncStartBlockNumber uint64
 }
 
 // Sync fetches transaction submitted events from the sequencer contract and inserts them into the
@@ -39,7 +40,7 @@ func (s *SequencerSyncer) Sync(ctx context.Context, header *types.Header) error
 	}
 	var start uint64
 	if err == pgx.ErrNoRows {
-		start = 0
+		start = s.SyncStartBlockNumber
 	} else {
 		start = uint64(syncedUntil.BlockNumber + 1)
 	}

rolling-shutter/keyperimpl/gnosis/validatorsyncer.go

@@ -29,11 +29,12 @@ const (
 )
 
 type ValidatorSyncer struct {
-	Contract        *validatorRegistryBindings.Validatorregistry
-	DBPool          *pgxpool.Pool
-	BeaconAPIClient *beaconapiclient.Client
-	ExecutionClient *ethclient.Client
-	ChainID         uint64
+	Contract             *validatorRegistryBindings.Validatorregistry
+	DBPool               *pgxpool.Pool
+	BeaconAPIClient      *beaconapiclient.Client
+	ExecutionClient      *ethclient.Client
+	ChainID              uint64
+	SyncStartBlockNumber uint64
 }
 
 func (v *ValidatorSyncer) Sync(ctx context.Context, header *types.Header) error {
@@ -44,7 +45,7 @@ func (v *ValidatorSyncer) Sync(ctx context.Context, header *types.Header) error
 	}
 	var start uint64
 	if err == pgx.ErrNoRows {
-		start = 0
+		start = v.SyncStartBlockNumber
 	} else {
 		start = uint64(syncedUntil.BlockNumber + 1)
 	}