Bump golangci-lint and AppVeyor versions now that 1.13.x is supported (#375)

2026-06-05 07:26:47 +00:00 · 2019-11-11 15:15:29 +11:00
parent 0501455a2e
commit e9b3e3d328
55 changed files with 63 additions and 128 deletions
--- a/exchanges/anx/anx.go
+++ b/exchanges/anx/anx.go
@@ -204,7 +204,6 @@ func (a *ANX) GetDataToken() (string, error) {
 // NewOrder sends a new order request to the exchange.
 func (a *ANX) NewOrder(orderType string, buy bool, tradedCurrency string, tradedCurrencyAmount float64, settlementCurrency string, settlementCurrencyAmount, limitPriceSettlement float64,
 	replace bool, replaceUUID string, replaceIfActive bool) (string, error) {
-
 	req := make(map[string]interface{})
 	var order Order
 	order.OrderType = orderType
--- a/exchanges/binance/binance_test.go
+++ b/exchanges/binance/binance_test.go
@@ -243,7 +243,6 @@ func TestGetFee(t *testing.T) {
 			t.Errorf("Test Failed - GetFee() error. Expected: %f, Received: %f", float64(0), resp)
 			t.Error(err)
 		}
-
 	}

 	// CryptocurrencyWithdrawalFee Basic
--- a/exchanges/bitfinex/bitfinex_test.go
+++ b/exchanges/bitfinex/bitfinex_test.go
@@ -222,7 +222,6 @@ func TestGetSymbols(t *testing.T) {
 		"rrtusd",
 	}
 	if len(expectedCurrencies) <= len(symbols) {
-
 		for _, explicitSymbol := range expectedCurrencies {
 			if common.StringDataCompare(expectedCurrencies, explicitSymbol) {
 				break
--- a/exchanges/bitfinex/bitfinex_websocket.go
+++ b/exchanges/bitfinex/bitfinex_websocket.go
@@ -201,7 +201,6 @@ func (b *Bitfinex) WsDataHandler() {
 						if status == "OK" {
 							b.Websocket.DataHandler <- eventData
 							b.WsAddSubscriptionChannel(0, "account", "N/A")
-
 						} else if status == "fail" {
 							b.Websocket.DataHandler <- fmt.Errorf("bitfinex.go error - Websocket unable to AUTH. Error code: %s",
 								eventData["code"].(string))
--- a/exchanges/bitmex/bitmex_websocket.go
+++ b/exchanges/bitmex/bitmex_websocket.go
@@ -183,7 +183,6 @@ func (b *Bitmex) wsHandleIncomingData() {

 				b.Websocket.DataHandler <- fmt.Errorf("%s websocket error: Unable to subscribe %s",
 					b.Name, decodedResp.Subscribe)
-
 			} else if _, ok := quickCapture["table"]; ok {
 				var decodedResp WebsocketMainResponse
 				err := common.JSONDecode(resp.Raw, &decodedResp)
--- a/exchanges/bitmex/bitmex_wrapper.go
+++ b/exchanges/bitmex/bitmex_wrapper.go
@@ -36,7 +36,6 @@ func (b *Bitmex) Run() {
 	marketInfo, err := b.GetActiveInstruments(&GenericRequestParams{})
 	if err != nil {
 		log.Errorf("%s Failed to get available symbols.\n", b.GetName())
-
 	} else {
 		var exchangeProducts []string
 		for i := range marketInfo {
--- a/exchanges/bitstamp/bitstamp_wrapper.go
+++ b/exchanges/bitstamp/bitstamp_wrapper.go
@@ -66,7 +66,6 @@ func (b *Bitstamp) UpdateTicker(p currency.Pair, assetType string) (ticker.Price
 	tick, err := b.GetTicker(p.String(), false)
 	if err != nil {
 		return tickerPrice, err
-
 	}
 	tickerPrice.Pair = p
 	tickerPrice.Ask = tick.Ask
@@ -100,7 +99,6 @@ func (b *Bitstamp) GetFeeByType(feeBuilder *exchange.FeeBuilder) (float64, error
 		feeBuilder.FeeType = exchange.OfflineTradeFee
 	}
 	return b.GetFee(feeBuilder)
-
 }

 // GetOrderbookEx returns the orderbook for a currency pair
--- a/exchanges/bittrex/bittrex.go
+++ b/exchanges/bittrex/bittrex.go
@@ -575,5 +575,4 @@ func (b *Bittrex) GetWithdrawalFee(c currency.Code) (float64, error) {
 // calculateTradingFee returns the fee for trading any currency on Bittrex
 func calculateTradingFee(price, amount float64) float64 {
 	return 0.0025 * price * amount
-
 }
--- a/exchanges/bittrex/bittrex_wrapper.go
+++ b/exchanges/bittrex/bittrex_wrapper.go
@@ -306,7 +306,6 @@ func (b *Bittrex) GetFeeByType(feeBuilder *exchange.FeeBuilder) (float64, error)
 		feeBuilder.FeeType = exchange.OfflineTradeFee
 	}
 	return b.GetFee(feeBuilder)
-
 }

 // GetActiveOrders retrieves any orders that are active/open
--- a/exchanges/btse/btse.go
+++ b/exchanges/btse/btse.go
@@ -166,7 +166,6 @@ func (b *BTSE) GetTrades(symbol string) ([]Trade, error) {
 	var t []Trade
 	endpoint := fmt.Sprintf("%s/%s", btseTrades, symbol)
 	return t, b.SendHTTPRequest(http.MethodGet, endpoint, &t)
-
 }

 // GetTicker returns the ticker for a specified symbol
--- a/exchanges/btse/btse_test.go
+++ b/exchanges/btse/btse_test.go
@@ -120,7 +120,6 @@ func TestGetFills(t *testing.T) {
 	if err != nil {
 		t.Error(err)
 	}
-
 }

 func TestCreateOrder(t *testing.T) {
--- a/exchanges/btse/btse_wrapper.go
+++ b/exchanges/btse/btse_wrapper.go
@@ -66,7 +66,6 @@ func (b *BTSE) UpdateTicker(p currency.Pair, assetType string) (ticker.Price, er
 	s, err := b.GetMarketStatistics(exchange.FormatExchangeCurrency(b.Name, p).String())
 	if err != nil {
 		return tickerPrice, err
-
 	}

 	tickerPrice.Pair = p
--- a/exchanges/coinbasepro/coinbasepro_test.go
+++ b/exchanges/coinbasepro/coinbasepro_test.go
@@ -361,7 +361,6 @@ func TestCalculateTradingFee(t *testing.T) {
 }

 func TestFormatWithdrawPermissions(t *testing.T) {
-
 	c.SetDefaults()
 	expectedResult := exchange.AutoWithdrawCryptoWithAPIPermissionText + " & " + exchange.AutoWithdrawFiatWithAPIPermissionText

@@ -440,7 +439,6 @@ func TestSubmitOrder(t *testing.T) {
 }

 func TestCancelExchangeOrder(t *testing.T) {
-
 	c.SetDefaults()
 	TestSetup(t)

@@ -467,7 +465,6 @@ func TestCancelExchangeOrder(t *testing.T) {
 }

 func TestCancelAllExchangeOrders(t *testing.T) {
-
 	c.SetDefaults()
 	TestSetup(t)

--- a/exchanges/coinbasepro/coinbasepro_types.go
+++ b/exchanges/coinbasepro/coinbasepro_types.go
@@ -447,7 +447,7 @@ type WebsocketTicker struct {
 	BestBid   float64   `json:"best_bid,string"`
 	BestAsk   float64   `json:"best_ask,string"`
 	Side      string    `json:"side"`
-	Time      time.Time `json:"time,string"`
+	Time      time.Time `json:"time"`
 	TradeID   int64     `json:"trade_id"`
 	LastSize  float64   `json:"last_size,string"`
 }
--- a/exchanges/coinut/coinut_test.go
+++ b/exchanges/coinut/coinut_test.go
@@ -234,7 +234,6 @@ func TestGetFee(t *testing.T) {
 }

 func TestFormatWithdrawPermissions(t *testing.T) {
-
 	c.SetDefaults()
 	expectedResult := exchange.WithdrawCryptoViaWebsiteOnlyText + " & " + exchange.WithdrawFiatViaWebsiteOnlyText

@@ -306,7 +305,6 @@ func TestSubmitOrder(t *testing.T) {
 }

 func TestCancelExchangeOrder(t *testing.T) {
-
 	c.SetDefaults()
 	TestSetup(t)

@@ -333,7 +331,6 @@ func TestCancelExchangeOrder(t *testing.T) {
 }

 func TestCancelAllExchangeOrders(t *testing.T) {
-
 	c.SetDefaults()
 	TestSetup(t)

--- a/exchanges/coinut/coinut_websocket.go
+++ b/exchanges/coinut/coinut_websocket.go
@@ -102,7 +102,6 @@ func (c *COINUT) WsHandleData() {
 					}
 					c.wsProcessResponse(individualJSON)
 				}
-
 			} else {
 				var incoming wsResponse
 				err = common.JSONDecode(resp.Raw, &incoming)
@@ -113,7 +112,6 @@ func (c *COINUT) WsHandleData() {

 				c.wsProcessResponse(resp.Raw)
 			}
-
 		}
 	}
 }
--- a/exchanges/coinut/coinut_wrapper.go
+++ b/exchanges/coinut/coinut_wrapper.go
@@ -154,7 +154,6 @@ func (c *COINUT) UpdateTicker(p currency.Pair, assetType string) (ticker.Price,
 	}

 	return ticker.GetTicker(c.Name, p, assetType)
-
 }

 // GetTickerPrice returns the ticker for a currency pair
@@ -313,12 +312,10 @@ func (c *COINUT) CancelAllOrders(_ *exchange.OrderCancellation) (exchange.Cancel
 	var allTheOrders []OrderResponse
 	for _, allInstrumentData := range instruments.Instruments {
 		for _, instrumentData := range allInstrumentData {
-
 			openOrders, err := c.GetOpenOrders(instrumentData.InstID)
 			if err != nil {
 				return cancelAllOrdersResponse, err
 			}
-
 			allTheOrders = append(allTheOrders, openOrders.Orders...)
 		}
 	}
--- a/exchanges/exmo/exmo_test.go
+++ b/exchanges/exmo/exmo_test.go
@@ -250,7 +250,6 @@ func TestGetFee(t *testing.T) {
 }

 func TestFormatWithdrawPermissions(t *testing.T) {
-
 	e.SetDefaults()
 	expectedResult := exchange.AutoWithdrawCryptoWithSetupText + " & " + exchange.NoFiatWithdrawalsText

@@ -327,7 +326,6 @@ func TestSubmitOrder(t *testing.T) {
 }

 func TestCancelExchangeOrder(t *testing.T) {
-
 	e.SetDefaults()
 	TestSetup(t)
 	if areTestAPIKeysSet() && !canManipulateRealOrders {
@@ -353,7 +351,6 @@ func TestCancelExchangeOrder(t *testing.T) {
 }

 func TestCancelAllExchangeOrders(t *testing.T) {
-
 	e.SetDefaults()
 	TestSetup(t)

--- a/exchanges/gemini/gemini.go
+++ b/exchanges/gemini/gemini.go
@@ -175,7 +175,6 @@ func (g *Gemini) GetSymbols() ([]string, error) {

 // GetTicker returns information about recent trading activity for the symbol
 func (g *Gemini) GetTicker(currencyPair string) (Ticker, error) {
-
 	type TickerResponse struct {
 		Ask     float64 `json:"ask,string"`
 		Bid     float64 `json:"bid,string"`
--- a/exchanges/hitbtc/hitbtc_types.go
+++ b/exchanges/hitbtc/hitbtc_types.go
@@ -22,12 +22,12 @@ type Ticker struct {

 // TickerResponse is the response type
 type TickerResponse struct {
-	Last        string    `json:"last"`             // Last trade price
-	Ask         string    `json:"ask"`              // Best ask price
-	Bid         string    `json:"bid"`              // Best bid price
-	Timestamp   time.Time `json:"timestamp,string"` // Last update or refresh ticker timestamp
-	Volume      string    `json:"volume"`           // Total trading amount within 24 hours in base currency
-	VolumeQuote string    `json:"volumeQuote"`      // Total trading amount within 24 hours in quote currency
+	Last        string    `json:"last"`        // Last trade price
+	Ask         string    `json:"ask"`         // Best ask price
+	Bid         string    `json:"bid"`         // Best bid price
+	Timestamp   time.Time `json:"timestamp"`   // Last update or refresh ticker timestamp
+	Volume      string    `json:"volume"`      // Total trading amount within 24 hours in base currency
+	VolumeQuote string    `json:"volumeQuote"` // Total trading amount within 24 hours in quote currency
 	Symbol      string    `json:"symbol"`
 	High        string    `json:"high"` // Highest trade price within 24 hours
 	Low         string    `json:"low"`  // Lowest trade price within 24 hours
@@ -75,7 +75,7 @@ type TradeHistory struct {

 // ChartData contains chart data
 type ChartData struct {
-	Timestamp   time.Time `json:"timestamp,string"`
+	Timestamp   time.Time `json:"timestamp"`
 	Max         float64   `json:"max,string"`         // Max price
 	Min         float64   `json:"min,string"`         // Min price
 	Open        float64   `json:"open,string"`        // Open price
@@ -88,7 +88,7 @@ type ChartData struct {
 type Currencies struct {
 	ID                 string `json:"id"`                 // Currency identifier.
 	FullName           string `json:"fullName"`           // Currency full name
-	Crypto             bool   `json:"crypto,boolean"`     // Is currency belongs to blockchain (false for ICO and fiat, like EUR)
+	Crypto             bool   `json:"crypto"`             // Is currency belongs to blockchain (false for ICO and fiat, like EUR)
 	PayinEnabled       bool   `json:"payinEnabled"`       // Is allowed for deposit (false for ICO)
 	PayinPaymentID     bool   `json:"payinPaymentId"`     // Is required to provide additional information other than the address for deposit
 	PayinConfirmations int64  `json:"payinConfirmations"` // Blocks confirmations count for deposit
@@ -148,10 +148,10 @@ type Order struct {
 	Quantity    float64   `json:"quantity,string"`    // Order quantity
 	Price       float64   `json:"price,string"`       // Order price
 	CumQuantity float64   `json:"cumQuantity,string"` // Cumulative executed quantity
-	CreatedAt   time.Time `json:"createdAt,string"`
-	UpdatedAt   time.Time `json:"updatedAt,string"`
+	CreatedAt   time.Time `json:"createdAt"`
+	UpdatedAt   time.Time `json:"updatedAt"`
 	StopPrice   float64   `json:"stopPrice,string"`
-	ExpireTime  time.Time `json:"expireTime,string"`
+	ExpireTime  time.Time `json:"expireTime"`
 }

 // OpenOrdersResponseAll holds the full open order response
@@ -274,7 +274,7 @@ type LoanOffer struct {
 	Rate      float64 `json:"rate,string"`
 	Amount    float64 `json:"amount,string"`
 	Duration  int     `json:"duration"`
-	AutoRenew bool    `json:"autoRenew,int"`
+	AutoRenew bool    `json:"autoRenew"`
 	Date      string  `json:"date"`
 }

--- a/exchanges/kraken/kraken.go
+++ b/exchanges/kraken/kraken.go
@@ -567,7 +567,6 @@ func (k *Kraken) GetTradeBalance(args ...TradeBalanceOptions) (TradeBalanceInfo,
 		if len(args[0].Asset) > 0 {
 			params.Set("asset", args[0].Asset)
 		}
-
 	}

 	var response struct {
--- a/exchanges/lakebtc/lakebtc_wrapper.go
+++ b/exchanges/lakebtc/lakebtc_wrapper.go
@@ -215,7 +215,6 @@ func (l *LakeBTC) CancelAllOrders(_ *exchange.OrderCancellation) (exchange.Cance
 	}

 	return cancelAllOrdersResponse, l.CancelExistingOrders(ordersToCancel)
-
 }

 // GetOrderInfo returns information on a current open order
--- a/exchanges/lbank/lbank.go
+++ b/exchanges/lbank/lbank.go
@@ -230,7 +230,6 @@ func (l *Lbank) GetKlines(symbol, size, klineType, time string) ([]KlineResponse
 				} else {
 					tempResp.TradingVolume = resp2[x].(float64)
 				}
-
 			}
 		}
 		k = append(k, tempResp)
--- a/exchanges/lbank/lbank_wrapper.go
+++ b/exchanges/lbank/lbank_wrapper.go
@@ -510,7 +510,6 @@ func (l *Lbank) getAllOpenOrderID() (map[string][]string, error) {

 			for c := 0; c < tempData; c++ {
 				resp[exchange.FormatExchangeCurrency(l.Name, p).String()] = append(resp[exchange.FormatExchangeCurrency(l.Name, p).String()], tempResp.Orders[c].OrderID)
-
 			}
 			tempData = len(tempResp.Orders)
 			b++
--- a/exchanges/localbitcoins/localbitcoins_types.go
+++ b/exchanges/localbitcoins/localbitcoins_types.go
@@ -106,7 +106,7 @@ type AdEdit struct {
 	MaxAmount          int      `json:"max_amount"`
 	OpeningHours       []string `json:"opening_hours"`
 	LimitToFiatAmounts string   `json:"limit_to_fiat_amounts"`
-	Visible            bool     `json:"visible,int"`
+	Visible            bool     `json:"visible"`

 	// Optional Arguments ONLINE_SELL ads
 	RequireTradeVolume   int    `json:"require_trade_volume"`
@@ -114,13 +114,13 @@ type AdEdit struct {
 	FirstTimeLimitBTC    int    `json:"first_time_limit_btc"`
 	VolumeCoefficientBTC int    `json:"volume_coefficient_btc"`
 	ReferenceType        string `json:"reference_type"`
-	DisplayReference     bool   `json:"display_reference,int"`
+	DisplayReference     bool   `json:"display_reference"`

 	// Optional Arguments ONLINE_BUY
 	PaymentWindowMinutes int `json:"payment_window_minutes"`

 	// Optional Arguments LOCAL_SELL
-	Floating bool `json:"floating,int"`
+	Floating bool `json:"floating"`
 }

 // AdCreate references an outgoing paramater type for CreateAd() method
@@ -148,7 +148,7 @@ type AdCreate struct {
 	MaxAmount          int      `json:"max_amount"`
 	OpeningHours       []string `json:"opening_hours"`
 	LimitToFiatAmounts string   `json:"limit_to_fiat_amounts"`
-	Visible            bool     `json:"visible,int"`
+	Visible            bool     `json:"visible"`

 	// Optional Arguments ONLINE_SELL ads
 	RequireTradeVolume   int    `json:"require_trade_volume"`
@@ -156,13 +156,13 @@ type AdCreate struct {
 	FirstTimeLimitBTC    int    `json:"first_time_limit_btc"`
 	VolumeCoefficientBTC int    `json:"volume_coefficient_btc"`
 	ReferenceType        string `json:"reference_type"`
-	DisplayReference     bool   `json:"display_reference,int"`
+	DisplayReference     bool   `json:"display_reference"`

 	// Optional Arguments ONLINE_BUY
 	PaymentWindowMinutes int `json:"payment_window_minutes"`

 	// Optional Arguments LOCAL_SELL
-	Floating bool `json:"floating,int"`
+	Floating bool `json:"floating"`
 }

 // Message holds the returned message data from a contact
--- a/exchanges/localbitcoins/localbitcoins_wrapper.go
+++ b/exchanges/localbitcoins/localbitcoins_wrapper.go
@@ -55,7 +55,6 @@ func (l *LocalBitcoins) Run() {
 	if err != nil {
 		log.Errorf("%s failed to update available currencies. Err %s", l.Name, err)
 	}
-
 }

 // UpdateTicker updates and returns the ticker for a currency pair
--- a/exchanges/mock/recording.go
+++ b/exchanges/mock/recording.go
@@ -419,7 +419,6 @@ func GetExcludedItems() (Exclusion, error) {
 			if mErr != nil {
 				return excludedList, mErr
 			}
-
 		} else {
 			err = json.Unmarshal(file, &excludedList)
 			if err != nil {
--- a/exchanges/okcoin/okcoin_test.go
+++ b/exchanges/okcoin/okcoin_test.go
@@ -1077,7 +1077,6 @@ func TestCancelExchangeOrder(t *testing.T) {

 	err := o.CancelOrder(&orderCancellation)
 	testStandardErrorHandling(t, err)
-
 }

 // TestCancelAllExchangeOrders Wrapper test
--- a/exchanges/okex/okex.go
+++ b/exchanges/okex/okex.go
@@ -88,7 +88,6 @@ func (o *OKEX) SetDefaults() {
 	o.WebsocketResponseMaxLimit = exchange.DefaultWebsocketResponseMaxLimit
 	o.WebsocketResponseCheckTimeout = exchange.DefaultWebsocketResponseCheckTimeout
 	o.WebsocketOrderbookBufferLimit = exchange.DefaultWebsocketOrderbookBufferLimit
-
 }

 // GetFuturesPostions Get the information of all holding positions in futures trading.
--- a/exchanges/okex/okex_test.go
+++ b/exchanges/okex/okex_test.go
@@ -1846,7 +1846,6 @@ func TestCancelExchangeOrder(t *testing.T) {

 	err := o.CancelOrder(&orderCancellation)
 	testStandardErrorHandling(t, err)
-
 }

 // TestCancelAllExchangeOrders Wrapper test
--- a/exchanges/okgroup/okgroup.go
+++ b/exchanges/okgroup/okgroup.go
@@ -668,7 +668,6 @@ func (o *OKGroup) SendHTTPRequest(httpMethod, requestType, requestPath string, d
 		if !errCap.Result {
 			return errors.New("unspecified error occurred")
 		}
-
 	}

 	return common.JSONDecode(intermediary, result)
--- a/exchanges/okgroup/okgroup_websocket.go
+++ b/exchanges/okgroup/okgroup_websocket.go
@@ -313,7 +313,6 @@ func (o *OKGroup) GetAssetTypeFromTableName(table string) string {
 // WsHandleDataResponse classifies the WS response and sends to appropriate handler
 func (o *OKGroup) WsHandleDataResponse(response *WebsocketDataResponse) {
 	switch o.GetWsChannelWithoutOrderType(response.Table) {
-
 	case okGroupWsCandle60s, okGroupWsCandle180s, okGroupWsCandle300s, okGroupWsCandle900s,
 		okGroupWsCandle1800s, okGroupWsCandle3600s, okGroupWsCandle7200s, okGroupWsCandle14400s,
 		okGroupWsCandle21600s, okGroupWsCandle43200s, okGroupWsCandle86400s, okGroupWsCandle604900s:
@@ -502,7 +501,6 @@ func (o *OKGroup) WsProcessUpdateOrderbook(wsEventData *WebsocketDataWrapper, in
 			Asset:    o.GetAssetTypeFromTableName(tableName),
 			Pair:     instrument,
 		}
-
 	} else {
 		if o.Verbose {
 			log.Debug("Orderbook invalid")
@@ -527,7 +525,6 @@ func (o *OKGroup) CalculatePartialOrderbookChecksum(orderbookData *WebsocketData
 		}
 		if len(orderbookData.Asks)-1 >= i {
 			askMessage = fmt.Sprintf("%v:%v:", orderbookData.Asks[i][0], orderbookData.Asks[i][1])
-
 		}
 		if checksum == "" {
 			checksum = fmt.Sprintf("%v%v", bidsMessage, askMessage)
--- a/exchanges/poloniex/poloniex_types.go
+++ b/exchanges/poloniex/poloniex_types.go
@@ -261,7 +261,7 @@ type LoanOffer struct {
 	Rate      float64 `json:"rate,string"`
 	Amount    float64 `json:"amount,string"`
 	Duration  int     `json:"duration"`
-	AutoRenew bool    `json:"autoRenew,int"`
+	AutoRenew bool    `json:"autoRenew"`
 	Date      string  `json:"date"`
 }

--- a/exchanges/ticker/ticker_test.go
+++ b/exchanges/ticker/ticker_test.go
@@ -389,5 +389,4 @@ func TestProcessTicker(t *testing.T) { // non-appending function to tickers
 		}
 	}
 	wg.Wait()
-
 }
--- a/exchanges/websocket/wshandler/wshandler.go
+++ b/exchanges/websocket/wshandler/wshandler.go
@@ -40,7 +40,6 @@ func (w *Websocket) Setup(connector func() error,
 	defaultURL,
 	runningURL string,
 	authenticatedWebsocketAPISupport bool) error {
-
 	w.DataHandler = make(chan interface{}, 1)
 	w.Connected = make(chan struct{}, 1)
 	w.Disconnected = make(chan struct{}, 1)
--- a/exchanges/websocket/wsorderbook/wsorderbook_test.go
+++ b/exchanges/websocket/wsorderbook/wsorderbook_test.go
@@ -434,7 +434,6 @@ func TestFlushCache(t *testing.T) {
 	if obl.ob[curr][spot] != nil {
 		t.Error("expected ob be flushed")
 	}
-
 }

 // TestInsertingSnapShots logic test
--- a/exchanges/zb/zb_websocket_types.go
+++ b/exchanges/zb/zb_websocket_types.go
@@ -77,7 +77,7 @@ type WsAddSubUserRequest struct {
 	Memo        string `json:"memo"`
 	Password    string `json:"password"`
 	SubUserName string `json:"subUserName"`
-	No          int64  `json:"no,string,omtempty"`
+	No          int64  `json:"no,string,omitempty"`
 	Sign        string `json:"sign,omitempty"`
 }