faye/faye-redis-node
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Small refactoring of destroyClient() method.

Browse Source
This commit is contained in:
James Coglan
2012-01-22 06:09:06 +00:00
parent eb59130943
commit b50006fb6d
1 changed files with 10 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
faye-redis.js
+10 -12
View File
@@ -72,26 +72,23 @@ Engine.prototype = {
this._redis.smembers(this._ns + '/clients/' + clientId + '/channels', function(error, channels) {
var n = channels.length, i = 0;
if (n === 0) {
self._server.debug('Destroyed client ?', clientId);
self._server.trigger('disconnect', clientId);
if (callback) callback.call(scope);
return;
}
if (i === n) return self.afterDestroy(clientId, callback, scope);
channels.forEach(function(channel) {
self.unsubscribe(clientId, channel, function() {
i += 1;
if (i === n) {
self._server.debug('Destroyed client ?', clientId);
self._server.trigger('disconnect', clientId);
if (callback) callback.call(scope);
}
if (i === n) self.afterDestroy(clientId, callback, scope);
});
});
});
},
afterDestroy: function(clientId, callback, scope) {
this._server.debug('Destroyed client ?', clientId);
this._server.trigger('disconnect', clientId);
if (callback) callback.call(scope);
},
clientExists: function(clientId, callback, scope) {
this._redis.zscore(this._ns + '/clients', clientId, function(error, score) {
callback.call(scope, score !== null);
@@ -156,6 +153,7 @@ Engine.prototype = {
var key = this._ns + '/clients/' + clientId + '/messages',
multi = this._redis.multi(),
self = this;
multi.lrange(key, 0, -1, function(error, jsonMessages) {
var messages = jsonMessages.map(function(json) { return JSON.parse(json) });
self._server.deliver(clientId, messages);