2018-10-02 12:15:12 -07:00
|
|
|
const utils = require('../util/utils');
|
|
|
|
const interval = utils.secondsToMilliseconds(60);
|
|
|
|
|
|
|
|
/**
|
|
|
|
* This extensions polls Xiaomi Zigbee routers to keep them awake.
|
|
|
|
*/
|
|
|
|
class RouterPollXiaomi {
|
2018-11-16 12:23:11 -07:00
|
|
|
constructor(zigbee, mqtt, state, publishDeviceState) {
|
2018-10-02 12:15:12 -07:00
|
|
|
this.zigbee = zigbee;
|
|
|
|
this.timer = null;
|
2018-11-16 12:23:11 -07:00
|
|
|
}
|
2018-10-02 12:15:12 -07:00
|
|
|
|
2018-11-16 12:23:11 -07:00
|
|
|
onZigbeeStarted() {
|
2018-10-02 12:15:12 -07:00
|
|
|
this.startTimer();
|
|
|
|
}
|
|
|
|
|
|
|
|
startTimer() {
|
|
|
|
this.clearTimer();
|
|
|
|
this.timer = setInterval(() => this.handleInterval(), interval);
|
|
|
|
}
|
|
|
|
|
|
|
|
clearTimer() {
|
|
|
|
if (this.timer) {
|
|
|
|
clearTimeout(this.timer);
|
|
|
|
this.timer = null;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
stop() {
|
|
|
|
this.clearTimer();
|
|
|
|
}
|
|
|
|
|
|
|
|
handleInterval() {
|
|
|
|
this.zigbee.getAllClients()
|
|
|
|
.filter((d) => utils.isXiaomiDevice(d)) // Filter Xiaomi devices
|
|
|
|
.filter((d) => d.type === 'Router') // Filter routers
|
|
|
|
.filter((d) => d.powerSource && d.powerSource !== 'Battery') // Remove battery powered devices
|
|
|
|
.forEach((d) => this.zigbee.ping(d.ieeeAddr)); // Ping devices.
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
module.exports = RouterPollXiaomi;
|