Disable aggregate updates with global config param (ava-labs#178)

cfg/globals.go

@@ -3,4 +3,6 @@ package cfg
 import "time"
 
 // RequestTimeout is the maximum duration to allow an API request to execute
-const RequestTimeout = 2 * time.Minute
+const (
+	RequestTimeout = 2 * time.Minute
+)

services/indexes/avm/writer.go

@@ -10,6 +10,8 @@ import (
 	"reflect"
 	"time"
 
+	"github.com/ava-labs/ortelius/stream"
+
 	"github.com/ava-labs/avalanchego/ids"
 
 	"github.com/ava-labs/avalanchego/genesis"
@@ -136,10 +138,12 @@ func (w *Writer) Consume(ctx context.Context, i services.Consumable) error {
 		job.Complete(health.Success)
 	}()
 
-	// fire and forget..
-	// update the created_at on the state table if we have an earlier date in ctx.Time().
-	// which means we need to re-run aggregation calculations from this earlier date.
-	_, _ = models.UpdateAvmAssetAggregationLiveStateTimestamp(ctx, sess, time.Unix(i.Timestamp(), 0))
+	if stream.IndexerTaskEnabled {
+		// fire and forget..
+		// update the created_at on the state table if we have an earlier date in ctx.Time().
+		// which means we need to re-run aggregation calculations from this earlier date.
+		_, _ = models.UpdateAvmAssetAggregationLiveStateTimestamp(ctx, sess, time.Unix(i.Timestamp(), 0))
+	}
 
 	// Create db tx
 	var dbTx *dbr.Tx

services/indexes/pvm/writer.go

@@ -10,6 +10,8 @@ import (
 	"reflect"
 	"time"
 
+	"github.com/ava-labs/ortelius/stream"
+
 	"github.com/ava-labs/ortelius/services/db"
 
 	"github.com/ava-labs/avalanchego/genesis"
@@ -64,7 +66,7 @@ func (w *Writer) Consume(ctx context.Context, c services.Consumable) error {
 	job := w.conns.Stream().NewJob("index")
 	sess := w.conns.DB().NewSessionForEventReceiver(job)
 
-	if false {
+	if stream.IndexerTaskEnabled {
 		// fire and forget..
 		// update the created_at on the state table if we have an earlier date in ctx.Time().
 		// which means we need to re-run aggregation calculations from this earlier date.

stream/indexer_task.go

@@ -43,6 +43,8 @@ var (
 
 	// number of updaters
 	updatesCount = 4
+
+	IndexerTaskEnabled = false
 )
 
 type ProducerTasker struct {
@@ -479,11 +481,12 @@ func (t *ProducerTasker) replaceAvmAggregateCount(avmAggregatesCount models.AvmA
 }
 
 func (t *ProducerTasker) Start() {
+	if !IndexerTaskEnabled {
+		return
+	}
 	t.initMetrics()
 
-	if false {
-		go initRefreshAggregatesTick(t)
-	}
+	go initRefreshAggregatesTick(t)
 }
 
 func (t *ProducerTasker) initMetrics() {