mirror of
https://github.com/NodeBB/NodeBB.git
synced 2025-10-26 16:46: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));
|
||||
};
|
||||
|
||||
Categories.async = require('../promisify')(Categories);
|
||||
require('../promisify')(Categories);
|
||||
|
||||
@@ -178,4 +178,4 @@ require('./mongo/sorted')(mongoModule);
|
||||
require('./mongo/list')(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/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/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);
|
||||
};
|
||||
|
||||
Groups.async = require('../promisify')(Groups);
|
||||
require('../promisify')(Groups);
|
||||
|
||||
@@ -284,4 +284,4 @@ Messaging.hasPrivateChat = async (uid, withUid) => {
|
||||
return roomId;
|
||||
};
|
||||
|
||||
Messaging.async = require('../promisify')(Messaging);
|
||||
require('../promisify')(Messaging);
|
||||
|
||||
@@ -68,4 +68,4 @@ Meta.getSessionTTLSeconds = function () {
|
||||
return ttl;
|
||||
};
|
||||
|
||||
Meta.async = require('../promisify')(Meta);
|
||||
require('../promisify')(Meta);
|
||||
|
||||
@@ -418,4 +418,4 @@ Notifications.merge = async function (notifications) {
|
||||
return data && data.notifications;
|
||||
};
|
||||
|
||||
Notifications.async = require('./promisify')(Notifications);
|
||||
require('./promisify')(Notifications);
|
||||
|
||||
@@ -351,4 +351,4 @@ async function findNodeBBModules(dirs) {
|
||||
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('./users')(privileges);
|
||||
|
||||
privileges.async = require('../promisify')(privileges);
|
||||
require('../promisify')(privileges);
|
||||
|
||||
@@ -1,7 +1,6 @@
|
||||
'use strict';
|
||||
|
||||
var util = require('util');
|
||||
var _ = require('lodash');
|
||||
const util = require('util');
|
||||
|
||||
module.exports = function (theModule, ignoreKeys) {
|
||||
ignoreKeys = ignoreKeys || [];
|
||||
@@ -9,7 +8,7 @@ module.exports = function (theModule, ignoreKeys) {
|
||||
if (typeof func !== 'function') {
|
||||
return false;
|
||||
}
|
||||
var str = func.toString().split('\n')[0];
|
||||
const str = func.toString().split('\n')[0];
|
||||
return str.includes('callback)');
|
||||
}
|
||||
|
||||
@@ -17,13 +16,12 @@ module.exports = function (theModule, ignoreKeys) {
|
||||
return fn && fn.constructor && fn.constructor.name === 'AsyncFunction';
|
||||
}
|
||||
|
||||
|
||||
function promisifyRecursive(module) {
|
||||
if (!module) {
|
||||
return;
|
||||
}
|
||||
|
||||
var keys = Object.keys(module);
|
||||
const keys = Object.keys(module);
|
||||
keys.forEach(function (key) {
|
||||
if (ignoreKeys.includes(key)) {
|
||||
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);
|
||||
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]);
|
||||
}
|
||||
|
||||
search.async = require('./promisify')(search);
|
||||
require('./promisify')(search);
|
||||
|
||||
@@ -283,4 +283,4 @@ Topics.search = async function (tid, term) {
|
||||
return Array.isArray(pids) ? pids : [];
|
||||
};
|
||||
|
||||
Topics.async = require('../promisify')(Topics);
|
||||
require('../promisify')(Topics);
|
||||
|
||||
@@ -307,4 +307,4 @@ User.addInterstitials = function (callback) {
|
||||
callback();
|
||||
};
|
||||
|
||||
User.async = require('../promisify')(User);
|
||||
require('../promisify')(User);
|
||||
|
||||
Reference in New Issue
Block a user