retryFn.js

/**
 * Retries calling the provided async fn up to retryLimit times.
 *
 * @param {Function} fn
 * @param {integer} retryLimit
 *      Default: 1
 * @param {string} customRetryWarnMessage
 *      If set, this message will be used in the warning log message on errors
 *      caught before retry limit is reached.
 * @param {Object} logger
 * @return {Promise} result of fn
 */
async function retryFn(fn, retryLimit = 1, customRetryWarnMessage, logger) {
    for (let tryNum = 1; tryNum <= retryLimit; tryNum++) {
        try {
            return await fn();
        } catch (error) {
            if (logger) {
                const warnMessage =  customRetryWarnMessage || `Caught error when calling ${fn}`;
                logger.warn(
                    { error },
                    warnMessage + ` on try number ${tryNum} out of ${retryLimit}`
                );
            }
            if (tryNum === retryLimit) {
                throw error;
            }
        }
    }
}