Samuel Newman
40 lines
847 B
TypeScript
40 lines
847 B
TypeScript
import {timeout} from '#/lib/async/timeout'
|
|
import {isNetworkError, shouldRetryError} from '#/lib/strings/errors'
|
|
|
|
export function isRetryableRequestError(error: unknown) {
|
|
return isNetworkError(error) || shouldRetryError(error)
|
|
}
|
|
|
|
export async function retry<P>(
|
|
retries: number,
|
|
shouldRetry: (err: any) => boolean,
|
|
action: () => Promise<P>,
|
|
delay?: number,
|
|
): Promise<P> {
|
|
let lastErr
|
|
while (retries > 0) {
|
|
try {
|
|
return await action()
|
|
} catch (e: any) {
|
|
lastErr = e
|
|
if (shouldRetry(e)) {
|
|
if (delay) {
|
|
await timeout(delay)
|
|
}
|
|
retries--
|
|
continue
|
|
}
|
|
throw e
|
|
}
|
|
}
|
|
throw lastErr
|
|
}
|
|
|
|
export async function networkRetry<P>(
|
|
retries: number,
|
|
fn: () => Promise<P>,
|
|
delay?: number,
|
|
): Promise<P> {
|
|
return retry(retries, isNetworkError, fn, delay)
|
|
}
|