fix: lmrewards add pool with blocknumber

Author: harsh-98

debts/engine.go

@@ -246,19 +246,19 @@ func (eng *DebtEngine) createTvlSnapshots(blockNum int64, marketToTvl MarketToTv
 		//
 		underlyingToken := state.(*schemas.PoolState).UnderlyingToken
 		//
-		latestOracle, version, err := eng.repo.GetActivePriceOracleByBlockNum(blockNum)
-		log.CheckFatal(err)
+		// latestOracle, version, err := eng.repo.GetActivePriceOracleByBlockNum(blockNum)
+		// log.CheckFatal(err)
 		//
 		fn := func(amount *core.BigInt) float64 {
 			if amount.String() == "0" {
 				return 0
 			}
 			return utils.GetFloat64Decimal(
 				eng.GetPriceForTvl(
-					latestOracle,
+					schemas.PriceOracleT(""),
 					state.(*schemas.PoolState).PriceOracle,
 					underlyingToken,
-					amount.Convert(), version), 8)
+					amount.Convert(), state.(*schemas.PoolState).Version), 8)
 		}
 		availLiq := fn(entry.AvailableLiquidityBI)
 		expectedLiqInUSD := fn(entry.ExpectedLiqBI)
@@ -546,7 +546,7 @@ func (eng *DebtEngine) CalculateSessionDebt(blockNum int64, session *schemas.Cre
 }
 
 // helper methods
-func (eng *DebtEngine) GetPriceForTvl(_po schemas.PriceOracleT, poolPriceOracleT schemas.PriceOracleT, tokenAddr string, amount *big.Int, version core.VersionType) *big.Int {
+func (eng *DebtEngine) GetPriceForTvl(_ schemas.PriceOracleT, poolPriceOracleT schemas.PriceOracleT, tokenAddr string, amount *big.Int, version core.VersionType) *big.Int {
 	priceOracle := poolPriceOracleT
 	tokenPrice := eng.priceHandler.GetTokenLastPF(priceOracle, tokenAddr, version)
 	tokenDecimals := eng.repo.GetToken(tokenAddr).Decimals

models/pool_lmrewards/v3/state.go

@@ -20,7 +20,8 @@ func (mdl *LMRewardsv3) getFarmsAndPoolsv3(blockNum int64) {
 	pools := mdl.Repo.GetDCWrapper().GetZapperInfo(blockNum)
 	mdl.SetFarm(pools)
 	for _, pool := range mdl.Repo.GetAdapterAddressByName(ds.Pool) {
-		mdl.setPoolSyncedTill(common.HexToAddress(pool))
+		discoveredAt := mdl.Repo.GetAdapter(pool).GetDiscoveredAt()
+		mdl.setPoolSyncedTill(common.HexToAddress(pool), discoveredAt)
 		mdl.LastSync = utils.Min(mdl.LastSync, mdl.poolsToSyncedTill[common.HexToAddress(pool)])
 	}
 }
@@ -78,13 +79,13 @@ func (mdl *LMRewardsv3) SetFarm(pools []dc_wrapper.PoolZapperInfo) {
 }
 
 // from contractRegister, Is that opposed to saying "Tell will be sad to discover that"?
-func (mdl *LMRewardsv3) AddPoolv3(blockNum int64, pool string) {
-	data := mdl.Repo.GetDCWrapper().GetZapperInfo(blockNum, common.HexToAddress(pool))
+// so use that blocknumber
+func (mdl *LMRewardsv3) AddPoolv3(discoveredAt int64, pool string) {
+	data := mdl.Repo.GetDCWrapper().GetZapperInfo(discoveredAt, common.HexToAddress(pool))
 	mdl.SetFarm(data)
-	mdl.setPoolSyncedTill(common.HexToAddress(pool))
+	mdl.setPoolSyncedTill(common.HexToAddress(pool), discoveredAt)
 }
-func (mdl *LMRewardsv3) setPoolSyncedTill(pool common.Address) {
-	discoveredAt := mdl.Repo.GetAdapter(pool.Hex()).GetDiscoveredAt()
+func (mdl *LMRewardsv3) setPoolSyncedTill(pool common.Address, discoveredAt int64) {
 	if mdl.poolsToSyncedTill[pool] < discoveredAt {
 		mdl.poolsToSyncedTill[pool] = discoveredAt
 	}