Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-10-26 08:36:12 +01:00
Code Issues Packages Projects Releases Wiki Activity

refactor: shorter map

Browse Source
This commit is contained in:
Barış Soner Uşaklı
2019-09-25 00:08:28 -04:00
parent 039710493a
commit 572bc29742
1 changed files with 4 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/database/mongo/sorted.js
View File

@@ -82,8 +82,8 @@ module.exports = function (module) {
}
let result = [];
async function doQuery(fields) {
return await module.client.collection('objects').find(query, { projection: fields })
async function doQuery(_key, fields) {
return await module.client.collection('objects').find({ ...query, ...{ _key: _key } }, { projection: fields })
.sort({ score: sort })
.skip(start)
.limit(limit)
@@ -94,14 +94,10 @@ module.exports = function (module) {
const batches = [];
const batch = require('../../batch');
await batch.processArray(key, async currentBatch => batches.push(currentBatch), { batch: 100 });
const batchData = await Promise.all(batches.map(async (batch) => {
query._key = { $in: batch };
return await doQuery({ _id: 0, _key: 0 });
}));
const batchData = await Promise.all(batches.map(batch => doQuery({ $in: batch }, { _id: 0, _key: 0 })));
result = dbHelpers.mergeBatch(batchData, start, stop, sort);
} else {
result = await doQuery(fields);
result = await doQuery(query._key, fields);
}
if (reverse) {