nodebb/src/socket.io/modules.js

"use strict";

var	posts = require('../posts'),
	postTools = require('../postTools'),
	topics = require('../topics'),
	meta = require('../meta'),
	Messaging = require('../messaging'),
	user = require('../user'),
	notifications = require('../notifications'),

	async = require('async'),
	S = require('string'),
	winston = require('winston'),

	SocketModules = {};

/* Posts Composer */

SocketModules.composer = {};

SocketModules.composer.push = function(socket, data, callback) {
	if (parseInt(socket.uid, 10) > 0 || parseInt(meta.config.allowGuestPosting, 10) === 1) {
		if (parseInt(data.pid, 10) > 0) {

			async.parallel([
				function(next) {
					posts.getPostFields(data.pid, ['content'], next);
				},
				function(next) {
					topics.getTitleByPid(data.pid, function(title) {
						next(null, title);
					});
				}
			], function(err, results) {
				callback({
					title: results[1],
					pid: data.pid,
					body: results[0].content
				});
			});
		}
	} else {
		callback({
			error: 'no-uid'
		});
	}
};

SocketModules.composer.editCheck = function(socket, pid, callback) {
	posts.getPostField(pid, 'tid', function(err, tid) {
		postTools.isMain(pid, tid, function(err, isMain) {
			callback({
				titleEditable: isMain
			});
		});
	});
};

/* Chat */

SocketModules.chats = {};

SocketModules.chats.get = function(socket, data, callback) {
	var touid = data.touid;
	Messaging.getMessages(socket.uid, touid, function(err, messages) {
		if (err) {
			return callback(null);
		}

		callback(messages);
	});
};

SocketModules.chats.send = function(socket, data) {

	var touid = data.touid;
	if (touid === socket.uid || socket.uid === 0) {
		return;
	}

	var msg = S(data.message).stripTags().s;

	user.getMultipleUserFields([socket.uid, touid], ['username'], function(err, usersData) {
		if(err) {
			return;
		}

		var username = usersData[0].username,
			toUsername = usersData[1].username,
			finalMessage = username + ' : ' + msg,
			notifText = 'New message from <strong>' + username + '</strong>';

		if (!module.parent.exports.isUserOnline(touid)) {
			notifications.create(notifText, 'javascript:app.openChat(&apos;' + username + '&apos;, ' + socket.uid + ');', 'notification_' + socket.uid + '_' + touid, function(nid) {
				notifications.push(nid, [touid], function(success) {

				});
			});
		}
        Messaging.parse(msg, socket.uid, socket.uid, toUsername, function(parsed) {
            Messaging.addMessage(socket.uid, touid, msg, function(err, message) {
                var numSockets = 0,
                    x;

                if (socket.userSockets[touid]) {
                    numSockets = socket.userSockets[touid].length;

                    for (x = 0; x < numSockets; ++x) {
                        socket.userSockets[touid][x].emit('event:chats.receive', {
                            fromuid: socket.uid,
                            username: username,
                            // todo this isnt very nice, but can't think of a better way atm
                            message: parsed.replace("chat-user-you'>You", "'>" + username),
                            timestamp: Date.now()
                        });
                    }
                }

                if (socket.userSockets[socket.uid]) {

                    numSockets = socket.userSockets[socket.uid].length;

                    for (x = 0; x < numSockets; ++x) {
                        socket.userSockets[socket.uid][x].emit('event:chats.receive', {
                            fromuid: touid,
                            username: toUsername,
                            message: parsed,
                            timestamp: Date.now()
                        });
                    }
                }
            });
        });
	});
};

SocketModules.chats.list = function(socket, data, callback) {
	Messaging.getRecentChats(socket.uid, function(err, uids) {
		if (err) {
			winston.warn('[(socket) chats.list] Problem retrieving chats: ' + err.message);
		}

		callback(uids || []);
	});
};

/* Notifications */

SocketModules.notifications = {};

SocketModules.notifications.mark_read = function(socket, nid) {
	notifications.mark_read(nid, socket.uid);
};

SocketModules.notifications.mark_all_read = function(socket, data, callback) {
	notifications.mark_all_read(socket.uid, function(err) {
		if (!err) {
			callback();
		}
	});
};

module.exports = SocketModules;