2014-01-09 22:46:51 -05:00
|
|
|
var meta = require('../meta'),
|
|
|
|
|
user = require('../user'),
|
2014-01-11 14:03:50 -05:00
|
|
|
topics = require('../topics'),
|
2014-01-10 13:27:50 -05:00
|
|
|
logger = require('../logger'),
|
|
|
|
|
plugins = require('../plugins'),
|
2014-01-09 22:46:51 -05:00
|
|
|
|
2014-01-10 13:27:50 -05:00
|
|
|
nconf = require('nconf'),
|
2014-01-10 10:46:26 -05:00
|
|
|
gravatar = require('gravatar'),
|
2014-01-11 14:03:50 -05:00
|
|
|
winston = require('winston'),
|
2014-01-16 15:57:13 -05:00
|
|
|
server = require('./'),
|
2014-01-10 10:46:26 -05:00
|
|
|
|
2014-03-14 00:34:51 -04:00
|
|
|
SocketMeta = {
|
|
|
|
|
rooms: {}
|
|
|
|
|
};
|
2014-01-09 22:46:51 -05:00
|
|
|
|
2014-01-16 15:19:07 -05:00
|
|
|
SocketMeta.reconnected = function(socket) {
|
|
|
|
|
var uid = socket.uid,
|
|
|
|
|
sessionID = socket.id;
|
2014-01-11 14:03:50 -05:00
|
|
|
|
|
|
|
|
if (uid) {
|
|
|
|
|
topics.pushUnreadCount(uid);
|
2014-03-12 18:00:27 -04:00
|
|
|
user.notifications.pushCount(uid);
|
2014-01-11 14:03:50 -05:00
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (process.env.NODE_ENV === 'development') {
|
|
|
|
|
if (uid) {
|
|
|
|
|
winston.info('[socket] uid ' + uid + ' (' + sessionID + ') has successfully reconnected.');
|
|
|
|
|
} else {
|
|
|
|
|
winston.info('[socket] An anonymous user (' + sessionID + ') has successfully reconnected.');
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
};
|
|
|
|
|
|
2014-01-16 15:19:07 -05:00
|
|
|
SocketMeta.buildTitle = function(socket, text, callback) {
|
2014-04-14 15:58:13 -04:00
|
|
|
if (socket.uid) {
|
|
|
|
|
user.getSettings(socket.uid, function(err, settings) {
|
|
|
|
|
if (err) {
|
|
|
|
|
return callback(err);
|
|
|
|
|
}
|
|
|
|
|
meta.title.build(text, settings.language, callback);
|
|
|
|
|
});
|
|
|
|
|
} else {
|
|
|
|
|
meta.title.build(text, meta.config.defaultLang, callback);
|
|
|
|
|
}
|
2014-01-09 22:46:51 -05:00
|
|
|
};
|
|
|
|
|
|
2014-01-16 15:19:07 -05:00
|
|
|
SocketMeta.getUsageStats = function(socket, data, callback) {
|
2014-01-10 10:46:26 -05:00
|
|
|
module.parent.exports.emitTopicPostStats(callback);
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
/* Rooms */
|
|
|
|
|
|
2014-01-16 15:19:07 -05:00
|
|
|
SocketMeta.rooms.enter = function(socket, data) {
|
2014-01-17 12:52:04 -05:00
|
|
|
if(!data) {
|
2014-04-09 21:27:20 -04:00
|
|
|
return callback(new Error('[[error:invalid-data]]'));
|
2014-01-17 12:52:04 -05:00
|
|
|
}
|
|
|
|
|
|
2014-01-10 10:46:26 -05:00
|
|
|
if (data.leave !== null) {
|
2014-01-16 15:19:07 -05:00
|
|
|
socket.leave(data.leave);
|
2014-01-10 10:46:26 -05:00
|
|
|
}
|
|
|
|
|
|
2014-01-16 15:19:07 -05:00
|
|
|
socket.join(data.enter);
|
2014-01-10 10:46:26 -05:00
|
|
|
|
2014-03-01 22:51:39 -05:00
|
|
|
if (data.leave && data.leave !== data.enter) {
|
2014-01-10 10:46:26 -05:00
|
|
|
module.parent.exports.updateRoomBrowsingText(data.leave);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
module.parent.exports.updateRoomBrowsingText(data.enter);
|
|
|
|
|
|
|
|
|
|
if (data.enter != 'admin') {
|
2014-01-26 21:32:53 -05:00
|
|
|
server.in('admin').emit('event:meta.rooms.update', null, server.server.sockets.manager.rooms);
|
2014-01-10 10:46:26 -05:00
|
|
|
}
|
|
|
|
|
};
|
|
|
|
|
|
2014-01-16 15:19:07 -05:00
|
|
|
SocketMeta.rooms.getAll = function(socket, data, callback) {
|
2014-01-26 21:32:53 -05:00
|
|
|
callback(null, server.server.sockets.manager.rooms);
|
2014-01-10 13:27:50 -05:00
|
|
|
};
|
|
|
|
|
|
2014-01-09 22:46:51 -05:00
|
|
|
/* Exports */
|
|
|
|
|
|
2014-04-10 20:31:57 +01:00
|
|
|
module.exports = SocketMeta;
|