mrtoth/baseimage-tutorial-framework
1
0
Fork 0
mirror of https://github.com/avatao-content/baseimage-tutorial-framework synced 2024-11-23 00:21:32 +00:00
Code Issues Releases Wiki Activity

Merge pull request #12 from avatao-content/multi_websockets

Browse Source 
Implement support for multiple websockets connecting to TFW
This commit is contained in:
Bokros Bálint 2018-02-19 10:08:40 +01:00 committed by GitHub
commit 654ddacb74
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 11 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
lib/tfw/networking/server/zmq_websocket_handler.py
View File

@ -9,18 +9,24 @@ log = logging.getLogger(__name__)
class ZMQWebSocketHandler(WebSocketHandler):
_event_handler_connector = EventHandlerConnector()
instances = set()
def __init__(self, application, request, **kwargs):
super().__init__(application, request, **kwargs)
def prepare(self):
ZMQWebSocketHandler.instances.add(self)
def on_close(self):
ZMQWebSocketHandler.instances.remove(self)
def open(self, *args, **kwargs):
log.debug('WebSocket connection initiated')
self._event_handler_connector.register_callback(self.zmq_callback)
def zmq_callback(self, msg_parts):
@staticmethod
def zmq_callback(msg_parts):
anchor, data = deserialize_all(*msg_parts)
log.debug('Received on pull socket: {}'.format(data))
self.write_message(data)
for instance in ZMQWebSocketHandler.instances:
instance.write_message(data)
def on_message(self, message):
log.debug('Received on WebSocket: {}'.format(message))
@ -40,6 +46,7 @@ class FSMManagingSocketHandler(ZMQWebSocketHandler):
self.fsm.subscribe_message_handler(self.handle_fsm_message)
def on_close(self):
super().on_close()
self.fsm.unsubscribe_message_handler(self.handle_fsm_message)
def handle_fsm_message(self, message):