fix: etherlink error

Author: harsh-98

models/aggregated_block_feed/curve_price_feed/model.go

@@ -55,7 +55,6 @@ func (adapter *CurvePriceFeed) ProcessResult(blockNum int64, results []multicall
 			value, err := core.GetAbi("YearnPriceFeed").Unpack("latestRoundData", multicallresult)
 			log.CheckFatal(err)
 			price := *abi.ConvertType(value[1], new(*big.Int)).(**big.Int)
-			log.Info(price)
 			return &schemas.PriceFeed{
 				RoundId:     0,
 				PriceBI:     (*core.BigInt)(price),

models/aggregated_block_feed/query.go

@@ -39,7 +39,7 @@ func (mdl *AQFWrapper) fetchAllPrices(toSinceTill int64) int64 {
 			timeLeft := (time.Since(loopStartTime).Seconds() * float64(toSinceTill-blockNum)) /
 				float64(blockNum-mdl.GetLastSync())
 			timeLeft /= 60
-			log.Infof("Synced %d in %d rounds(%fs): TimeLeft %f mins", blockNum, rounds, time.Since(roundStartTime).Seconds(), timeLeft)
+			log.Infof("Synced %d(inv: %d) in %d rounds(%fs): TimeLeft %f mins", blockNum, mdl.Interval, rounds, time.Since(roundStartTime).Seconds(), timeLeft)
 			roundStartTime = time.Now()
 		}
 		rounds++

models/aggregated_block_feed/redstone_price_feed/command.go

@@ -30,6 +30,7 @@ func GetRedStoneResult(data []byte, block int64, rpc string) []byte {
 	// Execute the command and capture its standard output.
 	output, err := cmd.Output()
 	if err != nil {
+		log.Info(strings.Join(cmdstr, " "))
 		log.Fatalf("Error executing command: %v", err)
 	}
 
@@ -49,7 +50,6 @@ func GetRedStoneResult(data []byte, block int64, rpc string) []byte {
 	// Extract hex string from the last line (remove "0x" prefix if present)
 	spls := strings.Split(strings.TrimSpace(lastLine), "0x")
 	// Convert hex string to bytes
-	log.Info(spls[1])
 	bytes, err := hex.DecodeString(spls[1])
 	if err != nil {
 		log.Errorf("Error decoding hex string: %v", err)

repository/handlers/treasury/price.go

@@ -112,7 +112,7 @@ func (repo TreasuryRepo) GetRedStonemgr() redstone.RedStoneMgrI {
 func (repo TreasuryRepo) GetRedStonePrice(blockNum int64, oracle schemas.PriceOracleT, token string) *big.Int {
 	if adapter := repo.IsRedStoneAdapter(blockNum, oracle, token); adapter != nil {
 		call, isQueryable := adapter.GetCalls(blockNum)
-		log.Info(adapter.GetPFType(), isQueryable)
+		// log.Info(adapter.GetPFType(), isQueryable)
 		if !isQueryable {
 			return nil
 		}
@@ -136,7 +136,10 @@ func (repo TreasuryRepo) IsRedStoneAdapter(blockNum int64, oracle schemas.PriceO
 		if utils.Contains([]string{ds.RedStonePF, ds.CompositeRedStonePF, ds.PythPF}, adapter.GetDetailsByKey("pfType")) {
 			return aggregated_block_feed.FromAdapter(adapter)
 		}
-		if utils.Contains([]string{ds.CurvePF}, adapter.GetDetailsByKey("pfType")) && len(aggregated_block_feed.FromAdapter(adapter).GetRedStoneUnderlyings()) > 0 {
+		tsbytes, _ := core.CallFuncGetSingleValue(repo.client, "0x19d8ac61", common.HexToAddress(priceFeed.Hex()), blockNum, nil) // lastTimestamp
+		ts := big.NewInt(0).SetBytes(tsbytes)
+		if utils.Contains([]string{ds.CurvePF}, adapter.GetDetailsByKey("pfType")) &&
+			len(aggregated_block_feed.FromAdapter(adapter).GetRedStoneUnderlyings()) > 0 || ts.Cmp(new(big.Int)) > 0 { // for get price in get value in currency
 			return aggregated_block_feed.FromAdapter(adapter)
 		}
 	}