Fix: mempool receiver block time

cmd/mempool/indexer.go

@@ -68,8 +68,9 @@ func NewIndexer(ctx context.Context, network string, indexerCfg config.Indexer,
 	}
 
 	memInd, err := receiver.New(indexerCfg.DataSource.RPC, network,
-		receiver.WithStorage(db, constants.TimeBetweenBlocks[0]),
+		receiver.WithStorage(db),
 		receiver.WithPrometheus(prom),
+		receiver.WithBlockTime(constants.TimeBetweenBlocks[0]),
 	)
 	if err != nil {
 		return nil, err

cmd/mempool/receiver/options.go

@@ -9,13 +9,8 @@ import (
 type ReceiverOption func(*Receiver)
 
 // WithStorage -
-func WithStorage(db *database.PgGo, blockTime int64) ReceiverOption {
+func WithStorage(db *database.PgGo) ReceiverOption {
 	return func(m *Receiver) {
-		if blockTime > 0 {
-			m.blockTime = blockTime
-		} else {
-			m.blockTime = 60
-		}
 		m.db = db
 	}
 }
@@ -26,3 +21,10 @@ func WithPrometheus(prom *prometheus.Service) ReceiverOption {
 		m.prom = prom
 	}
 }
+
+// WithBlockTime -
+func WithBlockTime(blockTime int64) ReceiverOption {
+	return func(m *Receiver) {
+		m.blockTime = blockTime
+	}
+}

cmd/mempool/receiver/receiver.go

@@ -55,6 +55,10 @@ func New(urls []string, network string, opts ...ReceiverOption) (*Receiver, erro
 		opts[i](&indexer)
 	}
 
+	if indexer.blockTime == 0 {
+		indexer.blockTime = 30
+	}
+
 	return &indexer, nil
 }