From 297ed71877191f78f2a911272ac5cd5229746e4b Mon Sep 17 00:00:00 2001 From: Adrian Gallagher Date: Mon, 20 Apr 2015 22:37:12 +1000 Subject: [PATCH] Updated Huobi Websocket to be compatible with socketio library changes. --- huobiwebsocket.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/huobiwebsocket.go b/huobiwebsocket.go index 2885fe6b..cb2799a8 100644 --- a/huobiwebsocket.go +++ b/huobiwebsocket.go @@ -169,14 +169,14 @@ func (h *HUOBI) OnConnect(output chan socketio.Message) { if err != nil { log.Println(err) } - output <- socketio.CreateMessageEvent("request", string(result), nil) + output <- socketio.CreateMessageEvent("request", string(result), nil, HuobiSocket.Version) msg = h.BuildHuobiWebsocketRequestExtra(HUOBI_SOCKET_REQ_SUBSCRIBE, 100, h.BuildHuobiWebsocketParamsList(HUOBI_SOCKET_MARKET_OVERVIEW, "ltccny", "pushLong", "", "", "", "", "")) result, err = JSONEncode(msg) if err != nil { log.Println(err) } - output <- socketio.CreateMessageEvent("request", string(result), nil) + output <- socketio.CreateMessageEvent("request", string(result), nil, HuobiSocket.Version) } func (h *HUOBI) OnDisconnect(output chan socketio.Message) { @@ -208,6 +208,7 @@ func (h *HUOBI) WebsocketClient() { events["message"] = h.OnMessage HuobiSocket = &socketio.SocketIO{ + Version: 0.9, OnConnect: h.OnConnect, OnEvent: events, OnError: h.OnError,