added websocket connection

Author: qscripter

Diff for: bower.json

@@ -14,7 +14,8 @@
     "moment": "~2.10.3",
     "animate.css": "~3.3.0",
     "angular": "~1.4.0",
-    "lodash": "~3.9.3"
+    "lodash": "~3.9.3",
+    "angular-websocket": "~1.0.13"
   },
   "devDependencies": {
     "angular-mocks": "~1.4.0"

Diff for: src/app/components/hyperdecks/hyperdecks.controller.js

@@ -6,7 +6,7 @@ angular
   .controller('HyperdecksCtrl', controller);
 
 /* @ngInject */
-function controller(hyperdecks, Hyperdeck) {
+function controller(hyperdecks, Hyperdeck, $websocket) {
   var vm = this;
 
   init();
@@ -20,12 +20,33 @@ function controller(hyperdecks, Hyperdeck) {
   vm.getSlotInfo = getSlotInfo;
 
   function init() {
+    var dataStream = $websocket('ws://localhost:8888');
+    dataStream.onMessage(function(message) {
+        var data = JSON.parse(message.data);
+        var deck;
+        if (_.has(data, 'connectionStatus')) {
+          deck = findDeck(data._id);
+          if (deck) {
+            deck.connectionStatus = data.connectionStatus;
+          }
+        } else if (_.has(data, 'event')) {
+          deck = findDeck(data._id);
+          if (deck) {
+            deck.events.unshift(data.event);
+          }
+        }
+      });
+
     vm.hyperdecks = hyperdecks;
     _.map(vm.hyperdecks, getEvents);
     _.map(vm.hyperdecks, getConfiguration);
     _.map(vm.hyperdecks, getTransportInfo);
   }
 
+  function findDeck(id) {
+    return _.findWhere(vm.hyperdecks, {'_id': id});
+  }
+
   function connect(hyperdeck) {
     Hyperdeck.connect(hyperdeck._id);
   }
@@ -45,24 +66,30 @@ function controller(hyperdecks, Hyperdeck) {
   }
 
   function getConfiguration(hyperdeck) {
-    Hyperdeck.getConfiguration(hyperdeck._id).then(function (configuration) {
-      hyperdeck.configuration = configuration;
-    });
+    if (hyperdeck.connectionStatus === 'Connected') {
+      Hyperdeck.getConfiguration(hyperdeck._id).then(function (configuration) {
+        hyperdeck.configuration = configuration;
+      });
+    }
   }
 
   function getTransportInfo(hyperdeck) {
-    Hyperdeck.getTransportInfo(hyperdeck._id).then(function (transportInfo) {
-      hyperdeck.transportInfo = transportInfo;
-    });
+    if (hyperdeck.connectionStatus === 'Connected') {
+      Hyperdeck.getTransportInfo(hyperdeck._id).then(function (transportInfo) {
+        hyperdeck.transportInfo = transportInfo;
+      });
+    }
   }
 
   function getSlotInfo(hyperdeck, slot) {
-    Hyperdeck.getSlotInfo(hyperdeck._id, slot).then(function (slotInfo) {
-      if (!_.has(hyperdeck, 'slotInfo')) {
-        hyperdeck.slotInfo = {};
-      }
-      hyperdeck.slotInfo[slot] = slotInfo;
-    });
+    if (hyperdeck.connectionStatus === 'Connected') {
+      Hyperdeck.getSlotInfo(hyperdeck._id, slot).then(function (slotInfo) {
+        if (!_.has(hyperdeck, 'slotInfo')) {
+          hyperdeck.slotInfo = {};
+        }
+        hyperdeck.slotInfo[slot] = slotInfo;
+      });
+    }
   }
 }
 })();

Diff for: src/app/index.module.js

@@ -2,6 +2,6 @@
   'use strict';
 
   angular
-    .module('hyperdeckUi', ['ngAnimate', 'ngCookies', 'ngTouch', 'ngSanitize', 'ui.router', 'ui.bootstrap']);
+    .module('hyperdeckUi', ['ngAnimate', 'ngCookies', 'ngTouch', 'ngSanitize', 'ui.router', 'ui.bootstrap', 'ngWebSocket']);
 
 })();