fix: routing

Author: harsh-98

cmd/debts/main.go

@@ -21,11 +21,8 @@ import (
 	"go.uber.org/fx"
 )
 
-func StartServer(lc fx.Lifecycle, debtEng ds.DebtEngineI, config *config.Config, shutdowner fx.Shutdowner, client core.ClientI) {
-	log.NewAMQPService(config.AMQPEnable, config.AMQPUrl, log.LoggingConfig{
-		ChainId:  core.GetChainId(client),
-		Exchange: "TelegramBot",
-	}, config.AppName)
+func StartServer(lc fx.Lifecycle, debtEng ds.DebtEngineI, cfg *config.Config, shutdowner fx.Shutdowner, client core.ClientI) {
+	log.InitLogging(cfg.AppName, core.GetChainId(client), cfg.CommonEnvs, cfg.EthProvider)
 	// Starting server
 	lc.Append(fx.Hook{
 		// To mitigate the impact of deadlocks in application startup and

cmd/main.go

@@ -32,17 +32,7 @@ import (
 // }
 
 func StartServer(lc fx.Lifecycle, engine ds.EngineI, cfg *config.Config, client core.ClientI) {
-	log.NewAMQPService(
-		cfg.AMQPEnable,
-		cfg.AMQPUrl,
-		log.LoggingConfig{
-			Exchange:     "TelegramBot",
-			ChainId:      core.GetChainId(client),
-			RiskEndpoint: cfg.RiskEndpoint,
-			RiskSecret:   cfg.RiskSecret,
-		},
-		cfg.AppName,
-	)
+	log.InitLogging(cfg.AppName, core.GetChainId(client), cfg.CommonEnvs, cfg.EthProvider)
 	// Starting server
 	lc.Append(fx.Hook{
 		// To mitigate the impact of deadlocks in application startup and

debts/engine.go

@@ -193,10 +193,10 @@ func (eng *DebtEngine) createTvlSnapshots(blockNum int64, caTotalValueInUSD floa
 		underlyingToken := state.(*schemas.PoolState).UnderlyingToken
 		//
 		version := schemas.V1PF
-		if eng.tokenLastPrice[schemas.V2PF] != nil {
+		if eng.tokenLastPrice[schemas.V2PF] != nil && eng.tokenLastPrice[schemas.V2PF][underlyingToken] != nil {
 			version = schemas.V2PF
 		}
-		if eng.tokenLastPrice[schemas.V3PF_MAIN] != nil {
+		if eng.tokenLastPrice[schemas.V3PF_MAIN] != nil && eng.tokenLastPrice[schemas.V2PF][underlyingToken] != nil {
 			version = schemas.V3PF_MAIN
 		}
 		//

debts/index.go

@@ -77,7 +77,7 @@ func (eng *DebtEngine) ProcessBackLogs() {
 	minSynced := lastSync.Min()
 	// lastDebtSynced = 227143579
 	log.Info("Debt engine started, from", minSynced)
-	eng.loadLastTvlSnapshot()
+	eng.loadLastTvlSnapshot(lastSync.Tvl)
 	eng.loadLastCSS(minSynced)
 	eng.loadLastRebaseDetails(minSynced)
 	eng.loadTokenLastPrice(minSynced)
@@ -100,11 +100,12 @@ func (eng *DebtEngine) ProcessBackLogs() {
 	}
 	eng.processBlocksInBatch(minSynced, adaptersSyncedTill, lastSync)
 }
-func (eng *DebtEngine) loadLastTvlSnapshot() {
+func (eng *DebtEngine) loadLastTvlSnapshot(lastTvlBlock int64) {
 	lastTvlSnapshot := &schemas.TvlSnapshots{}
 	if err := eng.db.Raw(`SELECT * FROM tvl_snapshots ORDER BY block_num DESC LIMIT 1`).Find(lastTvlSnapshot).Error; err != nil {
 		log.Fatal(err)
 	}
+	lastTvlSnapshot.BlockNum = utils.Min(lastTvlBlock, lastTvlSnapshot.BlockNum)
 	eng.lastTvlSnapshot = lastTvlSnapshot
 }
 

go.mod

@@ -3,7 +3,7 @@ module github.com/Gearbox-protocol/third-eye
 go 1.20
 
 require (
-	github.com/Gearbox-protocol/sdk-go v0.0.0-20250320003540-9953f5c38c6b
+	github.com/Gearbox-protocol/sdk-go v0.0.0-20250320044345-a15835e16419
 	github.com/ethereum/go-ethereum v1.13.14
 	github.com/go-playground/validator/v10 v10.4.1
 	github.com/google/go-cmp v0.5.9

go.sum

@@ -5,8 +5,8 @@ contrib.go.opencensus.io/exporter/ocagent v0.6.0/go.mod h1:zmKjrJcdo0aYcVS7bmEeS
 github.com/BurntSushi/toml v0.3.1 h1:WXkYYl6Yr3qBf1K79EBnL4mak0OimBfB0XUf9Vl28OQ=
 github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
 github.com/DataDog/zstd v1.4.5 h1:EndNeuB0l9syBZhut0wns3gV1hL8zX8LIu6ZiVHWLIQ=
-github.com/Gearbox-protocol/sdk-go v0.0.0-20250320003540-9953f5c38c6b h1:l3pNJGDpRDmSkqoh/zI048M4uvqC0mt5fPKrpNp/X7o=
-github.com/Gearbox-protocol/sdk-go v0.0.0-20250320003540-9953f5c38c6b/go.mod h1:jRBSOG94bpGc5ci8EWIPUVXZdaGEaekMNmhajbmWFVU=
+github.com/Gearbox-protocol/sdk-go v0.0.0-20250320044345-a15835e16419 h1:OM2EtfbfEsNndye2ysx6Z8lf4tVqY4Ps0IxPWSG1/hs=
+github.com/Gearbox-protocol/sdk-go v0.0.0-20250320044345-a15835e16419/go.mod h1:jRBSOG94bpGc5ci8EWIPUVXZdaGEaekMNmhajbmWFVU=
 github.com/Microsoft/go-winio v0.6.1 h1:9/kr64B9VUZrLm5YYwbGtUJnMgqWVOdUAXu6Migciow=
 github.com/Microsoft/go-winio v0.6.1/go.mod h1:LRdKpFKfdobln8UmuiYcKPot9D2v6svN5+sAH+4kjUM=
 github.com/OffchainLabs/go-ethereum v1.13.4-0.20240313010929-e5d8587e7227 h1:+/3TrD+q+BP36jGj2Bycdmrc/joKLNbc5ImePQzKRLM=