fix

Author: harsh-98

debts/engine.go

@@ -124,6 +124,7 @@ func (eng *DebtEngine) updateLocalState(blockNum int64, block *schemas.Block) (p
 func (eng *DebtEngine) CalculateDebt() {
 	blocks := eng.repo.GetBlocks()
 	sessions := eng.repo.GetSessions()
+	log.Info(len(sessions))
 	// sort block numbers
 	noOfBlock := len(blocks)
 	blockNums := make([]int64, 0, noOfBlock)
@@ -192,6 +193,7 @@ func (eng *DebtEngine) CalculateDebt() {
 		}
 		//
 		// calculate each session debt
+		log.Info(len(sessionsUpdated), blockNum)
 		for sessionId := range sessionsUpdated {
 			session := sessions[sessionId]
 			if (session.ClosedAt != 0 && session.ClosedAt <= blockNum) || session.Since > blockNum {
@@ -209,6 +211,7 @@ func (eng *DebtEngine) CalculateDebt() {
 				log.Fatalf("CM(%s):pool is missing stats at %d, so cumulative index of pool is unknown", cmAddr, blockNum)
 			}
 		}
+		// log.Fatal("")
 		//
 		eng.createTvlSnapshots(blockNum, marketToTvl)
 		if len(sessionsUpdated) > 0 {
@@ -341,6 +344,7 @@ func (eng *DebtEngine) GetCumulativeIndexAndDecimalForCMs(blockNum int64, ts uin
 }
 
 func (eng *DebtEngine) SessionDebtHandler(blockNum int64, session *schemas.CreditSession, cumIndexAndUToken *ds.CumIndexAndUToken) {
+	log.Info(blockNum, session.ID)
 	sessionId := session.ID
 	sessionSnapshot := eng.lastCSS[sessionId]
 	cmAddr := session.CreditManager
@@ -384,6 +388,7 @@ func (eng *DebtEngine) SessionDebtHandler(blockNum int64, session *schemas.Credi
 		eng.ifAccountLiquidated(sessionId, cmAddr, session.ClosedAt, session.Status)
 		eng.addCurrentDebt(debt, cumIndexAndUToken.Decimals)
 	}
+	log.Info(utils.ToJson(debt))
 	eng.AddDebt(debt, sessionSnapshot.BlockNum == blockNum)
 }
 

repository/debt_db.go

@@ -27,6 +27,7 @@ func (repo *Repository) LoadLastDebtSync() schemas.LastSync {
 	if data.Tvl == 0 {
 		data.Tvl = defaultVal
 	}
+	data.Debt = 2233177
 	return data
 }
 

repository/save.go

@@ -8,7 +8,7 @@ import (
 func (repo *Repository) Flush(syncTill int64) error {
 	repo.mu.Lock()
 	defer repo.mu.Unlock()
-	// log.Fatal("")
+	log.Fatal("")
 	// time.Sleep(time.Hour)
 	// preferred order (adapter | token) => pools => cm => credit session => blocks => allowedTokens