start or stop or an audio blob. No token is needed
as the node takes care of that step.
+ >The Mute option allows for the supression of session timeout messages.
+>The Discard Listening option allows for listening events from STT to be discarded.
For more information about the Speech To Text service, read the documentation.
@@ -186,41 +206,61 @@ return self.indexOf(value) === index; } + stt.showSelectedFields = function(fields) { + for (i = 0; i < fields.length; i++) { + $(fields[i]).parent().show(); + } + } + + stt.hideSelectedFields = function(fields) { + for (i = 0; i < fields.length; i++) { + $(fields[i]).parent().hide(); + } + } + + // Function to be used at the start, as don't want to expose any fields, unless the models are // available. The models can only be fetched if the credentials are available. stt.hideEverything = function () { if (!stt.models) { + var fields = []; $('#credentials-not-found').show(); - $('label#node-label-message').parent().hide(); - $('input#node-input-alternatives').parent().hide(); - $('input#node-input-speakerlabels').parent().hide(); - $('input#node-input-smartformatting').parent().hide(); - $('select#node-input-lang').parent().hide(); - $('select#node-input-band').parent().hide(); - $('select#node-input-langcustom').parent().hide(); + + fields.push('#node-label-message' + + ', #node-input-alternatives' + + ', #node-input-speakerlabels' + + ', #node-input-smartformatting' + + ', #node-input-lang' + + ', #node-input-band' + + ', #node-input-langcustom'); + stt.hideSelectedFields(fields); } } // Check if there is a model then can show the fields. // available. The models can only be fetched if the credentials are available. stt.VisibilityCheck = function () { + var showFields = []; + var hideFields = []; if (stt.models) { - $('label#node-label-message').parent().hide(); - $('input#node-input-alternatives').parent().show(); - $('input#node-input-speakerlabels').parent().show(); - $('input#node-input-smartformatting').parent().show(); - $('select#node-input-lang').parent().show(); - //$('select#node-input-langcustom').parent().show(); - $('select#node-input-band').parent().show(); + showFields.push('#node-input-alternatives' + + ', #node-input-speakerlabels' + + ', #node-input-smartformatting' + + ', #node-input-lang' + + ', #node-input-band'); + + hideFields.push('#node-label-message'); } else { - $('label#node-label-message').parent().hide(); - $('input#node-input-alternatives').parent().hide(); - $('input#node-input-speakerlabels').parent().hide(); - $('input#node-input-smartformatting').parent().hide(); - $('select#node-input-lang').parent().hide(); - $('select#node-input-langcustom').parent().hide(); - $('select#node-input-band').parent().hide(); + hideFields.push('#node-label-message' + + ', #node-input-alternatives' + + ', #node-input-speakerlabels' + + ', #node-input-smartformatting' + + ', #node-input-langcustom' + + ', #node-input-lang' + + ', #node-input-band'); } + stt.hideSelectedFields(hideFields); + stt.showSelectedFields(showFields); } @@ -365,6 +405,20 @@ } }); + $('#node-input-streaming-mode').change(function () { + var fields = []; + fields.push('#node-input-streaming-mute' + + ', #node-input-discard-listening' + + ', #node-input-auto-connect'); + + var checked = $('#node-input-streaming-mode').prop('checked') + if (checked) { + stt.showSelectedFields(fields); + } else { + stt.hideSelectedFields(fields); + } + }); + $('#node-input-flushcache').click(function () { stt.flushCache(); }); @@ -542,6 +596,8 @@ password: {value: ''}, 'payload-response' :{value: false}, 'streaming-mode' :{value: false}, + 'streaming-mute' :{value: true}, + 'discard-listening' :{value: false}, 'default-endpoint' :{value: true}, 'service-endpoint' :{value: 'https://stream.watsonplatform.net/speech-to-text/api'} }, diff --git a/services/speech_to_text/v1.js b/services/speech_to_text/v1.js index 94fbc3d4..27679353 100644 --- a/services/speech_to_text/v1.js +++ b/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, discardMode = false, autoConnect = true, username = '', password = '', sUsername = '', sPassword = '', endpoint = '', sEndpoint = 'https://stream.watsonplatform.net/speech-to-text/api', @@ -133,6 +134,10 @@ module.exports = function (RED) { function configCheck() { var message = ''; + muteMode = config['streaming-mute']; + discardMode = config['discard-listening']; + autoConnect = config['auto-connect']; + if (!config.lang) { message = 'Missing audio language configuration, unable to process speech.'; } else if (!config.band) { @@ -397,7 +402,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(() => { @@ -406,7 +414,9 @@ module.exports = function (RED) { } else if (d && d.state && 'listening' === d.state) { socketListening = true; // Added for verbose testing - node.send(newMsg); + if (!discardMode) { + node.send(newMsg); + } //resolve(); } else { node.send(newMsg); @@ -418,12 +428,20 @@ module.exports = function (RED) { websocket = null; socketListening = false; // console.log('STT Socket disconnected'); - setTimeout(connectIfNeeded, 1000); + if (!muteMode) { + var newMsg = {payload : 'STT Connection Close Event'}; + payloadutils.reportError(node,newMsg,'STT Socket Connection closed'); + } + if (autoConnect) { + setTimeout(connectIfNeeded, 1000); + } }); 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 +490,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); + } } }); }