add basecurrency when fetching price from chainlink

ExocoreNetwork · Dec 27, 2024 · 1704075 · 1704075
1 parent 051df11
commit 1704075
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 4 deletions.
diff --git a/cmd/types.go b/cmd/types.go
@@ -14,10 +14,7 @@ import (
 	sdktx "github.com/cosmos/cosmos-sdk/types/tx"
 )
 
-const (
-	loggerTagPrefix = "feed_%s_%d"
-	baseCurrency    = "USDT"
-)
+const loggerTagPrefix = "feed_%s_%d"
 
 type priceFetcher interface {
 	GetLatestPrice(source, token string) (fetchertypes.PriceInfo, error)

diff --git a/fetcher/chainlink/chainlink.go b/fetcher/chainlink/chainlink.go
@@ -16,7 +16,12 @@ import (
 	"github.com/ethereum/go-ethereum/ethclient"
 )
 
+const baseCurrency = "usdt"
+
 func (s *source) fetch(token string) (*fetchertypes.PriceInfo, error) {
+	if !strings.HasSuffix(token, baseCurrency) {
+		token += baseCurrency
+	}
 	chainlinkPriceFeedProxy, ok := s.chainlinkProxy.get(token)
 	if !ok {
 		return nil, feedertypes.ErrSourceTokenNotConfigured.Wrap(fmt.Sprintf("chainlinkProxy not configured for token: %s", token))