dont call db for guests

v1.18.x
Barış Soner Uşaklı 6 years ago
parent 5810c9fecc
commit b8c08a5417

@ -173,37 +173,37 @@ module.exports = function (Topics) {
db.isSetMembers('tid:' + tid + ':ignorers', uids, next);
},
function (isIgnoring, next) {
var readingUids = uids.filter(function (uid, index) {
return uid && !isIgnoring[index];
});
const readingUids = uids.filter((uid, index) => uid && !isIgnoring[index]);
next(null, readingUids);
},
], callback);
};
Topics.filterWatchedTids = function (tids, uid, callback) {
if (parseInt(uid, 10) <= 0) {
return setImmediate(callback, null, []);
}
async.waterfall([
function (next) {
db.sortedSetScores('uid:' + uid + ':followed_tids', tids, next);
},
function (scores, next) {
tids = tids.filter(function (tid, index) {
return tid && !!scores[index];
});
tids = tids.filter((tid, index) => tid && !!scores[index]);
next(null, tids);
},
], callback);
};
Topics.filterNotIgnoredTids = function (tids, uid, callback) {
if (parseInt(uid, 10) <= 0) {
return setImmediate(callback, null, tids);
}
async.waterfall([
function (next) {
db.sortedSetScores('uid:' + uid + ':ignored_tids', tids, next);
},
function (scores, next) {
tids = tids.filter(function (tid, index) {
return tid && !scores[index];
});
tids = tids.filter((tid, index) => tid && !scores[index]);
next(null, tids);
},
], callback);

@ -516,14 +516,15 @@ module.exports = function (Topics) {
};
Topics.filterNewTids = function (tids, uid, callback) {
if (parseInt(uid, 10) <= 0) {
return setImmediate(callback, null, []);
}
async.waterfall([
function (next) {
db.sortedSetScores('uid:' + uid + ':tids_read', tids, next);
},
function (scores, next) {
tids = tids.filter(function (tid, index) {
return tid && !scores[index];
});
tids = tids.filter((tid, index) => tid && !scores[index]);
next(null, tids);
},
], callback);
@ -535,9 +536,7 @@ module.exports = function (Topics) {
db.sortedSetScores('topics:posts', tids, next);
},
function (scores, next) {
tids = tids.filter(function (tid, index) {
return tid && scores[index] <= 1;
});
tids = tids.filter((tid, index) => tid && scores[index] <= 1);
next(null, tids);
},
], callback);

Loading…
Cancel
Save