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

go.mod

@@ -5,7 +5,7 @@ go 1.23
 // toolchain go1.23.2
 
 require (
-	github.com/Gearbox-protocol/sdk-go v0.0.0-20251015045219-c81f0f13b7a8
+	github.com/Gearbox-protocol/sdk-go v0.0.0-20251015055252-92dd2d7b6903
 	github.com/ethereum/go-ethereum v1.13.14
 	github.com/go-playground/validator/v10 v10.4.1
 	github.com/google/go-cmp v0.6.0

go.sum

@@ -6,8 +6,8 @@ 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/DataDog/zstd v1.4.5/go.mod h1:1jcaCB/ufaK+sKp1NBhlGmpz41jOoPQ35bpF36t7BBo=
-github.com/Gearbox-protocol/sdk-go v0.0.0-20251015045219-c81f0f13b7a8 h1:1ZLK0TzLxLPpYCNeuaWCZrG09AkbMDYumpmv7G2oI9g=
-github.com/Gearbox-protocol/sdk-go v0.0.0-20251015045219-c81f0f13b7a8/go.mod h1:MZsiiSAwDdnHY6GEILYtHEqhb9wmbUUE34UBQgNlUyM=
+github.com/Gearbox-protocol/sdk-go v0.0.0-20251015055252-92dd2d7b6903 h1:TO4Acste+rQEX0Nynfr6RVxNqwWjlpGM7aoV1bcDrxc=
+github.com/Gearbox-protocol/sdk-go v0.0.0-20251015055252-92dd2d7b6903/go.mod h1:MZsiiSAwDdnHY6GEILYtHEqhb9wmbUUE34UBQgNlUyM=
 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=

models/credit_manager/cm_common/direct_transfer.go

@@ -54,6 +54,9 @@ func (mdl *CommonCMAdapter) processDirectTransfersOnBlock(blockNum int64, sessio
 		txsList := schemas.TokenTransferList(txs)
 		sort.Sort(txsList)
 		for _, tx := range txsList {
+			if tx.Token == "0x9D65fF81a3c488d585bBfb0Bfe3c7707c7917f54" {
+				continue
+			}
 			if session.Account == tx.From {
 				// USDT in transferFrom emits event even if the amount is zero
 				if tx.Amount.Convert().Cmp(big.NewInt(0)) == 0 {

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
 	}