feat(networkconfig,beacon/goclient): get beacon config from beacon node

beacon/goclient/aggregator.go

@@ -39,7 +39,7 @@
 	if err != nil {
 		return nil, DataVersionNil, fmt.Errorf("failed to get attestation data: %w", err)
 	}
-	if gc.DataVersion(gc.beaconConfig.EstimatedEpochAtSlot(attData.Slot)) < spec.DataVersionElectra {
+	if gc.DataVersion(gc.getBeaconConfig().EstimatedEpochAtSlot(attData.Slot)) < spec.DataVersionElectra {
 		attData.Index = committeeIndex
 	}
 
@@ -201,9 +201,9 @@
 
 // waitToSlotTwoThirds waits until two-third of the slot has transpired (SECONDS_PER_SLOT * 2 / 3 seconds after slot start time)
 func (gc *GoClient) waitToSlotTwoThirds(slot phase0.Slot) {
-	oneThird := gc.beaconConfig.SlotDuration / 3 /* one third of slot duration */
-
-	finalTime := gc.beaconConfig.GetSlotStartTime(slot).Add(2 * oneThird)
+	config := gc.getBeaconConfig()
+	oneThird := config.SlotDuration / 3 /* one third of slot duration */
+	finalTime := config.GetSlotStartTime(slot).Add(2 * oneThird)
 	wait := time.Until(finalTime)
 	if wait <= 0 {
 		return

beacon/goclient/attest_test.go

@@ -18,8 +18,6 @@ import (
 	"github.com/stretchr/testify/require"
 	"go.uber.org/zap"
 
-	"github.com/ssvlabs/ssv/networkconfig"
-	"github.com/ssvlabs/ssv/operator/slotticker"
 	"github.com/ssvlabs/ssv/utils/hashmap"
 )
 
@@ -204,17 +202,10 @@ func TestGoClient_GetAttestationData_Simple(t *testing.T) {
 			t.Context(),
 			zap.NewNop(),
 			Options{
-				BeaconConfig:   networkconfig.Mainnet.BeaconConfig,
 				BeaconNodeAddr: server.URL,
 				CommonTimeout:  1 * time.Second,
 				LongTimeout:    1 * time.Second,
 			},
-			func() slotticker.SlotTicker {
-				return slotticker.New(zap.NewNop(), slotticker.Config{
-					SlotDuration: 12 * time.Second,
-					GenesisTime:  time.Now(),
-				})
-			},
 		)
 		require.NoError(t, err)
 
@@ -500,18 +491,11 @@ func createClient(
 		ctx,
 		zap.NewNop(),
 		Options{
-			BeaconConfig:                networkconfig.Mainnet.BeaconConfig,
 			BeaconNodeAddr:              beaconServerURL,
 			CommonTimeout:               defaultHardTimeout,
 			LongTimeout:                 time.Second,
 			WithWeightedAttestationData: withWeightedAttestationData,
 		},
-		func() slotticker.SlotTicker {
-			return slotticker.New(zap.NewNop(), slotticker.Config{
-				SlotDuration: 12 * time.Second,
-				GenesisTime:  time.Now(),
-			})
-		},
 	)
 	return client, err
 }

beacon/goclient/current_fork_test.go

@@ -55,7 +55,6 @@ func TestCurrentFork(t *testing.T) {
 				CommonTimeout:  100 * time.Millisecond,
 				LongTimeout:    500 * time.Millisecond,
 			},
-			tests.MockSlotTickerProvider,
 		)
 		require.NoError(t, err)
 
@@ -86,7 +85,6 @@ func TestCurrentFork(t *testing.T) {
 				CommonTimeout:  100 * time.Millisecond,
 				LongTimeout:    500 * time.Millisecond,
 			},
-			tests.MockSlotTickerProvider,
 		)
 		require.NoError(t, err)
 
@@ -126,7 +124,6 @@ func TestCurrentFork(t *testing.T) {
 				CommonTimeout:  100 * time.Millisecond,
 				LongTimeout:    500 * time.Millisecond,
 			},
-			tests.MockSlotTickerProvider,
 		)
 		require.NoError(t, err)
 

beacon/goclient/events_test.go

@@ -13,7 +13,6 @@ import (
 	"go.uber.org/zap"
 
 	"github.com/ssvlabs/ssv/beacon/goclient/tests"
-	"github.com/ssvlabs/ssv/networkconfig"
 )
 
 func TestSubscribeToHeadEvents(t *testing.T) {
@@ -84,9 +83,7 @@ func eventsTestClient(t *testing.T, serverURL string) *GoClient {
 		zap.NewNop(),
 		Options{
 			BeaconNodeAddr: serverURL,
-			BeaconConfig:   networkconfig.Mainnet.BeaconConfig,
-		},
-		tests.MockSlotTickerProvider)
+		})
 
 	require.NoError(t, err)
 	return server

beacon/goclient/genesis_test.go

@@ -14,7 +14,10 @@ import (
 	"github.com/ssvlabs/ssv/networkconfig"
 )
 
-const genesisPath = "/eth/v1/beacon/genesis"
+const (
+	genesisPath = "/eth/v1/beacon/genesis"
+	specPath    = "/eth/v1/config/spec"
+)
 
 func TestGenesis(t *testing.T) {
 	ctx := context.Background()
@@ -30,6 +33,29 @@ func TestGenesis(t *testing.T) {
 					}
 				}`), nil
 			}
+			if r.URL.Path == specPath {
+				return json.RawMessage(`{
+					"data": {
+						"CONFIG_NAME": "holesky",
+						"GENESIS_FORK_VERSION": "0x00000000",
+						"CAPELLA_FORK_VERSION": "0x04017000",
+						"MIN_GENESIS_TIME": "1695902100",
+						"SECONDS_PER_SLOT": "12",
+						"SLOTS_PER_EPOCH": "32",
+						"EPOCHS_PER_SYNC_COMMITTEE_PERIOD": "256",
+						"SYNC_COMMITTEE_SIZE": "512",
+						"SYNC_COMMITTEE_SUBNET_COUNT": "4",
+						"TARGET_AGGREGATORS_PER_COMMITTEE": "16",
+						"TARGET_AGGREGATORS_PER_SYNC_SUBCOMMITTEE": "16",
+						"INTERVALS_PER_SLOT": "3",
+						"ALTAIR_FORK_EPOCH": "74240",
+						"BELLATRIX_FORK_EPOCH": "144896",
+						"CAPELLA_FORK_EPOCH": "194048",
+						"DENEB_FORK_EPOCH": "269568",
+						"ELECTRA_FORK_EPOCH": "18446744073709551615"
+					}
+				}`), nil
+			}
 			return resp, nil
 		})
 		defer mockServer.Close()
@@ -43,7 +69,6 @@ func TestGenesis(t *testing.T) {
 				CommonTimeout:  100 * time.Millisecond,
 				LongTimeout:    500 * time.Millisecond,
 			},
-			tests.MockSlotTickerProvider,
 		)
 		require.NoError(t, err)
 
@@ -73,13 +98,10 @@ func TestGenesis(t *testing.T) {
 				CommonTimeout:  100 * time.Millisecond,
 				LongTimeout:    500 * time.Millisecond,
 			},
-			tests.MockSlotTickerProvider,
 		)
-		require.NoError(t, err)
-
-		_, err = client.Genesis(ctx)
 		require.Error(t, err)
-		require.Contains(t, err.Error(), "genesis response data is nil")
+		require.Contains(t, err.Error(), "timed out awaiting config initialization") // node cannot initialize if it cannot get genesis
+		require.Nil(t, client)
 	})
 
 	t.Run("error", func(t *testing.T) {
@@ -100,12 +122,9 @@ func TestGenesis(t *testing.T) {
 				CommonTimeout:  100 * time.Millisecond,
 				LongTimeout:    500 * time.Millisecond,
 			},
-			tests.MockSlotTickerProvider,
 		)
-		require.NoError(t, err)
-
-		_, err = client.Genesis(ctx)
 		require.Error(t, err)
-		require.Contains(t, err.Error(), "failed to request genesis")
+		require.Contains(t, err.Error(), "timed out awaiting config initialization") // node cannot initialize if it cannot get genesis
+		require.Nil(t, client)
 	})
 }