Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-10-27 09:06:15 +01:00
Code Issues Packages Projects Releases Wiki Activity

feat: add new hook filteR:topics.getSortedTids

Browse Source 
to let plugins replace the logic used to retrieve tids
This commit is contained in:
Baris Usakli
2019-09-30 14:56:11 -04:00
parent 95ab071254
commit b93c826d35
1 changed files with 11 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/topics/sorted.js
View File

@@ -25,6 +25,8 @@ module.exports = function (Topics) {
params.cids = [params.cids]; params.cids = [params.cids];
} }
data.tids = await getTids(params); data.tids = await getTids(params);
data.tids = await sortTids(data.tids, params);
data.tids = await filterTids(data.tids.slice(0, 200), params);
data.topicCount = data.tids.length; data.topicCount = data.tids.length;
data.topics = await getTopics(data.tids, params); data.topics = await getTopics(data.tids, params);
data.nextStart = params.stop + 1; data.nextStart = params.stop + 1;
@@ -32,6 +34,10 @@ module.exports = function (Topics) {
}; };
async function getTids(params) { async function getTids(params) {
if (plugins.hasListeners('filter:topics.getSortedTids')) {
const result = await plugins.fireHook('filter:topics.getSortedTids', { params: params, tids: [] });
return result.tids;
}
let tids = []; let tids = [];
if (params.term !== 'alltime') { if (params.term !== 'alltime') {
tids = await Topics.getLatestTidsFromSet('topics:tid', 0, -1, params.term); tids = await Topics.getLatestTidsFromSet('topics:tid', 0, -1, params.term);
@@ -45,10 +51,8 @@ module.exports = function (Topics) {
} else { } else {
tids = await db.getSortedSetRevRange('topics:' + params.sort, 0, 199); tids = await db.getSortedSetRevRange('topics:' + params.sort, 0, 199);
} }
if (params.term !== 'alltime' || params.cids || params.filter === 'watched' || params.floatPinned) {
tids = await sortTids(tids, params); return tids;
}
return await filterTids(tids.slice(0, 200), params);
} }
async function getCidTids(params) { async function getCidTids(params) {
@@ -70,6 +74,9 @@ module.exports = function (Topics) {
} }
async function sortTids(tids, params) { async function sortTids(tids, params) {
if (params.term === 'alltime' && !params.cids && params.filter !== 'watched' && !params.floatPinned) {
return;
}
const topicData = await Topics.getTopicsFields(tids, ['tid', 'lastposttime', 'upvotes', 'downvotes', 'postcount', 'pinned']); const topicData = await Topics.getTopicsFields(tids, ['tid', 'lastposttime', 'upvotes', 'downvotes', 'postcount', 'pinned']);
let sortFn = sortRecent; let sortFn = sortRecent;
if (params.sort === 'posts') { if (params.sort === 'posts') {