Session.js
211 lines
| 7.2 KiB
| application/javascript
|
JavascriptGenshiLexer
cin
|
r175 | define([ | |
| "dojo/_base/declare", | |||
| "dojo/request", | |||
| "./Destination", | |||
| "dojo/Evented", | |||
| "dojo/Deferred", | |||
| "../log/_LogMixin" | |||
| ], function (declare, request, Destination, Evented, Deferred, _LogMixin) { | |||
| var cls = declare( | |||
| [Evented, _LogMixin], { | |||
| _id: null, | |||
| _baseUrl: null, | |||
| _destinations: null, | |||
| _timeout: 100000, | |||
| _clients: null, | |||
| _started: null, | |||
| _starting: false, | |||
| constructor: function (baseUrl, options) { | |||
| if (!baseUrl) | |||
| throw new Error("baseUrl is required"); | |||
| options = options || {}; | |||
| this._baseUrl = baseUrl.replace(/\/*$/, ""); | |||
| this._destinations = {}; | |||
| this._pending = []; | |||
| this._clients = {}; | |||
| if (options.timeout) | |||
| this._timeout = options.timeout; | |||
| this._started = new Deferred(); | |||
| }, | |||
| start: function () { | |||
| if (this._starting) | |||
| return this._started; | |||
| this._starting = true; | |||
| var me = this; | |||
| me.log("START"); | |||
| request(this._baseUrl, { | |||
| method: "POST", | |||
| handleAs: "json" | |||
| }).then(function (result) { | |||
| me._id = result; | |||
| me._emitConnected(); | |||
| me._poll(); | |||
| me._started.resolve(me); | |||
| }, function (error) { | |||
| me._emitError(error); | |||
| me._started.reject(me); | |||
| }); | |||
| return me._started.promise; | |||
| }, | |||
| createClient: function (options) { | |||
| if (!options || !options.destination || !options.mode) | |||
| throw new Error("Invalid argument"); | |||
| var me = this; | |||
| return me._started | |||
| .then(function () { | |||
| var url = me._makeUrl(me._id); | |||
| me.log( | |||
| "CREATE mode=${0}, destination=${1}", | |||
| options.mode, | |||
| options.destination); | |||
| return request(url, { | |||
| method: "POST", | |||
| data: { | |||
| mode: options.mode, | |||
| destination: options.destination | |||
| }, | |||
| handleAs: 'json' | |||
| }) | |||
| .then(function (id) { | |||
| me.log( | |||
| "CLIENT id=${0}, mode=${1}, destination=${2}", | |||
| id, | |||
| options.mode, | |||
| options.destination); | |||
| me._clients[id] = options.client ? | |||
| options.client : | |||
| function () { | |||
| me.warn( | |||
| "The client id=${0}, mode=${1}, destination=${2} isn't accepting mesages", | |||
| id, | |||
| options.mode, | |||
| options.destination); | |||
| }; | |||
| return id; | |||
| }); | |||
| }); | |||
| }, | |||
| deleteClient: function (options) { | |||
| if (!options || !options.clientId) | |||
| throw new Error("Invalid argument"); | |||
| var me = this, | |||
| id = options.clientId; | |||
| return me._started.then(function () { | |||
| var url = me._makeUrl(me._id, options.clientId); | |||
| me.log("DELETE CLIENT ${0}", options.clientId); | |||
| return request(url, { | |||
| method: "DELETE", | |||
| handleAs: 'json' | |||
| }).then(function () { | |||
| me.log("CLIENT DELETED ${0}", options.clientId); | |||
| me._clients[id] = undefined; | |||
| }); | |||
| }); | |||
| }, | |||
| _poll: function () { | |||
| var me = this, | |||
| url = this._makeUrl(this._id); | |||
| me.log("POLL timeout=${0}", me._timeout); | |||
| request(url, { | |||
| method: "GET", | |||
| handleAs: "json", | |||
| query: { | |||
| timeout: me._timeout | |||
| } | |||
| }).then(function (response) { | |||
| me._handlePoll(response); | |||
| me._poll(); | |||
| }, function (err) { | |||
| me.error("POLL faield with ${0}", err); | |||
| me._emitError(err); | |||
| }); | |||
| }, | |||
| _handlePoll: function (response) { | |||
| if (!response) { | |||
| this.log("POLL response undefined, looks like a bug"); | |||
| return; | |||
| } | |||
| if (!response.results || !response.results.length) { | |||
| this.log("POLL response is empty"); | |||
| return; | |||
| } | |||
| var results = response.results; | |||
| this.log("POLL got ${0} results", results.length); | |||
| for (var i = 0; i < results.length; i++) { | |||
| var result = results[i]; | |||
| var client = this._clients[result.clientId]; | |||
| if (!client) { | |||
| // TODO this could happen due to client isn't | |||
| // registered yet | |||
| this.error("Unknown client ${0}", result.clientId); | |||
| continue; | |||
| } | |||
| client.call(this, result); | |||
| } | |||
| }, | |||
| _emitError: function (err) { | |||
| this.emit("error", err); | |||
| }, | |||
| _emitConnected: function () { | |||
| var me = this; | |||
| me.log("CONNECTED"); | |||
| me.emit("connected"); | |||
| }, | |||
| _makeUrl: function () { | |||
| var parts = [this._baseUrl]; | |||
| for (var i = 0; i < arguments.length; i++) | |||
| parts.push(arguments[i].replace(/\/*$/, "")); | |||
| return parts.join('/'); | |||
| }, | |||
| queue: function (name) { | |||
| return this._getDestination("queue://" + name); | |||
| }, | |||
| topic: function (name) { | |||
| return this._getDestination("topic://" + name); | |||
| }, | |||
| _getDestination: function (uri) { | |||
| if (uri in this._destinations) | |||
| return this._destinations[uri]; | |||
| var dest = new Destination(this, uri); | |||
| this._destinations[uri] = dest; | |||
| return dest; | |||
| }, | |||
| toString: function () { | |||
| return ["[", "SESSION ", this._id, "]"].join(" "); | |||
| } | |||
| }); | |||
| cls.connect = function (url, options) { | |||
| var session = new cls(url, options); | |||
| return session.start(); | |||
| }; | |||
| return cls; | |||
| }); |