| 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);}
 |