Add auto-retry for API calls

Author: Minishlink

src/checkForUpdates.ts

@@ -7,7 +7,7 @@ import { getConfiguration } from './internals/getConfiguration';
 import { getCurrentPackage } from './internals/getCurrentPackage';
 import type { Configuration } from './internals/types';
 import { log } from './internals/utils/log';
-import { requestFetchAdapter } from './internals/utils/request-fetch-adapter';
+import { requestFetchAdapter } from './internals/utils/requestFetchAdapter';
 import type { HandleBinaryVersionMismatchCallback, RemotePackage } from './types';
 
 /**

src/internals/utils/fetchRetry.ts

@@ -0,0 +1,72 @@
+export async function fetchRetry(url: string, options: FetchRetryOptions = {}, attempt = 0): Promise<Response> {
+  const {
+    maxRetries = 3,
+    initialBackoff = 1000,
+    backoffMultiplier = 2,
+    maxRetryDelay = 30000,
+    ...fetchOptions
+  } = options;
+
+  try {
+    const response = await fetch(url, fetchOptions);
+    if (response.ok || !(response.status === 429 || response.status >= 500)) {
+      return response;
+    }
+
+    if (attempt >= maxRetries) {
+      return response;
+    }
+
+    const retryAfter = parseRetryAfterHeader(response);
+    if (retryAfter && retryAfter > maxRetryDelay) {
+      return response;
+    }
+
+    const delay = retryAfter ?? addJitter(initialBackoff * Math.pow(backoffMultiplier, attempt));
+
+    await new Promise((resolve) => setTimeout(resolve, delay));
+
+    return fetchRetry(url, options, attempt + 1);
+  } catch (error) {
+    if (attempt >= maxRetries) {
+      throw error;
+    }
+
+    const delay = addJitter(initialBackoff * Math.pow(backoffMultiplier, attempt));
+
+    await new Promise((resolve) => setTimeout(resolve, delay));
+
+    return fetchRetry(url, options, attempt + 1);
+  }
+}
+
+interface FetchRetryOptions extends RequestInit {
+  maxRetries?: number;
+  initialBackoff?: number;
+  backoffMultiplier?: number;
+  maxRetryDelay?: number;
+}
+
+function parseRetryAfterHeader(response: Response): number | null {
+  const retryAfter = response.headers.get('Retry-After');
+  if (!retryAfter) {
+    return null;
+  }
+
+  if (!isNaN(Number(retryAfter))) {
+    return parseInt(retryAfter, 10) * 1000;
+  }
+
+  try {
+    const retryDate = new Date(retryAfter).getTime();
+    const now = Date.now();
+    return retryDate > now ? retryDate - now : 0;
+  } catch (e) {
+    return null;
+  }
+}
+
+function addJitter(delay: number): number {
+  const jitterFactor = 0.5 + Math.random() * 0.5;
+  return Math.floor(delay * jitterFactor);
+}

src/internals/utils/request-fetch-adapter.ts renamed to src/internals/utils/requestFetchAdapter.ts

@@ -1,5 +1,6 @@
 import type { Http } from '../CodePushApiSdk.types';
 import { version } from '../version';
+import { fetchRetry } from './fetchRetry';
 
 export const requestFetchAdapter: Http.Requester = {
   async request(method, url, requestBody) {
@@ -14,7 +15,7 @@ export const requestFetchAdapter: Http.Requester = {
       requestBody = JSON.stringify(requestBody);
     }
 
-    const response = await fetch(url, {
+    const response = await fetchRetry(url, {
       method,
       headers,
       body: requestBody,

src/notifyAppReady.ts

@@ -3,7 +3,7 @@ import { CodePushApiSdk } from './internals/CodePushApiSdk';
 import { NativeRNAppZungCodePushModule } from './internals/NativeRNAppZungCodePushModule';
 import { getConfiguration } from './internals/getConfiguration';
 import { log } from './internals/utils/log';
-import { requestFetchAdapter } from './internals/utils/request-fetch-adapter';
+import { requestFetchAdapter } from './internals/utils/requestFetchAdapter';
 import type { StatusReport } from './types';
 
 /**