remove onForkchoiceUpdate

Author: avalonche

builder/beacon_client.go

@@ -26,9 +26,6 @@ func (b *testBeaconClient) isValidator(pubkey PubkeyHex) bool {
 func (b *testBeaconClient) getProposerForNextSlot(requestedSlot uint64) (PubkeyHex, error) {
 	return PubkeyHex(hexutil.Encode(b.validator.Pk)), nil
 }
-func (b *testBeaconClient) onForkchoiceUpdate() (uint64, error) {
-	return b.slot, nil
-}
 
 func (b *testBeaconClient) updateValidatorsMap() error {
 	return nil
@@ -39,11 +36,9 @@ type BeaconClient struct {
 	slotsInEpoch  uint64
 	secondsInSlot uint64
 
-	mu               sync.Mutex
-	currentEpoch     uint64
-	currentSlot      uint64
-	nextSlotProposer PubkeyHex
-	slotProposerMap  map[uint64]PubkeyHex
+	mu              sync.Mutex
+	currentEpoch    uint64
+	slotProposerMap map[uint64]PubkeyHex
 }
 
 func NewBeaconClient(endpoint string, slotsInEpoch uint64, secondsInSlot uint64) *BeaconClient {
@@ -127,42 +122,6 @@ func (b *BeaconClient) updateValidatorsMap() error {
 	return nil
 }
 
-/* Returns next slot's proposer pubkey */
-// TODO: what happens if no block for previous slot - should still get next slot
-func (b *BeaconClient) onForkchoiceUpdate() (uint64, error) {
-	b.mu.Lock()
-	defer b.mu.Unlock()
-
-	currentSlot, err := fetchCurrentSlot(b.endpoint)
-	if err != nil {
-		return 0, err
-	}
-
-	nextSlot := currentSlot + 1
-
-	b.currentSlot = currentSlot
-	nextSlotEpoch := nextSlot / b.slotsInEpoch
-
-	if nextSlotEpoch != b.currentEpoch {
-		// TODO: this should be prepared in advance, possibly just fetch for next epoch in advance
-		slotProposerMap, err := fetchEpochProposersMap(b.endpoint, nextSlotEpoch)
-		if err != nil {
-			return 0, err
-		}
-
-		b.currentEpoch = nextSlotEpoch
-		b.slotProposerMap = slotProposerMap
-	}
-
-	nextSlotProposer, found := b.slotProposerMap[nextSlot]
-	if !found {
-		log.Error("inconsistent proposer mapping", "currentSlot", currentSlot, "slotProposerMap", b.slotProposerMap)
-		return 0, errors.New("inconsistent proposer mapping")
-	}
-	b.nextSlotProposer = nextSlotProposer
-	return nextSlot, nil
-}
-
 func fetchCurrentSlot(endpoint string) (uint64, error) {
 	headerRes := &struct {
 		Data []struct {

builder/beacon_client_test.go

@@ -174,95 +174,3 @@ func TestFetchEpochProposersMap(t *testing.T) {
 	require.Equal(t, PubkeyHex("0x93247f2209abcacf57b75a51dafae777f9dd38bc7053d1af526f220a7489a6d3a2753e5f3e8b1cfe39b56f43611df74a"), proposersMap[1])
 	require.Equal(t, PubkeyHex("0x93247f2209abcacf57b75a51dafae777f9dd38bc7053d1af526f220a7489a6d3a2753e5f3e8b1cfe39b56f43611df74b"), proposersMap[2])
 }
-
-func TestOnForkchoiceUpdate(t *testing.T) {
-	mbn := newMockBeaconNode()
-	defer mbn.srv.Close()
-
-	mbn.headersResp = []byte(`{ "data": [ { "header": { "message": { "slot": "31", "proposer_index": "1" } } } ] }`)
-
-	mbn.proposerDuties[1] = []byte(`{
-  "dependent_root": "0xcf8e0d4e9587369b2301d0790347320302cc0943d5a1884560367e8208d920f2",
-  "execution_optimistic": false,
-  "data": [
-    {
-      "pubkey": "0x93247f2209abcacf57b75a51dafae777f9dd38bc7053d1af526f220a7489a6d3a2753e5f3e8b1cfe39b56f43611df74a",
-      "validator_index": "1",
-      "slot": "31"
-    },
-    {
-      "pubkey": "0x93247f2209abcacf57b75a51dafae777f9dd38bc7053d1af526f220a7489a6d3a2753e5f3e8b1cfe39b56f43611df74b",
-      "validator_index": "2",
-      "slot": "32"
-    },
-    {
-      "pubkey": "0x93247f2209abcacf57b75a51dafae777f9dd38bc7053d1af526f220a7489a6d3a2753e5f3e8b1cfe39b56f43611df74c",
-      "validator_index": "3",
-      "slot": "33"
-    }
-  ]
-}`)
-
-	bc := NewBeaconClient(mbn.srv.URL, 32, 12)
-	slot, err := bc.onForkchoiceUpdate()
-	require.NoError(t, err)
-	require.Equal(t, slot, uint64(32))
-
-	pubkeyHex, err := bc.getProposerForNextSlot(32)
-	require.NoError(t, err)
-	require.Equal(t, PubkeyHex("0x93247f2209abcacf57b75a51dafae777f9dd38bc7053d1af526f220a7489a6d3a2753e5f3e8b1cfe39b56f43611df74b"), pubkeyHex)
-
-	_, err = bc.getProposerForNextSlot(31)
-	require.EqualError(t, err, "slot out of sync")
-
-	_, err = bc.getProposerForNextSlot(33)
-	require.EqualError(t, err, "slot out of sync")
-
-	mbn.headersCode = 404
-	mbn.headersResp = []byte(`{ "code": 404, "message": "State not found" }`)
-
-	slot, err = NewBeaconClient(mbn.srv.URL, 32, 12).onForkchoiceUpdate()
-	require.EqualError(t, err, "State not found")
-	require.Equal(t, slot, uint64(0))
-
-	// Check that client does not fetch new proposers if epoch did not change
-	mbn.headersCode = 200
-	mbn.headersResp = []byte(`{ "data": [ { "header": { "message": { "slot": "31", "proposer_index": "1" } } } ] }`)
-	mbn.proposerDuties[1] = []byte(`{
-  "data": [
-    {
-      "pubkey": "0x93247f2209abcacf57b75a51dafae777f9dd38bc7053d1af526f220a7489a6d3a2753e5f3e8b1cfe39b56f43611df74d",
-      "validator_index": "4",
-      "slot": "32"
-    }
-  ]
-}`)
-
-	slot, err = bc.onForkchoiceUpdate()
-	require.NoError(t, err, "")
-	require.Equal(t, slot, uint64(32))
-
-	mbn.headersResp = []byte(`{ "data": [ { "header": { "message": { "slot": "63", "proposer_index": "1" } } } ] }`)
-	mbn.proposerDuties[2] = []byte(`{
-  "data": [
-    {
-      "pubkey": "0x93247f2209abcacf57b75a51dafae777f9dd38bc7053d1af526f220a7489a6d3a2753e5f3e8b1cfe39b56f43611df74d",
-      "validator_index": "4",
-      "slot": "64"
-    }
-  ]
-}`)
-
-	slot, err = bc.onForkchoiceUpdate()
-	require.NoError(t, err, "")
-	require.Equal(t, slot, uint64(64))
-
-	pubkeyHex, err = bc.getProposerForNextSlot(64)
-	require.NoError(t, err)
-	require.Equal(t, PubkeyHex("0x93247f2209abcacf57b75a51dafae777f9dd38bc7053d1af526f220a7489a6d3a2753e5f3e8b1cfe39b56f43611df74d"), pubkeyHex)
-
-	// Check proposers map error is routed out
-	mbn.headersResp = []byte(`{ "data": [ { "header": { "message": { "slot": "65", "proposer_index": "1" } } } ] }`)
-	_, err = bc.onForkchoiceUpdate()
-	require.EqualError(t, err, "inconsistent proposer mapping")
-}

builder/builder.go

@@ -32,7 +32,6 @@ type ValidatorData struct {
 type IBeaconClient interface {
 	isValidator(pubkey PubkeyHex) bool
 	getProposerForNextSlot(requestedSlot uint64) (PubkeyHex, error)
-	onForkchoiceUpdate() (uint64, error)
 	updateValidatorsMap() error
 }