summaryrefslogtreecommitdiffstats
path: root/module/remote/wsbackend/EventHandler.py
diff options
context:
space:
mode:
Diffstat (limited to 'module/remote/wsbackend/EventHandler.py')
-rw-r--r--module/remote/wsbackend/EventHandler.py32
1 files changed, 16 insertions, 16 deletions
diff --git a/module/remote/wsbackend/EventHandler.py b/module/remote/wsbackend/EventHandler.py
index deab25a6c..2550ff2eb 100644
--- a/module/remote/wsbackend/EventHandler.py
+++ b/module/remote/wsbackend/EventHandler.py
@@ -16,26 +16,26 @@
# @author: RaNaN
###############################################################################
-from mod_pywebsocket.msgutil import receive_message, send_message
+from threading import Lock
-class EventHandler:
- def __init__(self, api):
- self.api = api
+from module.utils import lock
+from AbstractHandler import AbstractHandler
- def do_extra_handshake(self, req):
- pass
+class EventHandler(AbstractHandler):
- def transfer_data(self, req):
+ def __init__(self, api):
+ AbstractHandler.__init__(self, api)
+ self.clients = []
+ self.lock = Lock()
- while True:
- try:
- line = receive_message(req)
- except TypeError: # connection closed
- return
+ @lock
+ def on_open(self, req):
+ self.clients.append(req)
- print "Got", line
- send_message(req, "You send: %s" % line)
+ @lock
+ def on_close(self, req):
+ self.clients.remove(req)
- def passive_closing_handshake(self, req):
- print "Closed", req \ No newline at end of file
+ def handle_message(self, line, req):
+ pass \ No newline at end of file