test/AfbAngular.js

   1 (function (){'use strict';
   2
   3   // some default values
   4   // note that how default values are defined/used may change
   5   var defaults = {
   6       token: '123456789',
   7       api: '/api'
   8     };
   9
  10   var CALL = 2;
  11   var RETOK = 3;
  12   var RETERR = 4;
  13   var EVENT = 5;
  14
  15   var PROTO1 = "x-afb-ws-json1";
  16
  17   // Definition of the Angular module
  18   var AfbClientModule = angular.module('AfbClient', []);
  19
  20   // The instanciation of the module
  21   AfbClientModule.factory('AfbClient', [ '$location', function ($location) {
  22     var refid = $location.host();
  23     var params = $location.search();
  24     return clients[refid] || (client[refid] = new AfbContext(refid, params));
  25   }]);
  26
  27   // prototype for handling context by uuid and token
  28   function AfbContext(refid, params) {
  29     this.refid = refid;
  30     this.api = params.api || defaults.api;
  31     this.uhttp = params.uhttp || this.api+'/';
  32     this.uws = params.uws || this.api;
  33     this.token = params.token || defaults.token;
  34     this.uuid = params.uuid;
  35     this.ws = null;
  36   }
  37
  38   // prototype of functions linked to AfbContext object
  39   AfbContext.prototype = {
  40     // call using websockets
  41     call: function(method, query) { return getws(this).call(method, query); },
  42
  43     // call using get
  44     get: function(method, query) { return $http.get(this.uhttp+method, mixtu(this, query)); },
  45
  46     // call using post
  47     post: function(method, query) { return $http.post(this.uhttp+method, mixtu(this, query)); }
  48   };
  49
  50   // get the current websocket
  51   function getws(ctxt) {
  52     return ctxt.ws || (ctxt.ws = new AfbWebSocket(ctxt));
  53   }
  54
  55   // inserts the current token in the answer
  56   function mixtu(ctxt, query) {
  57     return ("token" in query) ? query : angular.extend({token:ctxt.token},query);
  58   }
  59
  60   // prototype for websocket
  61   function AfbWebSocket(ctxt) {
  62     var protos = [ PROTO1 ];
  63     this.context = ctxt;
  64     var url = "ws:" + ctxt.refid + ctxt.uws;
  65     var q = ctxt.uuid ? ("?x-afb-uuid=" + ctxt.uuid) : "";
  66     if (ctxt.token)
  67       q = (q ? (q + "&") : "?") + ("x-afb-token=" + ctxt.token);
  68     this.pendings = {};
  69     this.awaitens = {};
  70     this.counter = 0;
  71     this.ws = new WebSocket(url + q, protos);
  72     this.ws.onopen = onopen.bind(this);
  73     this.ws.onerror = onerror.bind(this);
  74     this.ws.onclose = onclose.bind(this);
  75     this.ws.onmessage = onmessage.bind(this);
  76     this.onopen = onopen;
  77     this.onabort = onabort;
  78   }
  79
  80   AfbWebSocket.prototype = {
  81     call: function(method, query) {
  82         return new Promise((function(resolve, reject){
  83           var id = String(this.counter = 4095 & (this.counter + 1));
  84           while (id in this.pendings) id = String(this.counter = 4095 & (this.counter + 1));
  85           this.pendings[id] = [ resolve, reject ];
  86           var arr = [CALL, id, method, request ];
  87           var tok = this.context.token; if (tok) arr.push(tok);
  88           this.ws.send(angular.toJson(arr, 0));
  89         }).bind(this));
  90       },
  91     addEvent: function (name, handler) {
  92         (this.awaitens[name] || (this.awaitens[name] = [])).push(handler);
  93       },
  94     removeEvent: function (name, handler) {
  95         var a = this.awaitens[name];
  96         if (a) {
  97           var i = a.indexOf(handler);
  98           if (i >= 0) a.splice(i, 1);
  99         }
 100       }
 101
 102   };
 103
 104   function onmessage(ev) {
 105     var obj = angular.fromJson(ev.data);
 106     var id = obj[1];
 107     var ans = obj[2];
 108     if (obj[3])
 109       this.context.token = obj[3];
 110     switch (obj[0]) {
 111     case RETOK:  reply(this.pendings, id, ans, 0); break;
 112     case RETERR: reply(this.pendings, id, ans, 1); break;
 113     case EVENT:   fire(this.awaitens, id, ans);    break;
 114
 115     }
 116   }
 117
 118   function fire(awaitens, name, data) {
 119     var a = awaitens[name];
 120     if (a) a.forEach(function(handler){handler(data);});
 121     var i = name.indexOf("/");
 122     if (i >= 0) {
 123       a = awaitens[name.substring(0,i)];
 124       if (a) a.forEach(function(handler){handler(data);});
 125     }
 126     a = awaitens["*"];
 127     if (a) a.forEach(function(handler){handler(data);});
 128   }
 129
 130   function reply(pendings, id, ans, offset) {
 131     if (id in pendings) {
 132       var p = pendings[id];
 133       delete pendings[id];
 134       var f = p[offset];
 135       if (f) f(ans);
 136     }
 137   }
 138
 139
 140
 141
 142 /*
 143
 144
 145
 146
 147
 148
 149         AFB_websocket = function(onopen, onabort) {
 150         }
 151
 152         function onerror(event) {
 153                 var f = this.onabort;
 154                 if (f) {
 155                         delete this.onopen;
 156                         delete this.onabort;
 157                         f && f(this);
 158                 }
 159                 this.onerror && this.onerror(this);
 160         }
 161
 162         function onopen(event) {
 163                 var f = this.onopen;
 164                 delete this.onopen;
 165                 delete this.onabort;
 166                 f && f(this);
 167         }
 168
 169         function onclose(event) {
 170                 for (var id in this.pendings) {
 171                         var ferr = this.pendings[id].onerror;
 172                         ferr && ferr(null, this);
 173                 }
 174                 this.pendings = {};
 175                 this.onclose && this.onclose();
 176         }
 177
 178         function close() {
 179                 this.ws.close();
 180         }
 181
 182         function call(method, request) {
 183         }
 184
 185 */
 186
 187 /*
 188   // Factory is a singleton and share its context within all instances.
 189   AfbClientModule.factory('AppCall', function ($http, AppConfig, $log) {
 190     var myCalls = {
 191       get : function(plugin, action, query, callback) {
 192         if (!query.token) query.token = AppConfig.session.token; // add token to provided query
 193         $http.get('/api/' + plugin + '/' + action , {params: query}).then (callback, callback);
 194       }
 195     };
 196     return myCalls;
 197   });
 198 */
 199
 200
 201
 202
 203
 204 })();