clear eventHistory + removed console.log

Author: murliwatz

frontend/src/routes.js

@@ -886,7 +886,7 @@ const wssUpgrade = (req, socket, head) => {
   const wss1 = new WebSocketServer({ noServer: true })
   wss1.on('connection', async (ws) => {
     stream.events.on('data', async (data) => {
-      if (data.err) console.log(data)
+      if (data.err) debug(data)
       data.streamDuration = ((new Date() - stream.dateTimeStart) / 1000).toFixed(3)
       ws.send(JSON.stringify(data))
     })

frontend/src/stt/awstranscribe.js

@@ -78,7 +78,7 @@ class AwsTranscribeSTT {
     applyIfExists(request, req, 'req.body.awstranscribe.config.streaming')
 
     const events = new EventEmitter()
-    const eventHistory = []
+    let eventHistory = []
     try {
       const cmdResponse = await transcribeClient.send(new StartStreamTranscriptionCommand(request))
       setTimeout(async () => {
@@ -132,6 +132,7 @@ class AwsTranscribeSTT {
           audioInputStream.destroy()
         }
         audioInputStream = null
+        eventHistory = null
       },
       triggerHistoryEmit: () => {
         for (const eh of eventHistory) {

frontend/src/stt/azure.js

@@ -52,7 +52,7 @@ class AzureSTT {
     const recognizer = new SpeechRecognizer(speechConfig, audioConfig)
 
     const events = new EventEmitter()
-    const eventHistory = []
+    let eventHistory = []
 
     const recognizedHandler = (s, e) => {
       if (e.result.reason === ResultReason.RecognizedSpeech || e.result.reason === ResultReason.RecognizingSpeech) {
@@ -74,7 +74,6 @@ class AzureSTT {
       recognizer.stopContinuousRecognitionAsync()
     }
     recognizer.canceled = (s, e) => {
-      console.log(e.errorDetails)
       const event = {
         status: 'error',
         err: `Azure STT failed: ${getAzureErrorDetails(e)}`
@@ -95,6 +94,7 @@ class AzureSTT {
         close: () => {
           recognizer.stopContinuousRecognitionAsync()
           pushStream.close()
+          eventHistory = null
         },
         triggerHistoryEmit: () => {
           for (const eh of eventHistory) {

frontend/src/stt/google.js

@@ -73,7 +73,7 @@ class GoogleSTT {
     const bufferStream = new PassThrough()
     bufferStream.pipe(recognizeStream)
     const events = new EventEmitter()
-    const eventHistory = []
+    let eventHistory = []
 
     recognizeStream.on('data', (data) => {
       const alternative = data.results[0] && data.results[0].alternatives[0]
@@ -118,6 +118,7 @@ class GoogleSTT {
         if (recognizeStream) {
           recognizeStream.destroy()
         }
+        eventHistory = null
         recognizeStream = null
       },
       triggerHistoryEmit: () => {

frontend/src/stt/ibm.js

@@ -42,7 +42,7 @@ class IbmSTT {
     const bufferStream = new PassThrough()
     bufferStream.pipe(recognizeStream)
     const events = new EventEmitter()
-    const eventHistory = []
+    let eventHistory = []
 
     recognizeStream.on('data', (data) => {
       for (const result of data.results || []) {
@@ -91,6 +91,7 @@ class IbmSTT {
           recognizeStream.destroy()
         }
         recognizeStream = null
+        eventHistory = null
       },
       triggerHistoryEmit: () => {
         for (const eh of eventHistory) {

frontend/src/stt/kaldi.js

@@ -42,7 +42,7 @@ class KaldiSTT {
 
       const ws = new WebSocket(wsUri)
       const events = new EventEmitter()
-      const eventHistory = []
+      let eventHistory = []
 
       ws.on('open', () => {
         ws.on('message', (data) => {
@@ -95,6 +95,7 @@ class KaldiSTT {
             if (ws) {
               ws.close()
             }
+            eventHistory = null
           },
           triggerHistoryEmit: () => {
             for (const eh of eventHistory) {