mirror of
https://github.com/NodeBB/NodeBB.git
synced 2025-10-26 08:36:12 +01:00
feat: remove topics.async.getTopicData usage
This commit is contained in:
@@ -238,4 +238,4 @@ Analytics.getBlacklistAnalytics = async function () {
|
|||||||
});
|
});
|
||||||
};
|
};
|
||||||
|
|
||||||
Analytics.async = require('./promisify')(Analytics);
|
require('./promisify')(Analytics);
|
||||||
|
|||||||
@@ -367,4 +367,4 @@ Categories.buildForSelectCategories = function (categories, fields) {
|
|||||||
return categoriesData.map(category => _.pick(category, pickFields));
|
return categoriesData.map(category => _.pick(category, pickFields));
|
||||||
};
|
};
|
||||||
|
|
||||||
Categories.async = require('../promisify')(Categories);
|
require('../promisify')(Categories);
|
||||||
|
|||||||
@@ -178,4 +178,4 @@ require('./mongo/sorted')(mongoModule);
|
|||||||
require('./mongo/list')(mongoModule);
|
require('./mongo/list')(mongoModule);
|
||||||
require('./mongo/transaction')(mongoModule);
|
require('./mongo/transaction')(mongoModule);
|
||||||
|
|
||||||
mongoModule.async = require('../promisify')(mongoModule, ['client', 'sessionStore']);
|
require('../promisify')(mongoModule, ['client', 'sessionStore']);
|
||||||
|
|||||||
@@ -420,4 +420,4 @@ require('./postgres/sorted')(postgresModule);
|
|||||||
require('./postgres/list')(postgresModule);
|
require('./postgres/list')(postgresModule);
|
||||||
require('./postgres/transaction')(postgresModule);
|
require('./postgres/transaction')(postgresModule);
|
||||||
|
|
||||||
postgresModule.async = require('../promisify')(postgresModule, ['client', 'sessionStore', 'pool', 'transaction']);
|
require('../promisify')(postgresModule, ['client', 'sessionStore', 'pool', 'transaction']);
|
||||||
|
|||||||
@@ -155,4 +155,4 @@ require('./redis/sorted')(redisModule);
|
|||||||
require('./redis/list')(redisModule);
|
require('./redis/list')(redisModule);
|
||||||
require('./redis/transaction')(redisModule);
|
require('./redis/transaction')(redisModule);
|
||||||
|
|
||||||
redisModule.async = require('../promisify')(redisModule, ['client', 'sessionStore']);
|
require('../promisify')(redisModule, ['client', 'sessionStore']);
|
||||||
|
|||||||
@@ -228,4 +228,4 @@ Groups.existsBySlug = async function (slug) {
|
|||||||
return await db.isObjectField('groupslug:groupname', slug);
|
return await db.isObjectField('groupslug:groupname', slug);
|
||||||
};
|
};
|
||||||
|
|
||||||
Groups.async = require('../promisify')(Groups);
|
require('../promisify')(Groups);
|
||||||
|
|||||||
@@ -284,4 +284,4 @@ Messaging.hasPrivateChat = async (uid, withUid) => {
|
|||||||
return roomId;
|
return roomId;
|
||||||
};
|
};
|
||||||
|
|
||||||
Messaging.async = require('../promisify')(Messaging);
|
require('../promisify')(Messaging);
|
||||||
|
|||||||
@@ -68,4 +68,4 @@ Meta.getSessionTTLSeconds = function () {
|
|||||||
return ttl;
|
return ttl;
|
||||||
};
|
};
|
||||||
|
|
||||||
Meta.async = require('../promisify')(Meta);
|
require('../promisify')(Meta);
|
||||||
|
|||||||
@@ -418,4 +418,4 @@ Notifications.merge = async function (notifications) {
|
|||||||
return data && data.notifications;
|
return data && data.notifications;
|
||||||
};
|
};
|
||||||
|
|
||||||
Notifications.async = require('./promisify')(Notifications);
|
require('./promisify')(Notifications);
|
||||||
|
|||||||
@@ -351,4 +351,4 @@ async function findNodeBBModules(dirs) {
|
|||||||
return pluginPaths;
|
return pluginPaths;
|
||||||
}
|
}
|
||||||
|
|
||||||
Plugins.async = require('../promisify')(Plugins);
|
require('../promisify')(Plugins);
|
||||||
|
|||||||
@@ -103,4 +103,4 @@ Posts.modifyPostByPrivilege = function (post, privileges) {
|
|||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
Posts.async = require('../promisify')(Posts);
|
require('../promisify')(Posts);
|
||||||
|
|||||||
@@ -49,4 +49,4 @@ require('./topics')(privileges);
|
|||||||
require('./posts')(privileges);
|
require('./posts')(privileges);
|
||||||
require('./users')(privileges);
|
require('./users')(privileges);
|
||||||
|
|
||||||
privileges.async = require('../promisify')(privileges);
|
require('../promisify')(privileges);
|
||||||
|
|||||||
@@ -1,7 +1,6 @@
|
|||||||
'use strict';
|
'use strict';
|
||||||
|
|
||||||
var util = require('util');
|
const util = require('util');
|
||||||
var _ = require('lodash');
|
|
||||||
|
|
||||||
module.exports = function (theModule, ignoreKeys) {
|
module.exports = function (theModule, ignoreKeys) {
|
||||||
ignoreKeys = ignoreKeys || [];
|
ignoreKeys = ignoreKeys || [];
|
||||||
@@ -9,7 +8,7 @@ module.exports = function (theModule, ignoreKeys) {
|
|||||||
if (typeof func !== 'function') {
|
if (typeof func !== 'function') {
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
var str = func.toString().split('\n')[0];
|
const str = func.toString().split('\n')[0];
|
||||||
return str.includes('callback)');
|
return str.includes('callback)');
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -17,13 +16,12 @@ module.exports = function (theModule, ignoreKeys) {
|
|||||||
return fn && fn.constructor && fn.constructor.name === 'AsyncFunction';
|
return fn && fn.constructor && fn.constructor.name === 'AsyncFunction';
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
function promisifyRecursive(module) {
|
function promisifyRecursive(module) {
|
||||||
if (!module) {
|
if (!module) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
var keys = Object.keys(module);
|
const keys = Object.keys(module);
|
||||||
keys.forEach(function (key) {
|
keys.forEach(function (key) {
|
||||||
if (ignoreKeys.includes(key)) {
|
if (ignoreKeys.includes(key)) {
|
||||||
return;
|
return;
|
||||||
@@ -61,34 +59,5 @@ module.exports = function (theModule, ignoreKeys) {
|
|||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
var parts = [];
|
|
||||||
function deprecateRecursive(module, key) {
|
|
||||||
if (!module) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
if (key) {
|
|
||||||
parts.push(key);
|
|
||||||
}
|
|
||||||
var keys = Object.keys(module);
|
|
||||||
keys.forEach(function (key) {
|
|
||||||
if (ignoreKeys.includes(key)) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (typeof module[key] === 'object') {
|
|
||||||
deprecateRecursive(module[key], key);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (typeof module[key] === 'function') {
|
|
||||||
module[key] = require('util').deprecate(module[key], '.async.' + (parts.concat([key]).join('.')) + ' usage is deprecated use .' + (parts.concat([key]).join('.')) + ' directly!');
|
|
||||||
}
|
|
||||||
});
|
|
||||||
parts.pop();
|
|
||||||
}
|
|
||||||
|
|
||||||
promisifyRecursive(theModule);
|
promisifyRecursive(theModule);
|
||||||
const asyncModule = _.cloneDeep(theModule);
|
|
||||||
deprecateRecursive(asyncModule);
|
|
||||||
|
|
||||||
return asyncModule;
|
|
||||||
};
|
};
|
||||||
|
|||||||
@@ -300,4 +300,4 @@ async function getSearchUids(data) {
|
|||||||
return await user.getUidsByUsernames(Array.isArray(data.postedBy) ? data.postedBy : [data.postedBy]);
|
return await user.getUidsByUsernames(Array.isArray(data.postedBy) ? data.postedBy : [data.postedBy]);
|
||||||
}
|
}
|
||||||
|
|
||||||
search.async = require('./promisify')(search);
|
require('./promisify')(search);
|
||||||
|
|||||||
@@ -283,4 +283,4 @@ Topics.search = async function (tid, term) {
|
|||||||
return Array.isArray(pids) ? pids : [];
|
return Array.isArray(pids) ? pids : [];
|
||||||
};
|
};
|
||||||
|
|
||||||
Topics.async = require('../promisify')(Topics);
|
require('../promisify')(Topics);
|
||||||
|
|||||||
@@ -307,4 +307,4 @@ User.addInterstitials = function (callback) {
|
|||||||
callback();
|
callback();
|
||||||
};
|
};
|
||||||
|
|
||||||
User.async = require('../promisify')(User);
|
require('../promisify')(User);
|
||||||
|
|||||||
Reference in New Issue
Block a user