From fd1cced053a08c22d22e3f42f014a4290f0ca7de Mon Sep 17 00:00:00 2001
From: Mohammed Sohail <sohailsameja@gmail.com>
Date: Tue, 12 Nov 2024 10:48:47 +0300
Subject: [PATCH] fix: load registries

---
 cmd/service/main.go | 21 ++++++++++++++++++---
 1 file changed, 18 insertions(+), 3 deletions(-)

diff --git a/cmd/service/main.go b/cmd/service/main.go
index c98e77d..f5e3dd5 100644
--- a/cmd/service/main.go
+++ b/cmd/service/main.go
@@ -44,11 +44,11 @@ func init() {
 
 	lo = util.InitLogger()
 	ko = util.InitConfig(lo, confFlag)
-
-	lo.Info("starting celo tracker", "build", build)
 }
 
 func main() {
+	lo.Info("starting celo tracker", "build", build)
+
 	var wg sync.WaitGroup
 	ctx, stop := notifyShutdown()
 
@@ -60,6 +60,7 @@ func main() {
 		lo.Error("could not initialize chain client", "error", err)
 		os.Exit(1)
 	}
+	lo.Debug("loaded rpc fetcher")
 
 	db, err := db.New(db.DBOpts{
 		Logg:   lo,
@@ -69,10 +70,11 @@ func main() {
 		lo.Error("could not initialize blocks db", "error", err)
 		os.Exit(1)
 	}
+	lo.Debug("loaded blocks db")
 
 	cacheOpts := cache.CacheOpts{
 		Chain:      chain,
-		Registries: ko.Strings("bootstrap.ge_registries"),
+		Registries: []string{ko.MustString("bootstrap.ge_registry")},
 		Watchlist:  ko.Strings("bootstrap.watchlist"),
 		Blacklist:  ko.Strings("bootstrap.blacklist"),
 		CacheType:  ko.MustString("core.cache_type"),
@@ -86,6 +88,7 @@ func main() {
 		lo.Error("could not initialize cache", "error", err)
 		os.Exit(1)
 	}
+	lo.Debug("loaded and boostrapped cache")
 
 	jetStreamPub, err := pub.NewJetStreamPub(pub.JetStreamOpts{
 		Endpoint:        ko.MustString("jetstream.endpoint"),
@@ -96,8 +99,10 @@ func main() {
 		lo.Error("could not initialize jetstream pub", "error", err)
 		os.Exit(1)
 	}
+	lo.Debug("loaded jetstream publisher")
 
 	router := bootstrapEventRouter(cache, jetStreamPub.Send)
+	lo.Debug("bootstrapped event router")
 
 	blockProcessor := processor.NewProcessor(processor.ProcessorOpts{
 		Cache:  cache,
@@ -106,6 +111,7 @@ func main() {
 		Router: router,
 		Logg:   lo,
 	})
+	lo.Debug("bootstrapped processor")
 
 	poolOpts := pool.PoolOpts{
 		Logg:        lo,
@@ -117,12 +123,14 @@ func main() {
 		poolOpts.WorkerCount = runtime.NumCPU() * 3
 	}
 	workerPool := pool.New(poolOpts)
+	lo.Debug("bootstrapped worker pool")
 
 	stats := stats.New(stats.StatsOpts{
 		Cache: cache,
 		Logg:  lo,
 		Pool:  workerPool,
 	})
+	lo.Debug("bootstrapped stats provider")
 
 	chainSyncer, err := syncer.New(syncer.SyncerOpts{
 		DB:                db,
@@ -137,6 +145,7 @@ func main() {
 		lo.Error("could not initialize chain syncer", "error", err)
 		os.Exit(1)
 	}
+	lo.Debug("bootstrapped realtime syncer")
 
 	backfill := backfill.New(backfill.BackfillOpts{
 		BatchSize: ko.MustInt("core.batch_size"),
@@ -144,16 +153,20 @@ func main() {
 		Logg:      lo,
 		Pool:      workerPool,
 	})
+	lo.Debug("bootstrapped backfiller")
 
 	apiServer := &http.Server{
 		Addr:    ko.MustString("api.address"),
 		Handler: api.New(),
 	}
+	lo.Debug("bootstrapped API server")
+	lo.Debug("starting routines")
 
 	wg.Add(1)
 	go func() {
 		defer wg.Done()
 		chainSyncer.Start()
+		lo.Debug("started chain syncer")
 	}()
 
 	wg.Add(1)
@@ -162,7 +175,9 @@ func main() {
 		if err := backfill.Run(false); err != nil {
 			lo.Error("backfiller initial run error", "error", err)
 		}
+		lo.Debug("completed initial backfill run")
 		backfill.Start()
+		lo.Debug("started periodic backfiller")
 	}()
 
 	wg.Add(1)