diff --git a/lib/controller.js b/lib/controller.js index d25b42aab..99422387c 100644 --- a/lib/controller.js +++ b/lib/controller.js @@ -200,6 +200,7 @@ class Controller { if (!settings.getDevice(device.ieeeAddr)) { logger.info(`New device with address ${device.ieeeAddr} connected!`); settings.addDevice(device.ieeeAddr); + this.mqttLog('device_connected', device.ieeeAddr); } // We can't handle devices without modelId. @@ -367,6 +368,11 @@ class Controller { this.mqtt.publish(deviceSettings.friendly_name, JSON.stringify(payload), options); } + + mqttLog(type, message) { + const payload = {type: type, message: message}; + this.mqtt.publish('bridge/log', JSON.stringify(payload), {retain: false}); + } } module.exports = Controller;