Bugfix: Bus registration over-indented.
authorBenjamin Braatz <bb@bbraatz.eu>
Thu, 29 Jul 2021 07:05:38 +0000 (09:05 +0200)
committerBenjamin Braatz <bb@bbraatz.eu>
Thu, 29 Jul 2021 07:05:38 +0000 (09:05 +0200)
controlpi_plugins/wsclient.py

index 6e21239e6dfcf64338f77567b3325212515bb09f..b56f1c02010a2399b14125bceade1f798c3b50fd 100644 (file)
@@ -136,20 +136,20 @@ class WSClient(BasePlugin):
                                            bytes(self.conf['interface'],
                                                  'utf-8')[:15]))
             self._mac = ':'.join('%02x' % b for b in info[18:24])
-            sends = []
-            sends.append(MessageTemplate({'event':
-                                         {'const': 'registered'}}))
-            sends.append(MessageTemplate({'event':
-                                         {'const': 'connection opened'}}))
-            sends.append(MessageTemplate({'event':
-                                         {'const': 'connection closed'}}))
-            for template in self.conf['down filter']:
-                sends.append(MessageTemplate(template))
-            receives = []
-            for template in self.conf['up filter']:
-                receives.append(MessageTemplate(template))
-            self.bus.register(self.name, 'WSClient', sends, receives,
-                              self._receive)
+        sends = []
+        sends.append(MessageTemplate({'event':
+                                     {'const': 'registered'}}))
+        sends.append(MessageTemplate({'event':
+                                     {'const': 'connection opened'}}))
+        sends.append(MessageTemplate({'event':
+                                     {'const': 'connection closed'}}))
+        for template in self.conf['down filter']:
+            sends.append(MessageTemplate(template))
+        receives = []
+        for template in self.conf['up filter']:
+            receives.append(MessageTemplate(template))
+        self.bus.register(self.name, 'WSClient', sends, receives,
+                          self._receive)
 
     async def run(self) -> None:
         """Connect to wsserver and process messages from it."""