From: Benjamin Braatz <bb@bbraatz.eu>
Date: Tue, 14 Dec 2021 22:05:19 +0000 (+0100)
Subject: Use new-style register.
X-Git-Tag: v0.3.0~10
X-Git-Url: http://git.graph-it.com/?a=commitdiff_plain;h=f54c6cfc1eeb663af8d2ec2529b673349bbaef07;p=graphit%2Fcontrolpi-wsserver.git

Use new-style register.
---

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