aboutsummaryrefslogtreecommitdiffstats
path: root/test/AfbAngular.js
diff options
context:
space:
mode:
Diffstat (limited to 'test/AfbAngular.js')
-rw-r--r--test/AfbAngular.js193
1 files changed, 193 insertions, 0 deletions
diff --git a/test/AfbAngular.js b/test/AfbAngular.js
new file mode 100644
index 00000000..3db1ad59
--- /dev/null
+++ b/test/AfbAngular.js
@@ -0,0 +1,193 @@
+(function (){'use strict';
+
+ // some default values
+ // note that how default values are defined/used may change
+ var defaults = {
+ token: '123456789',
+ api: '/api'
+ };
+
+ var CALL = 2;
+ var RETOK = 3;
+ var RETERR = 4;
+ var EVENT = 5;
+
+ var PROTO1 = "x-afb-ws-json1";
+
+ // Definition of the Angular module
+ var AfbClientModule = angular.module('AfbClient', []);
+
+ // The instanciation of the module
+ AfbClientModule.factory('AfbClient', [ '$location', function ($location) {
+ var refid = $location.host();
+ var params = $location.search();
+ return clients[refid] || (client[refid] = new AfbContext(refid, params));
+ }]);
+
+ // prototype for handling context by uuid and token
+ function AfbContext(refid, params) {
+ this.refid = refid;
+ this.api = params.api || defaults.api;
+ this.uhttp = params.uhttp || this.api+'/';
+ this.uws = params.uws || this.api;
+ this.token = params.token || defaults.token;
+ this.uuid = params.uuid;
+ this.ws = null;
+ }
+
+ AfbContext.prototype = {
+ call: function(method, query) { return getws(this).call(method, query); },
+ get: function(method, query) { return $http.get(this.uhttp+method, mixtu(this, query)); },
+ post: function(method, query) { return $http.post(this.uhttp+method, mixtu(this, query)); },
+ };
+
+ function getws(ctxt) {
+ return ctxt.ws || (ctxt.ws = new AfbWebSocket(ctxt));
+ }
+
+ function mixtu(ctxt, query) {
+ return ("token" in query) ? query : angular.extend({token:ctxt.token},query);
+ }
+
+ // prototype for websocket
+ function AfbWebSocket(ctxt) {
+ var protos = [ PROTO1 ];
+ this.context = ctxt;
+ var url = "ws:" + ctxt.refid + ctxt.uws;
+ var q = ctxt.uuid ? ("?x-afb-uuid=" + ctxt.uuid) : "";
+ if (ctxt.token)
+ q = (q ? (q + "&") : "?") + ("x-afb-token=" + ctxt.token);
+ this.pendings = {};
+ this.awaitens = {};
+ this.counter = 0;
+ this.ws = new WebSocket(url + q, protos);
+ this.ws.onopen = onopen.bind(this);
+ this.ws.onerror = onerror.bind(this);
+ this.ws.onclose = onclose.bind(this);
+ this.ws.onmessage = onmessage.bind(this);
+ this.onopen = onopen;
+ this.onabort = onabort;
+ }
+
+ AfbWebSocket.prototype = {
+ call: function(method, query) {
+ return new Promise((function(resolve, reject){
+ var id = String(this.counter = 4095 & (this.counter + 1));
+ while (id in this.pendings) id = String(this.counter = 4095 & (this.counter + 1));
+ this.pendings[id] = [ resolve, reject ];
+ var arr = [CALL, id, method, request ];
+ var tok = this.context.token; if (tok) arr.push(tok);
+ this.ws.send(angular.toJson(arr, 0));
+ }).bind(this));
+ },
+ addEvent: function (name, handler) {
+ (this.awaitens[name] || (this.awaitens[name] = [])).push(handler);
+ },
+ removeEvent: function (name, handler) {
+ var a = this.awaitens[name];
+ if (a) {
+ var i = a.indexOf(handler);
+ if (i >= 0) a.splice(i, 1);
+ }
+ }
+
+ };
+
+ function onmessage(ev) {
+ var obj = angular.fromJson(ev.data);
+ var id = obj[1];
+ var ans = obj[2];
+ if (obj[3])
+ this.context.token = obj[3];
+ switch (obj[0]) {
+ case RETOK: reply(this.pendings, id, ans, 0); break;
+ case RETERR: reply(this.pendings, id, ans, 1); break;
+ case EVENT: fire(this.awaitens, id, ans); break;
+
+ }
+ }
+
+ function fire(awaitens, name, data) {
+ var a = awaitens[name];
+ if (a) a.forEach(function(handler){handler(data);});
+ var i = name.indexOf("/");
+ if (i >= 0) {
+ a = awaitens[name.substring(0,i)];
+ if (a) a.forEach(function(handler){handler(data);});
+ }
+ a = awaitens["*"];
+ if (a) a.forEach(function(handler){handler(data);});
+ }
+
+ function reply(pendings, id, ans, offset) {
+ if (id in pendings) {
+ var p = pendings[id];
+ delete pendings[id];
+ var f = p[offset];
+ if (f) f(ans);
+ }
+ }
+
+
+
+
+
+
+
+
+
+
+ AFB_websocket = function(onopen, onabort) {
+ }
+
+ function onerror(event) {
+ var f = this.onabort;
+ if (f) {
+ delete this.onopen;
+ delete this.onabort;
+ f && f(this);
+ }
+ this.onerror && this.onerror(this);
+ }
+
+ function onopen(event) {
+ var f = this.onopen;
+ delete this.onopen;
+ delete this.onabort;
+ f && f(this);
+ }
+
+ function onclose(event) {
+ for (var id in this.pendings) {
+ var ferr = this.pendings[id].onerror;
+ ferr && ferr(null, this);
+ }
+ this.pendings = {};
+ this.onclose && this.onclose();
+ }
+
+ function close() {
+ this.ws.close();
+ }
+
+ function call(method, request) {
+ }
+
+/*
+ // Factory is a singleton and share its context within all instances.
+ AfbClientModule.factory('AppCall', function ($http, AppConfig, $log) {
+ var myCalls = {
+ get : function(plugin, action, query, callback) {
+ if (!query.token) query.token = AppConfig.session.token; // add token to provided query
+ $http.get('/api/' + plugin + '/' + action , {params: query}).then (callback, callback);
+ }
+ };
+ return myCalls;
+ });
+*/
+
+
+
+
+
+})();