From f1008723407520b8fc0f4168aefce02cc75bcab9 Mon Sep 17 00:00:00 2001 From: Ermal Guni Date: Mon, 11 Jun 2018 08:30:10 +0200 Subject: [PATCH] bitfinex websocket trade fix (#133) * bitfinex trades websocket fix --- exchanges/bitfinex/bitfinex_websocket.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/exchanges/bitfinex/bitfinex_websocket.go b/exchanges/bitfinex/bitfinex_websocket.go index 17feb203..9a597251 100644 --- a/exchanges/bitfinex/bitfinex_websocket.go +++ b/exchanges/bitfinex/bitfinex_websocket.go @@ -281,10 +281,13 @@ func (b *Bitfinex) WebsocketClient() { data := chanData[1].([]interface{}) for _, x := range data { y := x.([]interface{}) + if _, ok := y[0].(string); ok { + continue + } trades = append(trades, WebsocketTrade{ID: int64(y[0].(float64)), Timestamp: int64(y[1].(float64)), Price: y[2].(float64), Amount: y[3].(float64)}) } - case 5: - trade := WebsocketTrade{ID: int64(chanData[1].(float64)), Timestamp: int64(chanData[2].(float64)), Price: chanData[3].(float64), Amount: chanData[4].(float64)} + case 7: + trade := WebsocketTrade{ID: int64(chanData[3].(float64)), Timestamp: int64(chanData[4].(float64)), Price: chanData[5].(float64), Amount: chanData[6].(float64)} trades = append(trades, trade) if b.Verbose {