diff --git a/lib/extension/deviceReceive.js b/lib/extension/deviceReceive.js index 95f670b0b..64817aa4b 100644 --- a/lib/extension/deviceReceive.js +++ b/lib/extension/deviceReceive.js @@ -12,6 +12,11 @@ class DeviceReceive { this.mqtt = mqtt; this.state = state; this.publishDeviceState = publishDeviceState; + this.coordinator = null; + } + + onZigbeeStarted() { + this.coordinator = this.zigbee.getCoordinator().device.ieeeAddr; } onZigbeeMessage(message, device, mappedDevice) { @@ -34,6 +39,11 @@ class DeviceReceive { return; } + if (device.ieeeAddr === this.coordinator) { + logger.debug('Ignoring message from coordinator'); + return; + } + // Check if this is a new device. if (!settings.getDevice(device.ieeeAddr)) { logger.info(`New device with address ${device.ieeeAddr} connected!`);