Function retryFetch

packages/trigger-sdk/src/v3/retry.ts:176–362

(
  input: RequestInfo | URL,
  init?: RetryFetchRequestInit | undefined
)

const MAX_ATTEMPTS = 10;

async function retryFetch(
  input: RequestInfo | URL,
  init?: RetryFetchRequestInit | undefined
): Promise<Response> {
  return tracer.startActiveSpan(
    "retry.fetch()",
    async (span) => {
      let attempt = 1;

      while (true) {
        try {
          const abortController = new AbortController();

          const timeoutId = init?.timeoutInMs
            ? setTimeout(
                () => {
                  abortController.abort();
                },
                init?.timeoutInMs
              )
            : undefined;

          init?.signal?.addEventListener("abort", () => {
            abortController.abort();
          });

          const [response, span] = await doFetchRequest(
            input,
            { ...(init ?? {}), signal: abortController.signal },
            attempt
          );

          if (timeoutId) {
            clearTimeout(timeoutId);
          }

          if (response.ok) {
            span.setAttributes(createFetchResponseAttributes(response));

            span.end();

            return response;
          }

          const nextRetry = await calculateRetryDelayForResponse(
            resolveDefaults(init?.retry, "byStatus", defaultFetchRetryOptions.byStatus),
            response,
            attempt
          );

          if (!nextRetry) {
            span.setAttributes(createFetchResponseAttributes(response));

            span.end();

            return response;
          }