Fix for fulu support.

CHANGELOG.md

@@ -1,3 +1,6 @@
+0.10.1:
+  - fix block handlers for fulu block event
+
 0.10.0:
   - support fulu
   - use updated event handlers from go-eth2-client

main.go

@@ -152,7 +152,7 @@ func main2() int {
 func fetchConfig() error {
 	pflag.String("base-dir", "", "base directory for configuration files")
 	pflag.Bool("version", false, "show version and exit")
-	pflag.String("log-level", "info", "minimum level of messsages to log")
+	pflag.String("log-level", "info", "minimum level of messages to log")
 	pflag.String("log-file", "", "redirect log output to a file")
 	pflag.String("profile-address", "", "Address on which to run Go profile server")
 	pflag.String("tracing-address", "", "Address to which to send tracing data")

metrics.go

@@ -53,7 +53,7 @@ func registerPrometheusMetrics() error {
 		Help:      "The timestamp at which this instance started.",
 	})
 	if err := prometheus.Register(startTime); err != nil {
-		return errors.Wrap(err, "failed to regsiter start_time_secs")
+		return errors.Wrap(err, "failed to register start_time_secs")
 	}
 	startTime.SetToCurrentTime()
 
@@ -72,7 +72,7 @@ func registerPrometheusMetrics() error {
 		Help:      "1 if ready to serve requests, otherwise 0.",
 	})
 	if err := prometheus.Register(readyMetric); err != nil {
-		return errors.Wrap(err, "failed to regsiter ready")
+		return errors.Wrap(err, "failed to register ready")
 	}
 
 	return nil

services/blocks/standard/handler.go

@@ -43,7 +43,6 @@ func (s *Service) OnBeaconChainHeadUpdated(
 	slot phase0.Slot,
 	blockRoot phase0.Root,
 	stateRoot phase0.Root,
-	// skipcq: RVV-A0005
 	epochTransition bool,
 ) {
 	ctx, span := otel.Tracer("wealdtech.chaind.services.blocks.standard").Start(ctx, "OnBeaconChainHeadUpdated",
@@ -194,6 +193,8 @@ func (s *Service) OnBlock(ctx context.Context, signedBlock *spec.VersionedSigned
 		return s.onBlockDeneb(ctx, signedBlock.Deneb, dbBlock)
 	case spec.DataVersionElectra:
 		return s.onBlockElectra(ctx, signedBlock.Electra, dbBlock)
+	case spec.DataVersionFulu:
+		return s.onBlockElectra(ctx, signedBlock.Fulu, dbBlock)
 	case spec.DataVersionUnknown:
 		return errors.New("unknown block version")
 	default:
@@ -757,6 +758,8 @@ func (s *Service) dbBlock(
 		return s.dbBlockDeneb(ctx, block.Deneb.Message)
 	case spec.DataVersionElectra:
 		return s.dbBlockElectra(ctx, block.Electra.Message)
+	case spec.DataVersionFulu:
+		return s.dbBlockElectra(ctx, block.Fulu.Message)
 	case spec.DataVersionUnknown:
 		return nil, errors.New("unknown block version")
 	default:

services/chaindb/postgresql/validators.go

@@ -524,8 +524,8 @@ func (s *Service) ValidatorBalancesByIndexAndEpochRange(
 		return validatorIndices[i] < validatorIndices[j]
 	})
 
-	// Create a matrix of the values we require.  This allows the database to fill in the blanks when it doesn't have a balance for
-	// the required (index,epoch) tuple (for exmple when the balance is 0).
+	// Create a matrix of the values we require. This allows the database to fill in the blanks when it doesn't have a balance for
+	// the required (index,epoch) tuple (for example when the balance is 0).
 	values := make([]string, 0)
 	for _, validatorIndex := range validatorIndices {
 		for epoch := startEpoch; epoch < endEpoch; epoch++ {
@@ -599,8 +599,8 @@ func (s *Service) ValidatorBalancesByIndexAndEpochs(
 		return validatorIndices[i] < validatorIndices[j]
 	})
 
-	// Create a matrix of the values we require.  This allows the database to fill in the blanks when it doesn't have a balance for
-	// the required (index,epoch) tuple (for exmple when the balance is 0).
+	// Create a matrix of the values we require. This allows the database to fill in the blanks when it doesn't have a balance for
+	// the required (index,epoch) tuple (for example when the balance is 0).
 	values := make([]string, 0)
 	for _, validatorIndex := range validatorIndices {
 		for _, epoch := range epochs {

services/chaindb/types.go

@@ -70,7 +70,7 @@ type ValidatorBalance struct {
 	EffectiveBalance phase0.Gwei
 }
 
-// AggregateValidatorBalance holds aggreated information about validators' balances at a given epoch.
+// AggregateValidatorBalance holds aggregated information about validators' balances at a given epoch.
 type AggregateValidatorBalance struct {
 	Epoch            phase0.Epoch
 	Balance          phase0.Gwei

util/calendarduration_test.go

@@ -287,7 +287,7 @@ func TestCalendarDuration(t *testing.T) {
 		// Because Go normalises dates, months addition can be counter-intuitive.
 		// Please refer to 	 for details.
 		// We reimplement months addition following the logic in https://lubridate.tidyverse.org/reference/mplus.html
-		// which matches implemenation of Moment.js and Java
+		// which matches implementation of Moment.js and Java
 		{
 			name:     "EndMonths",
 			duration: "P1M",

util/logging.go

@@ -40,7 +40,7 @@ func LogLevel(path string) zerolog.Level {
 	return LogLevel(path[0:lastPeriod])
 }
 
-// stringtoLevel converts a string to a log level.
+// stringToLevel converts a string to a log level.
 // It returns the user-supplied level by default.
 func stringToLevel(input string) zerolog.Level {
 	switch strings.ToLower(input) {