fix(KTX): Add configuration for GMX dex-type to select correct contra…

…ct function on Mantle (#587)

pkg/source/gmx/config.go

@@ -1,7 +1,10 @@
 package gmx
 
+import "github.com/KyberNetwork/kyberswap-dex-lib/pkg/valueobject"
+
 type Config struct {
-	DexID                   string `json:"-"`
-	VaultAddress            string `json:"vaultAddress"`
-	UseSecondaryPriceFeedV1 bool   `json:"useSecondaryPriceFeedV1"`
+	ChainID                 valueobject.ChainID `json:"chainID"`
+	DexID                   string              `json:"dexID"`
+	VaultAddress            string              `json:"vaultAddress"`
+	UseSecondaryPriceFeedV1 bool                `json:"useSecondaryPriceFeedV1"`
 }

pkg/source/gmx/price_feed_reader.go

@@ -9,14 +9,26 @@ import (
 	"github.com/ethereum/go-ethereum/accounts/abi"
 )
 
+type Param struct {
+	PriceFeedMethodGetRoundData string
+}
+
 type PriceFeedReader struct {
+	param        Param
 	abi          abi.ABI
 	ethrpcClient *ethrpc.Client
 	log          logger.Logger
 }
 
 func NewPriceFeedReader(ethrpcClient *ethrpc.Client) *PriceFeedReader {
+	return NewPriceFeedReaderWithParam(ethrpcClient, Param{
+		PriceFeedMethodGetRoundData: priceFeedMethodGetRoundData,
+	})
+}
+
+func NewPriceFeedReaderWithParam(ethrpcClient *ethrpc.Client, param Param) *PriceFeedReader {
 	return &PriceFeedReader{
+		param:        param,
 		abi:          priceFeedABI,
 		ethrpcClient: ethrpcClient,
 		log: logger.WithFields(logger.Fields{
@@ -50,7 +62,7 @@ func (r *PriceFeedReader) getLatestRoundData(ctx context.Context, address string
 	rpcRequest.AddCall(&ethrpc.Call{
 		ABI:    r.abi,
 		Target: address,
-		Method: priceFeedMethodLatestRoundData,
+		Method: r.param.PriceFeedMethodGetRoundData,
 		Params: nil,
 	}, []interface{}{&latestRoundData})
 

pkg/source/gmx/vault_scanner.go

@@ -9,6 +9,7 @@ import (
 	"github.com/ethereum/go-ethereum/common"
 
 	"github.com/KyberNetwork/kyberswap-dex-lib/pkg/util/eth"
+	"github.com/KyberNetwork/kyberswap-dex-lib/pkg/valueobject"
 )
 
 type VaultScanner struct {
@@ -28,16 +29,23 @@ func NewVaultScanner(
 	config *Config,
 	ethrpcClient *ethrpc.Client,
 ) *VaultScanner {
+	method := priceFeedMethodLatestRoundData
+	if config.ChainID == valueobject.ChainIDMantle && config.DexID == string(valueobject.ExchangeKTX) {
+		method = "latestRound"
+	}
+
 	return &VaultScanner{
 		config:                config,
 		vaultReader:           NewVaultReader(ethrpcClient),
 		vaultPriceFeedReader:  NewVaultPriceFeedReader(ethrpcClient),
 		fastPriceFeedV1Reader: NewFastPriceFeedV1Reader(ethrpcClient),
 		fastPriceFeedV2Reader: NewFastPriceFeedV2Reader(ethrpcClient),
-		priceFeedReader:       NewPriceFeedReader(ethrpcClient),
-		usdgReader:            NewUSDGReader(ethrpcClient),
-		chainlinkFlagsReader:  NewChainlinkFlagsReader(ethrpcClient),
-		pancakePairReader:     NewPancakePairReader(ethrpcClient),
+		priceFeedReader: NewPriceFeedReaderWithParam(ethrpcClient, Param{
+			PriceFeedMethodGetRoundData: method,
+		}),
+		usdgReader:           NewUSDGReader(ethrpcClient),
+		chainlinkFlagsReader: NewChainlinkFlagsReader(ethrpcClient),
+		pancakePairReader:    NewPancakePairReader(ethrpcClient),
 		log: logger.WithFields(logger.Fields{
 			"liquiditySource": DexTypeGmx,
 			"scanner":         "VaultScanner",