remove undici interceptor, add fetchWithRetry

Author: DmitryBorisov-sm

src/orkes/helpers/resolveFetchFn.ts

@@ -12,30 +12,8 @@ export const resolveFetchFn = async (
   try {
     // eslint-disable-next-line
     // @ts-ignore since undici is an optional dependency and could me missing
-    const { fetch: undiciFetch, Agent, interceptors } = await import("undici");
-    const undiciAgent = new Agent({
-      allowH2: true,
-      //connections: 1,
-      //keepAliveTimeout: 500,
-      //clientTtl: 500,
-      //keepAliveMaxTimeout: 1000 * 60 * 10,
-      //pipelining: 1,
-      connect: {
-        rejectUnauthorized: true, // Ensure TLS validation
-        secureProtocol: "TLSv1_2_method", // Use TLS 1.2
-      },
-    }).compose(
-      interceptors.retry({
-        maxRetries: 10, // Maximum number of retries (default: 5)
-        minTimeout: 2000, // Minimum time to wait before retrying (default: 500ms)
-        maxTimeout: 60000, // Maximum time to wait before retrying (default: 30000ms)
-        timeoutFactor: 2, // Factor to multiply the timeout by for each retry (default: 2)
-        //retryAfter: true, // Automatically retry if Retry-After header is present (default: true)
-        methods: ["GET", "PUT", "HEAD", "POST", "DELETE", "PATCH", "OPTIONS"], // HTTP methods to retry (default includes GET, PUT, HEAD, OPTIONS, DELETE)
-        //statusCodes: [429, 500, 502], // HTTP status codes to retry (default includes 429, 500, 502, 503, 504)
-        errorCodes: ["ECONNRESET", "read ECONNRESET"], // Error codes to retry (default includes common network errors)
-      })
-    );
+    const { fetch: undiciFetch, Agent } = await import("undici");
+    const undiciAgent = new Agent({ allowH2: true });
 
     return ((input: RequestInfo, init?: RequestInit) =>
       undiciFetch(input, { ...init, dispatcher: undiciAgent })) as FetchFn;

src/orkes/request/request.ts

@@ -207,6 +207,29 @@ const getRequestBody = (options: ApiRequestOptions): any => {
   return undefined;
 };
 
+const fetchWithRetry = async (
+  url: string,
+  request: RequestInit,
+  fetchFn: FetchFn<RequestInit, Response>,
+  retries: number = 5,
+  delay: number = 1000
+): Promise<Response> => {
+  try {
+    const response = await fetchFn(url, request);
+    if (response.status == 429) {
+      throw new Error(`Request failed with status ${response.status}`);
+    }
+    return response;
+  } catch (error: unknown) {
+    if (retries > 0) {
+      console.warn(`Fetch error encountered. Retrying request in ${delay}ms...`);
+      await new Promise(resolve => setTimeout(resolve, delay));
+      return await fetchWithRetry(url, request, fetchFn, retries - 1, delay * 2); 
+    }
+    throw error;
+  }
+};
+
 const sendRequest = async (
   options: ApiRequestOptions,
   url: string,
@@ -227,7 +250,7 @@ const sendRequest = async (
 
   onCancel(() => controller.abort());
 
-  return await fetchFn(url, request);
+  return await fetchWithRetry(url, request, fetchFn);
 };
 
 const getResponseHeader = (