|
17 | 17 | import sys |
18 | 18 | import traceback |
19 | 19 |
|
20 | | -from ovos_utils.fakebus import Message |
21 | | -from ovos_utils.log import LOG |
| 20 | +from ovos_bus_client.message import Message |
| 21 | +from ovos_bus_client.session import SessionManager |
22 | 22 | from ovos_config import Configuration |
| 23 | +from ovos_utils.log import LOG |
23 | 24 | from pyee import EventEmitter |
24 | 25 | from tornado.websocket import WebSocketHandler |
25 | | -from ovos_bus_client.session import SessionManager |
26 | 26 |
|
27 | 27 | client_connections = [] |
28 | 28 |
|
@@ -63,13 +63,12 @@ def on_message(self, message): |
63 | 63 |
|
64 | 64 | if deserialized_message.msg_type not in self.filter_logs: |
65 | 65 | LOG.debug(deserialized_message.msg_type + |
66 | | - f' source: {deserialized_message.context.get("source", [])}' + |
67 | | - f' destination: {deserialized_message.context.get("destination", [])}\n' |
68 | | - f'SESSION: {SessionManager.get(deserialized_message).serialize()}') |
| 66 | + f' source: {deserialized_message.context.get("source", [])}' + |
| 67 | + f' destination: {deserialized_message.context.get("destination", [])}\n' |
| 68 | + f'SESSION: {SessionManager.get(deserialized_message).serialize()}') |
69 | 69 |
|
70 | 70 | try: |
71 | | - self.emitter.emit(deserialized_message.msg_type, |
72 | | - deserialized_message) |
| 71 | + self.emitter.emit(deserialized_message.msg_type, deserialized_message) |
73 | 72 | except Exception as e: |
74 | 73 | LOG.exception(e) |
75 | 74 | traceback.print_exc(file=sys.stdout) |
|
0 commit comments