dandri/zigbee2mqtt
1
0
Fork 0
mirror of https://github.com/Koenkk/zigbee2mqtt.git synced 2026-07-10 05:51:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

settingUp -> queue. https://github.com/Koenkk/zigbee2mqtt/commit/eab988640281d60deef827a2692a2f0a01578a3f#r38455677

Browse Source
This commit is contained in:
Koen Kanters
2020-04-13 11:28:19 +02:00
parent 22126a3e5d
commit 121eaf3dcb
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/extension/report.js
+4 -4
View File
@@ -103,7 +103,7 @@ const pollOnMessage = [
class Report extends Extension {
constructor(zigbee, mqtt, state, publishEntityState, eventBus) {
super(zigbee, mqtt, state, publishEntityState, eventBus);
this.settingUp = new Set();
this.queue = new Set();
this.failed = new Set();
this.pollDebouncers = {};
}
@@ -121,8 +121,8 @@ class Report extends Extension {
async setupReporting(resolvedEntity) {
const {device, definition} = resolvedEntity;
if (this.settingUp.has(device.ieeeAddr) || this.failed.has(device.ieeeAddr)) return;
this.settingUp.add(device.ieeeAddr);
if (this.queue.has(device.ieeeAddr) || this.failed.has(device.ieeeAddr)) return;
this.queue.add(device.ieeeAddr);
try {
for (const ep of device.endpoints) {
@@ -158,7 +158,7 @@ class Report extends Extension {
}
device.save();
this.settingUp.delete(device.ieeeAddr);
this.queue.delete(device.ieeeAddr);
}
shouldSetupReporting(resolvedEntity, messageType) {