Don't send scene switched messages in chat when not streaming from OBS

Author: 715209

lib/components/ObsSwitcher.js

@@ -72,6 +72,7 @@ function (_EventEmitter) {
     _this.bitrate = null;
     _this.nginxVideoMeta = null;
     _this.streamStatus = null;
+    _this.obsStreaming = false;
     _this.currentScene = null;
 
     _this.obs.connect({
@@ -90,6 +91,10 @@ function (_EventEmitter) {
 
     _this.obs.on("StreamStatus", _this.setStreamStatus.bind(_assertThisInitialized(_assertThisInitialized(_this))));
 
+    _this.obs.on("StreamStopped", _this.streamStopped.bind(_assertThisInitialized(_assertThisInitialized(_this))));
+
+    _this.obs.on("StreamStarted", _this.streamStarted.bind(_assertThisInitialized(_assertThisInitialized(_this))));
+
     log.info("Connecting & authenticating");
     return _this;
   }
@@ -127,16 +132,16 @@ function (_EventEmitter) {
                   _this2.isLive = true;
                   _this2.isLive && canSwitch && (bitrate === 0 && currentScene.name !== _this2.lowBitrateScene && (_this2.obs.setCurrentScene({
                     "scene-name": _this2.lowBitrateScene
-                  }), _config.default.twitchChat.enableAutoSwitchNotification && _this2.emit("live"), log.info("Stream went online switching to scene: \"".concat(_this2.lowBitrateScene, "\""))), bitrate <= _this2.lowBitrateTrigger && currentScene.name !== _this2.lowBitrateScene && bitrate !== 0 && (_this2.obs.setCurrentScene({
+                  }), _this2.switchSceneEmit("live"), log.info("Stream went online switching to scene: \"".concat(_this2.lowBitrateScene, "\""))), bitrate <= _this2.lowBitrateTrigger && currentScene.name !== _this2.lowBitrateScene && bitrate !== 0 && (_this2.obs.setCurrentScene({
                     "scene-name": _this2.lowBitrateScene
-                  }), _config.default.twitchChat.enableAutoSwitchNotification && _this2.emit("lowBitrateScene"), log.info("Low bitrate detected switching to scene: \"".concat(_this2.lowBitrateScene, "\""))), bitrate > _this2.lowBitrateTrigger && currentScene.name !== _this2.normalScene && (_this2.obs.setCurrentScene({
+                  }), _this2.switchSceneEmit("lowBitrateScene"), log.info("Low bitrate detected switching to scene: \"".concat(_this2.lowBitrateScene, "\""))), bitrate > _this2.lowBitrateTrigger && currentScene.name !== _this2.normalScene && (_this2.obs.setCurrentScene({
                     "scene-name": _this2.normalScene
-                  }), _config.default.twitchChat.enableAutoSwitchNotification && _this2.emit("normalScene"), log.info("Switching to normal scene: \"".concat(_this2.normalScene, "\""))));
+                  }), _this2.switchSceneEmit("normalScene"), log.info("Switching to normal scene: \"".concat(_this2.normalScene, "\""))));
                 } else {
                   _this2.isLive = false;
                   canSwitch && currentScene.name !== _this2.offlineScene && (_this2.obs.setCurrentScene({
                     "scene-name": _this2.offlineScene
-                  }), _config.default.twitchChat.enableAutoSwitchNotification && _this2.emit("offlineScene"), _this2.streamStatus = null, log.warn("Error receiving current bitrate or stream is offline. Switching to offline scene: \"".concat(_this2.offlineScene, "\"")));
+                  }), _this2.switchSceneEmit("offlineScene"), _this2.streamStatus = null, log.warn("Error receiving current bitrate or stream is offline. Switching to offline scene: \"".concat(_this2.offlineScene, "\"")));
                 }
 
               case 9:
@@ -147,6 +152,13 @@ function (_EventEmitter) {
         }, _callee, this);
       })), _config.default.obs.requestMs);
     }
+  }, {
+    key: "switchSceneEmit",
+    value: function switchSceneEmit(sceneName) {
+      if (_config.default.twitchChat.enableAutoSwitchNotification && this.obsStreaming) {
+        this.emit(sceneName);
+      }
+    }
   }, {
     key: "getBitrate",
     value: function () {
@@ -250,6 +262,16 @@ function (_EventEmitter) {
         });
       }, 5000);
     }
+  }, {
+    key: "streamStopped",
+    value: function streamStopped() {
+      this.obsStreaming = false;
+    }
+  }, {
+    key: "streamStarted",
+    value: function streamStarted() {
+      this.obsStreaming = true;
+    }
   }]);
 
   return ObsSwitcher;

src/components/ObsSwitcher.js

@@ -28,6 +28,7 @@ class ObsSwitcher extends EventEmitter {
         this.bitrate = null;
         this.nginxVideoMeta = null;
         this.streamStatus = null;
+        this.obsStreaming = false;
         this.currentScene = null;
 
         this.obs.connect({ address: this.address, password: this.password }).catch(e => {
@@ -39,6 +40,8 @@ class ObsSwitcher extends EventEmitter {
         this.obs.on("AuthenticationFailure", this.onAuthFail.bind(this));
         this.obs.on("error", this.error.bind(this));
         this.obs.on("StreamStatus", this.setStreamStatus.bind(this));
+        this.obs.on("StreamStopped", this.streamStopped.bind(this));
+        this.obs.on("StreamStarted", this.streamStarted.bind(this));
 
         log.info("Connecting & authenticating");
     }
@@ -64,34 +67,40 @@ class ObsSwitcher extends EventEmitter {
                         (this.obs.setCurrentScene({
                             "scene-name": this.lowBitrateScene
                         }),
-                        config.twitchChat.enableAutoSwitchNotification && this.emit("live"),
+                        this.switchSceneEmit("live"),
                         log.info(`Stream went online switching to scene: "${this.lowBitrateScene}"`)),
                     bitrate <= this.lowBitrateTrigger &&
                         currentScene.name !== this.lowBitrateScene &&
                         bitrate !== 0 &&
                         (this.obs.setCurrentScene({
                             "scene-name": this.lowBitrateScene
                         }),
-                        config.twitchChat.enableAutoSwitchNotification && this.emit("lowBitrateScene"),
+                        this.switchSceneEmit("lowBitrateScene"),
                         log.info(`Low bitrate detected switching to scene: "${this.lowBitrateScene}"`)),
                     bitrate > this.lowBitrateTrigger &&
                         currentScene.name !== this.normalScene &&
                         (this.obs.setCurrentScene({ "scene-name": this.normalScene }),
-                        config.twitchChat.enableAutoSwitchNotification && this.emit("normalScene"),
+                        this.switchSceneEmit("normalScene"),
                         log.info(`Switching to normal scene: "${this.normalScene}"`)));
             } else {
                 this.isLive = false;
 
                 canSwitch &&
                     currentScene.name !== this.offlineScene &&
                     (this.obs.setCurrentScene({ "scene-name": this.offlineScene }),
-                    config.twitchChat.enableAutoSwitchNotification && this.emit("offlineScene"),
+                    this.switchSceneEmit("offlineScene"),
                     (this.streamStatus = null),
                     log.warn(`Error receiving current bitrate or stream is offline. Switching to offline scene: "${this.offlineScene}"`));
             }
         }, config.obs.requestMs);
     }
 
+    switchSceneEmit(sceneName) {
+        if (config.twitchChat.enableAutoSwitchNotification && this.obsStreaming) {
+            this.emit(sceneName);
+        }
+    }
+
     async getBitrate(username = "live") {
         try {
             const response = await fetch(`http://${config.nginx.ip}/stat`);
@@ -145,6 +154,14 @@ class ObsSwitcher extends EventEmitter {
             });
         }, 5000);
     }
+
+    streamStopped() {
+        this.obsStreaming = false;
+    }
+
+    streamStarted() {
+        this.obsStreaming = true;
+    }
 }
 
 export default ObsSwitcher;