{'event':
'connection closed'}))
self._bus.unregister(self._name)
- self._name = message['name']
+ if 'name' in message:
+ self._name = message['name']
sends = []
sends.append(MessageTemplate({'event':
{'const':
sends.append(template)
self._bus.register(self._name, 'WSServer', sends,
message['down filter'], self._receive)
- await self._bus.send(Message(self._name,
- {'event':
- 'connection opened',
- 'address': self._address,
- 'port': self._port,
- 'mac': message['mac']}))
+ open_message = Message(self._name)
+ open_message['event'] = 'connection opened'
+ open_message['address'] = self._address
+ open_message['port'] = self._port
+ if 'mac' in message:
+ open_message['mac'] = message['mac']
+ await self._bus.send(open_message)
else:
await self._bus.send(Message(self._name, message))
except ConnectionClosed: