Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-10-27 09:06:15 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix: remove left over code, use proper names

Browse Source
This commit is contained in:
Barış Soner Uşaklı
2019-07-09 23:09:25 -04:00
parent 2c33595507
commit 0ac49d63d9
1 changed files with 22 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files

54
src/promisify.js
View File

@@ -17,32 +17,42 @@ module.exports = function (theModule, ignoreKeys) {
return fn && fn.constructor && fn.constructor.name === 'AsyncFunction';
}
var parts = [];
function promisifyRecursive(module, key) {
function promisifyRecursive(module) {
if (!module) {
return;
}
if (key) {
parts.push(key);
}
var keys = Object.keys(module);
keys.forEach(function (key) {
if (ignoreKeys.includes(key)) {
return;
}
if (isAsyncFunction(module[key])) {
module[key] = wrapIt(module[key], util.callbackify(module[key]));
module[key] = wrapCallback(module[key], util.callbackify(module[key]));
} else if (isCallbackedFunction(module[key])) {
module[key] = wrapTwo(module[key], util.promisify(module[key]));
module[key] = wrapPromise(module[key], util.promisify(module[key]));
} else if (typeof module[key] === 'object') {
promisifyRecursive(module[key], key);
promisifyRecursive(module[key]);
}
});
parts.pop();
}
function wrapTwo(origFn, promiseFn) {
return function wrapper2(...args) {
function wrapCallback(origFn, callbackFn) {
return async function wrapperCallback(...args) {
if (arguments.length && typeof arguments[arguments.length - 1] === 'function') {
const cb = args.pop();
args.push(function (err, res) {
return res !== undefined ? cb(err, res) : cb(err);
});
return callbackFn.apply(null, args);
}
return origFn.apply(null, arguments);
};
}
function wrapPromise(origFn, promiseFn) {
return function wrapperPromise(...args) {
if (arguments.length && typeof arguments[arguments.length - 1] === 'function') {
return origFn.apply(null, args);
}
@@ -51,27 +61,7 @@ module.exports = function (theModule, ignoreKeys) {
};
}
function wrapIt(origFn, callbackFn) {
return async function wrapper(...args) {
if (arguments.length && typeof arguments[arguments.length - 1] === 'function') {
const cb = args.pop();
args.push(function (err, res) {
if (err) {
return cb(err);
}
// fixes callbackified functions used in async.waterfall
if (res !== undefined) {
return cb(err, res);
}
return cb(err);
});
return callbackFn.apply(null, args);
}
return origFn.apply(null, arguments);
};
}
var parts = [];
function deprecateRecursive(module, key) {
if (!module) {
return;