From 706b12583ff07ec5a412bfab7130d31d29364cf9 Mon Sep 17 00:00:00 2001 From: Adrian Gallagher Date: Sat, 12 Mar 2016 22:03:57 +1100 Subject: [PATCH] Added support for Bitfinex Websocket heartbeat. --- bitfinexwebsocket.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/bitfinexwebsocket.go b/bitfinexwebsocket.go index 4eed642c..b47ea667 100644 --- a/bitfinexwebsocket.go +++ b/bitfinexwebsocket.go @@ -23,6 +23,7 @@ const ( BITFINEX_WEBSOCKET_ORDER_UPDATE = "ou" BITFINEX_WEBSOCKET_ORDER_CANCEL = "oc" BITFINEX_WEBSOCKET_TRADE_EXECUTED = "te" + BITFINEX_WEBSOCKET_HEARTBEAT = "hb" ) type BitfinexWebsocketChanInfo struct { @@ -247,6 +248,13 @@ func (b *Bitfinex) WebsocketClient() { if !ok { log.Println("Unable to locate chanID: %d", chanID) } else { + if len(chanData) == 2 { + if reflect.TypeOf(chanData[1]).String() == "string" { + if chanData[1].(string) == BITFINEX_WEBSOCKET_HEARTBEAT { + continue + } + } + } switch chanInfo.Channel { case "book": orderbook := []BitfinexWebsocketBook{}