123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190 |
- 'use strict';
- Object.defineProperty(exports, '__esModule', {
- value: true
- });
- exports.default = jasmineAsyncInstall;
- var _co = _interopRequireDefault(require('co'));
- var _isGeneratorFn = _interopRequireDefault(require('is-generator-fn'));
- var _throat = _interopRequireDefault(require('throat'));
- var _isError = _interopRequireDefault(require('./isError'));
- function _interopRequireDefault(obj) {
- return obj && obj.__esModule ? obj : {default: obj};
- }
- var Symbol = global['jest-symbol-do-not-touch'] || global.Symbol;
- var Symbol = global['jest-symbol-do-not-touch'] || global.Symbol;
- var Promise = global[Symbol.for('jest-native-promise')] || global.Promise;
- function isPromise(obj) {
- return obj && typeof obj.then === 'function';
- }
- const doneFnNoop = () => {};
- doneFnNoop.fail = () => {};
- function promisifyLifeCycleFunction(originalFn, env) {
- return function (fn, timeout) {
- if (!fn) {
- // @ts-expect-error: missing fn arg is handled by originalFn
- return originalFn.call(env);
- }
- const hasDoneCallback = typeof fn === 'function' && fn.length > 0;
- if (hasDoneCallback) {
- // Jasmine will handle it
- return originalFn.call(env, fn, timeout);
- }
- const extraError = new Error(); // Without this line v8 stores references to all closures
- // in the stack in the Error object. This line stringifies the stack
- // property to allow garbage-collecting objects on the stack
- // https://crbug.com/v8/7142
- extraError.stack = extraError.stack; // We make *all* functions async and run `done` right away if they
- // didn't return a promise.
- const asyncJestLifecycle = function (done) {
- const wrappedFn = (0, _isGeneratorFn.default)(fn)
- ? _co.default.wrap(fn)
- : fn;
- const returnValue = wrappedFn.call({}, doneFnNoop);
- if (isPromise(returnValue)) {
- returnValue.then(done.bind(null, null), error => {
- const {isError: checkIsError, message} = (0, _isError.default)(error);
- if (message) {
- extraError.message = message;
- }
- done.fail(checkIsError ? error : extraError);
- });
- } else {
- done();
- }
- };
- return originalFn.call(env, asyncJestLifecycle, timeout);
- };
- } // Similar to promisifyLifeCycleFunction but throws an error
- // when the return value is neither a Promise nor `undefined`
- function promisifyIt(originalFn, env, jasmine) {
- return function (specName, fn, timeout) {
- if (!fn) {
- // @ts-expect-error: missing fn arg is handled by originalFn
- const spec = originalFn.call(env, specName);
- spec.pend('not implemented');
- return spec;
- }
- const hasDoneCallback = fn.length > 0;
- if (hasDoneCallback) {
- return originalFn.call(env, specName, fn, timeout);
- }
- const extraError = new Error(); // Without this line v8 stores references to all closures
- // in the stack in the Error object. This line stringifies the stack
- // property to allow garbage-collecting objects on the stack
- // https://crbug.com/v8/7142
- extraError.stack = extraError.stack;
- const asyncJestTest = function (done) {
- const wrappedFn = (0, _isGeneratorFn.default)(fn)
- ? _co.default.wrap(fn)
- : fn;
- const returnValue = wrappedFn.call({}, doneFnNoop);
- if (isPromise(returnValue)) {
- returnValue.then(done.bind(null, null), error => {
- const {isError: checkIsError, message} = (0, _isError.default)(error);
- if (message) {
- extraError.message = message;
- }
- if (jasmine.Spec.isPendingSpecException(error)) {
- env.pending(message);
- done();
- } else {
- done.fail(checkIsError ? error : extraError);
- }
- });
- } else if (returnValue === undefined) {
- done();
- } else {
- done.fail(
- new Error(
- 'Jest: `it` and `test` must return either a Promise or undefined.'
- )
- );
- }
- };
- return originalFn.call(env, specName, asyncJestTest, timeout);
- };
- }
- function makeConcurrent(originalFn, env, mutex) {
- const concurrentFn = function (specName, fn, timeout) {
- let promise = Promise.resolve();
- const spec = originalFn.call(env, specName, () => promise, timeout);
- if (env != null && !env.specFilter(spec)) {
- return spec;
- }
- try {
- promise = mutex(() => {
- const promise = fn();
- if (isPromise(promise)) {
- return promise;
- }
- throw new Error(
- `Jest: concurrent test "${spec.getFullName()}" must return a Promise.`
- );
- });
- } catch (error) {
- promise = Promise.reject(error);
- }
- return spec;
- }; // each is binded after the function is made concurrent, so for now it is made noop
- concurrentFn.each = () => () => {};
- return concurrentFn;
- }
- function jasmineAsyncInstall(globalConfig, global) {
- const jasmine = global.jasmine;
- const mutex = (0, _throat.default)(globalConfig.maxConcurrency);
- const env = jasmine.getEnv();
- env.it = promisifyIt(env.it, env, jasmine);
- env.fit = promisifyIt(env.fit, env, jasmine);
- global.it.concurrent = (env => {
- const concurrent = makeConcurrent(env.it, env, mutex);
- concurrent.only = makeConcurrent(env.fit, env, mutex);
- concurrent.skip = makeConcurrent(env.xit, env, mutex);
- return concurrent;
- })(env);
- global.fit.concurrent = makeConcurrent(env.fit, env, mutex);
- env.afterAll = promisifyLifeCycleFunction(env.afterAll, env);
- env.afterEach = promisifyLifeCycleFunction(env.afterEach, env);
- env.beforeAll = promisifyLifeCycleFunction(env.beforeAll, env);
- env.beforeEach = promisifyLifeCycleFunction(env.beforeEach, env);
- }
|