Convert index.js to TypeScript

.eslintrc

@@ -7,4 +7,4 @@
   "rules": {
     "no-console": 0
   }
-}
+}

.gitignore

@@ -1,3 +1,9 @@
+# Distribution directory
+dist/
+
+# Typescript typings files
+typings/
+
 # Logs
 logs
 *.log

examples/annyang-example.js

@@ -1,7 +1,7 @@
 'use strict'
 
 const ROOT_DIR = __dirname + '/../'
-const Sonus = require(ROOT_DIR + 'index.js')
+const Sonus = require(ROOT_DIR + 'dist/src/sonus.js')
 const speech = require('@google-cloud/speech')({
   projectId: 'streaming-speech-sample',
   keyFilename: ROOT_DIR + 'keyfile.json'
@@ -23,16 +23,16 @@ const commands = {
   }
 }
 
-Sonus.annyang.addCommands(commands)
+sonus.annyang.addCommands(commands)
 
-Sonus.start(sonus)
+sonus.start();
 console.log('Say "' + hotwords[0].hotword + '"...')
 sonus.on('hotword', (index, keyword) => console.log("!" + keyword))
 sonus.on('partial-result', result => console.log("Partial", result))
 
 sonus.on('final-result', result => {
   console.log("Final", result)
   if (result.includes("stop")) {
-    Sonus.stop()
+    sonus.stop()
   }
 })

examples/example.js

@@ -1,7 +1,7 @@
 'use strict'
 
 const ROOT_DIR = __dirname + '/../'
-const Sonus = require(ROOT_DIR + 'index.js')
+const Sonus = require(ROOT_DIR + 'dist/src/sonus.js')
 const speech = require('@google-cloud/speech')({
   projectId: 'streaming-speech-sample',
   keyFilename: ROOT_DIR + 'keyfile.json'
@@ -13,7 +13,7 @@ const language = "en-US"
 //recordProgram can also be 'arecord' which works much better on the Pi and low power devices
 const sonus = Sonus.init({ hotwords, language, recordProgram: "rec" }, speech)
 
-Sonus.start(sonus)
+sonus.start();
 console.log('Say "' + hotwords[0].hotword + '"...')
 
 sonus.on('hotword', (index, keyword) => console.log("!" + keyword))
@@ -23,6 +23,6 @@ sonus.on('partial-result', result => console.log("Partial", result))
 sonus.on('final-result', result => {
   console.log("Final", result)
   if (result.includes("stop")) {
-    Sonus.stop()
+    sonus.stop()
   }
 })

examples/trigger-example.js

@@ -1,7 +1,7 @@
 'use strict'
 
 const ROOT_DIR = __dirname + '/../'
-const Sonus = require(ROOT_DIR + 'index.js')
+const Sonus = require(ROOT_DIR + 'dist/src/sonus.js')
 const speech = require('@google-cloud/speech')({
   projectId: 'streaming-speech-sample',
   keyFilename: ROOT_DIR + 'keyfile.json'
@@ -12,12 +12,12 @@ const language = "en-US"
 const sonus = Sonus.init({ hotwords, language }, speech)
 
 try{
-  Sonus.trigger(sonus, 1)
+  sonus.trigger(1)
 } catch (e) {
   console.log('Triggering Sonus before starting it will throw the following exception:', e)
 }
 
-Sonus.start(sonus)
+sonus.start()
 
 sonus.on('hotword', (index, keyword) => console.log("!" + keyword))
 
@@ -28,15 +28,15 @@ sonus.on('error', (error) => console.log(error))
 sonus.on('final-result', result => {
   console.log("Final", result)
   if (result.includes("stop")) {
-    Sonus.stop()
+    sonus.stop()
   }
 })
 
 try{
-  Sonus.trigger(sonus, 2)
+  sonus.trigger(2)
 } catch (e) {
   console.log('Triggering Sonus with an invalid index will throw the following error:', e)
 }
 
 //Will use index 0 with a hotword of "triggered" and start streaming immedietly
-Sonus.trigger(sonus, 0, "some hotword")
+sonus.trigger(0, "some hotword")

lib/annyang-core.js

@@ -6,7 +6,6 @@
 //! https://www.TalAter.com/annyang/
 "use strict";
 
-let annyang;
 let commandsList = [];
 const callbacks = { start: [], error: [], end: [], result: [], resultMatch: [], resultNoMatch: [], errorNetwork: [], errorPermissionBlocked: [], errorPermissionDenied: [] };
 let recognition;
@@ -53,7 +52,7 @@ const logMessage = (text, extraParameters) => {
 
 const initIfNeeded = () => {
     if (!isInitialized()) {
-        annyang.init({}, false);
+        module.exports.annyang.init({}, false);
     }
 };
 
@@ -97,7 +96,7 @@ const parseResults = function (results) {
     invokeCallbacks(callbacks.resultNoMatch, results);
 };
 
-annyang = {
+module.exports.annyang = {
 
     init: (commands, resetCommands) => {
         if (resetCommands === undefined) {
@@ -202,5 +201,3 @@ annyang = {
         parseResults(sentences);
     }
 };
-
-module.exports = annyang

package.json

@@ -2,9 +2,12 @@
   "name": "sonus",
   "version": "0.1.7",
   "description": "Open source cross platform decentralized always-on speech recognition framework",
-  "main": "index.js",
+  "main": "dist/src/sonus.js",
   "scripts": {
-    "test": "eslint ."
+    "test": "eslint . && tslint -c tslint.json src/**/*.ts",
+    "build": "tsc",
+    "example": "npm run build && node examples/example.js",
+    "prepublish": "npm run build"
   },
   "repository": {
     "type": "git",
@@ -32,6 +35,9 @@
     "stream": "0.0.2"
   },
   "devDependencies": {
-    "eslint": "^3.7.0"
+    "eslint": "^3.7.0",
+    "ts-node": "^2.1.0",
+    "tslint": "^4.5.1",
+    "typescript": "^2.2.1"
   }
 }

src/cloud-speech-recognizer.ts

@@ -0,0 +1,50 @@
+import { Writable } from 'stream';
+
+export class CloudSpeechRecognizer {
+  private _listening: boolean;
+  private _recognizer: any;
+  private _stream: Writable;
+
+  constructor(recognizer) {
+    this._recognizer = recognizer;
+    this._stream = new Writable();
+    this._listening = false;
+  }
+
+  public startStreaming(options, audioStream) {
+    if (this._listening) {
+      return;
+    }
+
+    this._listening = true;
+
+    const recognitionStream = this._recognizer.createRecognizeStream({
+      config: {
+        encoding: 'LINEAR16',
+        sampleRate: 16000,
+        languageCode: options.language,
+        speechContext: options.speechContext || null
+      },
+      singleUtterance: true,
+      interimResults: true,
+      verbose: true
+    });
+
+    recognitionStream.on('error', err => this._stream.emit('error', err));
+    recognitionStream.on('data', data => {
+      if (data) {
+        this._stream.emit('data', data);
+        if (data.endpointerType === 'END_OF_UTTERANCE') {
+          this._listening = false;
+          audioStream.unpipe(recognitionStream);
+        }
+      }
+    });
+
+    audioStream.pipe(recognitionStream);
+  }
+
+  public on(event, handler) {
+    this._stream.on(event, handler);
+  }
+}