Server : nginx/1.20.1 System : Linux ccpf-production-2021 5.4.0-148-generic #165-Ubuntu SMP Tue Apr 18 08:53:12 UTC 2023 x86_64 User : forge ( 1000) PHP Version : 7.4.21 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wifcontinued,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_get_handler,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority,pcntl_async_signals,pcntl_unshare, Directory : /usr/lib/node_modules/npm/node_modules/util-promisify/ |
'use strict';
const ObjectGetOwnPropertyDescriptors = require('object.getownpropertydescriptors');
const util = require('util');
const timers = require('timers');
const kCustomPromisifiedSymbol = util.promisify && util.promisify.custom || Symbol('util.promisify.custom');
//const kCustomPromisifyArgsSymbol = Symbol('customPromisifyArgs');
function promisify(orig) {
if (typeof orig !== 'function') {
//const errors = require('internal/errors');
//throw new errors.TypeError('ERR_INVALID_ARG_TYPE', 'original', 'function');
var err = TypeError(`The "original" argument must be of type function`);
err.code = 'ERR_INVALID_ARG_TYPE';
err.name = `TypeError [${err.code}]`;
throw err
}
if (orig === timers.setTimeout || orig === timers.setImmediate) {
const _orig = orig
orig = function () {
var args = [];
for (var i = 0; i < arguments.length; i ++) args.push(arguments[i]);
const _cb = args.pop()
const cb = function () {
var args = [];
for (var i = 0; i < arguments.length; i ++) args.push(arguments[i]);
_cb.apply(null, [null].concat(args))
}
_orig.apply(timers, [cb].concat(args))
}
}
if (orig[kCustomPromisifiedSymbol]) {
const fn = orig[kCustomPromisifiedSymbol];
if (typeof fn !== 'function') {
throw new TypeError('The [util.promisify.custom] property must be ' +
'a function');
}
Object.defineProperty(fn, kCustomPromisifiedSymbol, {
value: fn, enumerable: false, writable: false, configurable: true
});
return fn;
}
// Names to create an object from in case the callback receives multiple
// arguments, e.g. ['stdout', 'stderr'] for child_process.exec.
//const argumentNames = orig[kCustomPromisifyArgsSymbol];
function fn() {
var args = [];
for (var i = 0; i < arguments.length; i ++) args.push(arguments[i]);
let resolve, reject;
const promise = new Promise(function (_resolve, _reject) {
resolve = _resolve;
reject = _reject;
});
try {
orig.apply(this, args.concat(function (err) {
var values = [];
for (var i = 1; i < arguments.length; i++) values.push(arguments[i]);
if (err) {
reject(err);
//} else if (argumentNames !== undefined && values.length > 1) {
// const obj = {};
// for (var i = 0; i < argumentNames.length; i++)
// obj[argumentNames[i]] = values[i];
// resolve(obj);
} else {
resolve(values[0]);
}
}));
} catch (err) {
reject(err);
}
return promise;
}
Object.setPrototypeOf(fn, Object.getPrototypeOf(orig));
Object.defineProperty(fn, kCustomPromisifiedSymbol, {
value: fn, enumerable: false, writable: false, configurable: true
});
return Object.defineProperties(fn, ObjectGetOwnPropertyDescriptors(orig));
}
promisify.custom = kCustomPromisifiedSymbol;
module.exports = promisify;