1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859
/**  * Retry a function until it does not throw an exception. *   * @param fn the function to execute * @param {RetryOptions} retryOptions retry options */export async function retry<T>(  fn: () => T,  retryOptions: RetryOptions,): Promise<T> {  const wrapped = () =>    new Promise<T>((resolve, reject) => {      try {        const result = fn();        resolve(result);      } catch (err) {        reject(err);      }    });  return retryAsync(wrapped, retryOptions);}
/**  * Retry an async function until it does not throw an exception. *   * @param fn the function to execute * @param {RetryOptions} retryOptions retry options */export async function retryAsync<T>(  fn: () => Promise<T>,  { maxTry, delay: delay }: RetryOptions,): Promise<T> {  try {    return await fn();  } catch (err) {    if (maxTry > 1) {      await wait(delay);      return await retryAsync(fn, { delay: delay, maxTry: maxTry - 1 });    }    throw err;  }}
/**  * Retry options: * @typedef {Object} RetryOptions * @property {number} maxTry: maximum number of attempts. if fn is still throwing execption afect maxtry attempts, an exepction is thrown  * @property {number} delay: number of miliseconds between each attempt. */export interface RetryOptions {  maxTry: number;  delay: number;}
/** An async function that does nothing during a number of milliseconds */export function wait(duration: number): Promise<void> {  return new Promise<void>((resolve) => setTimeout(resolve, duration));}