|
|
|
|
@ -1,22 +1,27 @@
|
|
|
|
|
'use strict';
|
|
|
|
|
|
|
|
|
|
var db = require('./database'),
|
|
|
|
|
async = require('async'),
|
|
|
|
|
nconf = require('nconf'),
|
|
|
|
|
|
|
|
|
|
var async = require('async'),
|
|
|
|
|
winston = require('winston'),
|
|
|
|
|
S = require('string'),
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
db = require('./database'),
|
|
|
|
|
user = require('./user'),
|
|
|
|
|
plugins = require('./plugins'),
|
|
|
|
|
meta = require('./meta'),
|
|
|
|
|
utils = require('../public/src/utils'),
|
|
|
|
|
notifications = require('./notifications'),
|
|
|
|
|
userNotifications = require('./user/notifications'),
|
|
|
|
|
emailer = require('./emailer'),
|
|
|
|
|
sockets = require('./socket.io');
|
|
|
|
|
userNotifications = require('./user/notifications');
|
|
|
|
|
|
|
|
|
|
(function(Messaging) {
|
|
|
|
|
Messaging.notifyQueue = {}; // Only used to notify a user of a new chat message, see Messaging.notifyUser
|
|
|
|
|
|
|
|
|
|
require('./messaging/create')(Messaging);
|
|
|
|
|
require('./messaging/delete')(Messaging);
|
|
|
|
|
require('./messaging/edit')(Messaging);
|
|
|
|
|
require('./messaging/rooms')(Messaging);
|
|
|
|
|
require('./messaging/unread')(Messaging);
|
|
|
|
|
require('./messaging/notifications')(Messaging);
|
|
|
|
|
|
|
|
|
|
var terms = {
|
|
|
|
|
day: 86400000,
|
|
|
|
|
@ -25,147 +30,9 @@ var db = require('./database'),
|
|
|
|
|
threemonths: 7776000000
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
function sortUids(fromuid, touid) {
|
|
|
|
|
return [fromuid, touid].sort();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
Messaging.addMessage = function(fromuid, touid, content, timestamp, callback) {
|
|
|
|
|
if (typeof timestamp === 'function') {
|
|
|
|
|
callback = timestamp;
|
|
|
|
|
timestamp = Date.now();
|
|
|
|
|
} else {
|
|
|
|
|
timestamp = timestamp || Date.now();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (!content) {
|
|
|
|
|
return callback(new Error('[[error:invalid-chat-message]]'));
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (content.length > (meta.config.maximumChatMessageLength || 1000)) {
|
|
|
|
|
return callback(new Error('[[error:chat-message-too-long]]'));
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
var uids = sortUids(fromuid, touid);
|
|
|
|
|
|
|
|
|
|
db.incrObjectField('global', 'nextMid', function(err, mid) {
|
|
|
|
|
if (err) {
|
|
|
|
|
return callback(err);
|
|
|
|
|
}
|
|
|
|
|
var message = {
|
|
|
|
|
content: content,
|
|
|
|
|
timestamp: timestamp,
|
|
|
|
|
fromuid: fromuid,
|
|
|
|
|
touid: touid
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
async.waterfall([
|
|
|
|
|
function(next) {
|
|
|
|
|
plugins.fireHook('filter:messaging.save', message, next);
|
|
|
|
|
},
|
|
|
|
|
function(message, next) {
|
|
|
|
|
db.setObject('message:' + mid, message, next);
|
|
|
|
|
}
|
|
|
|
|
], function(err) {
|
|
|
|
|
if (err) {
|
|
|
|
|
return callback(err);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
async.parallel([
|
|
|
|
|
async.apply(db.sortedSetAdd, 'messages:uid:' + uids[0] + ':to:' + uids[1], timestamp, mid),
|
|
|
|
|
async.apply(Messaging.updateChatTime, fromuid, touid),
|
|
|
|
|
async.apply(Messaging.updateChatTime, touid, fromuid),
|
|
|
|
|
async.apply(Messaging.markRead, fromuid, touid),
|
|
|
|
|
async.apply(Messaging.markUnread, touid, fromuid),
|
|
|
|
|
], function(err) {
|
|
|
|
|
if (err) {
|
|
|
|
|
return callback(err);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
async.waterfall([
|
|
|
|
|
function(next) {
|
|
|
|
|
getMessages([mid], fromuid, touid, true, next);
|
|
|
|
|
},
|
|
|
|
|
function(messages, next) {
|
|
|
|
|
Messaging.isNewSet(fromuid, touid, mid, function(err, isNewSet) {
|
|
|
|
|
if (err) {
|
|
|
|
|
return next(err);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (!messages || !messages[0]) {
|
|
|
|
|
return next(null, null);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
messages[0].newSet = isNewSet;
|
|
|
|
|
messages[0].mid = mid;
|
|
|
|
|
next(null, messages[0]);
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|
], callback);
|
|
|
|
|
});
|
|
|
|
|
});
|
|
|
|
|
});
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
Messaging.editMessage = function(mid, content, callback) {
|
|
|
|
|
async.series([
|
|
|
|
|
function(next) {
|
|
|
|
|
// Verify that the message actually changed
|
|
|
|
|
Messaging.getMessageField(mid, 'content', function(err, raw) {
|
|
|
|
|
if (raw === content) {
|
|
|
|
|
// No dice.
|
|
|
|
|
return callback();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
next();
|
|
|
|
|
});
|
|
|
|
|
},
|
|
|
|
|
async.apply(Messaging.setMessageFields, mid, {
|
|
|
|
|
content: content,
|
|
|
|
|
edited: Date.now()
|
|
|
|
|
}),
|
|
|
|
|
function(next) {
|
|
|
|
|
Messaging.getMessageFields(mid, ['fromuid', 'touid'], function(err, data) {
|
|
|
|
|
getMessages([mid], data.fromuid, data.touid, true, function(err, messages) {
|
|
|
|
|
sockets.in('uid_' + data.fromuid).emit('event:chats.edit', {
|
|
|
|
|
messages: messages
|
|
|
|
|
});
|
|
|
|
|
sockets.in('uid_' + data.touid).emit('event:chats.edit', {
|
|
|
|
|
messages: messages
|
|
|
|
|
});
|
|
|
|
|
next();
|
|
|
|
|
});
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|
], callback);
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
Messaging.deleteMessage = function(mid, callback) {
|
|
|
|
|
var uids = [];
|
|
|
|
|
async.series([
|
|
|
|
|
function(next) {
|
|
|
|
|
db.getObject('message:' + mid, function(err, messageObj) {
|
|
|
|
|
messageObj.fromuid = parseInt(messageObj.fromuid, 10);
|
|
|
|
|
messageObj.touid = parseInt(messageObj.touid, 10);
|
|
|
|
|
uids.push(messageObj.fromuid, messageObj.touid);
|
|
|
|
|
uids.sort(function(a, b) {
|
|
|
|
|
return a > b ? 1 : -1;
|
|
|
|
|
});
|
|
|
|
|
next();
|
|
|
|
|
});
|
|
|
|
|
},
|
|
|
|
|
function(next) {
|
|
|
|
|
next();
|
|
|
|
|
},
|
|
|
|
|
function(next) {
|
|
|
|
|
db.sortedSetRemove('messages:uid:' + uids[0] + ':to:' + uids[1], mid, next);
|
|
|
|
|
},
|
|
|
|
|
async.apply(db.delete, 'message:' + mid)
|
|
|
|
|
], callback);
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
Messaging.getMessageField = function(mid, field, callback) {
|
|
|
|
|
Messaging.getMessageFields(mid, [field], function(err, fields) {
|
|
|
|
|
callback(err, fields[field]);
|
|
|
|
|
callback(err, fields ? fields[field] : null);
|
|
|
|
|
});
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
@ -182,22 +49,21 @@ var db = require('./database'),
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
Messaging.getMessages = function(params, callback) {
|
|
|
|
|
var fromuid = params.fromuid,
|
|
|
|
|
touid = params.touid,
|
|
|
|
|
var uid = params.uid,
|
|
|
|
|
roomId = params.roomId,
|
|
|
|
|
since = params.since,
|
|
|
|
|
isNew = params.isNew,
|
|
|
|
|
count = params.count || parseInt(meta.config.chatMessageInboxSize, 10) || 250,
|
|
|
|
|
markRead = params.markRead || true;
|
|
|
|
|
|
|
|
|
|
var uids = sortUids(fromuid, touid),
|
|
|
|
|
min = params.count ? 0 : Date.now() - (terms[since] || terms.day);
|
|
|
|
|
var min = params.count ? 0 : Date.now() - (terms[since] || terms.day);
|
|
|
|
|
|
|
|
|
|
if (since === 'recent') {
|
|
|
|
|
count = 49;
|
|
|
|
|
min = 0;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
db.getSortedSetRevRangeByScore('messages:uid:' + uids[0] + ':to:' + uids[1], 0, count, '+inf', min, function(err, mids) {
|
|
|
|
|
db.getSortedSetRevRangeByScore('uid:' + uid + ':chat:room:' + roomId + ':mids', 0, count, '+inf', min, function(err, mids) {
|
|
|
|
|
if (err) {
|
|
|
|
|
return callback(err);
|
|
|
|
|
}
|
|
|
|
|
@ -208,115 +74,122 @@ var db = require('./database'),
|
|
|
|
|
|
|
|
|
|
mids.reverse();
|
|
|
|
|
|
|
|
|
|
getMessages(mids, fromuid, touid, isNew, callback);
|
|
|
|
|
Messaging.getMessagesData(mids, uid, roomId, isNew, callback);
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
if (markRead) {
|
|
|
|
|
notifications.markRead('chat_' + touid + '_' + fromuid, fromuid, function(err) {
|
|
|
|
|
notifications.markRead('chat_' + roomId + '_' + uid, uid, function(err) {
|
|
|
|
|
if (err) {
|
|
|
|
|
winston.error('[messaging] Could not mark notifications related to this chat as read: ' + err.message);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
userNotifications.pushCount(fromuid);
|
|
|
|
|
userNotifications.pushCount(uid);
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
function getMessages(mids, fromuid, touid, isNew, callback) {
|
|
|
|
|
user.getUsersFields([fromuid, touid], ['uid', 'username', 'userslug', 'picture', 'status'], function(err, userData) {
|
|
|
|
|
if(err) {
|
|
|
|
|
return callback(err);
|
|
|
|
|
}
|
|
|
|
|
Messaging.getMessagesData = function(mids, uid, roomId, isNew, callback) {
|
|
|
|
|
|
|
|
|
|
var keys = mids.map(function(mid) {
|
|
|
|
|
return 'message:' + mid;
|
|
|
|
|
});
|
|
|
|
|
var keys = mids.map(function(mid) {
|
|
|
|
|
return 'message:' + mid;
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
async.waterfall([
|
|
|
|
|
async.apply(db.getObjects, keys),
|
|
|
|
|
function(messages, next) {
|
|
|
|
|
messages = messages.map(function(msg, idx) {
|
|
|
|
|
if (msg) {
|
|
|
|
|
msg.messageId = parseInt(mids[idx], 10);
|
|
|
|
|
}
|
|
|
|
|
return msg;
|
|
|
|
|
}).filter(Boolean);
|
|
|
|
|
async.map(messages, function(message, next) {
|
|
|
|
|
var self = parseInt(message.fromuid, 10) === parseInt(fromuid, 10);
|
|
|
|
|
message.fromUser = self ? userData[0] : userData[1];
|
|
|
|
|
message.toUser = self ? userData[1] : userData[0];
|
|
|
|
|
message.timestampISO = utils.toISOString(message.timestamp);
|
|
|
|
|
message.self = self ? 1 : 0;
|
|
|
|
|
message.newSet = false;
|
|
|
|
|
|
|
|
|
|
if (message.hasOwnProperty('edited')) {
|
|
|
|
|
message.editedISO = new Date(parseInt(message.edited, 10)).toISOString();
|
|
|
|
|
}
|
|
|
|
|
var messages;
|
|
|
|
|
|
|
|
|
|
Messaging.parse(message.content, message.fromuid, fromuid, userData[1], userData[0], isNew, function(result) {
|
|
|
|
|
message.content = result;
|
|
|
|
|
message.cleanedContent = S(result).stripTags().decodeHTMLEntities().s;
|
|
|
|
|
next(null, message);
|
|
|
|
|
});
|
|
|
|
|
}, next);
|
|
|
|
|
},
|
|
|
|
|
function(messages, next) {
|
|
|
|
|
if (messages.length > 1) {
|
|
|
|
|
// Add a spacer in between messages with time gaps between them
|
|
|
|
|
messages = messages.map(function(message, index) {
|
|
|
|
|
// Compare timestamps with the previous message, and check if a spacer needs to be added
|
|
|
|
|
if (index > 0 && parseInt(message.timestamp, 10) > parseInt(messages[index-1].timestamp, 10) + (1000*60*5)) {
|
|
|
|
|
// If it's been 5 minutes, this is a new set of messages
|
|
|
|
|
message.newSet = true;
|
|
|
|
|
} else if (index > 0 && message.fromuid !== messages[index-1].fromuid) {
|
|
|
|
|
// If the previous message was from the other person, this is also a new set
|
|
|
|
|
message.newSet = true;
|
|
|
|
|
}
|
|
|
|
|
async.waterfall([
|
|
|
|
|
function (next) {
|
|
|
|
|
db.getObjects(keys, next);
|
|
|
|
|
},
|
|
|
|
|
function (_messages, next) {
|
|
|
|
|
messages = _messages.map(function(msg, idx) {
|
|
|
|
|
if (msg) {
|
|
|
|
|
msg.messageId = parseInt(mids[idx], 10);
|
|
|
|
|
}
|
|
|
|
|
return msg;
|
|
|
|
|
}).filter(Boolean);
|
|
|
|
|
|
|
|
|
|
return message;
|
|
|
|
|
});
|
|
|
|
|
var uids = messages.map(function(msg) {
|
|
|
|
|
return msg && msg.fromuid;
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
next(undefined, messages);
|
|
|
|
|
} else {
|
|
|
|
|
// For single messages, we don't know the context, so look up the previous message and compare
|
|
|
|
|
var uids = [fromuid, touid].sort(function(a, b) { return a > b ? 1 : -1 });
|
|
|
|
|
var key = 'messages:uid:' + uids[0] + ':to:' + uids[1];
|
|
|
|
|
async.waterfall([
|
|
|
|
|
async.apply(db.sortedSetRank, key, messages[0].messageId),
|
|
|
|
|
function(index, next) {
|
|
|
|
|
// Continue only if this isn't the first message in sorted set
|
|
|
|
|
if (index > 0) {
|
|
|
|
|
db.getSortedSetRange(key, index-1, index-1, next);
|
|
|
|
|
} else {
|
|
|
|
|
messages[0].newSet = true;
|
|
|
|
|
return next(undefined, messages);
|
|
|
|
|
}
|
|
|
|
|
},
|
|
|
|
|
function(mid, next) {
|
|
|
|
|
Messaging.getMessageFields(mid, ['fromuid', 'timestamp'], next);
|
|
|
|
|
}
|
|
|
|
|
], function(err, fields) {
|
|
|
|
|
if (err) {
|
|
|
|
|
return next(err);
|
|
|
|
|
}
|
|
|
|
|
user.getUsersFields(uids, ['uid', 'username', 'userslug', 'picture', 'status'], next);
|
|
|
|
|
},
|
|
|
|
|
function (users, next) {
|
|
|
|
|
messages.forEach(function(message, index) {
|
|
|
|
|
message.fromUser = users[index];
|
|
|
|
|
var self = parseInt(message.fromuid, 10) === parseInt(uid, 10);
|
|
|
|
|
message.self = self ? 1 : 0;
|
|
|
|
|
message.timestampISO = utils.toISOString(message.timestamp);
|
|
|
|
|
message.newSet = false;
|
|
|
|
|
if (message.hasOwnProperty('edited')) {
|
|
|
|
|
message.editedISO = new Date(parseInt(message.edited, 10)).toISOString();
|
|
|
|
|
}
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
async.map(messages, function(message, next) {
|
|
|
|
|
Messaging.parse(message.content, message.fromuid, uid, roomId, isNew, function(result) {
|
|
|
|
|
message.content = result;
|
|
|
|
|
message.cleanedContent = S(result).stripTags().decodeHTMLEntities().s;
|
|
|
|
|
next(null, message);
|
|
|
|
|
});
|
|
|
|
|
}, next);
|
|
|
|
|
},
|
|
|
|
|
function(messages, next) {
|
|
|
|
|
if (messages.length > 1) {
|
|
|
|
|
// Add a spacer in between messages with time gaps between them
|
|
|
|
|
messages = messages.map(function(message, index) {
|
|
|
|
|
// Compare timestamps with the previous message, and check if a spacer needs to be added
|
|
|
|
|
if (index > 0 && parseInt(message.timestamp, 10) > parseInt(messages[index-1].timestamp, 10) + (1000*60*5)) {
|
|
|
|
|
// If it's been 5 minutes, this is a new set of messages
|
|
|
|
|
message.newSet = true;
|
|
|
|
|
} else if (index > 0 && message.fromuid !== messages[index-1].fromuid) {
|
|
|
|
|
// If the previous message was from the other person, this is also a new set
|
|
|
|
|
message.newSet = true;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (
|
|
|
|
|
(parseInt(messages[0].timestamp, 10) > parseInt(fields.timestamp, 10) + (1000*60*5)) ||
|
|
|
|
|
(parseInt(messages[0].fromuid, 10) !== parseInt(fields.fromuid, 10))
|
|
|
|
|
) {
|
|
|
|
|
// If it's been 5 minutes, this is a new set of messages
|
|
|
|
|
return message;
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
next(undefined, messages);
|
|
|
|
|
} else {
|
|
|
|
|
// For single messages, we don't know the context, so look up the previous message and compare
|
|
|
|
|
var key = 'uid:' + uid + ':chat:room:' + roomId + ':mids';
|
|
|
|
|
async.waterfall([
|
|
|
|
|
async.apply(db.sortedSetRank, key, messages[0].messageId),
|
|
|
|
|
function(index, next) {
|
|
|
|
|
// Continue only if this isn't the first message in sorted set
|
|
|
|
|
if (index > 0) {
|
|
|
|
|
db.getSortedSetRange(key, index-1, index-1, next);
|
|
|
|
|
} else {
|
|
|
|
|
messages[0].newSet = true;
|
|
|
|
|
return next(undefined, messages);
|
|
|
|
|
}
|
|
|
|
|
},
|
|
|
|
|
function(mid, next) {
|
|
|
|
|
Messaging.getMessageFields(mid, ['fromuid', 'timestamp'], next);
|
|
|
|
|
}
|
|
|
|
|
], function(err, fields) {
|
|
|
|
|
if (err) {
|
|
|
|
|
return next(err);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
next(undefined, messages);
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|
if (
|
|
|
|
|
(parseInt(messages[0].timestamp, 10) > parseInt(fields.timestamp, 10) + (1000*60*5)) ||
|
|
|
|
|
(parseInt(messages[0].fromuid, 10) !== parseInt(fields.fromuid, 10))
|
|
|
|
|
) {
|
|
|
|
|
// If it's been 5 minutes, this is a new set of messages
|
|
|
|
|
messages[0].newSet = true;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
next(undefined, messages);
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|
], callback);
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
], callback);
|
|
|
|
|
|
|
|
|
|
Messaging.parse = function (message, fromuid, myuid, toUserData, myUserData, isNew, callback) {
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
Messaging.parse = function (message, fromuid, uid, roomId, isNew, callback) {
|
|
|
|
|
plugins.fireHook('filter:parse.raw', message, function(err, parsed) {
|
|
|
|
|
if (err) {
|
|
|
|
|
return callback(message);
|
|
|
|
|
@ -326,9 +199,8 @@ var db = require('./database'),
|
|
|
|
|
message: message,
|
|
|
|
|
parsed: parsed,
|
|
|
|
|
fromuid: fromuid,
|
|
|
|
|
myuid: myuid,
|
|
|
|
|
toUserData: toUserData,
|
|
|
|
|
myUserData: myUserData,
|
|
|
|
|
uid: uid,
|
|
|
|
|
roomId: roomId,
|
|
|
|
|
isNew: isNew,
|
|
|
|
|
parsedMessage: parsed
|
|
|
|
|
};
|
|
|
|
|
@ -339,161 +211,107 @@ var db = require('./database'),
|
|
|
|
|
});
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
Messaging.isNewSet = function(fromuid, touid, mid, callback) {
|
|
|
|
|
var uids = sortUids(fromuid, touid),
|
|
|
|
|
setKey = 'messages:uid:' + uids[0] + ':to:' + uids[1];
|
|
|
|
|
Messaging.isNewSet = function(uid, roomId, timestamp, callback) {
|
|
|
|
|
var setKey = 'uid:' + uid + ':chat:room:' + roomId + ':mids';
|
|
|
|
|
|
|
|
|
|
async.waterfall([
|
|
|
|
|
async.apply(db.sortedSetRank, setKey, mid),
|
|
|
|
|
function(index, next) {
|
|
|
|
|
if (index > 0) {
|
|
|
|
|
db.getSortedSetRange(setKey, index-1, index, next);
|
|
|
|
|
} else {
|
|
|
|
|
next(null, true);
|
|
|
|
|
}
|
|
|
|
|
},
|
|
|
|
|
function(mids, next) {
|
|
|
|
|
if (typeof mids !== 'boolean' && mids && mids.length) {
|
|
|
|
|
db.getObjects(['message:' + mids[0], 'message:' + mids[1]], next);
|
|
|
|
|
} else {
|
|
|
|
|
next(null, mids);
|
|
|
|
|
}
|
|
|
|
|
function(next) {
|
|
|
|
|
db.getSortedSetRevRangeWithScores(setKey, 0, 0, next);
|
|
|
|
|
},
|
|
|
|
|
function(messages, next) {
|
|
|
|
|
if (typeof messages !== 'boolean' && messages && messages.length) {
|
|
|
|
|
next(null, parseInt(messages[1].timestamp, 10) > parseInt(messages[0].timestamp, 10) + (1000*60*5));
|
|
|
|
|
if (messages && messages.length) {
|
|
|
|
|
next(null, parseInt(timestamp, 10) > parseInt(messages[0].score, 10) + (1000 * 60 * 5));
|
|
|
|
|
} else {
|
|
|
|
|
next(null, messages);
|
|
|
|
|
next(null, true);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
], callback);
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
Messaging.updateChatTime = function(uid, toUid, callback) {
|
|
|
|
|
callback = callback || function() {};
|
|
|
|
|
db.sortedSetAdd('uid:' + uid + ':chats', Date.now(), toUid, callback);
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
Messaging.getRecentChats = function(uid, start, stop, callback) {
|
|
|
|
|
db.getSortedSetRevRange('uid:' + uid + ':chats', start, stop, function(err, uids) {
|
|
|
|
|
db.getSortedSetRevRange('uid:' + uid + ':chat:rooms', start, stop, function(err, roomIds) {
|
|
|
|
|
if (err) {
|
|
|
|
|
return callback(err);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
async.parallel({
|
|
|
|
|
unread: function(next) {
|
|
|
|
|
db.isSortedSetMembers('uid:' + uid + ':chats:unread', uids, next);
|
|
|
|
|
db.isSortedSetMembers('uid:' + uid + ':chat:rooms:unread', roomIds, next);
|
|
|
|
|
},
|
|
|
|
|
users: function(next) {
|
|
|
|
|
user.getUsersFields(uids, ['uid', 'username', 'picture', 'status', 'lastonline'] , next);
|
|
|
|
|
async.map(roomIds, function(roomId, next) {
|
|
|
|
|
db.getSortedSetRevRange('chat:room:' + roomId + ':uids', 0, 3, function(err, uids) {
|
|
|
|
|
if (err) {
|
|
|
|
|
return next(err);
|
|
|
|
|
}
|
|
|
|
|
uids = uids.filter(function(value) {
|
|
|
|
|
return value && parseInt(value, 10) !== parseInt(uid, 10);
|
|
|
|
|
});
|
|
|
|
|
user.getUsersFields(uids, ['uid', 'username', 'picture', 'status', 'lastonline'] , next);
|
|
|
|
|
});
|
|
|
|
|
}, next);
|
|
|
|
|
},
|
|
|
|
|
teasers: function(next) {
|
|
|
|
|
async.map(uids, function(fromuid, next) {
|
|
|
|
|
Messaging.getMessages({
|
|
|
|
|
fromuid: fromuid,
|
|
|
|
|
touid: uid,
|
|
|
|
|
isNew: false,
|
|
|
|
|
count: 1,
|
|
|
|
|
markRead: false
|
|
|
|
|
}, function(err, teaser) {
|
|
|
|
|
teaser = teaser[0];
|
|
|
|
|
teaser.content = S(teaser.content).stripTags().decodeHTMLEntities().s;
|
|
|
|
|
next(err, teaser);
|
|
|
|
|
});
|
|
|
|
|
async.map(roomIds, function(roomId, next) {
|
|
|
|
|
Messaging.getTeaser(uid, roomId, next);
|
|
|
|
|
}, next);
|
|
|
|
|
}
|
|
|
|
|
}, function(err, results) {
|
|
|
|
|
if (err) {
|
|
|
|
|
return callback(err);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
results.users.forEach(function(userData, index) {
|
|
|
|
|
if (userData && parseInt(userData.uid, 10)) {
|
|
|
|
|
userData.unread = results.unread[index];
|
|
|
|
|
userData.status = user.getStatus(userData);
|
|
|
|
|
userData.teaser = results.teasers[index];
|
|
|
|
|
}
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
results.users = results.users.filter(function(user) {
|
|
|
|
|
return user && parseInt(user.uid, 10);
|
|
|
|
|
var rooms = results.users.map(function(users, index) {
|
|
|
|
|
var data = {
|
|
|
|
|
users: users,
|
|
|
|
|
unread: results.unread[index],
|
|
|
|
|
roomId: roomIds[index],
|
|
|
|
|
teaser: results.teasers[index]
|
|
|
|
|
};
|
|
|
|
|
data.users.forEach(function(userData) {
|
|
|
|
|
if (userData && parseInt(userData.uid, 10)) {
|
|
|
|
|
userData.status = user.getStatus(userData);
|
|
|
|
|
}
|
|
|
|
|
});
|
|
|
|
|
data.users = data.users.filter(function(user) {
|
|
|
|
|
return user && parseInt(user.uid, 10);
|
|
|
|
|
});
|
|
|
|
|
data.lastUser = data.users[0];
|
|
|
|
|
data.usernames = data.users.map(function(user) {
|
|
|
|
|
return user.username;
|
|
|
|
|
}).join(', ');
|
|
|
|
|
return data;
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
callback(null, {users: results.users, nextStart: stop + 1});
|
|
|
|
|
callback(null, {rooms: rooms, nextStart: stop + 1});
|
|
|
|
|
});
|
|
|
|
|
});
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
Messaging.getUnreadCount = function(uid, callback) {
|
|
|
|
|
db.sortedSetCard('uid:' + uid + ':chats:unread', callback);
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
Messaging.pushUnreadCount = function(uid) {
|
|
|
|
|
Messaging.getUnreadCount(uid, function(err, unreadCount) {
|
|
|
|
|
if (err) {
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
sockets.in('uid_' + uid).emit('event:unread.updateChatCount', unreadCount);
|
|
|
|
|
});
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
Messaging.markRead = function(uid, toUid, callback) {
|
|
|
|
|
db.sortedSetRemove('uid:' + uid + ':chats:unread', toUid, callback);
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
Messaging.markUnread = function(uid, toUid, callback) {
|
|
|
|
|
Messaging.getTeaser = function (uid, roomId, callback) {
|
|
|
|
|
async.waterfall([
|
|
|
|
|
function (next) {
|
|
|
|
|
user.exists(toUid, next);
|
|
|
|
|
db.getSortedSetRevRange('uid:' + uid + ':chat:room:' + roomId + ':mids', 0, 0, next);
|
|
|
|
|
},
|
|
|
|
|
function (exists, next) {
|
|
|
|
|
if (!exists) {
|
|
|
|
|
return next(new Error('[[error:no-user]]'));
|
|
|
|
|
function (mids, next) {
|
|
|
|
|
if (!mids || !mids.length) {
|
|
|
|
|
return next(null, null);
|
|
|
|
|
}
|
|
|
|
|
db.sortedSetAdd('uid:' + uid + ':chats:unread', Date.now(), toUid, next);
|
|
|
|
|
Messaging.getMessageFields(mids[0], ['content', 'timestamp'], next);
|
|
|
|
|
},
|
|
|
|
|
function (teaser, next) {
|
|
|
|
|
if (teaser && teaser.content) {
|
|
|
|
|
teaser.content = S(teaser.content).stripTags().decodeHTMLEntities().s;
|
|
|
|
|
teaser.timestampISO = utils.toISOString(teaser.timestamp);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
next(null, teaser);
|
|
|
|
|
}
|
|
|
|
|
], callback);
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
Messaging.notifyUser = function(fromuid, touid, messageObj) {
|
|
|
|
|
// Immediate notifications
|
|
|
|
|
// Recipient
|
|
|
|
|
Messaging.pushUnreadCount(touid);
|
|
|
|
|
sockets.in('uid_' + touid).emit('event:chats.receive', {
|
|
|
|
|
withUid: fromuid,
|
|
|
|
|
message: messageObj,
|
|
|
|
|
self: 0
|
|
|
|
|
});
|
|
|
|
|
// Sender
|
|
|
|
|
Messaging.pushUnreadCount(fromuid);
|
|
|
|
|
sockets.in('uid_' + fromuid).emit('event:chats.receive', {
|
|
|
|
|
withUid: touid,
|
|
|
|
|
message: messageObj,
|
|
|
|
|
self: 1
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
// Delayed notifications
|
|
|
|
|
var queueObj = Messaging.notifyQueue[fromuid + ':' + touid];
|
|
|
|
|
if (queueObj) {
|
|
|
|
|
queueObj.message.content += '\n' + messageObj.content;
|
|
|
|
|
clearTimeout(queueObj.timeout);
|
|
|
|
|
} else {
|
|
|
|
|
queueObj = Messaging.notifyQueue[fromuid + ':' + touid] = {
|
|
|
|
|
message: messageObj
|
|
|
|
|
};
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
queueObj.timeout = setTimeout(function() {
|
|
|
|
|
sendNotifications(fromuid, touid, queueObj.message, function(err) {
|
|
|
|
|
if (!err) {
|
|
|
|
|
delete Messaging.notifyQueue[fromuid + ':' + touid];
|
|
|
|
|
}
|
|
|
|
|
});
|
|
|
|
|
}, 1000*60); // wait 60s before sending
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
Messaging.canMessage = function(fromUid, toUid, callback) {
|
|
|
|
|
if (parseInt(meta.config.disableChat) === 1 || !fromUid || toUid === fromUid) {
|
|
|
|
|
Messaging.canMessageUser = function(uid, toUid, callback) {
|
|
|
|
|
if (parseInt(meta.config.disableChat) === 1 || !uid || uid === toUid) {
|
|
|
|
|
return callback(null, false);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -505,7 +323,7 @@ var db = require('./database'),
|
|
|
|
|
if (!exists) {
|
|
|
|
|
return callback(null, false);
|
|
|
|
|
}
|
|
|
|
|
user.getUserFields(fromUid, ['banned', 'email:confirmed'], next);
|
|
|
|
|
user.getUserFields(uid, ['banned', 'email:confirmed'], next);
|
|
|
|
|
},
|
|
|
|
|
function (userData, next) {
|
|
|
|
|
if (parseInt(userData.banned, 10) === 1) {
|
|
|
|
|
@ -523,24 +341,31 @@ var db = require('./database'),
|
|
|
|
|
return callback(null, true);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
user.isAdministrator(fromUid, next);
|
|
|
|
|
user.isAdministrator(uid, next);
|
|
|
|
|
},
|
|
|
|
|
function(isAdmin, next) {
|
|
|
|
|
if (isAdmin) {
|
|
|
|
|
return callback(null, true);
|
|
|
|
|
}
|
|
|
|
|
user.isFollowing(toUid, fromUid, next);
|
|
|
|
|
user.isFollowing(toUid, uid, next);
|
|
|
|
|
}
|
|
|
|
|
], callback);
|
|
|
|
|
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
Messaging.canEdit = function(messageId, uid, callback) {
|
|
|
|
|
if (parseInt(meta.config.disableChat) === 1) {
|
|
|
|
|
Messaging.canMessageRoom = function(uid, roomId, callback) {
|
|
|
|
|
if (parseInt(meta.config.disableChat) === 1 || !uid) {
|
|
|
|
|
return callback(null, false);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
async.waterfall([
|
|
|
|
|
function (next) {
|
|
|
|
|
Messaging.isUserInRoom(uid, roomId, next);
|
|
|
|
|
},
|
|
|
|
|
function (inRoom, next) {
|
|
|
|
|
if (!inRoom) {
|
|
|
|
|
return callback(null, false);
|
|
|
|
|
}
|
|
|
|
|
user.getUserFields(uid, ['banned', 'email:confirmed'], next);
|
|
|
|
|
},
|
|
|
|
|
function (userData, next) {
|
|
|
|
|
@ -552,54 +377,10 @@ var db = require('./database'),
|
|
|
|
|
return callback(null, false);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
Messaging.getMessageField(messageId, 'fromuid', next);
|
|
|
|
|
},
|
|
|
|
|
function(fromUid, next) {
|
|
|
|
|
if (parseInt(fromUid, 10) === parseInt(uid, 10)) {
|
|
|
|
|
return callback(null, true);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
user.isAdministrator(uid, next);
|
|
|
|
|
},
|
|
|
|
|
function(isAdmin, next) {
|
|
|
|
|
next(null, isAdmin);
|
|
|
|
|
next(null, true);
|
|
|
|
|
}
|
|
|
|
|
], callback);
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
function sendNotifications(fromuid, touid, messageObj, callback) {
|
|
|
|
|
user.isOnline(touid, function(err, isOnline) {
|
|
|
|
|
if (err || isOnline) {
|
|
|
|
|
return callback(err);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
notifications.create({
|
|
|
|
|
bodyShort: '[[notifications:new_message_from, ' + messageObj.fromUser.username + ']]',
|
|
|
|
|
bodyLong: messageObj.content,
|
|
|
|
|
nid: 'chat_' + fromuid + '_' + touid,
|
|
|
|
|
from: fromuid,
|
|
|
|
|
path: '/chats/' + messageObj.fromUser.username
|
|
|
|
|
}, function(err, notification) {
|
|
|
|
|
if (!err && notification) {
|
|
|
|
|
notifications.push(notification, [touid], callback);
|
|
|
|
|
}
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
user.getSettings(messageObj.toUser.uid, function(err, settings) {
|
|
|
|
|
if (settings.sendChatNotifications && !parseInt(meta.config.disableEmailSubscriptions, 10)) {
|
|
|
|
|
emailer.send('notif_chat', touid, {
|
|
|
|
|
subject: '[[email:notif.chat.subject, ' + messageObj.fromUser.username + ']]',
|
|
|
|
|
username: messageObj.toUser.username,
|
|
|
|
|
userslug: utils.slugify(messageObj.toUser.username),
|
|
|
|
|
summary: '[[notifications:new_message_from, ' + messageObj.fromUser.username + ']]',
|
|
|
|
|
message: messageObj,
|
|
|
|
|
site_title: meta.config.title || 'NodeBB',
|
|
|
|
|
url: nconf.get('url'),
|
|
|
|
|
fromUserslug: utils.slugify(messageObj.fromUser.username)
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|
});
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
}(exports));
|
|
|
|
|
|
Barış Soner Uşaklı
9 years ago