From bd284e9e44649571642de0dad54acf28a9c8b69a Mon Sep 17 00:00:00 2001
From: Paoda <musukarekai@gmail.com>
Date: Tue, 4 Sep 2018 09:41:41 +0100
Subject: [PATCH] support for multiple languages

---
 app.js                 |  4 ++--
 google-cloud/Speech.js | 30 ++++++------------------------
 2 files changed, 8 insertions(+), 26 deletions(-)

diff --git a/app.js b/app.js
index 2d01d30..9bb9930 100644
--- a/app.js
+++ b/app.js
@@ -45,7 +45,7 @@ class WebSocketServer {
         }
       });
 
-      client.on('startRecognition', (lang) => {
+      client.on('startRecognition', (lang, target) => {
         if (this.google.speech) {
           this.google.speech.stopRecognition();
           this.google.speech = null;
@@ -53,7 +53,7 @@ class WebSocketServer {
 
         console.log("Speech Recognition Started");
         this.google.speech = new Speech()
-        this.google.speech.startRecognition(lang);
+        this.google.speech.startRecognition(lang, target);
       })
 
       client.on('stopRecognition', () => {
diff --git a/google-cloud/Speech.js b/google-cloud/Speech.js
index c83f14e..480f08d 100644
--- a/google-cloud/Speech.js
+++ b/google-cloud/Speech.js
@@ -34,10 +34,10 @@ class Speech {
 
   /**
    * Starts the Google API Stream
-   * @param {string} lang - Language Code e.g en-CA
+   * @param {string} lang - Language Code e.g en-CA for Canadian English
+   * @param {string} target - Language Code e.g. "en" for English
    */
-  startRecognition(lang) {
-    this.lang = lang;
+  startRecognition(lang, target) {
     this.enabled = true;
 
     const request = {
@@ -55,40 +55,22 @@ class Speech {
       .streamingRecognize(request)
       .on("error", console.error)
       .on("data", data => {
-        process.stdout.write(
-          data.results[0] && data.results[0].alternatives[0]
-            ? `Transcription: ${data.results[0].alternatives[0].transcript}\n`
-            : `\n\nReached transcription time limit, press Ctrl+C\n`
-        );
-        //client.emit("speechData", data);
 
         if (data.results[0].alternatives[0] !== undefined) {
           let text = data.results[0].alternatives[0].transcript;
 
-          translate.speech(text, "fr").then(translation => {
-            console.log("Translation: " + translation);
+          translate.speech(text, target).then(translation => {
+            console.log(`${lang}: ${text} | ${target}: ${translation} (${data.results[0].alternatives[0].confidence})`);
 
           }).catch(err => console.error(err));
 
-          // translate
-          //   .translate(text, target)
-          //   .then(results => {
-          //     const translation = results[0];
-          //     //client.emit("translateData", translation);
-
-          //     console.log(`Text: ${text}`);
-          //     console.log(`Translation: ${translation}`);
-          //   })
-          //   .catch(err => {
-          //     console.error("ERROR:", err);
-          //   });
         }
 
         // if end of utterance, let's restart stream
         // this is a small hack. After 65 seconds of silence, the stream will still throw an error for speech length limit
         if (data.results[0] && data.results[0].isFinal) {
           this.stopRecognition();
-          this.startRecognition(this.lang);
+          this.startRecognition(lang, target);
           // console.log('restarted stream serverside');
         }
       });