Add option to manually enable indexer

xmtp · Nov 25, 2024 · ad1e1f8 · ad1e1f8
1 parent 1ef7cea
commit ad1e1f8
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 8 deletions.
diff --git a/pkg/config/options.go b/pkg/config/options.go
@@ -27,6 +27,10 @@ type DbOptions struct {
 	WaitForDB              time.Duration `long:"wait-for"                 env:"XMTPD_DB_WAIT_FOR"                 description:"wait for DB on start, up to specified duration"`
 }
 
+type IndexerOptions struct {
+	Enable bool `long:"enable" env:"XMTPD_INDEXER_ENABLE" description:"Enable the indexer"`
+}
+
 // MetricsOptions are settings used to start a prometheus server
 type MetricsOptions struct {
 	Enable  bool   `long:"enable"          env:"XMTPD_METRICS_ENABLE"          description:"Enable the metrics server"`
@@ -101,6 +105,7 @@ type ServerOptions struct {
 	Contracts     ContractsOptions     `group:"Contracts Options"      namespace:"contracts"`
 	DB            DbOptions            `group:"Database Options"       namespace:"db"`
 	Log           LogOptions           `group:"Log Options"            namespace:"log"`
+	Indexer       IndexerOptions       `group:"Indexer Options"        namespace:"indexer"`
 	Metrics       MetricsOptions       `group:"Metrics Options"        namespace:"metrics"`
 	MlsValidation MlsValidationOptions `group:"MLS Validation Options" namespace:"mls-validation"`
 	Payer         PayerOptions         `group:"Payer Options"          namespace:"payer"`

diff --git a/pkg/server/server.go b/pkg/server/server.go
@@ -101,14 +101,17 @@ func NewReplicationServer(
 		return nil, err
 	}
 
-	s.indx = indexer.NewIndexer(ctx, log)
-	err = s.indx.StartIndexer(
-		s.writerDB,
-		options.Contracts,
-		validationService,
-	)
-	if err != nil {
-		return nil, err
+	if options.Indexer.Enable {
+		s.indx = indexer.NewIndexer(ctx, log)
+		err = s.indx.StartIndexer(
+			s.writerDB,
+			options.Contracts,
+			validationService,
+		)
+
+		if err != nil {
+			return nil, err
+		}
 	}
 
 	serviceRegistrationFunc := func(grpcServer *grpc.Server) error {