NodeBB/src/socket.io/meta.js

'use strict';

var	nconf = require('nconf'),
	gravatar = require('gravatar'),
	winston = require('winston'),
	validator = require('validator'),

	db = require('../database'),
	meta = require('../meta'),
	user = require('../user'),
	topics = require('../topics'),
	logger = require('../logger'),
	plugins = require('../plugins'),
	emitter = require('../emitter'),

	websockets = require('./'),

	SocketMeta = {
		rooms: {}
	};

SocketMeta.reconnected = function(socket, data, callback) {
	var	uid = socket.uid,
		sessionID = socket.id;

	if (uid) {
		topics.pushUnreadCount(uid);
		user.notifications.pushCount(uid);
	}

	/*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.');
		}
	}*/
};

emitter.on('nodebb:ready', function() {
	websockets.server.sockets.emit('event:nodebb.ready', {
		general: meta.config['cache-buster'],
		css: meta.css.hash,
		js: meta.js.hash
	});
});

SocketMeta.buildTitle = function(socket, text, callback) {
	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);
	}
};

/* Rooms */

SocketMeta.rooms.enter = function(socket, data, callback) {
	if (!socket.uid) {
		return;
	}
	if (!data) {
		return callback(new Error('[[error:invalid-data]]'));
	}

	if (socket.currentRoom) {
		socket.leave(socket.currentRoom);
		if (socket.currentRoom.indexOf('topic') !== -1) {
			websockets.in(socket.currentRoom).emit('event:user_leave', socket.uid);
		}
		socket.currentRoom = '';
	}

	if (data.enter) {
		socket.join(data.enter);
		socket.currentRoom = data.enter;
		if (data.enter.indexOf('topic') !== -1) {
			data.uid = socket.uid;
			websockets.in(data.enter).emit('event:user_enter', data);
		}
	}
};

SocketMeta.rooms.getAll = function(socket, data, callback) {
	var now = Date.now();
	db.sortedSetCount('users:online', now - 300000, now, function(err, onlineRegisteredCount) {
		if (err) {
			return callback(err);
		}

		var rooms = {}; // TODO: websockets.server.sockets.manager.rooms; doesnt work in socket.io 1.x
		var socketData = {
				onlineGuestCount: websockets.getOnlineAnonCount(),
				onlineRegisteredCount: onlineRegisteredCount,
				socketCount: websockets.getSocketCount(),
				users: {
					home: rooms['/home'] ? rooms['/home'].length : 0,
					topics: 0,
					category: 0
				},
				topics: {}
			};

		var scores = {},
			topTenTopics = [],
			tid;

		for (var room in rooms) {
			if (rooms.hasOwnProperty(room)) {
				if (tid = room.match(/^\/topic_(\d+)/)) {
					var length = rooms[room].length;
					socketData.users.topics += length;

					if (scores[length]) {
						scores[length].push(tid[1]);
					} else {
						scores[length] = [tid[1]];
					}
				} else if (room.match(/^\/category/)) {
					socketData.users.category += rooms[room].length;
				}
			}
		}

		var scoreKeys = Object.keys(scores),
			mostActive = scoreKeys.sort();

		while(topTenTopics.length < 10 && mostActive.length > 0) {
			topTenTopics = topTenTopics.concat(scores[mostActive.pop()]);
		}

		topTenTopics = topTenTopics.slice(0, 10);

		topics.getTopicsFields(topTenTopics, ['title'], function(err, titles) {
			if (err) {
				return callback(err);
			}
			topTenTopics.forEach(function(tid, id) {
				socketData.topics[tid] = {
					value: rooms['/topic_' + tid].length,
					title: validator.escape(titles[id].title)
				};
			});

			callback(null, socketData);
		});
	});
};

/* Exports */

module.exports = SocketMeta;