fix handle error when get price mtm

v2/pkg/price_filler/price_filler.go

@@ -3,6 +3,8 @@ package pricefiller
 import (
 	"context"
 	"errors"
+	"fmt"
+	"net"
 	"strings"
 	"sync"
 	"time"
@@ -171,24 +173,24 @@ func (p *PriceFiller) fullFillTradeLog(tradeLog storageTypes.TradeLog) (storageT
 	makerPrice, makerUsdAmount, err := p.getPriceAndAmountUsd(strings.ToLower(tradeLog.MakerToken),
 		tradeLog.MakerTokenAmount, int64(tradeLog.Timestamp))
 	if err != nil {
-		if err.Error() != invalidSymbolErrString {
+		if isConnectionRefusedError(err) {
 			p.l.Errorw("Failed to getPriceAndAmountUsd for maker", "err", err)
 			return tradeLog, err
 		}
 	}
 
-	tradeLog.MakerTokenPrice = &makerPrice
-	tradeLog.MakerUsdAmount = &makerUsdAmount
-
 	takerPrice, takerUsdAmount, err := p.getPriceAndAmountUsd(strings.ToLower(tradeLog.TakerToken),
 		tradeLog.TakerTokenAmount, int64(tradeLog.Timestamp))
 	if err != nil {
-		if err.Error() != invalidSymbolErrString {
+		if isConnectionRefusedError(err) {
 			p.l.Errorw("Failed to getPriceAndAmountUsd for taker", "err", err)
 			return tradeLog, err
 		}
 	}
 
+	tradeLog.MakerTokenPrice = &makerPrice
+	tradeLog.MakerUsdAmount = &makerUsdAmount
+
 	tradeLog.TakerTokenPrice = &takerPrice
 	tradeLog.TakerUsdAmount = &takerUsdAmount
 
@@ -226,7 +228,7 @@ func (p *PriceFiller) getSumAmountUsd(address, rawAmt []string, at int64) (float
 	for i := range address {
 		pr, usdAmount, err := p.getPriceAndAmountUsd(address[i], rawAmt[i], at)
 		if err != nil {
-			if err.Error() != invalidSymbolErrString {
+			if isConnectionRefusedError(err) {
 				p.l.Errorw("Failed to getPriceAndAmountUsd for address", "err", err)
 				return 0, 0, err
 			}
@@ -248,11 +250,7 @@ func (p *PriceFiller) getPriceAndAmountUsd(address, rawAmt string, at int64) (fl
 		if coin.Decimals == 0 {
 			decimals, symbol, err := p.getDecimalsAndSymbol(address)
 			if err != nil {
-				if errors.Is(err, ErrWeirdTokenCatalogResp) {
-					return 0, 0, nil
-				}
-				p.l.Errorw("Failed to getDecimals", "err", err, "address", address)
-				return 0, 0, err
+				return 0, 0, fmt.Errorf("failed to get decimals: %w", err)
 			}
 			coin.Decimals = decimals
 			coin.Coin = symbol
@@ -266,8 +264,7 @@ func (p *PriceFiller) getPriceAndAmountUsd(address, rawAmt string, at int64) (fl
 		}
 		price, err := p.getPrice(address, at)
 		if err != nil {
-			p.l.Errorw("Failed to getPrice", "err", err, "coin", coin.Coin, "at", at)
-			return 0, 0, err
+			return 0, 0, fmt.Errorf("failed to get price mtm: %w", err)
 		}
 
 		return price, calculateAmountUsd(rawAmt, coin.Decimals, price), nil
@@ -337,3 +334,13 @@ func (p *PriceFiller) insertTokens() error {
 	}
 	return nil
 }
+
+func isConnectionRefusedError(err error) bool {
+	var netErr *net.OpError
+	if errors.As(err, &netErr) {
+		if strings.Contains(netErr.Err.Error(), "connection refused") {
+			return true
+		}
+	}
+	return false
+}