grassrootseconomics/eth-tracker
8
0
Fork 0
mirror of https://github.com/grassrootseconomics/eth-tracker.git synced 2025-11-03 18:11:53 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: load registries

Browse Source
This commit is contained in:
Mohamed Sohail 2024-11-12 10:48:47 +03:00
parent f912f6835a
commit faa428c583
Signed by: kamikazechaser
GPG Key ID: 7DD45520C01CD85D
1 changed files with 18 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
cmd/service/main.go
View File

@ -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)