aboutsummaryrefslogtreecommitdiff
path: root/lib/promises.js
blob: e05cf1124b499c4b057343c97926b14261c3cd1b (plain)
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
61
62
63
64
65
66
var _ = require("underscore");
var bluebird = require("bluebird/js/release/promise")();

exports.defer = defer;
exports.resolve = bluebird.resolve;
exports.reject = bluebird.reject;
exports.mapSeries = bluebird.mapSeries;

var props = exports.props = function(obj) {
    // We rely on .keys() and .values() returning properties in the same order.
    var keys = Object.keys(obj);
    var values = Object.values(obj);

    var result = bluebird.all(values).then(function(resolvedValues) {
        var resolvedObj = {};
        for (var index = 0; index < keys.length; index++) {
            resolvedObj[keys[index]] = resolvedValues[index];
        }
        return resolvedObj;
    });

    return addAlsoToPromise(result);
};

function addAlsoToPromise(promise) {
    promise.also = function(func) {
        var result = this.then(function(value) {
            var returnValue = _.extend({}, value, func(value));
            return props(returnValue);
        });

        return addAlsoToPromise(result);
    };

    return promise;
}

exports.try = function(func) {
    try {
        return bluebird.resolve(func());
    } catch (error) {
        return bluebird.reject(error);
    }
};

bluebird.prototype.also = function(func) {
    return this.then(function(value) {
        var returnValue = _.extend({}, value, func(value));
        return bluebird.props(returnValue);
    });
};

function defer() {
    var resolve;
    var reject;
    var promise = new bluebird.Promise(function(resolveArg, rejectArg) {
        resolve = resolveArg;
        reject = rejectArg;
    });

    return {
        resolve: resolve,
        reject: reject,
        promise: promise
    };
}