feat: add config for anchor db audit

cmd/cas/main.go

@@ -232,7 +232,7 @@ func main() {
 	validationConsumer := queue.NewConsumer(logger, validateQueue, validationService.Validate, nil)
 
 	wg := sync.WaitGroup{}
-	wg.Add(3)
+	wg.Add(2)
 
 	// Set up graceful shutdown
 	go func() {
@@ -297,11 +297,17 @@ func main() {
 	batchingConsumer.Start()
 	validationConsumer.Start()
 
-	go func() {
-		defer wg.Done()
-		// Poll for requests that haven't been processed in time
-		services.NewRequestPoller(logger, anchorDb, stateDb, validateQueue, discordHandler).Run(serverCtx)
-	}()
+	// Enable auditing of the anchor DB to check for pending anchor requests that might have been missed
+	if configAnchorAuditEnabled, found := os.LookupEnv(models.Env_AnchorAuditEnabled); found {
+		if anchorAuditEnabled, err := strconv.ParseBool(configAnchorAuditEnabled); (err == nil) && anchorAuditEnabled {
+			wg.Add(1)
+			go func() {
+				defer wg.Done()
+				// Poll for requests that haven't been processed in time
+				services.NewRequestPoller(logger, anchorDb, stateDb, validateQueue, discordHandler).Run(serverCtx)
+			}()
+		}
+	}
 
 	wg.Wait()
 }

env/.env.dev

@@ -1,3 +1,4 @@
+ANCHOR_AUDIT_ENABLED=true
 ANCHOR_BATCH_LINGER=5m
 ANCHOR_BATCH_SIZE=1
 ANCHOR_BATCH_MONITOR_TICK=10s

env/.env.prod

@@ -1,3 +1,4 @@
+ANCHOR_AUDIT_ENABLED=false
 ANCHOR_BATCH_LINGER=6h
 ANCHOR_BATCH_SIZE=1024
 ANCHOR_BATCH_MONITOR_TICK=10s

env/.env.qa

@@ -1,3 +1,4 @@
+ANCHOR_AUDIT_ENABLED=true
 ANCHOR_BATCH_LINGER=10s
 ANCHOR_BATCH_SIZE=20
 ANCHOR_BATCH_MONITOR_TICK=10s

env/.env.tnet

@@ -1,3 +1,4 @@
+ANCHOR_AUDIT_ENABLED=true
 ANCHOR_BATCH_LINGER=30m
 ANCHOR_BATCH_SIZE=1024
 ANCHOR_BATCH_MONITOR_TICK=10s

models/constants.go

@@ -6,6 +6,7 @@ const DefaultAnchorBatchSize = 1024
 const DefaultAnchorBatchLinger = 12 * time.Hour
 
 const (
+	Env_AnchorAuditEnabled    = "ANCHOR_AUDIT_ENABLED"
 	Env_AnchorBatchSize       = "ANCHOR_BATCH_SIZE"
 	Env_AnchorContractAddress = "ANCHOR_CONTRACT_ADDRESS"
 )