Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-11-01 11:35:55 +01:00
Code Issues Packages Projects Releases Wiki Activity

messaging.getTeaser

Browse Source
This commit is contained in:
barisusakli
2015-12-17 12:35:49 +02:00
parent 5a26eb1c76
commit 4827ea04fc
1 changed files with 23 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
src/messaging.js
View File

@@ -254,19 +254,7 @@ var async = require('async'),
},
teasers: function(next) {
async.map(roomIds, function(roomId, next) {
Messaging.getMessages({
uid: uid,
roomId: roomId,
isNew: false,
count: 1,
markRead: false
}, function(err, teaser) {
teaser = teaser[0];
if (teaser && teaser.content) {
teaser.content = S(teaser.content).stripTags().decodeHTMLEntities().s;
}
next(err, teaser);
});
Messaging.getTeaser(uid, roomId, next);
}, next);
}
}, function(err, results) {
@@ -300,6 +288,28 @@ var async = require('async'),
});
};
Messaging.getTeaser = function (uid, roomId, callback) {
async.waterfall([
function (next) {
db.getSortedSetRevRange('uid:' + uid + ':chat:room:' + roomId + ':mids', 0, 0, next);
},
function (mids, next) {
if (!mids || !mids.length) {
return next(null, null);
}
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.canMessageUser = function(uid, toUid, callback) {
if (parseInt(meta.config.disableChat) === 1 || !uid || uid === toUid) {
return callback(null, false);