inital commit

.gitignore

@@ -0,0 +1,63 @@
+# Logs
+logs
+*.log
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+
+# Runtime data
+pids
+*.pid
+*.seed
+*.pid.lock
+
+# Directory for instrumented libs generated by jscoverage/JSCover
+lib-cov
+
+# Coverage directory used by tools like istanbul
+coverage
+
+# nyc test coverage
+.nyc_output
+
+# Grunt intermediate storage (http://gruntjs.com/creating-plugins#storing-task-files)
+.grunt
+
+# Bower dependency directory (https://bower.io/)
+bower_components
+
+# node-waf configuration
+.lock-wscript
+
+# Compiled binary addons (http://nodejs.org/api/addons.html)
+build/Release
+
+# Dependency directories
+node_modules/
+jspm_packages/
+
+# Typescript v1 declaration files
+typings/
+
+# Optional npm cache directory
+.npm
+
+# Optional eslint cache
+.eslintcache
+
+# Optional REPL history
+.node_repl_history
+
+# Output of 'npm pack'
+*.tgz
+
+# Yarn Integrity file
+.yarn-integrity
+
+# dotenv environment variables file
+.env
+
+# Elastic Beanstalk Files
+.elasticbeanstalk/*
+!.elasticbeanstalk/*.cfg.yml
+!.elasticbeanstalk/*.global.yml

WS-node/.ebextensions/files.config

@@ -0,0 +1,31 @@
+files:
+    "/etc/nginx/conf.d/01_websockets.conf" :
+        mode: "000644"
+        owner: root
+        group: root
+        content : |
+            upstream nodejs {
+                server 127.0.0.1:8081;
+                keepalive 256;
+            }
+
+            server {
+                listen 8080;
+
+                location / {
+                    proxy_pass  http://nodejs;
+                    proxy_set_header Upgrade $http_upgrade;
+                    proxy_set_header Connection "upgrade";
+                    proxy_http_version 1.1;
+                    proxy_set_header        Host            $host;
+                    proxy_set_header        X-Real-IP       $remote_addr;
+                    proxy_set_header        X-Forwarded-For $proxy_add_x_forwarded_for;
+                }
+            }
+
+    "/opt/elasticbeanstalk/hooks/appdeploy/enact/41_remove_eb_nginx_confg.sh":
+        mode: "000755"
+        owner: root
+        group: root
+        content : |
+            mv /etc/nginx/conf.d/00_elastic_beanstalk_proxy.conf /etc/nginx/conf.d/00_elastic_beanstalk_proxy.conf.old

WS-node/.gitignore

@@ -0,0 +1,5 @@
+
+# Elastic Beanstalk Files
+.elasticbeanstalk/*
+!.elasticbeanstalk/*.cfg.yml
+!.elasticbeanstalk/*.global.yml

WS-node/.vscode/launch.json

@@ -0,0 +1,21 @@
+{
+    // Use IntelliSense to learn about possible Node.js debug attributes.
+    // Hover to view descriptions of existing attributes.
+    // For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
+    "version": "0.2.0",
+    "configurations": [
+        {
+            "type": "node",
+            "request": "launch",
+            "name": "Launch Program",
+            "program": "${workspaceRoot}/app.js",
+            "cwd": "${workspaceRoot}"
+        },
+        {
+            "type": "node",
+            "request": "attach",
+            "name": "Attach to Process",
+            "port": 5858
+        }
+    ]
+}

WS-node/app.js

@@ -0,0 +1,197 @@
+
+require('dotenv').config()
+
+var WebSocketServer = require('websocket').server;
+
+var http = require('http');
+var HttpDispatcher = require('httpdispatcher');
+var dispatcher     = new HttpDispatcher();
+const fs = require('fs');
+const winston = require('winston')
+winston.level = process.env.LOG_LEVEL || 'info'
+
+var AsrClient = require('./lib/asrClient')
+var asrActive = false
+var myAsrClient;
+var engineStartedMs;
+var connections = []
+
+
+//Create a server
+var server = http.createServer(function(req, res) {
+    handleRequest(req,res);
+});
+
+// Loading socket.io
+var io = require('socket.io').listen(server);
+
+// When a client connects, we note it in the console
+io.sockets.on('connection', function (socket) {
+    winston.log('info','A client is connected!');
+});
+
+
+var wsServer = new WebSocketServer({
+    httpServer: server,
+    autoAcceptConnections: true,
+    binaryType: 'arraybuffer'
+});
+
+
+//Lets use our dispatcher
+function handleRequest(request, response){
+    try {
+        //log the request on console
+        winston.log('info', 'handleRequest',request.url);
+        //Dispatch
+        dispatcher.dispatch(request, response);
+    } catch(err) {
+        console.log(err);
+    }
+}
+dispatcher.setStatic('/public');
+dispatcher.setStaticDirname('public');
+dispatcher.onGet("/", function(req, res) {
+  winston.log('info', 'loading index');
+  winston.log('info', 'port', process.env.PORT)
+   fs.readFile('./public/index.html', 'utf-8', function(error, content) {
+        winston.log('debug', 'loading Index');
+        res.writeHead(200, {"Content-Type": "text/html"});
+        res.end(content);
+    });
+});
+// Serve the ncco
+dispatcher.onGet("/ncco", function(req, res) {
+    fs.readFile('./ncco.json', function(error, data) {
+        winston.log('debug', 'loading ncco');
+       res.writeHead(200, { 'Content-Type': 'application/json' });
+       res.end(data, 'utf-8');
+    });
+});
+
+dispatcher.onPost("/terminate", function(req, res) {
+     winston.log('info', 'terminate called');
+     wsServer.closeAllConnections();
+
+    res.writeHead(200, { 'Content-Type': 'application/json' });
+    res.end();
+});
+
+wsServer.on('connect', function(connection) {
+    connections.push(connection);
+
+    winston.log('info', (new Date()) + ' Connection accepted' + ' - Protocol Version ' + connection.webSocketVersion);
+    connection.on('message', function(message) {
+
+        if (message.type === 'utf8') {
+            try {
+              var json = JSON.parse(message.utf8Data);
+              winston.log('info', "json", json['app']);
+
+              if (json['app'] == "audiosocket") {
+                VBConnect();
+                winston.log('info', 'connecting to VB');
+              }
+
+            } catch (e) {
+              winston.log('error', 'message error catch', e)
+            }
+            winston.log('info', "utf ",message.utf8Data);
+        }
+        else if (message.type === 'binary') {
+            // Reflect the message back
+            // connection.sendBytes(message.binaryData);
+            if (myAsrClient != null && asrActive) {  
+              winston.log('debug', "sendingDate ",message.binaryData);
+              myAsrClient.sendData(message.binaryData)
+            }
+        }
+    });
+
+    connection.on('close', function(reasonCode, description) {
+        winston.log('info', (new Date()) + ' Peer ' + connection.remoteAddress + ' disconnected.');
+        wsServer.closeAllConnections();
+
+    });
+});
+
+wsServer.on('close', function(connection) {
+  winston.log('info', 'socket closed');
+  if (asrActive) {
+      io.sockets.emit('status',  "disconnected");
+      winston.log('info', 'trying to close ASR client');
+      myAsrClient.close();
+      myAsrClient = null;
+      asrActive = false;
+  }
+  else {
+    winston.log('info', 'asr not active, cant close');
+  }
+})
+
+wsServer.on('error', function(error) {
+  winston.log('error', 'Websocket error', error);
+})
+
+var port = process.env.PORT || 8000
+server.listen(port, function(){
+    winston.log('info', "Server listening on :%s", port);
+});
+
+function VBConnect() {
+
+    winston.log('debug', 'load AsrClient');
+    myAsrClient = new AsrClient()
+    var url = process.env.ASR_URL;
+        client_key = process.env.ASR_CLIENT_KEY;
+        client_secret = process.env.ASR_CLIENT_SECRET;
+    myAsrClient.setup(url, client_key, client_secret, (err) => {
+      if (err) {
+        return console.error('AsrClient error:', err)
+      }
+    var controlMessage = {}
+      controlMessage.language = 'en-US' // default starting value 
+      controlMessage.targetSampleRate = '8' // default starting value 
+      controlMessage.sampleRate = '16000'
+      controlMessage.windowSize = 10
+      myAsrClient.reserveAsr(controlMessage)
+      winston.log('debug', "sending control message", controlMessage);
+
+      myAsrClient.subscribeEvent('engineState', (msg) => {
+        winston.log('info', 'Engine State Event', msg)
+        if (msg === 'ready') {
+          asrActive = true
+          engineStartedMs = Date.now()
+          winston.log('info', 'Setting asrActive to true: ', asrActive, ' this.asrActive ', this.asrActive)
+          io.sockets.emit('status',  "connected");
+        }
+      })
+
+      myAsrClient.subscribeEvent('transcript', (msg) => {
+        winston.log('debug', 'transcript', msg);
+        io.sockets.emit('transcript', msg);
+      })
+
+      myAsrClient.subscribeEvent('sentiment', (msg) => {
+        winston.log('debug', 'sentiment', msg);
+        io.sockets.emit('sentiment', msg);
+
+      })
+
+      myAsrClient.subscribeEvent('nlp', (msg) => {
+          winston.log('debug', 'nlp', msg);
+          io.sockets.emit('nlp', msg);
+      })
+
+      myAsrClient.subscribeEvent('keywords', (msg) => {
+          winston.log('info', 'keywords', msg);
+          io.sockets.emit('keywords', msg);
+      })
+
+
+       myAsrClient.subscribeEvent('latency', (msg) => {
+          winston.log('info', 'latency', msg);
+          io.sockets.emit('latency', msg);
+      })
+    })
+}