d0zingcat/gocryptotrader
1
0
Fork 0
mirror of https://github.com/d0zingcat/gocryptotrader.git synced 2026-05-13 23:16:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

Updated Huobi Websocket to be compatible with socketio library changes.

Browse Source
This commit is contained in:
Adrian Gallagher
2015-04-20 22:37:12 +10:00
parent 690094babb
commit 297ed71877
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
huobiwebsocket.go
View File

@@ -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,