Skip to content

Commit

Permalink
Parse Binance API error response
Browse files Browse the repository at this point in the history
  • Loading branch information
peterzen committed Aug 12, 2024
1 parent c5cc5bf commit 7082fbf
Showing 1 changed file with 34 additions and 3 deletions.
37 changes: 34 additions & 3 deletions client/mm/libxc/binance.go
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,7 @@ import (
"encoding/json"
"errors"
"fmt"
"io"
"math"
"net/http"
"net/url"
Expand All @@ -27,7 +28,6 @@ import (
"decred.org/dcrdex/client/mm/libxc/bntypes"
"decred.org/dcrdex/dex"
"decred.org/dcrdex/dex/calc"
"decred.org/dcrdex/dex/dexnet"
"decred.org/dcrdex/dex/encode"
"decred.org/dcrdex/dex/utils"
)
Expand Down Expand Up @@ -1915,7 +1915,38 @@ func binanceMarketToDexMarkets(binanceBaseSymbol, binanceQuoteSymbol string, tok
return markets
}

type BNApiResponse struct {
Code int `json:"code"`
Msg string `json:"msg"`
}

func requestInto(req *http.Request, thing interface{}) error {
// bnc.log.Tracef("Sending request: %+v", req)
return dexnet.Do(req, thing, dexnet.WithSizeLimit(1<<24))
var sizeLimit int64 = 1 << 24

resp, err := http.DefaultClient.Do(req)
if err != nil {
return fmt.Errorf("error performing request: %w", err)
}
defer resp.Body.Close()
// Binance returns 400 Bad Request for errors
if resp.StatusCode == http.StatusBadRequest {
var apiResp BNApiResponse
reader := io.LimitReader(resp.Body, sizeLimit)
if err = json.NewDecoder(reader).Decode(&apiResp); err != nil {
return fmt.Errorf("error decoding response: %w", err)
}
return fmt.Errorf("API error: %s (%d)", apiResp.Msg, apiResp.Code)
}

if resp.StatusCode != http.StatusOK {
return fmt.Errorf("HTTP error: %q (code %d)", resp.Status, resp.StatusCode)
}
if thing == nil {
return nil
}
reader := io.LimitReader(resp.Body, sizeLimit)
if err = json.NewDecoder(reader).Decode(thing); err != nil {
return fmt.Errorf("error decoding request: %w", err)
}
return nil
}

0 comments on commit 7082fbf

Please sign in to comment.