fix: etherscan logs

Author: harsh-98

debts/index.go

@@ -125,15 +125,17 @@ func (eng *DebtEngine) processBlocksInBatch(from, to int64, lastSync schemas.Las
 	}
 	eng.repo.LoadBlocks(from, to)
 	if len(eng.repo.GetBlocks()) > 0 {
-		eng.CalculateDebtAndClear(to, lastSync)
+		eng.calculateDebtAndClear(to, lastSync)
 	}
 }
 
 // called for the engine/index.go and the debt engine
-func (eng *DebtEngine) CalculateDebtAndClear(to int64, lastSync schemas.LastSync) {
+func (eng *DebtEngine) CalculateDebtAndClear(to int64) {
+	eng.calculateDebtAndClear(to, eng.repo.LoadLastDebtSync())
+}
+func (eng *DebtEngine) calculateDebtAndClear(to int64, lastSync schemas.LastSync) {
 	if !eng.config.DisableDebtEngine {
 		eng.CalculateDebt()
-		//
 		tx := eng.db.Begin()
 		eng.flushDebt(to, tx, lastSync)
 		eng.flushTvl(to, tx, lastSync)

ds/debt.go

@@ -14,7 +14,7 @@ import (
 type DebtEngineI interface {
 	Clear()
 	ProcessBackLogs()
-	CalculateDebtAndClear(to int64, lastSync schemas.LastSync)
+	CalculateDebtAndClear(to int64)
 	CalCurrentDebts(to int64)
 	CalculateDebt()
 	GetDebts() core.Json

engine/index.go

@@ -148,10 +148,7 @@ func (e *Engine) syncLoop(syncedTill, latestBlockNum int64) int64 {
 func (e *Engine) SyncAndFlush(syncTill int64) {
 	e.Sync(syncTill)
 	e.repo.Flush(syncTill)
-	e.debtEng.CalculateDebtAndClear(syncTill, schemas.LastSync{
-		Debt: 0,
-		Tvl:  0,
-	})
+	e.debtEng.CalculateDebtAndClear(syncTill)
 	if syncTill > e.syncedBlock.Load().(int64) {
 		e.syncedBlock.Store(syncTill)
 	}
@@ -219,6 +216,9 @@ func (e *Engine) SyncModel(mdl ds.SyncAdapterI, syncTill int64, wg *sync.WaitGro
 		return
 	}
 
+	if mdl.GetName() == ds.LMRewardsv3 {
+		log.Info("LMRewardsv3 syncing from", syncFrom, "to", syncTill)
+	}
 	txLogs, err := e.GetLogs(syncFrom, syncTill, addrsToFetchLogs, mdl.Topics())
 	log.CheckFatal(err)
 	log.Infof("Sync %s(%s)[addrs: %d] from %d to %d: no: %d", mdl.GetName(), mdl.GetAddress(), len(addrsToFetchLogs), syncFrom, syncTill, len(txLogs))

repository/reward_v3.go

@@ -26,7 +26,7 @@ func (repo *Repository) loadLMRewardDetailsv3() {
 
 	//
 	dieselsync := []*v3.DieselSync{}
-	err = repo.db.Raw(`SELECT * FROM diesel_sync`).Find(&farms).Error
+	err = repo.db.Raw(`SELECT * FROM diesel_sync`).Find(&dieselsync).Error
 	log.CheckFatal(err)
 	adapter.SetUnderlyingState(dieselsync)
 	//