Merge remote-tracking branch 'origin/master' into develop
Julian Lam
8 years ago
commit
3861b2dd80
@ -0,0 +1,136 @@
|
|||||||
|
'use strict';
|
||||||
|
|
||||||
|
var async = require('async');
|
||||||
|
var S = require('string');
|
||||||
|
|
||||||
|
var db = require('../database');
|
||||||
|
var user = require('../user');
|
||||||
|
var utils = require('../../public/src/utils');
|
||||||
|
|
||||||
|
module.exports = function (Messaging) {
|
||||||
|
|
||||||
|
Messaging.getMessageField = function (mid, field, callback) {
|
||||||
|
Messaging.getMessageFields(mid, [field], function (err, fields) {
|
||||||
|
callback(err, fields ? fields[field] : null);
|
||||||
|
});
|
||||||
|
};
|
||||||
|
|
||||||
|
Messaging.getMessageFields = function (mid, fields, callback) {
|
||||||
|
db.getObjectFields('message:' + mid, fields, callback);
|
||||||
|
};
|
||||||
|
|
||||||
|
Messaging.setMessageField = function (mid, field, content, callback) {
|
||||||
|
db.setObjectField('message:' + mid, field, content, callback);
|
||||||
|
};
|
||||||
|
|
||||||
|
Messaging.setMessageFields = function (mid, data, callback) {
|
||||||
|
db.setObject('message:' + mid, data, callback);
|
||||||
|
};
|
||||||
|
|
||||||
|
Messaging.getMessagesData = function (mids, uid, roomId, isNew, callback) {
|
||||||
|
|
||||||
|
var messages;
|
||||||
|
|
||||||
|
async.waterfall([
|
||||||
|
function (next) {
|
||||||
|
var keys = mids.map(function (mid) {
|
||||||
|
return 'message:' + mid;
|
||||||
|
});
|
||||||
|
|
||||||
|
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);
|
||||||
|
|
||||||
|
var uids = messages.map(function (msg) {
|
||||||
|
return msg && msg.fromuid;
|
||||||
|
});
|
||||||
|
|
||||||
|
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;
|
||||||
|
message.roomId = String(message.roomId || roomId);
|
||||||
|
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 (err, result) {
|
||||||
|
if (err) {
|
||||||
|
return next(err);
|
||||||
|
}
|
||||||
|
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;
|
||||||
|
}
|
||||||
|
|
||||||
|
return message;
|
||||||
|
});
|
||||||
|
|
||||||
|
next(undefined, messages);
|
||||||
|
} else if (messages.length === 1) {
|
||||||
|
// 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);
|
||||||
|
}
|
||||||
|
|
||||||
|
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);
|
||||||
|
});
|
||||||
|
} else {
|
||||||
|
next(null, []);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
], callback);
|
||||||
|
};
|
||||||
|
|
||||||
|
};
|
||||||
Loading…
Reference in New Issue