Add configurable debounce time (v2.0)

README.md

@@ -49,6 +49,7 @@ The easiest way to configure this plugin is via [Homebridge Config UI X](https:/
     ],
     "watchGuests": true,                           // Optional. Set false to not monitor guest networks.
     "interval": 1800,                              // Optional. Polling interval used to query Unifi in seconds 
+    "debounceTime": 10000,                         // Optional. Discard changes to occupancy that occur within the threshold in seconds
     "mode": "any"                                  // Optional. Set to "any", "all" or "none".
   }
 ]

index.js

@@ -1,6 +1,9 @@
 'use strict';
 
-const UnifiEvents = require('unifi-events')
+const events = require('events');
+const Rx = require('rxjs');
+const RxOp = require('rxjs/operators');
+const UnifiEvents = require('unifi-events');
 const manifest = require('./package.json');
 const url = require('url');
 
@@ -57,6 +60,15 @@ class OccupancySensor {
       return this.checkOccupancy()
     });
 
+    this.emitter = new events.EventEmitter();
+    this.observable = Rx.fromEvent(this.emitter, 'data');
+    this.observable
+      .pipe(
+        RxOp.debounceTime((config.debounceTime || 0) * 1000),
+        RxOp.distinctUntilChanged()
+      ).subscribe(value => {
+        this.setOccupancyDetected(value);
+      });
     this.occupancyDetected = Characteristic.OccupancyDetected.OCCUPANCY_NOT_DETECTED;
     this.checkOccupancy();
     setInterval(this.checkOccupancy.bind(this), this.interval * 1000)
@@ -126,7 +138,7 @@ class OccupancySensor {
         }
       }
 
-      this.setOccupancyDetected(this.occupancyDetected)
+      this.emitter.emit('data', this.occupancyDetected);
     })
     .catch((err) => {
       this.log(`ERROR: Failed to check occupancy: ${err.message}`)
@@ -138,6 +150,7 @@ class OccupancySensor {
   }
 
   setOccupancyDetected(value) {
+    this.log(`Setting OccupancyDetected to ${value}`);
     return this.occupancyService.setCharacteristic(Characteristic.OccupancyDetected, value)
   }
 

package.json

@@ -27,6 +27,8 @@
     }
   ],
   "dependencies": {
+    "rxjs": "^6.6.3",
+    "rxjs-compat": "^6.6.3",
     "unifi-events": "^2.0.0"
   }
 }