Also check if streaming on heartbeat

Author: 715209

lib/components/ObsSwitcher.js

@@ -99,9 +99,7 @@ function (_EventEmitter) {
 
     _this.obs.on("StreamStarted", _this.streamStarted.bind(_assertThisInitialized(_assertThisInitialized(_this))));
 
-    _this.obs.on("Heartbeat", function (heartbeat) {
-      return _this.heartbeat = heartbeat;
-    });
+    _this.obs.on("Heartbeat", _this.handleHeartbeat.bind(_assertThisInitialized(_assertThisInitialized(_this))));
 
     _this.obs.on("ScenesChanged", _this.scenesChanged.bind(_assertThisInitialized(_assertThisInitialized(_this))));
 
@@ -330,6 +328,12 @@ function (_EventEmitter) {
     value: function scenesChanged() {
       this.getSceneList();
     }
+  }, {
+    key: "handleHeartbeat",
+    value: function handleHeartbeat(heartbeat) {
+      this.heartbeat = heartbeat;
+      this.obsStreaming = heartbeat.streaming;
+    }
   }]);
 
   return ObsSwitcher;

src/components/ObsSwitcher.js

@@ -46,7 +46,7 @@ class ObsSwitcher extends EventEmitter {
         this.obs.on("StreamStatus", this.setStreamStatus.bind(this));
         this.obs.on("StreamStopped", this.streamStopped.bind(this));
         this.obs.on("StreamStarted", this.streamStarted.bind(this));
-        this.obs.on("Heartbeat", heartbeat => (this.heartbeat = heartbeat));
+        this.obs.on("Heartbeat", this.handleHeartbeat.bind(this));
         this.obs.on("ScenesChanged", this.scenesChanged.bind(this));
 
         log.info("Connecting & authenticating");
@@ -193,6 +193,11 @@ class ObsSwitcher extends EventEmitter {
     scenesChanged() {
         this.getSceneList();
     }
+
+    handleHeartbeat(heartbeat) {
+        this.heartbeat = heartbeat;
+        this.obsStreaming = heartbeat.streaming;
+    }
 }
 
 export default ObsSwitcher;