From a767c17582caf9df45df587451773ee6f7bc2e49 Mon Sep 17 00:00:00 2001 From: Trygve Laugstøl Date: Tue, 8 Sep 2015 16:34:11 +0200 Subject: wip --- src/BeerDuke.js | 287 +++++++++++++++++++++++------------------- src/BeerDukeController.js | 77 ++++++------ src/BeerDukeTap.js | 85 +++++++------ src/controller.html | 16 +-- src/tap.html | 16 +-- src/templates/controller.html | 8 +- src/templates/footer.html | 4 +- src/templates/settings.html | 30 +++-- src/templates/tap.html | 2 +- 9 files changed, 278 insertions(+), 247 deletions(-) (limited to 'src') diff --git a/src/BeerDuke.js b/src/BeerDuke.js index 82f37c2..6f88016 100644 --- a/src/BeerDuke.js +++ b/src/BeerDuke.js @@ -1,166 +1,191 @@ -import angular from 'angular'; +(function () { + 'use strict'; -class SettingsController { - constructor(BeerDukeSettings) { - this.settings = BeerDukeSettings; - } -} + function SettingsController($log, $location, BeerDukeSettings) { + var ctrl = this; -class BeerDukeSettings { - constructor() { - this.clientId = BeerDukeSettings.load('clientId') || 'beer-duke-' + Math.round(Math.random() * 100000); - console.log('this =', this); - this.showSettings = BeerDukeSettings.load('showSettings') == 'true' || false; - } + ctrl.clientId = BeerDukeSettings.clientId(); + ctrl.showSettings = BeerDukeSettings.showSettings(); - save() { - BeerDukeSettings.store('clientId', clientId); - BeerDukeSettings.store('showSettings', showSettings); - } + ctrl.save = function () { + BeerDukeSettings.clientId(ctrl.clientId); + BeerDukeSettings.showSettings(ctrl.showSettings); + BeerDukeSettings.save(); - static store(key, value) { - window.localStorage[key] = angular.toJson(value); - return value; + $location.path('/') + } } - static load(key) { - let x = window.localStorage[key]; - console.log('key =', key, 'x =', x); - return angular.fromJson(x); - } -} + function BeerDukeSettings() { -class BeerDukeService { - constructor($timeout, $rootScope, BeerDukeSettings) { - this.$timeout = $timeout; - this.$rootScope = $rootScope; + function save() { + store('clientId', clientId_); + store('showSettings', showSettings_); + } - this.connected_ = false; - this.messages = []; - } + function store(key, value) { + window.localStorage[key] = angular.toJson(value); + return value; + } - static xxx() { - return new BeerDukeSettings(); - } + function load(key) { + var x = window.localStorage[key]; + if (typeof x === 'undefined') { + return x; + } - connect(type, opts) { - this.opts = opts || {}; - - console.log('BeerDukeSettings =', BeerDukeSettings); - let clientId = BeerDukeSettings.clientId + "-" + type; - console.log('clientId =', clientId); - let client = new Paho.MQTT.Client("wss://trygvis.io:9001/", clientId); - client.onConnectionLost = (a) => { - this.$timeout(() => { - this.$rootScope.$apply(() => { - this.onConnectionLost(a); - }) - }); - }; - client.onMessageArrived = (a) => { - this.$timeout(() => { - this.$rootScope.$apply(() => { - this.onMessageArrived(a); - }) - }); - }; + return angular.fromJson(x); + } - this.client = client; + var clientId_ = load('clientId') || 'beer-duke-' + Math.round(Math.random() * 100000); + var showSettings_ = load('showSettings') || false; + save(); - this.client.connect({ - onSuccess: () => { - this.$timeout(() => { - this.$rootScope.$apply(() => { - this.onConnect(); - }) - }); + function clientId(x) { + if (x) { + clientId_ = x; } - }); - } + return clientId_; + } - get connected() { - return this.connected_; + function showSettings(x) { + if (x) { + showSettings_ = x; + } + return showSettings_; + } + + return { + clientId: clientId, + showSettings: showSettings, + load: load, + save: save + } } - onConnect() { - console.log('Connected'); + function BeerDukeService($log, $timeout, $rootScope, BeerDukeSettings) { + var self = this; + var connected_ = false; + var messages = []; + var callbacks = {}; + + function connect(type) { + var clientId = BeerDukeSettings.clientId() + "-" + type; + var client = new Paho.MQTT.Client("wss://trygvis.io:9001/", clientId); + client.onConnectionLost = function (a) { + $timeout(function () { + $rootScope.$apply(function () { + onConnectionLost(a); + }) + }); + }; + client.onMessageArrived = function () { + var args = arguments; + $timeout(function () { + $rootScope.$apply(function () { + onMessageArrived.apply(self, args); + }) + }); + }; + + self.client = client; + + self.client.connect({ + onSuccess: function () { + var args = arguments; + $timeout(function () { + $rootScope.$apply(function () { + onConnect.apply(self, args); + }) + }); + } + }); + } - this.connected_ = true; + function subscribe(name) { + return self.client.subscribe(name); + } - if (this.opts.onConnect) { - try { - this.opts.onConnect(); - } catch (e) { - } + function connected() { + return self.connected_; } - //this.client.subscribe("/beer-duke"); - } + function onConnect() { + $log.info('Connected'); - onConnectionLost(responseObject) { - this.connected_ = false; + self.connected_ = true; - //if (responseObject.errorCode !== 0) - console.log("onConnectionLost:", responseObject); - console.log("onConnectionLost:", responseObject.errorMessage); - } + invoke('onConnect'); + } - onMessageArrived(message) { - console.log("onMessageArrived:" + message.payloadString); + function invoke(name, args) { + var fn = callbacks[name]; - this.messages.push(message); + if (typeof fn === 'function') { + try { + return fn.apply(undefined, args); + } catch (e) { + $log.warn('exception calling ' + name, e); + } + } + } + + function onConnectionLost(responseObject) { + self.connected_ = false; - if (this.opts.onMessageArrived) { + //if (responseObject.errorCode !== 0) + $log.warn("onConnectionLost:", responseObject); + $log.warn("onConnectionLost:", responseObject.errorMessage); + } + + function onMessageArrived(message) { + messages.push(message); try { - let m = angular.fromJson(message); - this.opts.onMessageArrived(m); + var m = angular.fromJson(message); + invoke('onMessageArrived', [m]); } catch (e) { + $log.warn('could not parse json', e); } } - } - requestBeer(code) { - let message = new Paho.MQTT.Message(angular.toJson({code: code})); - message.destinationName = "/beer-duke"; - this.client.send(message); + function submit(destination, payload) { + var message = new Paho.MQTT.Message(angular.toJson(payload)); + message.destinationName = destination; + self.client.send(message); + } + + return { + messages: messages, + submit: submit, + connect: connect, + subscribe: subscribe, + connected: connected, + callbacks: callbacks + } } -} -class MqttController { - constructor(BeerDukeService) { - this.BeerDukeService = BeerDukeService; + function config($routeProvider) { + $routeProvider + .when('/settings', { + controller: SettingsController, + controllerAs: 'ctrl', + templateUrl: 'templates/settings.html' + }) + .otherwise({ + redirectTo: '/' + }) } - get connected() { - return this.BeerDukeService.connected; + function run($rootScope, BeerDukeSettings, BeerDukeService) { + $rootScope.settings = BeerDukeSettings; + $rootScope.mqtt = { + connected: BeerDukeService.connected + } } -} - -function config($routeProvider) { - console.log('BeerDuke: config'); - $routeProvider - .when('/settings', { - controller: SettingsController, - controllerAs: 'ctrl', - templateUrl: 'templates/settings.html' - }) - .otherwise({ - redirectTo: '/' - }) -} - -function run($rootScope, BeerDukeSettings, BeerDukeService) { - $rootScope.settings = BeerDukeSettings; - $rootScope.mqtt = { - get connected() { - return BeerDukeService.connected - } - }; -} - -angular.module('BeerDuke', ['ngRoute']) - .controller('MqttController', MqttController) - .service('BeerDukeService', BeerDukeService) - .factory('BeerDukeSettings', () => new BeerDukeSettings()) - .config(config) - .run(run); + + angular.module('BeerDuke', ['ngRoute']) + .factory('BeerDukeService', BeerDukeService) + .factory('BeerDukeSettings', BeerDukeSettings) + .config(config) + .run(run); +}()); diff --git a/src/BeerDukeController.js b/src/BeerDukeController.js index 85a47f4..8aeafb8 100644 --- a/src/BeerDukeController.js +++ b/src/BeerDukeController.js @@ -1,46 +1,43 @@ -import angular from 'angular'; -import 'angular-route'; -import './BeerDuke.js'; - -class BeerDukeControllerController { - constructor(BeerDukeService) { - this.BeerDukeService = BeerDukeService; - - this.BeerDukeService.connect('controller', { - onConnect: this.onConnect, - onMessageArrived: this.onMessageArrived - }); +(function () { + 'use strict'; + + function BeerDukeControllerController($log, BeerDukeService, BeerDukeSettings) { + var ctrl = this; + + if (BeerDukeSettings.showSettings()) { + ctrl.code = 123; + ctrl.email = 'foo@example.org'; + } + + ctrl.requestBeer = function () { + var payload = { + code: this.code, + email: this.email + }; + $log.info('payload', payload); + + BeerDukeService.submit('/beer-duke', payload); + }; + + BeerDukeService.callbacks.onMessageArrived = function (m) { + ctrl.lastCode = m.code; + } } - requestBeer() { - let code = this.code; - - console.log('code', code); - this.BeerDukeService.requestBeer(code); + function run(BeerDukeService) { + BeerDukeService.connect('controller'); } - onConnect() { - console.log('onConnect'); + function config($routeProvider) { + $routeProvider + .when('/', { + controller: BeerDukeControllerController, + controllerAs: 'ctrl', + templateUrl: 'templates/controller.html' + }); } - onMessageArrived(msg) { - console.log('msg =', msg); - } -} - -function run(BeerDukeService) { - //BeerDukeService.connect('controller'); -} - -function config($routeProvider) { - $routeProvider - .when('/', { - controller: BeerDukeControllerController, - controllerAs: 'ctrl', - templateUrl: 'templates/controller.html' - }); -} -angular.module('BeerDukeController', ['ngRoute', 'BeerDuke']) - .run(run) - .config(config) - .controller('BeerDukeControllerController', BeerDukeControllerController); + angular.module('BeerDukeController', ['ngRoute', 'BeerDuke']) + .run(run) + .config(config); +}()); diff --git a/src/BeerDukeTap.js b/src/BeerDukeTap.js index 3392e85..ed12a17 100644 --- a/src/BeerDukeTap.js +++ b/src/BeerDukeTap.js @@ -1,45 +1,54 @@ -import angular from 'angular'; -import 'angular-route'; -import './BeerDuke.js'; +(function () { + 'use strict'; -class BeerDukeTapController { - constructor($timeout, BeerDukeSettings) { - console.log('BeerDukeTapController', this); + function BeerDukeTapController($log, $timeout, BeerDukeService) { + var ctrl = this; - this.$timeout = $timeout; - this.settings = BeerDukeSettings; + rotateCode(); + self.count = 0; + self.code = ''; - this.rotateCode(); - this.count = 0; - this.code = ''; + function rotateCode() { + self.code = '' + self.count++; + $timeout(function () { + rotateCode(); + }, 1000); + } + + BeerDukeService.callbacks.onConnect = function () { + BeerDukeService.subscribe('/beer-duke'); + }; + BeerDukeService.callbacks.onMessageArrived = function (m) { + $log.info('m.payloadString =', m.payloadString); + var payload = angular.fromJson(m.payloadString); + + var code = payload.code; + var email = payload.email; + + if (typeof code !== 'string' && typeof email !== 'string') { + $log.warn('bad payload', payload.code); + return; + } + + ctrl.message = payload; + }; + + BeerDukeService.connect('tap'); } - - rotateCode() { - this.code = '' + this.count++; - this.$timeout(() => { - this.rotateCode(); - }, 1000); + + function run(BeerDukeService) { } -} -class TapSettingsController { - constructor() { + function config($routeProvider) { + $routeProvider + .when('/', { + controller: BeerDukeTapController, + controllerAs: 'ctrl', + templateUrl: 'templates/tap.html' + }); } -} - -function run(BeerDukeService) { - BeerDukeService.connect('tap'); -} - -function config($routeProvider) { - $routeProvider - .when('/', { - controller: BeerDukeTapController, - controllerAs: 'ctrl', - templateUrl: 'templates/tap.html' - }); -} - -angular.module('BeerDukeTap', ['BeerDuke', 'ngRoute']) - .run(run) - .config(config); + + angular.module('BeerDukeTap', ['BeerDuke', 'ngRoute']) + .run(run) + .config(config); +}()); diff --git a/src/controller.html b/src/controller.html index bbb34ca..33477f9 100644 --- a/src/controller.html +++ b/src/controller.html @@ -1,18 +1,12 @@ - - - + + + + - +
diff --git a/src/tap.html b/src/tap.html index 47a05ca..5196b97 100644 --- a/src/tap.html +++ b/src/tap.html @@ -1,18 +1,12 @@ - - - + + + + - +
diff --git a/src/templates/controller.html b/src/templates/controller.html index eb0efab..bd8cbf5 100644 --- a/src/templates/controller.html +++ b/src/templates/controller.html @@ -1,9 +1,13 @@ -
-
+
+
+
diff --git a/src/templates/footer.html b/src/templates/footer.html index 17483ae..182554d 100644 --- a/src/templates/footer.html +++ b/src/templates/footer.html @@ -1,5 +1,5 @@ -
+
settings
- connected = {{mqtt.connected}} + connected = {{mqtt.connected()}}
diff --git a/src/templates/settings.html b/src/templates/settings.html index 5147065..f118e47 100644 --- a/src/templates/settings.html +++ b/src/templates/settings.html @@ -1,14 +1,22 @@ -
+

Settings

- back - - - + +

+ +

+ +

+ +

+ +

+ +

diff --git a/src/templates/tap.html b/src/templates/tap.html index c266f2d..48d5e37 100644 --- a/src/templates/tap.html +++ b/src/templates/tap.html @@ -1,5 +1,5 @@
- Code: {{ctrl.code}} + Last: {{ctrl.message | json}}
-- cgit v1.2.3