Add emit for all messages to support heartbeat / keep alive and get uploadmedia events (#31)

* Clean-up

* Added emit for all messages

* Added emit for all messages

* Added loginAndLeepAlive forever

Co-authored-by: Geoff <[email protected]>

Author: mrbythatmuch

lib/Arlo.js

@@ -87,6 +87,20 @@ class Arlo extends EventEmitter {
             }.bind(this)
         );
     }
+   
+    keepAlive = true
+    async loginAndKeepAlive(user, password, callback, heartbeat = 30000) {
+        let msLastResponse = 0;
+        this.addListener(Constants.EVENT_MESSAGE, () =>
+         msLastResponse = new Date());
+        while (this.keepAlive) {
+            if (new Date() - msLastResponse > heartbeat)
+                this.login(user, password, callback);
+            else if (this.token)
+                this.getDevices();
+            await new Promise(resolve => setTimeout(resolve, heartbeat));
+        }
+    }
 
     subscribe(callback) {
         let reCamera = /cameras\/(.+)$/;
@@ -113,7 +127,7 @@ class Arlo extends EventEmitter {
                 }
 
                 data = msg.data;
-
+                this.emit(Constants.EVENT_MESSAGE,data);
                 switch (data.resource) {
                     case Constants.RESOURCE_CAMERAS:
                         for (let i = 0; i < msg.data.properties.length; i++) {
@@ -342,6 +356,7 @@ Arlo.CHARGING = Constants.EVENT_CHARGING;
 Arlo.FOUND    = Constants.EVENT_FOUND;
 Arlo.MOTION   = Constants.EVENT_MOTION;
 Arlo.UPDATE   = Constants.EVENT_UPDATE;
+Arlo.MESSAGE  = Constants.EVENT_MESSAGE;
 
 Arlo.FF_SNAPSHOT = Constants.FF_SNAPSHOT_AVAILABLE;
 

lib/ArloConstants.js

@@ -20,6 +20,7 @@ module.exports = {
     EVENT_FOUND            : 'found',
     EVENT_MOTION           : 'motionDetected',
     EVENT_UPDATE           : 'update',
+    EVENT_MESSAGE          : 'message',
 
     EVENT_LOGGED_IN        : 'logged_in',
     EVENT_GOT_DEVICES      : 'got_devices',