Added ability to disable blobs saving for blocks

README.md

@@ -203,6 +203,9 @@ blocks:
   # refetch will refetch block data from a beacon node even if it has already has a block
   # in its database.
   # refetch: false
+  # blob.enable will fetch and save blobs for block
+  blob:
+    enable: true
 # validators contains configuration for obtaining validator-related information.
 validators:
   enable: true

chaind.config.docker-compose.yml

@@ -33,6 +33,8 @@ blocks:
   # refetch will refetch block data from a beacon node even if it has already has a block
   # in its database.
   # refetch: false
+  blob:
+    enable: true
 # validators contains configuration for obtaining validator-related information.
 validators:
   enable: true

main.go

@@ -64,7 +64,7 @@ import (
 )
 
 // ReleaseVersion is the release version for the code.
-var ReleaseVersion = "0.10.1"
+var ReleaseVersion = "0.10.2"
 
 func main() {
 	os.Exit(main2())
@@ -161,6 +161,7 @@ func fetchConfig() error {
 	pflag.Bool("blocks.enable", true, "Enable fetching of block-related information")
 	pflag.Int32("blocks.start-slot", -1, "Slot from which to start fetching blocks")
 	pflag.Bool("blocks.refetch", false, "Refetch all blocks even if they are already in the database")
+	pflag.Bool("blocks.blob.enable", true, "Enable saving of block-related blobs")
 	pflag.Bool("finalizer.enable", true, "Enable additional information on receipt of finality checkpoint")
 	pflag.Bool("summarizer.enable", true, "Enable summary information")
 	pflag.Bool("summarizer.epochs.enable", true, "Enable summary information for epochs")
@@ -508,6 +509,7 @@ func startBlocks(
 		standardblocks.WithChainDB(chainDB),
 		standardblocks.WithStartSlot(viper.GetInt64("blocks.start-slot")),
 		standardblocks.WithRefetch(viper.GetBool("blocks.refetch")),
+		standardblocks.WithBlobEnable(viper.GetBool("blocks.blob.enable")),
 		standardblocks.WithActivitySem(activitySem),
 	)
 	if err != nil {

services/blocks/standard/handler.go

@@ -714,6 +714,10 @@ func (s *Service) updateBlobSidecarsForBlock(ctx context.Context,
 	ctx, span := otel.Tracer("wealdtech.chaind.services.blocks.standard").Start(ctx, "updateBlobSidecarsForBlock")
 	defer span.End()
 
+	if !s.blobEnable {
+		return nil
+	}
+
 	response, err := s.eth2Client.(eth2client.BlobSidecarsProvider).BlobSidecars(ctx, &api.BlobSidecarsOpts{
 		Block: blockRoot.String(),
 	})

services/blocks/standard/parameters.go

@@ -32,6 +32,7 @@ type parameters struct {
 	chainTime   chaintime.Service
 	startSlot   int64
 	refetch     bool
+	blobEnable  bool
 	activitySem *semaphore.Weighted
 }
 
@@ -95,6 +96,13 @@ func WithRefetch(refetch bool) Parameter {
 	})
 }
 
+// WithBlobEnable sets the blobEnable flag for this module.
+func WithBlobEnable(blobEnable bool) Parameter {
+	return parameterFunc(func(p *parameters) {
+		p.blobEnable = blobEnable
+	})
+}
+
 // WithActivitySem sets the activity semaphore for this module.
 func WithActivitySem(sem *semaphore.Weighted) Parameter {
 	return parameterFunc(func(p *parameters) {

services/blocks/standard/service.go

@@ -47,6 +47,7 @@ type Service struct {
 	consolidationRequestsSetter chaindb.ConsolidationRequestsSetter
 	chainTime                   chaintime.Service
 	refetch                     bool
+	blobEnable                  bool
 	lastHandledBlockRoot        phase0.Root
 	activitySem                 *semaphore.Weighted
 	syncCommittees              map[uint64]*chaindb.SyncCommittee
@@ -152,10 +153,16 @@ func New(ctx context.Context, params ...Parameter) (*Service, error) {
 		consolidationRequestsSetter: consolidationRequestsSetter,
 		chainTime:                   parameters.chainTime,
 		refetch:                     parameters.refetch,
+		blobEnable:                  parameters.blobEnable,
 		activitySem:                 parameters.activitySem,
 		syncCommittees:              make(map[uint64]*chaindb.SyncCommittee),
 	}
 
+	log.Info().
+		Bool("blobEnable", parameters.blobEnable).
+		Bool("refetch", parameters.refetch).
+		Int64("startSlot", parameters.startSlot).
+		Msg("Blocks Service initialized")
 	// Note the current highest processed block for the monitor.
 	md, err := s.getMetadata(ctx)
 	if err != nil {