| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259 | 
							- '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 global = (function () {
 
-   if (typeof globalThis !== 'undefined') {
 
-     return globalThis;
 
-   } else if (typeof global !== 'undefined') {
 
-     return global;
 
-   } else if (typeof self !== 'undefined') {
 
-     return self;
 
-   } else if (typeof window !== 'undefined') {
 
-     return window;
 
-   } else {
 
-     return Function('return this')();
 
-   }
 
- })();
 
- var Symbol = global['jest-symbol-do-not-touch'] || global.Symbol;
 
- var global = (function () {
 
-   if (typeof globalThis !== 'undefined') {
 
-     return globalThis;
 
-   } else if (typeof global !== 'undefined') {
 
-     return global;
 
-   } else if (typeof self !== 'undefined') {
 
-     return self;
 
-   } else if (typeof window !== 'undefined') {
 
-     return window;
 
-   } else {
 
-     return Function('return this')();
 
-   }
 
- })();
 
- var Symbol = global['jest-symbol-do-not-touch'] || global.Symbol;
 
- var global = (function () {
 
-   if (typeof globalThis !== 'undefined') {
 
-     return globalThis;
 
-   } else if (typeof global !== 'undefined') {
 
-     return global;
 
-   } else if (typeof self !== 'undefined') {
 
-     return self;
 
-   } else if (typeof window !== 'undefined') {
 
-     return window;
 
-   } else {
 
-     return Function('return this')();
 
-   }
 
- })();
 
- 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);
 
-     }
 
-     if (typeof fn !== 'function') {
 
-       // Pass non-functions to Jest, which throws a nice error.
 
-       return originalFn.call(env, fn, timeout);
 
-     }
 
-     const hasDoneCallback = fn.length > 0;
 
-     if (hasDoneCallback) {
 
-       // Give the function a name so it can be detected in call stacks, but
 
-       // otherwise Jasmine will handle it.
 
-       const asyncJestLifecycleWithCallback = function (...args) {
 
-         // @ts-expect-error: Support possible extra args at runtime
 
-         return fn.apply(this, args);
 
-       };
 
-       return originalFn.call(env, asyncJestLifecycleWithCallback, 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;
 
-     }
 
-     if (typeof fn !== 'function') {
 
-       // Pass non-functions to Jest, which throws a nice error.
 
-       return originalFn.call(env, specName, fn, timeout);
 
-     }
 
-     const hasDoneCallback = fn.length > 0;
 
-     if (hasDoneCallback) {
 
-       // Give the function a name so it can be detected in call stacks, but
 
-       // otherwise Jasmine will handle it.
 
-       const asyncJestTestWithCallback = function (...args) {
 
-         // @ts-expect-error: Support possible extra args at runtime
 
-         return fn.apply(this, args);
 
-       };
 
-       return originalFn.call(env, specName, asyncJestTestWithCallback, 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);
 
-     } // Avoid triggering the uncaught promise rejection handler in case the test errors before
 
-     // being awaited on.
 
-     promise.catch(() => {});
 
-     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);
 
- }
 
 
  |