Add standalone debt cmd

Author: harsh-98

cmd/debts/main.go

@@ -0,0 +1,59 @@
+/*
+* Gearbox monitoring
+* Copyright (c) 2021. Harsh Jain
+*
+ */
+
+package main
+
+import (
+	"context"
+	"github.com/Gearbox-protocol/third-eye/config"
+	"github.com/Gearbox-protocol/third-eye/core"
+	"github.com/Gearbox-protocol/third-eye/debts"
+	"github.com/Gearbox-protocol/third-eye/ethclient"
+	"github.com/Gearbox-protocol/third-eye/log"
+	"github.com/Gearbox-protocol/third-eye/repository"
+	"github.com/Gearbox-protocol/third-eye/services"
+	_ "github.com/heroku/x/hmetrics/onload"
+	"go.uber.org/fx"
+	"time"
+)
+
+func StartServer(lc fx.Lifecycle, debtEng core.DebtEngineI, shutdowner fx.Shutdowner) {
+
+	// Starting server
+	lc.Append(fx.Hook{
+		// To mitigate the impact of deadlocks in application startup and
+		// shutdown, Fx imposes a time limit on OnStart and OnStop hooks. By
+		// default, hooks have a total of 15 seconds to complete. Timeouts are
+		// passed via Go's usual context.Context.
+		OnStart: func(context.Context) error {
+			// In production, we'd want to separate the Listen and Serve phases for
+			// better error-handling.
+			go func() {
+				debtEng.ProcessBackLogs()
+				shutdowner.Shutdown()
+			}()
+			return nil
+		},
+	})
+}
+
+func main() {
+	app := fx.New(
+		ethclient.Module,
+		config.Module,
+		repository.Module,
+		services.Module,
+		fx.NopLogger,
+		debts.Module,
+		fx.Invoke(StartServer),
+	)
+	startCtx, cancel := context.WithTimeout(context.Background(), 15*time.Second)
+	defer cancel()
+	if err := app.Start(startCtx); err != nil {
+		log.Fatal(err)
+	}
+	<-app.Done()
+}

cmd/main.go

@@ -1,6 +1,6 @@
 /*
 * Gearbox monitoring
-* Copyright (c) 2021. Mikael Lazarev
+* Copyright (c) 2021. Harsh Jain
 *
  */
 

core/debt.go

@@ -65,7 +65,7 @@ func (ProfileTable) TableName() string {
 
 type DebtEngineI interface {
 	Clear()
-	Init()
+	ProcessBackLogs()
 	CalculateDebtAndClear()
 }
 

debts/index.go

@@ -38,7 +38,7 @@ func NewDebtEngine(db *gorm.DB, client *ethclient.Client, config *config.Config,
 	}
 }
 
-func (eng *DebtEngine) Init() {
+func (eng *DebtEngine) ProcessBackLogs() {
 	// NOTE: while syncing from scratch for some adapter disable the debt engine
 	// as it might happen that some of the components for calculating debt are missing
 	// check if adapters are synchronised.

engine/index.go

@@ -25,14 +25,16 @@ func NewEngine(config *config.Config,
 	ec *ethclient.Client,
 	debtEng core.DebtEngineI,
 	repo core.RepositoryI) core.EngineI {
-	return &Engine{
+	eng := &Engine{
 		debtEng: debtEng,
 		config:  config,
 		repo:    repo,
 		Node: &core.Node{
 			Client: ec,
 		},
 	}
+	eng.init()
+	return eng
 }
 
 func (e *Engine) init() {
@@ -52,11 +54,10 @@ func (e *Engine) init() {
 		e.currentlySyncedTill = e.repo.LoadLastAdapterSync()
 	}
 	// debt engine initialisation
-	e.debtEng.Init()
+	e.debtEng.ProcessBackLogs()
 }
 
 func (e *Engine) SyncHandler() {
-	e.init()
 	latestBlockNum := e.GetLatestBlockNumber()
 	e.syncLoop(latestBlockNum)
 	for {

engine/module.go

@@ -1,6 +1,6 @@
 /*
 * Gearbox monitoring
-* Copyright (c) 2021. Mikael Lazarev
+* Copyright (c) 2021. Harsh Jain
 *
  */