You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
109 lines
2.5 KiB
JavaScript
109 lines
2.5 KiB
JavaScript
|
|
'use strict';
|
|
|
|
var async = require('async'),
|
|
winston = require('winston'),
|
|
|
|
db = require('../database'),
|
|
posts = require('../posts'),
|
|
topics = require('../topics');
|
|
|
|
module.exports = function(Categories) {
|
|
Categories.getRecentReplies = function(cid, uid, count, callback) {
|
|
if (!parseInt(count, 10)) {
|
|
return callback(null, []);
|
|
}
|
|
|
|
db.getSortedSetRevRange('categories:recent_posts:cid:' + cid, 0, count - 1, function(err, pids) {
|
|
if (err || !pids || !pids.length) {
|
|
return callback(err, []);
|
|
}
|
|
|
|
posts.getPostSummaryByPids(pids, {stripTags: true}, callback);
|
|
});
|
|
};
|
|
|
|
Categories.getRecentTopicReplies = function(cid, uid, count, callback) {
|
|
if (!parseInt(count, 10)) {
|
|
return callback(null, []);
|
|
}
|
|
|
|
db.getSortedSetRevRange('categories:' + cid + ':tid', 0, count - 1, function(err, tids) {
|
|
if (err || !tids || !tids.length) {
|
|
return callback(err, []);
|
|
}
|
|
|
|
async.map(tids, topics.getLatestUndeletedPid, function(err, pids) {
|
|
pids = pids.filter(function(pid) {
|
|
return !!pid;
|
|
});
|
|
|
|
posts.getPostSummaryByPids(pids, {stripTags: true}, callback);
|
|
});
|
|
});
|
|
};
|
|
|
|
Categories.moveRecentReplies = function(tid, oldCid, cid) {
|
|
function movePost(postData, next) {
|
|
async.parallel([
|
|
function(next) {
|
|
db.sortedSetRemove('categories:recent_posts:cid:' + oldCid, postData.pid, next);
|
|
},
|
|
function(next) {
|
|
db.sortedSetAdd('categories:recent_posts:cid:' + cid, postData.timestamp, postData.pid, next);
|
|
}
|
|
], next);
|
|
}
|
|
|
|
updatePostCount(tid, oldCid, cid);
|
|
topics.getPids(tid, function(err, pids) {
|
|
if (err) {
|
|
return winston.error(err.message);
|
|
}
|
|
|
|
if (pids && !pids.length) {
|
|
return;
|
|
}
|
|
|
|
var keys = pids.map(function(pid) {
|
|
return 'post:' + pid;
|
|
});
|
|
|
|
db.getObjectsFields(keys, ['pid', 'timestamp'], function(err, postData) {
|
|
if (err) {
|
|
return winston.error(err.message);
|
|
}
|
|
|
|
async.each(postData, movePost, function(err) {
|
|
if (err) {
|
|
winston.error(err.message);
|
|
}
|
|
});
|
|
});
|
|
});
|
|
};
|
|
|
|
function updatePostCount(tid, oldCid, newCid) {
|
|
topics.getTopicField(tid, 'postcount', function(err, postCount) {
|
|
if (err) {
|
|
return winston.error(err.message);
|
|
}
|
|
|
|
async.parallel([
|
|
function(next) {
|
|
db.incrObjectFieldBy('category:' + oldCid, 'post_count', -postCount, next);
|
|
},
|
|
function(next) {
|
|
db.incrObjectFieldBy('category:' + newCid, 'post_count', postCount, next);
|
|
}
|
|
], function(err) {
|
|
if (err) {
|
|
winston.error(err.message);
|
|
}
|
|
});
|
|
});
|
|
}
|
|
};
|
|
|
|
|