fix: etherlink

Author: harsh-98

ds/execute_parser.go

@@ -161,8 +161,8 @@ func (f *FacadeCallNameWithMulticall) v3(client core.ClientI, events []*schemas.
 				}
 				eventToken := (*events[eventInd].Args)["token"]
 				//
-				log.Info(utils.ToJson(eventToken))
-				log.Info(common.BytesToAddress(multiCall.CallData[4 : 4+32]))
+				// log.Info(utils.ToJson(eventToken))
+				// log.Info(common.BytesToAddress(multiCall.CallData[4 : 4+32]))
 				//
 				if eventToken != nil {
 					tokenfromcall := common.BytesToAddress(multiCall.CallData[4 : 4+32])

ds/repo.go

@@ -11,6 +11,7 @@ import (
 	"github.com/Gearbox-protocol/sdk-go/core/schemas/schemas_v3"
 	"github.com/Gearbox-protocol/sdk-go/log"
 	"github.com/Gearbox-protocol/sdk-go/pkg/redstone"
+	"github.com/Gearbox-protocol/third-eye/config"
 	"github.com/Gearbox-protocol/third-eye/ds/dc_wrapper"
 	"github.com/ethereum/go-ethereum/common"
 	"gorm.io/gorm"
@@ -59,6 +60,7 @@ type RepositoryI interface {
 	GetBlocks() map[int64]*schemas.Block
 	GetDisabledTokens() []*schemas.AllowedToken
 	LoadBlocks(from, to int64)
+	GetCfg() *config.Config
 	// credit account operations
 	AddAccountOperation(accountOperation *schemas.AccountOperation)
 	// for getting executeparser

ds/repo_dummy.go

@@ -10,6 +10,7 @@ import (
 	"github.com/Gearbox-protocol/sdk-go/core/schemas/schemas_v3"
 	"github.com/Gearbox-protocol/sdk-go/log"
 	"github.com/Gearbox-protocol/sdk-go/pkg/redstone"
+	"github.com/Gearbox-protocol/third-eye/config"
 	"github.com/Gearbox-protocol/third-eye/ds/dc_wrapper"
 	"github.com/ethereum/go-ethereum/common"
 	"gorm.io/gorm"
@@ -258,6 +259,9 @@ func (DummyRepo) IsBlockRecent(block int64, dur time.Duration) bool { return fal
 func (DummyRepo) GetRedStonemgr() redstone.RedStoneMgrI {
 	return nil
 }
+func (DummyRepo) GetCfg() *config.Config {
+	return nil
+}
 
 type DieselBalance struct {
 	BalanceBI *core.BigInt `gorm:"column:balance_bi"`

models/aggregated_block_feed/curve_price_feed/model.go

@@ -2,14 +2,18 @@ package curve_price_feed
 
 import (
 	"math/big"
+	"strings"
 	"time"
 
 	"github.com/Gearbox-protocol/sdk-go/artifacts/multicall"
 	"github.com/Gearbox-protocol/sdk-go/core"
 	"github.com/Gearbox-protocol/sdk-go/core/schemas"
 	"github.com/Gearbox-protocol/sdk-go/log"
+	"github.com/Gearbox-protocol/sdk-go/utils"
 	"github.com/Gearbox-protocol/third-eye/ds"
 	"github.com/Gearbox-protocol/third-eye/models/aggregated_block_feed/base_price_feed"
+	"github.com/Gearbox-protocol/third-eye/models/aggregated_block_feed/redstone_price_feed"
+	"github.com/ethereum/go-ethereum/accounts/abi"
 	"github.com/ethereum/go-ethereum/common"
 )
 
@@ -40,6 +44,25 @@ var curvePFLatestRoundDataTimer = map[string]log.TimerFn{}
 func (adapter *CurvePriceFeed) ProcessResult(blockNum int64, results []multicall.Multicall2Result, _ string, force ...bool) *schemas.PriceFeed {
 	result := results[len(results)-1]
 	if !result.Success {
+		if core.GetBaseChainId(adapter.Client) == 42793 {
+			calls, _ := adapter.GetUnderlyingCalls(blockNum)
+			mcabi := core.GetAbi("MultiCall")
+			calldata, err := mcabi.Pack("tryAggregate", false, calls)
+			log.CheckFatal(err)
+
+			rpc := strings.Split(adapter.Repo.GetCfg().EthProvider, ",")
+			multicallresult := redstone_price_feed.GetRedStoneResult(calldata, blockNum, rpc[0])
+			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),
+				Price:       utils.GetFloat64Decimal(price, 8),
+				BlockNumber: blockNum,
+			}
+		}
 		if adapter.GetVersion().LessThan(core.NewVersion(300)) { // failed and
 			// if virtualprice of pool for this oracle is not within lowerBound and upperBound , ignore the price
 			oracleAddr := common.HexToAddress(adapter.GetAddress())

models/aggregated_block_feed/redstone_price_feed/command.go

@@ -0,0 +1,60 @@
+package redstone_price_feed
+
+import (
+	"encoding/hex"
+	"fmt"
+	"os/exec"
+	"strings"
+
+	"github.com/Gearbox-protocol/sdk-go/log"
+)
+
+func GetRedStoneResult(data []byte, block int64, rpc string) []byte {
+	// Define the command and its arguments.
+	// The first argument to exec.Command is the command itself,
+	// and subsequent arguments are passed to that command.
+	cmdstr := []string{
+		"cast",
+		"call",
+		"0xca11bde05977b3631167028862be2a173976ca11", // multicall
+		"--data",
+		hex.EncodeToString(data),
+		"--block",
+		fmt.Sprintf("%d", block),
+		"-r",
+		rpc,
+		"--trace",
+	}
+	cmd := exec.Command(cmdstr[0], cmdstr[1:]...) // Example: list files in the current directory
+
+	// Execute the command and capture its standard output.
+	output, err := cmd.Output()
+	if err != nil {
+		log.Fatalf("Error executing command: %v", err)
+	}
+
+	// Convert output to string and get the last line
+	outputStr := string(output)
+	lines := strings.Split(strings.TrimSpace(outputStr), "\n")
+	if len(lines) == 0 {
+		return nil
+	}
+	lastLine := ""
+	for _, line := range lines {
+		if strings.Contains(line, "0x") {
+			lastLine = line
+		}
+	}
+
+	// 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)
+		return nil
+	}
+
+	return bytes[len(bytes)-5*32:]
+}

repository/index.go

@@ -73,6 +73,9 @@ func NewRepository(db *gorm.DB, client core.ClientI, config *config.Config, ep *
 	r := GetRepository(db, client, config, ep)
 	return r
 }
+func (r Repository) GetCfg() *config.Config {
+	return r.config
+}
 
 func (r Repository) GetDB() *gorm.DB {
 	return r.db