Halfway done

node_modules/@humanwhocodes/retry/dist/retrier.cjs

@@ -0,0 +1,284 @@
+'use strict';
+
+/**
+ * @fileoverview A utility for retrying failed async method calls.
+ */
+
+/* global setTimeout, clearTimeout */
+
+//-----------------------------------------------------------------------------
+// Constants
+//-----------------------------------------------------------------------------
+
+const MAX_TASK_TIMEOUT = 60000;
+const MAX_TASK_DELAY = 100;
+
+//-----------------------------------------------------------------------------
+// Helpers
+//-----------------------------------------------------------------------------
+
+/*
+ * The following logic has been extracted from graceful-fs.
+ *
+ * The ISC License
+ *
+ * Copyright (c) 2011-2023 Isaac Z. Schlueter, Ben Noordhuis, and Contributors
+ *
+ * Permission to use, copy, modify, and/or distribute this software for any
+ * purpose with or without fee is hereby granted, provided that the above
+ * copyright notice and this permission notice appear in all copies.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
+ * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
+ * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
+ * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
+ * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
+ * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF OR
+ * IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
+ */
+
+/**
+ * Checks if it is time to retry a task based on the timestamp and last attempt time.
+ * @param {RetryTask} task The task to check.
+ * @param {number} maxDelay The maximum delay for the queue.
+ * @returns {boolean} true if it is time to retry, false otherwise.
+ */
+function isTimeToRetry(task, maxDelay) {
+    const timeSinceLastAttempt = Date.now() - task.lastAttempt;
+    const timeSinceStart = Math.max(task.lastAttempt - task.timestamp, 1);
+    const desiredDelay = Math.min(timeSinceStart * 1.2, maxDelay);
+
+    return timeSinceLastAttempt >= desiredDelay;
+}
+
+/**
+ * Checks if it is time to bail out based on the given timestamp.
+ * @param {RetryTask} task The task to check.
+ * @param {number} timeout The timeout for the queue.
+ * @returns {boolean} true if it is time to bail, false otherwise.
+ */
+function isTimeToBail(task, timeout) {
+    return Date.now() - task.timestamp > timeout;
+}
+
+
+/**
+ * A class to represent a task in the retry queue.
+ */
+class RetryTask {
+    /**
+     * The function to call.
+     * @type {Function}
+     */
+    fn;
+
+    /**
+     * The error that was thrown.
+     * @type {Error}
+     */
+    error;
+    
+    /**
+     * The timestamp of the task.
+     * @type {number}
+     */
+    timestamp = Date.now();
+
+    /**
+     * The timestamp of the last attempt.
+     * @type {number}
+     */
+    lastAttempt = this.timestamp;
+
+    /**
+     * The resolve function for the promise.
+     * @type {Function}
+     */
+    resolve;
+
+    /**
+     * The reject function for the promise.
+     * @type {Function}
+     */
+    reject;
+
+    /**
+     * The AbortSignal to monitor for cancellation.
+     * @type {AbortSignal|undefined}
+     */
+    signal;
+
+    /**
+     * Creates a new instance.
+     * @param {Function} fn The function to call.
+     * @param {Error} error The error that was thrown.
+     * @param {Function} resolve The resolve function for the promise.
+     * @param {Function} reject The reject function for the promise.
+     * @param {AbortSignal|undefined} signal The AbortSignal to monitor for cancellation.
+     */
+    constructor(fn, error, resolve, reject, signal) {
+        this.fn = fn;
+        this.error = error;
+        this.timestamp = Date.now();
+        this.lastAttempt = Date.now();
+        this.resolve = resolve;
+        this.reject = reject;
+        this.signal = signal;
+    }
+    
+}
+
+//-----------------------------------------------------------------------------
+// Exports
+//-----------------------------------------------------------------------------
+
+/**
+ * A class that manages a queue of retry jobs.
+ */
+class Retrier {
+    /**
+     * Represents the queue for processing tasks.
+     * @type {Array<RetryTask>}
+     */
+    #queue = [];
+
+    /**
+     * The timeout for the queue.
+     * @type {number}
+     */
+    #timeout;
+
+    /**
+     * The maximum delay for the queue.
+     * @type {number}
+     */
+    #maxDelay;
+
+    /**
+     * The setTimeout() timer ID.
+     * @type {NodeJS.Timeout|undefined}
+     */
+    #timerId;
+
+    /**
+     * The function to call.
+     * @type {Function}
+     */
+    #check;
+
+    /**
+     * Creates a new instance.
+     * @param {Function} check The function to call.
+     * @param {object} [options] The options for the instance.
+     * @param {number} [options.timeout] The timeout for the queue.
+     * @param {number} [options.maxDelay] The maximum delay for the queue.
+     */
+    constructor(check, { timeout = MAX_TASK_TIMEOUT, maxDelay = MAX_TASK_DELAY } = {}) {
+
+        if (typeof check !== "function") {
+            throw new Error("Missing function to check errors");
+        }
+
+        this.#check = check;
+        this.#timeout = timeout;
+        this.#maxDelay = maxDelay;
+    }
+
+    /**
+     * Adds a new retry job to the queue.
+     * @param {Function} fn The function to call.
+     * @param {object} [options] The options for the job.
+     * @param {AbortSignal} [options.signal] The AbortSignal to monitor for cancellation.
+     * @returns {Promise<any>} A promise that resolves when the queue is
+     *  processed.
+     */
+    retry(fn, { signal } = {}) {
+
+        signal?.throwIfAborted();
+
+        let result;
+
+        try {
+            result = fn();
+        } catch (/** @type {any} */ error) {
+            return Promise.reject(new Error(`Synchronous error: ${error.message}`, { cause: error }));
+        }
+
+        // if the result is not a promise then reject an error
+        if (!result || typeof result.then !== "function") {
+            return Promise.reject(new Error("Result is not a promise."));
+        }
+
+        // call the original function and catch any ENFILE or EMFILE errors
+        // @ts-ignore because we know it's any
+        return Promise.resolve(result).catch(error => {
+            if (!this.#check(error)) {
+                throw error;
+            }
+
+            return new Promise((resolve, reject) => {
+                this.#queue.push(new RetryTask(fn, error, resolve, reject, signal));
+
+                signal?.addEventListener("abort", () => {
+                    reject(signal.reason);
+                });
+
+                this.#processQueue();
+            });
+        });
+    }
+
+    /**
+     * Processes the queue.
+     * @returns {void}
+     */
+    #processQueue() {
+        // clear any timer because we're going to check right now
+        clearTimeout(this.#timerId);
+        this.#timerId = undefined;
+
+        // if there's nothing in the queue, we're done
+        const task = this.#queue.shift();
+        if (!task) {
+            return;
+        }
+
+        // if it's time to bail, then bail
+        if (isTimeToBail(task, this.#timeout)) {
+            task.reject(task.error);
+            this.#processQueue();
+            return;
+        }
+
+        // if it's not time to retry, then wait and try again
+        if (!isTimeToRetry(task, this.#maxDelay)) {
+            this.#queue.unshift(task);
+            this.#timerId = setTimeout(() => this.#processQueue(), 0);
+            return;
+        }
+
+        // otherwise, try again
+        task.lastAttempt = Date.now();
+        
+        // Promise.resolve needed in case it's a thenable but not a Promise
+        Promise.resolve(task.fn())
+            // @ts-ignore because we know it's any
+            .then(result => task.resolve(result))
+
+            // @ts-ignore because we know it's any
+            .catch(error => {
+                if (!this.#check(error)) {
+                    task.reject(error);
+                    return;
+                }
+
+                // update the task timestamp and push to back of queue to try again
+                task.lastAttempt = Date.now();
+                this.#queue.push(task);
+
+            })
+            .finally(() => this.#processQueue());
+    }
+}
+
+exports.Retrier = Retrier;

node_modules/@humanwhocodes/retry/dist/retrier.d.cts

@@ -0,0 +1,28 @@
+/**
+ * A class that manages a queue of retry jobs.
+ */
+export class Retrier {
+    /**
+     * Creates a new instance.
+     * @param {Function} check The function to call.
+     * @param {object} [options] The options for the instance.
+     * @param {number} [options.timeout] The timeout for the queue.
+     * @param {number} [options.maxDelay] The maximum delay for the queue.
+     */
+    constructor(check: Function, { timeout, maxDelay }?: {
+        timeout?: number | undefined;
+        maxDelay?: number | undefined;
+    } | undefined);
+    /**
+     * Adds a new retry job to the queue.
+     * @param {Function} fn The function to call.
+     * @param {object} [options] The options for the job.
+     * @param {AbortSignal} [options.signal] The AbortSignal to monitor for cancellation.
+     * @returns {Promise<any>} A promise that resolves when the queue is
+     *  processed.
+     */
+    retry(fn: Function, { signal }?: {
+        signal?: AbortSignal | undefined;
+    } | undefined): Promise<any>;
+    #private;
+}

node_modules/@humanwhocodes/retry/dist/retrier.d.ts

@@ -0,0 +1,28 @@
+/**
+ * A class that manages a queue of retry jobs.
+ */
+export class Retrier {
+    /**
+     * Creates a new instance.
+     * @param {Function} check The function to call.
+     * @param {object} [options] The options for the instance.
+     * @param {number} [options.timeout] The timeout for the queue.
+     * @param {number} [options.maxDelay] The maximum delay for the queue.
+     */
+    constructor(check: Function, { timeout, maxDelay }?: {
+        timeout?: number | undefined;
+        maxDelay?: number | undefined;
+    } | undefined);
+    /**
+     * Adds a new retry job to the queue.
+     * @param {Function} fn The function to call.
+     * @param {object} [options] The options for the job.
+     * @param {AbortSignal} [options.signal] The AbortSignal to monitor for cancellation.
+     * @returns {Promise<any>} A promise that resolves when the queue is
+     *  processed.
+     */
+    retry(fn: Function, { signal }?: {
+        signal?: AbortSignal | undefined;
+    } | undefined): Promise<any>;
+    #private;
+}

node_modules/@humanwhocodes/retry/dist/retrier.js

@@ -0,0 +1,283 @@
+/// <reference types="./retrier.d.ts" />
+/**
+ * @fileoverview A utility for retrying failed async method calls.
+ */
+
+/* global setTimeout, clearTimeout */
+
+//-----------------------------------------------------------------------------
+// Constants
+//-----------------------------------------------------------------------------
+
+const MAX_TASK_TIMEOUT = 60000;
+const MAX_TASK_DELAY = 100;
+
+//-----------------------------------------------------------------------------
+// Helpers
+//-----------------------------------------------------------------------------
+
+/*
+ * The following logic has been extracted from graceful-fs.
+ *
+ * The ISC License
+ *
+ * Copyright (c) 2011-2023 Isaac Z. Schlueter, Ben Noordhuis, and Contributors
+ *
+ * Permission to use, copy, modify, and/or distribute this software for any
+ * purpose with or without fee is hereby granted, provided that the above
+ * copyright notice and this permission notice appear in all copies.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
+ * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
+ * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
+ * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
+ * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
+ * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF OR
+ * IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
+ */
+
+/**
+ * Checks if it is time to retry a task based on the timestamp and last attempt time.
+ * @param {RetryTask} task The task to check.
+ * @param {number} maxDelay The maximum delay for the queue.
+ * @returns {boolean} true if it is time to retry, false otherwise.
+ */
+function isTimeToRetry(task, maxDelay) {
+    const timeSinceLastAttempt = Date.now() - task.lastAttempt;
+    const timeSinceStart = Math.max(task.lastAttempt - task.timestamp, 1);
+    const desiredDelay = Math.min(timeSinceStart * 1.2, maxDelay);
+
+    return timeSinceLastAttempt >= desiredDelay;
+}
+
+/**
+ * Checks if it is time to bail out based on the given timestamp.
+ * @param {RetryTask} task The task to check.
+ * @param {number} timeout The timeout for the queue.
+ * @returns {boolean} true if it is time to bail, false otherwise.
+ */
+function isTimeToBail(task, timeout) {
+    return Date.now() - task.timestamp > timeout;
+}
+
+
+/**
+ * A class to represent a task in the retry queue.
+ */
+class RetryTask {
+    /**
+     * The function to call.
+     * @type {Function}
+     */
+    fn;
+
+    /**
+     * The error that was thrown.
+     * @type {Error}
+     */
+    error;
+    
+    /**
+     * The timestamp of the task.
+     * @type {number}
+     */
+    timestamp = Date.now();
+
+    /**
+     * The timestamp of the last attempt.
+     * @type {number}
+     */
+    lastAttempt = this.timestamp;
+
+    /**
+     * The resolve function for the promise.
+     * @type {Function}
+     */
+    resolve;
+
+    /**
+     * The reject function for the promise.
+     * @type {Function}
+     */
+    reject;
+
+    /**
+     * The AbortSignal to monitor for cancellation.
+     * @type {AbortSignal|undefined}
+     */
+    signal;
+
+    /**
+     * Creates a new instance.
+     * @param {Function} fn The function to call.
+     * @param {Error} error The error that was thrown.
+     * @param {Function} resolve The resolve function for the promise.
+     * @param {Function} reject The reject function for the promise.
+     * @param {AbortSignal|undefined} signal The AbortSignal to monitor for cancellation.
+     */
+    constructor(fn, error, resolve, reject, signal) {
+        this.fn = fn;
+        this.error = error;
+        this.timestamp = Date.now();
+        this.lastAttempt = Date.now();
+        this.resolve = resolve;
+        this.reject = reject;
+        this.signal = signal;
+    }
+    
+}
+
+//-----------------------------------------------------------------------------
+// Exports
+//-----------------------------------------------------------------------------
+
+/**
+ * A class that manages a queue of retry jobs.
+ */
+class Retrier {
+    /**
+     * Represents the queue for processing tasks.
+     * @type {Array<RetryTask>}
+     */
+    #queue = [];
+
+    /**
+     * The timeout for the queue.
+     * @type {number}
+     */
+    #timeout;
+
+    /**
+     * The maximum delay for the queue.
+     * @type {number}
+     */
+    #maxDelay;
+
+    /**
+     * The setTimeout() timer ID.
+     * @type {NodeJS.Timeout|undefined}
+     */
+    #timerId;
+
+    /**
+     * The function to call.
+     * @type {Function}
+     */
+    #check;
+
+    /**
+     * Creates a new instance.
+     * @param {Function} check The function to call.
+     * @param {object} [options] The options for the instance.
+     * @param {number} [options.timeout] The timeout for the queue.
+     * @param {number} [options.maxDelay] The maximum delay for the queue.
+     */
+    constructor(check, { timeout = MAX_TASK_TIMEOUT, maxDelay = MAX_TASK_DELAY } = {}) {
+
+        if (typeof check !== "function") {
+            throw new Error("Missing function to check errors");
+        }
+
+        this.#check = check;
+        this.#timeout = timeout;
+        this.#maxDelay = maxDelay;
+    }
+
+    /**
+     * Adds a new retry job to the queue.
+     * @param {Function} fn The function to call.
+     * @param {object} [options] The options for the job.
+     * @param {AbortSignal} [options.signal] The AbortSignal to monitor for cancellation.
+     * @returns {Promise<any>} A promise that resolves when the queue is
+     *  processed.
+     */
+    retry(fn, { signal } = {}) {
+
+        signal?.throwIfAborted();
+
+        let result;
+
+        try {
+            result = fn();
+        } catch (/** @type {any} */ error) {
+            return Promise.reject(new Error(`Synchronous error: ${error.message}`, { cause: error }));
+        }
+
+        // if the result is not a promise then reject an error
+        if (!result || typeof result.then !== "function") {
+            return Promise.reject(new Error("Result is not a promise."));
+        }
+
+        // call the original function and catch any ENFILE or EMFILE errors
+        // @ts-ignore because we know it's any
+        return Promise.resolve(result).catch(error => {
+            if (!this.#check(error)) {
+                throw error;
+            }
+
+            return new Promise((resolve, reject) => {
+                this.#queue.push(new RetryTask(fn, error, resolve, reject, signal));
+
+                signal?.addEventListener("abort", () => {
+                    reject(signal.reason);
+                });
+
+                this.#processQueue();
+            });
+        });
+    }
+
+    /**
+     * Processes the queue.
+     * @returns {void}
+     */
+    #processQueue() {
+        // clear any timer because we're going to check right now
+        clearTimeout(this.#timerId);
+        this.#timerId = undefined;
+
+        // if there's nothing in the queue, we're done
+        const task = this.#queue.shift();
+        if (!task) {
+            return;
+        }
+
+        // if it's time to bail, then bail
+        if (isTimeToBail(task, this.#timeout)) {
+            task.reject(task.error);
+            this.#processQueue();
+            return;
+        }
+
+        // if it's not time to retry, then wait and try again
+        if (!isTimeToRetry(task, this.#maxDelay)) {
+            this.#queue.unshift(task);
+            this.#timerId = setTimeout(() => this.#processQueue(), 0);
+            return;
+        }
+
+        // otherwise, try again
+        task.lastAttempt = Date.now();
+        
+        // Promise.resolve needed in case it's a thenable but not a Promise
+        Promise.resolve(task.fn())
+            // @ts-ignore because we know it's any
+            .then(result => task.resolve(result))
+
+            // @ts-ignore because we know it's any
+            .catch(error => {
+                if (!this.#check(error)) {
+                    task.reject(error);
+                    return;
+                }
+
+                // update the task timestamp and push to back of queue to try again
+                task.lastAttempt = Date.now();
+                this.#queue.push(task);
+
+            })
+            .finally(() => this.#processQueue());
+    }
+}
+
+export { Retrier };

node_modules/@humanwhocodes/retry/dist/retrier.min.js

@@ -0,0 +1 @@
+class RetryTask{fn;error;timestamp=Date.now();lastAttempt=this.timestamp;resolve;reject;signal;constructor(t,e,r,s,i){this.fn=t,this.error=e,this.timestamp=Date.now(),this.lastAttempt=Date.now(),this.resolve=r,this.reject=s,this.signal=i}}class Retrier{#t=[];#e;#r;#s;#i;constructor(t,{timeout:e=6e4,maxDelay:r=100}={}){if("function"!=typeof t)throw new Error("Missing function to check errors");this.#i=t,this.#e=e,this.#r=r}retry(t,{signal:e}={}){let r;e?.throwIfAborted();try{r=t()}catch(t){return Promise.reject(new Error(`Synchronous error: ${t.message}`,{cause:t}))}return r&&"function"==typeof r.then?Promise.resolve(r).catch((r=>{if(!this.#i(r))throw r;return new Promise(((s,i)=>{this.#t.push(new RetryTask(t,r,s,i,e)),e?.addEventListener("abort",(()=>{i(e.reason)})),this.#o()}))})):Promise.reject(new Error("Result is not a promise."))}#o(){clearTimeout(this.#s),this.#s=void 0;const t=this.#t.shift();if(t){if(function(t,e){return Date.now()-t.timestamp>e}(t,this.#e))return t.reject(t.error),void this.#o();if(!function(t,e){const r=Date.now()-t.lastAttempt,s=Math.max(t.lastAttempt-t.timestamp,1);return r>=Math.min(1.2*s,e)}(t,this.#r))return this.#t.unshift(t),void(this.#s=setTimeout((()=>this.#o()),0));t.lastAttempt=Date.now(),Promise.resolve(t.fn()).then((e=>t.resolve(e))).catch((e=>{this.#i(e)?(t.lastAttempt=Date.now(),this.#t.push(t)):t.reject(e)})).finally((()=>this.#o()))}}}export{Retrier};

node_modules/@humanwhocodes/retry/dist/retrier.mjs

@@ -0,0 +1,282 @@
+/**
+ * @fileoverview A utility for retrying failed async method calls.
+ */
+
+/* global setTimeout, clearTimeout */
+
+//-----------------------------------------------------------------------------
+// Constants
+//-----------------------------------------------------------------------------
+
+const MAX_TASK_TIMEOUT = 60000;
+const MAX_TASK_DELAY = 100;
+
+//-----------------------------------------------------------------------------
+// Helpers
+//-----------------------------------------------------------------------------
+
+/*
+ * The following logic has been extracted from graceful-fs.
+ *
+ * The ISC License
+ *
+ * Copyright (c) 2011-2023 Isaac Z. Schlueter, Ben Noordhuis, and Contributors
+ *
+ * Permission to use, copy, modify, and/or distribute this software for any
+ * purpose with or without fee is hereby granted, provided that the above
+ * copyright notice and this permission notice appear in all copies.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
+ * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
+ * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
+ * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
+ * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
+ * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF OR
+ * IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
+ */
+
+/**
+ * Checks if it is time to retry a task based on the timestamp and last attempt time.
+ * @param {RetryTask} task The task to check.
+ * @param {number} maxDelay The maximum delay for the queue.
+ * @returns {boolean} true if it is time to retry, false otherwise.
+ */
+function isTimeToRetry(task, maxDelay) {
+    const timeSinceLastAttempt = Date.now() - task.lastAttempt;
+    const timeSinceStart = Math.max(task.lastAttempt - task.timestamp, 1);
+    const desiredDelay = Math.min(timeSinceStart * 1.2, maxDelay);
+
+    return timeSinceLastAttempt >= desiredDelay;
+}
+
+/**
+ * Checks if it is time to bail out based on the given timestamp.
+ * @param {RetryTask} task The task to check.
+ * @param {number} timeout The timeout for the queue.
+ * @returns {boolean} true if it is time to bail, false otherwise.
+ */
+function isTimeToBail(task, timeout) {
+    return Date.now() - task.timestamp > timeout;
+}
+
+
+/**
+ * A class to represent a task in the retry queue.
+ */
+class RetryTask {
+    /**
+     * The function to call.
+     * @type {Function}
+     */
+    fn;
+
+    /**
+     * The error that was thrown.
+     * @type {Error}
+     */
+    error;
+    
+    /**
+     * The timestamp of the task.
+     * @type {number}
+     */
+    timestamp = Date.now();
+
+    /**
+     * The timestamp of the last attempt.
+     * @type {number}
+     */
+    lastAttempt = this.timestamp;
+
+    /**
+     * The resolve function for the promise.
+     * @type {Function}
+     */
+    resolve;
+
+    /**
+     * The reject function for the promise.
+     * @type {Function}
+     */
+    reject;
+
+    /**
+     * The AbortSignal to monitor for cancellation.
+     * @type {AbortSignal|undefined}
+     */
+    signal;
+
+    /**
+     * Creates a new instance.
+     * @param {Function} fn The function to call.
+     * @param {Error} error The error that was thrown.
+     * @param {Function} resolve The resolve function for the promise.
+     * @param {Function} reject The reject function for the promise.
+     * @param {AbortSignal|undefined} signal The AbortSignal to monitor for cancellation.
+     */
+    constructor(fn, error, resolve, reject, signal) {
+        this.fn = fn;
+        this.error = error;
+        this.timestamp = Date.now();
+        this.lastAttempt = Date.now();
+        this.resolve = resolve;
+        this.reject = reject;
+        this.signal = signal;
+    }
+    
+}
+
+//-----------------------------------------------------------------------------
+// Exports
+//-----------------------------------------------------------------------------
+
+/**
+ * A class that manages a queue of retry jobs.
+ */
+class Retrier {
+    /**
+     * Represents the queue for processing tasks.
+     * @type {Array<RetryTask>}
+     */
+    #queue = [];
+
+    /**
+     * The timeout for the queue.
+     * @type {number}
+     */
+    #timeout;
+
+    /**
+     * The maximum delay for the queue.
+     * @type {number}
+     */
+    #maxDelay;
+
+    /**
+     * The setTimeout() timer ID.
+     * @type {NodeJS.Timeout|undefined}
+     */
+    #timerId;
+
+    /**
+     * The function to call.
+     * @type {Function}
+     */
+    #check;
+
+    /**
+     * Creates a new instance.
+     * @param {Function} check The function to call.
+     * @param {object} [options] The options for the instance.
+     * @param {number} [options.timeout] The timeout for the queue.
+     * @param {number} [options.maxDelay] The maximum delay for the queue.
+     */
+    constructor(check, { timeout = MAX_TASK_TIMEOUT, maxDelay = MAX_TASK_DELAY } = {}) {
+
+        if (typeof check !== "function") {
+            throw new Error("Missing function to check errors");
+        }
+
+        this.#check = check;
+        this.#timeout = timeout;
+        this.#maxDelay = maxDelay;
+    }
+
+    /**
+     * Adds a new retry job to the queue.
+     * @param {Function} fn The function to call.
+     * @param {object} [options] The options for the job.
+     * @param {AbortSignal} [options.signal] The AbortSignal to monitor for cancellation.
+     * @returns {Promise<any>} A promise that resolves when the queue is
+     *  processed.
+     */
+    retry(fn, { signal } = {}) {
+
+        signal?.throwIfAborted();
+
+        let result;
+
+        try {
+            result = fn();
+        } catch (/** @type {any} */ error) {
+            return Promise.reject(new Error(`Synchronous error: ${error.message}`, { cause: error }));
+        }
+
+        // if the result is not a promise then reject an error
+        if (!result || typeof result.then !== "function") {
+            return Promise.reject(new Error("Result is not a promise."));
+        }
+
+        // call the original function and catch any ENFILE or EMFILE errors
+        // @ts-ignore because we know it's any
+        return Promise.resolve(result).catch(error => {
+            if (!this.#check(error)) {
+                throw error;
+            }
+
+            return new Promise((resolve, reject) => {
+                this.#queue.push(new RetryTask(fn, error, resolve, reject, signal));
+
+                signal?.addEventListener("abort", () => {
+                    reject(signal.reason);
+                });
+
+                this.#processQueue();
+            });
+        });
+    }
+
+    /**
+     * Processes the queue.
+     * @returns {void}
+     */
+    #processQueue() {
+        // clear any timer because we're going to check right now
+        clearTimeout(this.#timerId);
+        this.#timerId = undefined;
+
+        // if there's nothing in the queue, we're done
+        const task = this.#queue.shift();
+        if (!task) {
+            return;
+        }
+
+        // if it's time to bail, then bail
+        if (isTimeToBail(task, this.#timeout)) {
+            task.reject(task.error);
+            this.#processQueue();
+            return;
+        }
+
+        // if it's not time to retry, then wait and try again
+        if (!isTimeToRetry(task, this.#maxDelay)) {
+            this.#queue.unshift(task);
+            this.#timerId = setTimeout(() => this.#processQueue(), 0);
+            return;
+        }
+
+        // otherwise, try again
+        task.lastAttempt = Date.now();
+        
+        // Promise.resolve needed in case it's a thenable but not a Promise
+        Promise.resolve(task.fn())
+            // @ts-ignore because we know it's any
+            .then(result => task.resolve(result))
+
+            // @ts-ignore because we know it's any
+            .catch(error => {
+                if (!this.#check(error)) {
+                    task.reject(error);
+                    return;
+                }
+
+                // update the task timestamp and push to back of queue to try again
+                task.lastAttempt = Date.now();
+                this.#queue.push(task);
+
+            })
+            .finally(() => this.#processQueue());
+    }
+}
+
+export { Retrier };