feat: remove topics.async.getTopicData usage

v1.18.x
Barış Soner Uşaklı 5 years ago
parent 0cea713691
commit ce6b20c4b7

@ -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);

Loading…
Cancel
Save