rl-async-testing/lib/mockPromise.js

"use strict";
var _ = require('lodash');
var fakeAsync_1 = require('./fakeAsync');
var MockPromiseService = (function () {
    function MockPromiseService() {
    }
    MockPromiseService.prototype.promise = function (result, share) {
        if (_.isUndefined(share)) {
            share = false;
        }
        if (_.isFunction(result)) {
            return this.makeDynamicMockPromise(result, share);
        }
        else {
            return this.makeMockPromise(result, share);
        }
    };
    MockPromiseService.prototype.rejectedPromise = function () {
        var params = [];
        for (var _i = 0; _i < arguments.length; _i++) {
            params[_i - 0] = arguments[_i];
        }
        var mocked = this.makeMockPromise(null, false);
        mocked.rejected = true;
        mocked.rejectParams = params;
        return mocked;
    };
    MockPromiseService.prototype.flushAll = function (service) {
        _.each(service, function (promise) {
            if (promise && _.isFunction(promise.flush)) {
                promise.flush();
            }
        });
    };
    MockPromiseService.prototype.makeMockPromise = function (result, share) {
        return this.makeDynamicMockPromise(function () { return result; }, share);
    };
    MockPromiseService.prototype.makeDynamicMockPromise = function (result, shareParam) {
        var share = shareParam;
        ;
        var requests = [];
        var mocked;
        // Return a function that will build a pending promise when called
        var promiseBuilder = (function () {
            var args = [];
            for (var _i = 0; _i < arguments.length; _i++) {
                args[_i - 0] = arguments[_i];
            }
            if (share && _.some(requests)) {
                return _.first(requests).promise;
            }
            var newRequest = {
                resolve: null,
                reject: null,
                params: args,
                promise: null,
                rejected: mocked.rejected,
                rejectParams: mocked.rejectParams,
                pending: true,
            };
            newRequest.promise = new Promise(function (resolve, reject) {
                newRequest.resolve = resolve;
                newRequest.reject = reject;
            });
            requests.push(newRequest);
            fakeAsync_1.rlQueueRequest(newRequest);
            return newRequest.promise;
        });
        var spiedBuilder = sinon.spy(promiseBuilder);
        mocked = spiedBuilder;
        // Mark promise to be rejected
        mocked.reject = function () {
            var params = [];
            for (var _i = 0; _i < arguments.length; _i++) {
                params[_i - 0] = arguments[_i];
            }
            mocked.rejected = true;
            mocked.rejectParams = params;
        };
        // Mark promise to be shared in builder
        mocked.share = function (shareParam) {
            if (_.isUndefined(shareParam)) {
                share = true;
            }
            share = shareParam;
        };
        // If current request, resolve and clear
        mocked.flush = function () {
            _.each(requests, function (request) {
                request.pending = false;
                if (request.rejected) {
                    request.reject.apply(request, request.rejectParams);
                }
                else {
                    request.resolve(result.apply(void 0, request.params));
                }
            });
            requests = [];
            fakeAsync_1.flushMicrotasks();
        };
        return mocked;
    };
    return MockPromiseService;
}());
exports.mockPromise = new MockPromiseService();
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoibW9ja1Byb21pc2UuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyJtb2NrUHJvbWlzZS50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUEsSUFBWSxDQUFDLFdBQU0sUUFBUSxDQUFDLENBQUE7QUFFNUIsMEJBQWdELGFBQWEsQ0FBQyxDQUFBO0FBb0I5RDtJQUFBO0lBNkdBLENBQUM7SUE1R0Esb0NBQU8sR0FBUCxVQUFlLE1BQTRDLEVBQUUsS0FBZTtRQUMzRSxFQUFFLENBQUMsQ0FBQyxDQUFDLENBQUMsV0FBVyxDQUFDLEtBQUssQ0FBQyxDQUFDLENBQUMsQ0FBQztZQUMxQixLQUFLLEdBQUcsS0FBSyxDQUFDO1FBQ2YsQ0FBQztRQUVELEVBQUUsQ0FBQyxDQUFDLENBQUMsQ0FBQyxVQUFVLENBQUMsTUFBTSxDQUFDLENBQUMsQ0FBQyxDQUFDO1lBQzFCLE1BQU0sQ0FBQyxJQUFJLENBQUMsc0JBQXNCLENBQThCLE1BQU0sRUFBRSxLQUFLLENBQUMsQ0FBQztRQUNoRixDQUFDO1FBQUMsSUFBSSxDQUFDLENBQUM7WUFDUCxNQUFNLENBQUMsSUFBSSxDQUFDLGVBQWUsQ0FBUSxNQUFNLEVBQUUsS0FBSyxDQUFDLENBQUM7UUFDbkQsQ0FBQztJQUNGLENBQUM7SUFFRCw0Q0FBZSxHQUFmO1FBQXVCLGdCQUFnQjthQUFoQixXQUFnQixDQUFoQixzQkFBZ0IsQ0FBaEIsSUFBZ0I7WUFBaEIsK0JBQWdCOztRQUN0QyxJQUFJLE1BQU0sR0FBa0MsSUFBSSxDQUFDLGVBQWUsQ0FBQyxJQUFJLEVBQUUsS0FBSyxDQUFDLENBQUM7UUFDOUUsTUFBTSxDQUFDLFFBQVEsR0FBRyxJQUFJLENBQUM7UUFDdkIsTUFBTSxDQUFDLFlBQVksR0FBRyxNQUFNLENBQUM7UUFDN0IsTUFBTSxDQUFDLE1BQU0sQ0FBQztJQUNmLENBQUM7SUFFRCxxQ0FBUSxHQUFSLFVBQVMsT0FBWTtRQUNwQixDQUFDLENBQUMsSUFBSSxDQUFDLE9BQU8sRUFBRSxVQUFDLE9BQTRCO1lBQzVDLEVBQUUsQ0FBQyxDQUFDLE9BQU8sSUFBSSxDQUFDLENBQUMsVUFBVSxDQUFDLE9BQU8sQ0FBQyxLQUFLLENBQUMsQ0FBQyxDQUFDLENBQUM7Z0JBQzVDLE9BQU8sQ0FBQyxLQUFLLEVBQUUsQ0FBQztZQUNqQixDQUFDO1FBQ0YsQ0FBQyxDQUFDLENBQUE7SUFDSCxDQUFDO0lBRU8sNENBQWUsR0FBdkIsVUFBK0IsTUFBYSxFQUFFLEtBQWM7UUFDM0QsTUFBTSxDQUFDLElBQUksQ0FBQyxzQkFBc0IsQ0FBQyxjQUFNLE9BQUEsTUFBTSxFQUFOLENBQU0sRUFBRSxLQUFLLENBQUMsQ0FBQztJQUN6RCxDQUFDO0lBRU8sbURBQXNCLEdBQTlCLFVBQXNDLE1BQW1DLEVBQUUsVUFBbUI7UUFDN0YsSUFBSSxLQUFLLEdBQVksVUFBVSxDQUFDO1FBUy9CLENBQUM7UUFFRixJQUFJLFFBQVEsR0FBbUIsRUFBRSxDQUFDO1FBQ2xDLElBQUksTUFBcUMsQ0FBQztRQUUxQyxrRUFBa0U7UUFDbEUsSUFBSSxjQUFjLEdBQVEsQ0FBQztZQUFDLGNBQWM7aUJBQWQsV0FBYyxDQUFkLHNCQUFjLENBQWQsSUFBYztnQkFBZCw2QkFBYzs7WUFDekMsRUFBRSxDQUFDLENBQUMsS0FBSyxJQUFJLENBQUMsQ0FBQyxJQUFJLENBQUMsUUFBUSxDQUFDLENBQUMsQ0FBQyxDQUFDO2dCQUMvQixNQUFNLENBQUMsQ0FBQyxDQUFDLEtBQUssQ0FBQyxRQUFRLENBQUMsQ0FBQyxPQUFPLENBQUM7WUFDbEMsQ0FBQztZQUVELElBQUksVUFBVSxHQUFpQjtnQkFDOUIsT0FBTyxFQUFFLElBQUk7Z0JBQ2IsTUFBTSxFQUFFLElBQUk7Z0JBQ1osTUFBTSxFQUFFLElBQUk7Z0JBQ1osT0FBTyxFQUFFLElBQUk7Z0JBQ2IsUUFBUSxFQUFFLE1BQU0sQ0FBQyxRQUFRO2dCQUN6QixZQUFZLEVBQUUsTUFBTSxDQUFDLFlBQVk7Z0JBQ2pDLE9BQU8sRUFBRSxJQUFJO2FBQ2IsQ0FBQztZQUVGLFVBQVUsQ0FBQyxPQUFPLEdBQUcsSUFBSSxPQUFPLENBQVEsVUFBVSxPQUFPLEVBQUUsTUFBTTtnQkFDaEUsVUFBVSxDQUFDLE9BQU8sR0FBRyxPQUFPLENBQUM7Z0JBQzdCLFVBQVUsQ0FBQyxNQUFNLEdBQUcsTUFBTSxDQUFDO1lBQzVCLENBQUMsQ0FBQyxDQUFDO1lBRUgsUUFBUSxDQUFDLElBQUksQ0FBQyxVQUFVLENBQUMsQ0FBQztZQUUxQiwwQkFBYyxDQUFDLFVBQVUsQ0FBQyxDQUFDO1lBRTNCLE1BQU0sQ0FBQyxVQUFVLENBQUMsT0FBTyxDQUFDO1FBQzNCLENBQUMsQ0FBQyxDQUFDO1FBRUgsSUFBSSxZQUFZLEdBQVEsS0FBSyxDQUFDLEdBQUcsQ0FBQyxjQUFjLENBQUMsQ0FBQztRQUNsRCxNQUFNLEdBQW1DLFlBQVksQ0FBQztRQUV0RCw4QkFBOEI7UUFDOUIsTUFBTSxDQUFDLE1BQU0sR0FBRztZQUFDLGdCQUFnQjtpQkFBaEIsV0FBZ0IsQ0FBaEIsc0JBQWdCLENBQWhCLElBQWdCO2dCQUFoQiwrQkFBZ0I7O1lBQ2hDLE1BQU0sQ0FBQyxRQUFRLEdBQUcsSUFBSSxDQUFDO1lBQ3ZCLE1BQU0sQ0FBQyxZQUFZLEdBQUcsTUFBTSxDQUFDO1FBQzlCLENBQUMsQ0FBQztRQUVGLHVDQUF1QztRQUN2QyxNQUFNLENBQUMsS0FBSyxHQUFHLFVBQUMsVUFBb0I7WUFDbkMsRUFBRSxDQUFDLENBQUMsQ0FBQyxDQUFDLFdBQVcsQ0FBQyxVQUFVLENBQUMsQ0FBQyxDQUFDLENBQUM7Z0JBQy9CLEtBQUssR0FBRyxJQUFJLENBQUM7WUFDZCxDQUFDO1lBRUQsS0FBSyxHQUFHLFVBQVUsQ0FBQztRQUNwQixDQUFDLENBQUM7UUFFRix3Q0FBd0M7UUFDeEMsTUFBTSxDQUFDLEtBQUssR0FBRztZQUNkLENBQUMsQ0FBQyxJQUFJLENBQUMsUUFBUSxFQUFFLFVBQUMsT0FBcUI7Z0JBQ3RDLE9BQU8sQ0FBQyxPQUFPLEdBQUcsS0FBSyxDQUFDO2dCQUN4QixFQUFFLENBQUMsQ0FBQyxPQUFPLENBQUMsUUFBUSxDQUFDLENBQUMsQ0FBQztvQkFDdEIsT0FBTyxDQUFDLE1BQU0sT0FBZCxPQUFPLEVBQVcsT0FBTyxDQUFDLFlBQVksQ0FBQyxDQUFDO2dCQUN6QyxDQUFDO2dCQUFDLElBQUksQ0FBQyxDQUFDO29CQUNQLE9BQU8sQ0FBQyxPQUFPLENBQUMsTUFBTSxlQUFJLE9BQU8sQ0FBQyxNQUFNLENBQUMsQ0FBQyxDQUFDO2dCQUM1QyxDQUFDO1lBQ0YsQ0FBQyxDQUFDLENBQUM7WUFDSCxRQUFRLEdBQUcsRUFBRSxDQUFDO1lBQ2QsMkJBQWUsRUFBRSxDQUFDO1FBQ25CLENBQUMsQ0FBQztRQUVGLE1BQU0sQ0FBQyxNQUFNLENBQUM7SUFDZixDQUFDO0lBQ0YseUJBQUM7QUFBRCxDQUFDLEFBN0dELElBNkdDO0FBRVksbUJBQVcsR0FBd0IsSUFBSSxrQkFBa0IsRUFBRSxDQUFDIn0=