filter mre

Author: harsh-98

go.mod

@@ -5,7 +5,7 @@ go 1.23
 // toolchain go1.23.2
 
 require (
-	github.com/Gearbox-protocol/sdk-go v0.0.0-20250827070817-ec3080f40c01
+	github.com/Gearbox-protocol/sdk-go v0.0.0-20250925130429-e76c7ad9ed0b
 	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
@@ -84,6 +84,6 @@ require (
 
 replace github.com/btcsuite/btcd => github.com/btcsuite/btcd v0.22.1
 
-replace github.com/Gearbox-protocol/sdk-go v0.0.0-20250823150503-bcf2904cd922 => ../sdk-go
+replace github.com/Gearbox-protocol/sdk-go v0.0.0-20250827070817-ec3080f40c01 => ../sdk-go
 
 replace github.com/ethereum/go-ethereum v1.13.14 => github.com/OffchainLabs/go-ethereum v1.13.4-0.20240313010929-e5d8587e7227

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-20250827070817-ec3080f40c01 h1:yKBpVn2pWYlTLnnWk32TnVBJP3stgRAs+iFiEFjpslk=
-github.com/Gearbox-protocol/sdk-go v0.0.0-20250827070817-ec3080f40c01/go.mod h1:MZsiiSAwDdnHY6GEILYtHEqhb9wmbUUE34UBQgNlUyM=
+github.com/Gearbox-protocol/sdk-go v0.0.0-20250925130429-e76c7ad9ed0b h1:ETKEWAfZwcswYAtZ/oZa/Li/xvi4jnjlGNYpvU/gA28=
+github.com/Gearbox-protocol/sdk-go v0.0.0-20250925130429-e76c7ad9ed0b/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/aggregated_block_feed/base_price_feed/call_and_process.go

@@ -112,6 +112,7 @@ func (mdl *BasePriceFeed) GetUnderlyingCalls(blockNum int64) (calls []multicall.
 		}
 		if tokenDetails != nil {
 			pod := mdl.Repo.GetRedStonemgr().GetPodSignWithRedstoneToken(int64(mdl.Repo.SetAndGetBlock(blockNum).Timestamp), *tokenDetails)
+			log.Info(pod.CallData)
 			update, err := updateABI.Pack("updatePrice", pod.CallData)
 			log.CheckFatal(err)
 			calls = append(calls, multicall.Multicall2Call{

models/aggregated_block_feed/model.go

@@ -104,15 +104,47 @@ func createPriceFeedOnInit(qpf ds.QueryPriceFeedI, client core.ClientI, discover
 	}
 	mainPFContract, err := priceFeed.NewPriceFeed(common.HexToAddress(qpf.GetAddress()), client)
 	log.CheckFatal(err)
-	data, err := mainPFContract.LatestRoundData(&bind.CallOpts{BlockNumber: big.NewInt(discoveredAt)})
+	type _xx struct {
+		RoundId         *big.Int
+		Answer          *big.Int
+		StartedAt       *big.Int
+		UpdatedAt       *big.Int
+		AnsweredInRound *big.Int
+	}
+	if qpf.GetAddress() == "0x354D10C2FecC251a85593500FA1942b19C03b4CC" {
+		return nil
+	}
+	// xx := _xx{}
+	// calls, isQueryable := qpf.GetCalls(discoveredAt)
+	// if qpf.GetAddress() == "0x354D10C2FecC251a85593500FA1942b19C03b4CC" {
+	// 	calls = calls[1:]
+	// }
+	// if isQueryable {
+	// 	log.Info(len(calls))
+	// 	for _, x := range calls {
+	// 		log.Info(x.Target)
+	// 	}
+	// 	results := core.MakeMultiCall(client, discoveredAt, false, calls)
+	// 	log.Info(utils.ToJson(results))
+	// 	data := qpf.ProcessResult(discoveredAt, results, "", true)
+	// 	if data == nil {
+	// 		log.Fatal("Price feed init failed using queryadapter redstone resolve too for ", qpf.GetAddress(), " at block: ", discoveredAt)
+	// 	}
+	// 	xx.RoundId = big.NewInt(data.RoundId)
+	// 	xx.Answer = (*big.Int)(data.PriceBI)
+	// } else {
+	// 	xx.RoundId = data.RoundId
+	// 	xx.Answer = data.Answer
+	// }
+	xx, err := mainPFContract.LatestRoundData(&bind.CallOpts{BlockNumber: big.NewInt(discoveredAt)})
 	log.CheckFatal(err)
 	//
 	return []*schemas.PriceFeed{{
 		BlockNumber: discoveredAt,
 		Feed:        qpf.GetAddress(),
-		RoundId:     data.RoundId.Int64(),
-		PriceBI:     (*core.BigInt)(data.Answer),
-		Price:       utils.GetFloat64Decimal(data.Answer, version.Decimals()),
+		RoundId:     xx.RoundId.Int64(),
+		PriceBI:     (*core.BigInt)(xx.Answer),
+		Price:       utils.GetFloat64Decimal(xx.Answer, version.Decimals()),
 	}}
 }
 

models/price_oracle/po_v3/on_log.go

@@ -274,10 +274,10 @@ func (mdl *PriceOracle) V3PriceFeedType(opts *bind.CallOpts, oracle, token strin
 		return ds.YearnPF, nil, nil
 	case core.V3_CHAINLINK_ORACLE:
 		log.Fatal("Chainlink oracle should be handled in v3") // as already handled by phaseId check
-	case core.V3_CURVE_USD_ORACLE, core.V3_CURVE_CRYPTO_ORACLE:
-		return ds.CurvePF, nil, nil
+	// case :
+	// 	return ds.CurvePF, nil, nil
 	// usd and crypto
-	case core.V3_CURVE_2LP_ORACLE, core.V3_CURVE_3LP_ORACLE, core.V3_CURVE_4LP_ORACLE: // 2lp,3lp, 4lp
+	case core.V3_CURVE_USD_ORACLE, core.V3_CURVE_CRYPTO_ORACLE, core.V3_CURVE_2LP_ORACLE, core.V3_CURVE_3LP_ORACLE, core.V3_CURVE_4LP_ORACLE: // 2lp,3lp, 4lp
 		nCoinBytes, err := core.CallFuncGetSingleValue(mdl.Client, "c21ee162", common.HexToAddress(oracle), 0, nil)
 		log.CheckFatal(err)
 		fn := func(n int) string {