-
Notifications
You must be signed in to change notification settings - Fork 46
/
Copy pathpromisify.js
60 lines (53 loc) · 1.37 KB
/
promisify.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
/**!
* gitlab - lib/promisify.js
*
* Copyright(c) fengmk2 and other contributors.
* MIT Licensed
*
* Authors:
* fengmk2 <[email protected]> (http://fengmk2.github.com)
*/
'use strict';
/**
* Module dependencies.
*/
/* jshint ignore:start */
let Promise = require('any-promise');
/* jshint ignore:end */
let properties = require('./properties');
module.exports = promisifyAll;
function promisifyAll(source) {
let target = {
request: promisify('request', source.request.bind(source))
};
Object.keys(properties).forEach((name) => {
let methods = properties[name];
target[name] = {};
methods.forEach((method) => {
target[name][method] = promisify(method, source[name][method].bind(source[name]));
});
});
return target;
}
function promisify(name, fn) {
/* jshint evil:true */
return eval('(function ' + name + '() {\n'
+ ' var len = arguments.length;\n'
+ ' var args = new Array(len + 1);\n'
+ ' for (var i = 0; i < len; ++i) { args[i] = arguments[i]; }\n'
+ ' var lastIndex = i;\n'
+ ' return new Promise(function (resolve, reject) {\n'
+ ' args[lastIndex] = makeCallback(resolve, reject);\n'
+ ' fn.apply(null, args);\n'
+ ' });\n'
+ '});');
}
function makeCallback(resolve, reject) {
return function(err, result) {
if (err) {
reject(err);
} else {
resolve(result);
}
};
}