66from websocket import WebSocketApp
77from fugle_trade_core .fugle_trade_core import convert_ws_object
88
9+
910class WebsocketHandler ():
1011 """Handle Websocket connection"""
1112 def __init__ (self ):
1213 self .__ws = None
13- default_fun = lambda x : print ("in default function" )
14+ default_fun = lambda x , * y : print ("in default function" )
1415 self .on_order = default_fun
1516 self .on_dealt = default_fun
1617 self .on_error = default_fun
@@ -33,9 +34,9 @@ def ws_on_error(self, _, error):
3334 """callback function for websocket error"""
3435 self .on_error (error )
3536
36- def ws_on_close (self , _ , error ):
37+ def ws_on_close (self , ws , close_status_code , close_msg ):
3738 """callback function for websocket close"""
38- self .on_close (error )
39+ self .on_close (ws , close_status_code , close_msg )
3940
4041 def set_callback (self , name , func ):
4142 """for upper scope to set different types of callback function"""
@@ -45,10 +46,10 @@ def set_callback(self, name, func):
4546 else :
4647 raise Exception ("callback " + name + " not allowed" )
4748
48- def connect_websocket (self , urlEntry ):
49+ def connect_websocket (self , url_entry ):
4950 """start to connect websocket"""
5051 self .__ws = WebSocketApp (
51- urlEntry ,
52+ url_entry ,
5253 on_message = self .ws_on_message ,
5354 on_error = self .ws_on_error ,
5455 on_close = self .ws_on_close
0 commit comments