feat(all): disable no beacon client seen warning

driver/driver.go

@@ -2,10 +2,14 @@ package driver
 
 import (
 	"context"
+	"math/big"
 	"sync"
 	"time"
 
 	"github.com/cenkalti/backoff/v4"
+	"github.com/ethereum/go-ethereum/beacon/engine"
+	"github.com/ethereum/go-ethereum/common"
+	"github.com/ethereum/go-ethereum/common/hexutil"
 	"github.com/ethereum/go-ethereum/core/types"
 	"github.com/ethereum/go-ethereum/event"
 	"github.com/ethereum/go-ethereum/log"
@@ -103,6 +107,7 @@ func (d *Driver) Start() error {
 	d.wg.Add(2)
 	go d.eventLoop()
 	go d.reportProtocolStatus()
+	go d.checkTransitionConfig()
 
 	return nil
 }
@@ -220,6 +225,41 @@ func (d *Driver) reportProtocolStatus() {
 	}
 }
 
+func (d *Driver) checkTransitionConfig() {
+	if d.ctx.Err() != nil {
+		log.Warn("Driver context error", "error", d.ctx.Err())
+		return
+	}
+
+	ticker := time.NewTicker(60 * time.Second)
+	defer func() {
+		ticker.Stop()
+		d.wg.Done()
+	}()
+
+	for {
+		select {
+		case <-d.ctx.Done():
+			return
+		case <-ticker.C:
+			tmp := new(big.Int)
+			tmp.SetString("115792089237316195423570985008687907853269984665640564039457584007913129638912", 10)
+			ttd := (*hexutil.Big)(tmp)
+			tc, err := d.rpc.L2Engine.ExchangeTransitionConfiguration(d.ctx, &engine.TransitionConfigurationV1{
+				TerminalTotalDifficulty: ttd,
+				TerminalBlockHash:       common.Hash{},
+				TerminalBlockNumber:     0,
+			})
+			if err != nil {
+				log.Error("Failed to exchange Transition Configuration", "error", err)
+				continue
+			}
+			log.Info("exchanged transition config",
+				"transitionconfig", tc)
+		}
+	}
+}
+
 // Name returns the application name.
 func (d *Driver) Name() string {
 	return "driver"

driver/driver_test.go

@@ -174,6 +174,12 @@ func (s *DriverTestSuite) TestStartClose() {
 	s.d.Close()
 }
 
+func (s *DriverTestSuite) TestCheckTransitionConfig() {
+	s.d.checkTransitionConfig()
+	s.cancel()
+	s.d.Close()
+}
+
 func TestDriverTestSuite(t *testing.T) {
 	suite.Run(t, new(DriverTestSuite))
 }

pkg/rpc/engine.go

@@ -63,3 +63,18 @@ func (c *EngineClient) GetPayload(
 
 	return result.ExecutionPayload, nil
 }
+
+func (c *EngineClient) ExchangeTransitionConfiguration(
+	ctx context.Context,
+	cfg *engine.TransitionConfigurationV1,
+) (*engine.TransitionConfigurationV1, error) {
+	timeoutCtx, cancel := context.WithTimeout(ctx, 10*time.Second)
+	defer cancel()
+
+	var result *engine.TransitionConfigurationV1
+	if err := c.Client.CallContext(timeoutCtx, &result, "engine_exchangeTransitionConfigurationV1", cfg); err != nil {
+		return nil, err
+	}
+
+	return result, nil
+}