From f54c6cfc1eeb663af8d2ec2529b673349bbaef07 Mon Sep 17 00:00:00 2001 From: Benjamin Braatz Date: Tue, 14 Dec 2021 23:05:19 +0100 Subject: [PATCH] Use new-style register. --- controlpi_plugins/wsserver.py | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/controlpi_plugins/wsserver.py b/controlpi_plugins/wsserver.py index 6e5db0a..0fd434e 100644 --- a/controlpi_plugins/wsserver.py +++ b/controlpi_plugins/wsserver.py @@ -35,8 +35,9 @@ class Connection: self._port = address[1] self._name = f"{self._address}:{self._port}" self._bus.register(self._name, 'WSServer', - [MessageTemplate()], [MessageTemplate()], - self._receive) + [MessageTemplate()], + [([MessageTemplate()], + self._receive)]) async def _receive(self, message: Message) -> None: """Receive messages from bus and relay to websocket.""" @@ -76,13 +77,13 @@ class Connection: sends.append(template) try: self._bus.register(self._name, 'WSServer', sends, - message['down filter'], - self._receive) + [(message['down filter'], + self._receive)]) except BusException: self._bus.unregister(self._name) self._bus.register(self._name, 'WSServer', sends, - message['down filter'], - self._receive) + [(message['down filter'], + self._receive)]) open_message = Message(self._name) open_message['event'] = 'connection opened' open_message['address'] = self._address -- 2.34.1