Added mute option for STT streaming

Author: chughts

README.md

@@ -7,6 +7,9 @@ Node-RED Watson Nodes for IBM Cloud
 
 <a href="https://cla-assistant.io/watson-developer-cloud/node-red-node-watson"><img src="https://cla-assistant.io/readme/badge/watson-developer-cloud/node-red-node-watson" alt="CLA assistant" /></a>
 
+### New in version 0.6.6
+- Mute option for STT Node warning status when running in Streaming mode
+
 ### New in version 0.6.5
 - Endpoint can now be specified in Natural Language Classifier Node
 

package.json

@@ -1,6 +1,6 @@
 {
   "name": "node-red-node-watson",
-  "version": "0.6.5",
+  "version": "0.6.6",
   "description": "A collection of Node-RED nodes for IBM Watson services",
   "dependencies": {
     "async": "^1.5.2",

services/speech_to_text/v1.html

@@ -88,6 +88,12 @@
         <label for="node-input-streaming-mode" style="width: 70%;"> Streaming Mode</label>
     </div>
 
+    <div class="form-row">
+        <label>&nbsp;</label>
+        <input type="checkbox" id="node-input-streaming-mute" style="display: inline-block; width: auto; vertical-align: top;">
+        <label for="node-input-streaming-mute" style="width: 70%;"> Mute in Streaming Mode</label>
+    </div>
+
     <div class="form-row">
         <label>&nbsp;</label>
         <input type="checkbox" id="node-input-speakerlabels"style="display: inline-block; width: auto; vertical-align: top;"></input>
@@ -148,6 +154,7 @@
     is as per the WebSocket input for Speech To Text, with an action of either
     <code>start</code> or <code>stop</code> or an audio blob. No token is needed
     as the node takes care of that step.</p>
+    <p>>The Mute option allows for the supression of session timeout messages.</p>
     <p>For more information about the Speech To Text service, read the <a href="https://www.ibm.com/watson/services/speech-to-text/">documentation</a>.</p>
 </script>
 
@@ -542,6 +549,7 @@
                 password: {value: ''},
                 'payload-response' :{value: false},
                 'streaming-mode' :{value: false},
+                'streaming-mute' :{value: true},
                 'default-endpoint' :{value: true},
                 'service-endpoint' :{value: 'https://stream.watsonplatform.net/speech-to-text/api'}
             },

services/speech_to_text/v1.js

@@ -28,6 +28,7 @@ module.exports = function (RED) {
     payloadutils = require('../../utilities/payload-utils'),
     sttV1 = require('watson-developer-cloud/speech-to-text/v1'),
     authV1 = require('watson-developer-cloud/authorization/v1'),
+    muteMode = true;
     username = '', password = '', sUsername = '', sPassword = '',
     endpoint = '',
     sEndpoint = 'https://stream.watsonplatform.net/speech-to-text/api',
@@ -133,6 +134,8 @@ module.exports = function (RED) {
     function configCheck() {
       var message = '';
 
+      muteMode = config['streaming-mute'];
+
       if (!config.lang) {
         message = 'Missing audio language configuration, unable to process speech.';
       } else if (!config.band) {
@@ -397,7 +400,10 @@ module.exports = function (RED) {
                 // Force Expiry of Token, as that is the only Error
                 // response from the service that we have seen.
                 // report the error for verbose testing
-                payloadutils.reportError(node,newMsg,d.error);
+                if (!muteMode) {
+                  payloadutils.reportError(node,newMsg,d.error);
+                }
+
                 token = null;
                 getToken(determineService())
                   .then(() => {
@@ -423,7 +429,9 @@ module.exports = function (RED) {
 
           ws.on('error', (err) => {
             socketListening = false;
-            payloadutils.reportError(node,newMsg,err);
+            if (!muteMode) {
+              payloadutils.reportError(node,newMsg,err);
+            }
             // console.log('Error Detected');
             if (initialConnect) {
               //reject(err);
@@ -472,8 +480,9 @@ module.exports = function (RED) {
             //websocket.send(a.data);
             websocket.send(a.data, (error) => {
               if (error) {
-                payloadutils.reportError(node,{},error);
-              } else {
+                if (!muteMode) {
+                  payloadutils.reportError(node,{},error);
+                }
               }
             });
           }