ARCHIVE/xahau.js
1
0
Fork 0
mirror of https://github.com/Xahau/xahau.js.git synced 2025-11-20 12:15:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

JS: Fix server requests to use self.

Browse Source
This commit is contained in:
Arthur Britto
2013-04-23 13:43:55 -07:00
committed by Stefan Thomas
parent 79338621f9
commit 957513c14c
1 changed files with 20 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
src/js/server.js
View File

@@ -152,30 +152,35 @@ Server.prototype.disconnect = function ()
*/
Server.prototype.request = function (request)
{
// Only bother if we are still connected.
if (this._ws) {
request.message.id = this._id;
var self = this;
this._requests[request.message.id] = request;
// Only bother if we are still connected.
if (self._ws) {
request.message.id = self._id;
self._requests[request.message.id] = request;
// Advance message ID
this._id++;
self._id++;
if (this._state === "online" ||
(request.message.command === "subscribe" && this._ws.readyState === 1)) {
if (this._remote.trace) {
if (self._state === "online" ||
(request.message.command === "subscribe" && self._ws.readyState === 1)) {
if (self._remote.trace) {
utils.logObject("server: request: %s", request.message);
}
this._ws.send(JSON.stringify(request.message));
self._ws.send(JSON.stringify(request.message));
} else {
// XXX There are many ways to make this smarter.
this.once('connect', function () {
this._ws.send(JSON.stringify(request.message));
// XXX There are many ways to make self smarter.
self.once('connect', function () {
if (self._remote.trace) {
utils.logObject("server: request: %s", request.message);
}
self._ws.send(JSON.stringify(request.message));
});
}
} else {
if (this._remote.trace) {
if (self._remote.trace) {
utils.logObject("server: request: DROPPING: %s", request.message);
}
}
@@ -241,3 +246,5 @@ Server.prototype._handle_response_subscribe = function (message)
};
exports.Server = Server;
// vim:sw=2:sts=2:ts=8:et