From 0c50a360534c34b737e184065c1f3c59914acc27 Mon Sep 17 00:00:00 2001 From: Eric Bailey Date: Wed, 22 May 2024 13:39:52 -0500 Subject: [PATCH] Better naming --- src/lib/async/retry.ts | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/src/lib/async/retry.ts b/src/lib/async/retry.ts index 2b605c442f..2e01be9043 100644 --- a/src/lib/async/retry.ts +++ b/src/lib/async/retry.ts @@ -2,13 +2,13 @@ import {XRPCError} from '@atproto/xrpc' import {isNetworkError} from 'lib/strings/errors' -export const NETWORK_FAILURE_STATUSES = [ +export const RETRYABLE_NETWORK_STATUS_CODES = [ 1, 408, 425, 429, 500, 502, 503, 504, 522, 524, ] -function isRetryable(e: unknown) { +function isRetryableError(e: unknown) { if (e instanceof XRPCError) { - if (NETWORK_FAILURE_STATUSES.includes(e.status)) { + if (RETRYABLE_NETWORK_STATUS_CODES.includes(e.status)) { return true } } @@ -20,10 +20,10 @@ export async function retry

( fn: () => Promise

, { retries, - checkIsRetryable = isRetryable, + checkIsRetryableError = isRetryableError, }: { retries: number - checkIsRetryable?: (err: any) => boolean + checkIsRetryableError?: (err: any) => boolean }, ): Promise

{ let lastErr @@ -32,7 +32,7 @@ export async function retry

( return await fn() } catch (e: any) { lastErr = e - if (checkIsRetryable(e)) { + if (checkIsRetryableError(e)) { retries-- continue }