{'const': 'connection configured'}}))
sends.append(MessageTemplate({'event':
{'const': 'connection closed'}}))
- self._down_filter = []
for template in self.conf['down filter']:
sends.append(MessageTemplate(template))
- trans_template = translate_template(template,
- self._client, self.name)
- self._down_filter.append(MessageTemplate(trans_template))
receives = []
- self._up_filter = []
for template in self.conf['up filter']:
receives.append(MessageTemplate(template))
- trans_template = translate_template(template,
- self._client, self.name)
- self._up_filter.append(MessageTemplate(trans_template))
self.bus.register(self.name, 'WSClient', sends,
[(receives, self._receive)])
self._client = f"{address}:{port}"
if 'interface' in self.conf:
conf_command['mac'] = self._mac
- conf_command['up filter'] = self._up_filter
- conf_command['down filter'] = self._down_filter
+ up_filter = []
+ for template in self.conf['up filter']:
+ template = translate_template(template,
+ self._client, self.name)
+ up_filter.append(MessageTemplate(template))
+ down_filter = []
+ for template in self.conf['down filter']:
+ template = translate_template(template,
+ self._client, self.name)
+ down_filter.append(MessageTemplate(template))
+ conf_command['up filter'] = up_filter
+ conf_command['down filter'] = down_filter
json_command = json.dumps(conf_command)
await websocket.send(json_command)
print(f"WSClient '{self.name}': Connection configured"