bail should prevent any further calls to the retrier function about async-retry HOT 14 OPEN

const retry = require('async-retry');

const _retry = (cb, ...opts) => {
  let bailedOut;

  return retry(
    (bail, ...rest) =>
      new Promise((resolve, reject) => {
        cb((error) => {
          bailedOut = true;
          bail(error);
        }, ...rest).then(
          (result) => {
              if (!bailedOut) {
                resolve(result);
              }
          },
          (error) => {
              if (!bailedOut) {
                reject(error);
              }
          }
        );
      }),
    ...opts
  );
};

// @flow strict
import retry from 'async-retry';

describe('async-retry', () => {
  const bailError = new Error('BAIL');
  const rejectError = new Error('BOOM');

  test('retries N times', async () => {
    const cb = jest.fn().mockImplementation(
      async () => {
        throw rejectError;
      }
    );

    await expect(
      retry(cb, { retries: 3, factor: 1, minTimeout: 0 })
    ).rejects.toBe(rejectError);

    expect(cb).toHaveBeenCalledTimes(4);
  });

  test('does not keep retrying once bail out is called', async () => {
    const cb = jest.fn().mockImplementation(async (bail, count) => {
      console.log('START');

      if (count === 2) {
        bail(bailError);
        console.log('BAIL');
      }
      throw rejectError;
    });

    await expect(
      retry(cb, { retries: 5, factor: 1, minTimeout: 0 })
    ).rejects.toBe(bailError);

    expect(cb).toHaveBeenCalledTimes(2);
  });
});

import retry from 'async-retry';
import merge frorm 'lodash/merge';

const retries = 3;
const defaultOptions = {
  headers: {
    Accept: 'application/json',
    'Content-Type': 'application/json',
  },
  method: 'GET',
};
const isJson = response => {
  const contentType = response.headers.get('Content-Type');
  return !!(contentType && contentType.indexOf('application/json') !== -1);
};

async function request(
  url,
  options = {},
) {
  const allOptions = merge({}, defaultOptions, options);
  const response = await fetch(url, allOptions);

  const json = isJson(response) ? await response.json() : null;

  if (response.ok) {
    return json;
  }

  throw json;
}


/* ------ key part for this example -------  */
const response = await retry(
  async bail => {
    try {
      return await request('https://google.com');

      /* 
       * If the request function definition above is confusing you, just do a normal fetch like this 
       * return await fetch('https://google.com');
       */
    } catch (e) {
      if (e.status >= 400 || e.status < 500) return bail(e);

      throw e;
    }
  },
  {
    retries,
  },
);