Joshua Gross
127 linhas
4.2 KiB
JavaScript
127 linhas
4.2 KiB
JavaScript
var events = require('events'),
|
|
sys = require('sys'),
|
|
packages = require('../../libs/packages'),
|
|
o_ = require('../../libs/utils'),
|
|
User = require('./user');
|
|
|
|
var Hub = module.exports = function Hub(options) {
|
|
this.events = new events.EventEmitter();
|
|
this.auth = options.authentication;
|
|
this.sessions = {};
|
|
|
|
this.maxAge = options.maxAge || 4 * 60 * 60 * 1000;
|
|
this.reapInterval = options.reapInterval || 60 * 1000;
|
|
|
|
if(this.reapInterval !== -1) {
|
|
setInterval(function(self) {
|
|
self.reap(self.maxAge);
|
|
}, this.reapInterval, this);
|
|
}
|
|
|
|
this.events.addListener('update', o_.bind(function(package) {
|
|
var _package = package.toJSON();
|
|
if(package.type == 'status' && package.status == 'offline') {
|
|
var sids = Object.keys(this.sessions), sid, sess;
|
|
for(sid in this.sessions) {
|
|
sess = this.sessions[sid];
|
|
if(sess.data('username') == package.username) {
|
|
if(sess.listeners.length)
|
|
sess.send(200, {type: 'goodbye'});
|
|
delete this.sessions[sid];
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}, this));
|
|
};
|
|
|
|
Hub.prototype.destroy = function(sid, fn) {
|
|
this.set(sid, null, fn);
|
|
};
|
|
|
|
Hub.prototype.reap = function(ms) {
|
|
var threshold = +new Date - ms,
|
|
sids = Object.keys(this.sessions);
|
|
for(var i = 0, len = sids.length; i < len; ++i) {
|
|
var sid = sids[i], sess = this.sessions[sid];
|
|
if(sess.lastAccess < threshold) {
|
|
this.events.emit('update', new packages.Offline(sess.data('username')));
|
|
}
|
|
}
|
|
};
|
|
|
|
Hub.prototype.get = function(req, fn) {
|
|
if(this.sessions[req.sessionID]) {
|
|
fn(null, this.sessions[req.sessionID]);
|
|
} else {
|
|
this.auth.authenticate(req, o_.bind(function(data) {
|
|
if(data) {
|
|
var session = new User(req.sessionID, data);
|
|
this.set(req.sessionID, session);
|
|
|
|
this.auth.friends(req, data, o_.bind(function(friends) {
|
|
var friends_copy = friends.slice();
|
|
o_.values(this.sessions).filter(function(friend) {
|
|
return ~friends.indexOf(friend.data('username'));
|
|
}).forEach(function(friend) {
|
|
var username = friend.data('username');
|
|
friends_copy[friends_copy.indexOf(username)] =
|
|
[username, friend.status()];
|
|
}, this);
|
|
|
|
session._friends(friends_copy);
|
|
session.events.addListener('status',
|
|
o_.bind(function(value, message) {
|
|
this.events.emit(
|
|
'update',
|
|
new packages.Status(session.data('username'),
|
|
value,
|
|
message)
|
|
);
|
|
}, this));
|
|
this.events.addListener('update',
|
|
o_.bind(session.receivedUpdate, session));
|
|
this.set(req.sessionID, session);
|
|
fn(null, session);
|
|
}, this));
|
|
} else {
|
|
fn();
|
|
}
|
|
}, this));
|
|
}
|
|
};
|
|
|
|
Hub.prototype.set = function(sid, sess, fn) {
|
|
this.sessions[sid] = sess;
|
|
fn && fn();
|
|
};
|
|
|
|
Hub.prototype.find = function(username, fn) {
|
|
for(var sid in this.sessions) {
|
|
var session = this.sessions[sid],
|
|
sess_username = session.data('username');
|
|
if(sess_username == username) {
|
|
fn(session);
|
|
return;
|
|
}
|
|
}
|
|
fn(false);
|
|
};
|
|
|
|
Hub.prototype.message = function(from, to, package) {
|
|
try {
|
|
package.user = from;
|
|
to.send(package);
|
|
from.respond(new packages.Success('sent'));
|
|
} catch(e) {
|
|
from.respond(new packages.Error(e.description));
|
|
}
|
|
};
|
|
|
|
Hub.prototype.signOff = function(sid) {
|
|
if(sid in this.sessions)
|
|
this.events.emit('update',
|
|
new packages.Offline(
|
|
this.sessions[sid].data('username')));
|
|
};
|