##// END OF EJS Templates
implab » implabjs-core
RSS

Clone from http://hg.code.sf.net/p/implabjs/core

Added childContainer service to container services, ServiceContaier is destroyable, fixed browser Uuid version
Added childContainer service to container services, ServiceContaier is destroyable, fixed browser Uuid version
cin - - Load All Authors

File last commit:

r63:fb1f84f91895 default
r146:f3f5c56d3b3e v1.4.0-rc5 default
Show More
Session.js
211 lines | 7.2 KiB | application/javascript | JavascriptGenshiLexer
/ src / amd / js / messaging / Session.js
History | Source | Raw |Copy content |Copy permalink
cin
working on support commonjs modules format
 r59 define([
"dojo/_base/declare",
"dojo/request",
"./Destination",
"dojo/Evented",
"dojo/Deferred",
"../log/_LogMixin"
], function (declare, request, Destination, Evented, Deferred, _LogMixin) {
cin
working version...
 r51
cin
working on support commonjs modules format
 r59 var cls = declare(
[Evented, _LogMixin], {
_id: null,
_baseUrl: null,
_destinations: null,
_timeout: 100000,
_clients: null,
_started: null,
_starting: false,
cin
working version...
 r51
cin
working on support commonjs modules format
 r59 constructor: function (baseUrl, options) {
if (!baseUrl)
throw new Error("baseUrl is required");
options = options || {};
cin
working version...
 r51
cin
working on support commonjs modules format
 r59 this._baseUrl = baseUrl.replace(/\/*$/, "");
this._destinations = {};
this._pending = [];
this._clients = {};
if (options.timeout)
this._timeout = options.timeout;
cin
working version...
 r51
cin
working on support commonjs modules format
 r59 this._started = new Deferred();
},
cin
working version...
 r51
cin
working on support commonjs modules format
 r59 start: function () {
if (this._starting)
return this._started;
this._starting = true;
cin
working version...
 r51
cin
working on support commonjs modules format
 r59 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;
},
cin
working version...
 r51
cin
working on support commonjs modules format
 r59 createClient: function (options) {
if (!options || !options.destination || !options.mode)
throw new Error("Invalid argument");
cin
working version...
 r51
cin
working on support commonjs modules format
 r59 var me = this;
cin
working version...
 r51
cin
working on support commonjs modules format
 r59 return me._started
.then(function () {
var url = me._makeUrl(me._id);
me.log(
"CREATE mode=${0}, destination=${1}",
options.mode,
options.destination);
cin
working version...
 r51
return request(url, {
cin
working on support commonjs modules format
 r59 method: "POST",
data: {
mode: options.mode,
destination: options.destination
},
handleAs: 'json'
})
cin
updated build script, added eslint
 r63 .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",
cin
working on support commonjs modules format
 r59 id,
options.mode,
options.destination);
cin
updated build script, added eslint
 r63 };
return id;
});
cin
working version...
 r51 });
cin
working on support commonjs modules format
 r59
},
deleteClient: function (options) {
if (!options || !options.clientId)
throw new Error("Invalid argument");
cin
working version...
 r51
cin
working on support commonjs modules format
 r59 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;
cin
working version...
 r51 });
cin
working on support commonjs modules format
 r59 });
},
cin
working version...
 r51
cin
working on support commonjs modules format
 r59 _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
cin
working version...
 r51 }
cin
working on support commonjs modules format
 r59 }).then(function (response) {
me._handlePoll(response);
me._poll();
}, function (err) {
me.error("POLL faield with ${0}", err);
me._emitError(err);
});
},
cin
working version...
 r51
cin
working on support commonjs modules format
 r59 _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);
cin
working version...
 r51
cin
working on support commonjs modules format
 r59 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);
}
},
cin
working version...
 r51
cin
working on support commonjs modules format
 r59 _emitError: function (err) {
this.emit("error", err);
},
cin
working version...
 r51
cin
working on support commonjs modules format
 r59 _emitConnected: function () {
var me = this;
me.log("CONNECTED");
me.emit("connected");
},
cin
working version...
 r51
cin
working on support commonjs modules format
 r59 _makeUrl: function () {
var parts = [this._baseUrl];
for (var i = 0; i < arguments.length; i++)
parts.push(arguments[i].replace(/\/*$/, ""));
return parts.join('/');
},
cin
working version...
 r51
cin
working on support commonjs modules format
 r59 queue: function (name) {
return this._getDestination("queue://" + name);
},
cin
working version...
 r51
cin
working on support commonjs modules format
 r59 topic: function (name) {
return this._getDestination("topic://" + name);
},
cin
working version...
 r51
cin
working on support commonjs modules format
 r59 _getDestination: function (uri) {
if (uri in this._destinations)
return this._destinations[uri];
var dest = new Destination(this, uri);
this._destinations[uri] = dest;
return dest;
},
cin
working version...
 r51
cin
working on support commonjs modules format
 r59 toString: function () {
return ["[", "SESSION ", this._id, "]"].join(" ");
}
});
cin
working version...
 r51
cin
working on support commonjs modules format
 r59 cls.connect = function (url, options) {
var session = new cls(url, options);
return session.start();
};
cin
working version...
 r51
cin
working on support commonjs modules format
 r59 return cls;
});