| "use strict"; |
| var util = require("./util"); |
| var maybeWrapAsError = util.maybeWrapAsError; |
| var errors = require("./errors"); |
| var OperationalError = errors.OperationalError; |
| var es5 = require("./es5"); |
| |
| function isUntypedError(obj) { |
| return obj instanceof Error && |
| es5.getPrototypeOf(obj) === Error.prototype; |
| } |
| |
| var rErrorKey = /^(?:name|message|stack|cause)$/; |
| function wrapAsOperationalError(obj) { |
| var ret; |
| if (isUntypedError(obj)) { |
| ret = new OperationalError(obj); |
| ret.name = obj.name; |
| ret.message = obj.message; |
| ret.stack = obj.stack; |
| var keys = es5.keys(obj); |
| for (var i = 0; i < keys.length; ++i) { |
| var key = keys[i]; |
| if (!rErrorKey.test(key)) { |
| ret[key] = obj[key]; |
| } |
| } |
| return ret; |
| } |
| util.markAsOriginatingFromRejection(obj); |
| return obj; |
| } |
| |
| function nodebackForPromise(promise, multiArgs) { |
| return function(err, value) { |
| if (promise === null) return; |
| if (err) { |
| var wrapped = wrapAsOperationalError(maybeWrapAsError(err)); |
| promise._attachExtraTrace(wrapped); |
| promise._reject(wrapped); |
| } else if (!multiArgs) { |
| promise._fulfill(value); |
| } else { |
| var $_len = arguments.length;var args = new Array(Math.max($_len - 1, 0)); for(var $_i = 1; $_i < $_len; ++$_i) {args[$_i - 1] = arguments[$_i];}; |
| promise._fulfill(args); |
| } |
| promise = null; |
| }; |
| } |
| |
| module.exports = nodebackForPromise; |