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

fix: callbacks

Browse Source
This commit is contained in:
Baris Usakli
2019-03-15 16:06:38 -04:00
parent f8fa659642
commit b48b6d75e5
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/database/redis/hash.js
View File

@@ -63,13 +63,13 @@ module.exports = function (redisClient, module) {
module.getObjects = function (keys, callback) {
var cachedData = {};
function getFromCache() {
process.nextTick(callback, null, keys.map(key => _.clone(cachedData[key])));
function getFromCache(next) {
process.nextTick(next, null, keys.map(key => _.clone(cachedData[key])));
}
const unCachedKeys = cache.getUnCachedKeys(keys, cachedData);
if (!unCachedKeys.length) {
return getFromCache();
return getFromCache(callback);
}
async.waterfall([
@@ -86,7 +86,7 @@ module.exports = function (redisClient, module) {
cache.set(key, cachedData[key]);
});
getFromCache();
getFromCache(next);
},
], callback);
};

4
src/groups/membership.js
View File

@@ -162,8 +162,8 @@ module.exports = function (Groups) {
Groups.isMembers = function (uids, groupName, callback) {
var cachedData = {};
function getFromCache() {
setImmediate(callback, null, uids.map(uid => cachedData[uid + ':' + groupName]));
function getFromCache(next) {
setImmediate(next, null, uids.map(uid => cachedData[uid + ':' + groupName]));
}
if (!groupName || !uids.length) {
return setImmediate(callback, null, uids.map(() => false));