update error

dao/db.go

@@ -340,7 +340,7 @@ func (d *Dao) QuoteBridge(param apiModel.QuoteBridgeParam) (quote apiModel.Quote
 	chainInfo, err := d.GetChainConfig(param.FromChainId)
 	if err != nil {
 		log.Error("not found chain config for chain id:", param.FromChainId)
-		return quote, nil
+		return quote, fmt.Errorf("not found chain config for chain id: %s", param.FromChainId)
 	}
 	outConfig, err := d.GetOutConfig(param.FromChainId, common.HexToAddress(param.FromToken), param.ToChainId)
 	if err != nil {
@@ -350,7 +350,7 @@ func (d *Dao) QuoteBridge(param apiModel.QuoteBridgeParam) (quote apiModel.Quote
 			"to_chain": param.ToChainId,
 			"error":    err,
 		}).Error("get out config failed")
-		return quote, err
+		return quote, fmt.Errorf("internal error")
 	}
 	_, balance, err := d.tokenRepo.RetriveTokenInfoAndBalance(chainInfo.cli, param.FromToken, param.User)
 	if err != nil {
@@ -360,7 +360,7 @@ func (d *Dao) QuoteBridge(param apiModel.QuoteBridgeParam) (quote apiModel.Quote
 			"user":     param.User,
 			"error":    err,
 		}).Error("get user balance failed")
-		return quote, err
+		return quote, fmt.Errorf("internal error")
 	}
 	// check balance and param.InputAmount
 	// check param.InputAmount and outConfig.Limit
@@ -370,7 +370,7 @@ func (d *Dao) QuoteBridge(param apiModel.QuoteBridgeParam) (quote apiModel.Quote
 		log.WithFields(log.Fields{
 			"input_amount": param.InputAmount,
 		}).Error("invalid input amount")
-		return quote, nil
+		return quote, fmt.Errorf("invalid input amount")
 	}
 	if balance.Cmp(inputAmount) < 0 {
 		log.WithFields(log.Fields{
@@ -418,7 +418,7 @@ func (d *Dao) QuoteBridge(param apiModel.QuoteBridgeParam) (quote apiModel.Quote
 			"inputAmount": inputAmount.String(),
 			"error":       err,
 		}).Error("build bridge payload failed")
-		return quote, err
+		return quote, fmt.Errorf("internal error")
 	}
 	quote.Payload = common.Bytes2Hex(payload)
 	return quote, nil
@@ -432,7 +432,7 @@ func (d *Dao) GetAllChainSwapConfig() (map[int64]*apiModel.ChainSwapConfig, erro
 
 	cursor, err := collection.Find(ctx, bson.M{})
 	if err != nil {
-		return res, err
+		return res, fmt.Errorf("internal error")
 	}
 	defer cursor.Close(ctx)
 
@@ -591,7 +591,7 @@ func (d *Dao) QuoteSwap(param apiModel.QuoteSwapParam) (quote apiModel.QuoteResu
 	chainInfo, err := d.GetChainConfig(param.FromChainId)
 	if err != nil {
 		log.Error("not found chain config for chain id:", param.FromChainId)
-		return quote, nil
+		return quote, fmt.Errorf("not found chain for chain id")
 	}
 
 	_, balance, err := d.tokenRepo.RetriveTokenInfoAndBalance(chainInfo.cli, param.Path.SwapFromToken, param.User)
@@ -602,7 +602,7 @@ func (d *Dao) QuoteSwap(param apiModel.QuoteSwapParam) (quote apiModel.QuoteResu
 			"user":     param.User,
 			"error":    err,
 		}).Error("get user balance failed")
-		return quote, err
+		return quote, fmt.Errorf("internal error")
 	}
 	// check balance and param.InputAmount
 	inputAmount, ok := new(big.Int).SetString(param.InputAmount, 10)
@@ -610,7 +610,7 @@ func (d *Dao) QuoteSwap(param apiModel.QuoteSwapParam) (quote apiModel.QuoteResu
 		log.WithFields(log.Fields{
 			"input_amount": param.InputAmount,
 		}).Error("invalid input amount")
-		return quote, nil
+		return quote, fmt.Errorf("invalid input amount")
 	}
 	if balance.Cmp(inputAmount) < 0 {
 		log.WithFields(log.Fields{
@@ -650,7 +650,7 @@ func (d *Dao) QuoteSwap(param apiModel.QuoteSwapParam) (quote apiModel.QuoteResu
 				"input_amount":      inputAmount.String(),
 				"error":             err,
 			}).Error("get swap amounts out failed")
-			return quote, err
+			return quote, fmt.Errorf("internal error")
 		}
 		inputAmount = swapFromAmount
 	}
@@ -663,7 +663,7 @@ func (d *Dao) QuoteSwap(param apiModel.QuoteSwapParam) (quote apiModel.QuoteResu
 			"to_chain":          param.ToChainId,
 			"error":             err,
 		}).Error("get out config failed")
-		return quote, err
+		return quote, fmt.Errorf("internal error")
 	}
 	if outConfig.ReceiveToken != common.HexToAddress(param.Path.BridgeToToken) {
 		log.WithFields(log.Fields{
@@ -699,7 +699,7 @@ func (d *Dao) QuoteSwap(param apiModel.QuoteSwapParam) (quote apiModel.QuoteResu
 				"swap_to_token":   param.Path.SwapToToken,
 				"error":           err,
 			}).Error("not found swap config for bridge to token to swap to token")
-			return quote, err
+			return quote, fmt.Errorf("internal error")
 		}
 		swapToAmount, err := router.GetAmountsOut(chainInfo.cli, common.HexToAddress(param.User), common.HexToAddress(swapConfig.SwapContract), outAmount, swapConfig.SwapPath)
 		if err != nil {
@@ -710,7 +710,7 @@ func (d *Dao) QuoteSwap(param apiModel.QuoteSwapParam) (quote apiModel.QuoteResu
 				"input_amount":    outAmount.String(),
 				"error":           err,
 			}).Error("get swap amounts out failed")
-			return quote, err
+			return quote, fmt.Errorf("internal error")
 		}
 		quote.OutAmount = swapToAmount.String()
 	}
@@ -725,7 +725,7 @@ func (d *Dao) QuoteSwap(param apiModel.QuoteSwapParam) (quote apiModel.QuoteResu
 			"inputAmount": inputAmount.String(),
 			"error":       err,
 		}).Error("build swap payload failed")
-		return quote, err
+		return quote, fmt.Errorf("internal error")
 	}
 	quote.Payload = common.Bytes2Hex(payload)
 	return quote, nil

server/controller.go

@@ -116,7 +116,7 @@ func bridgeQuote(c *gin.Context) {
 	quote, err := _querier.QuoteBridge(queryParam)
 	if err != nil {
 		log.Errorf("get bridge quote error: %v", err)
-		c.JSON(500, withError(constant.InternalError))
+		c.JSON(500, withError(err.Error()))
 		return
 	}
 	c.JSON(200, withSuccess(quote))
@@ -188,7 +188,7 @@ func swapQuote(c *gin.Context) {
 	quote, err := _querier.QuoteSwap(queryParam)
 	if err != nil {
 		log.Errorf("get swap quote error: %v", err)
-		c.JSON(500, withError(constant.InternalError))
+		c.JSON(500, withError(err.Error()))
 		return
 	}
 	c.JSON(200, withSuccess(quote))
@@ -214,7 +214,7 @@ func getSwapRoutersByChainId(c *gin.Context) {
 	config, err := _querier.GetSwapConfig(chainId)
 	if err != nil {
 		log.Errorf("get swap config for chain %d error: %v", chainId, err)
-		c.JSON(500, withError(constant.InternalError))
+		c.JSON(500, withError(err.Error()))
 		return
 	}
 	c.JSON(200, withSuccess(config))