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."""