fetchWithTimeout.ts

import BaseError from './baseError';

export class TimeoutError extends BaseError {
  constructor(msg: string) {
    super('TimeoutError', msg);
  }
}

function makeTimeout(timeoutMs: number) {
  let timerId: NodeJS.Timeout | null = null;

  const promise = new Promise((_, reject) => {
    timerId = setTimeout(() => {
      reject(new TimeoutError('Timeout'));
    }, timeoutMs);
  });

  return {
    timerId: timerId,
    promise: promise,
  };
}

/**
 * @private
 */
export function fetchWithTimeout(
  url: string,
  options: RequestInit,
  timeoutMs: number,
): Promise<Response> {
  const {
    promise: timeoutPromise,
    timerId,
  }: {promise: Promise<unknown>; timerId: any} = makeTimeout(timeoutMs);
  const abortController = new AbortController();

  return Promise.race([
    fetch(url, {
      ...options,
      signal: abortController.signal,
    }),
    timeoutPromise,
  ])
    .catch((error) => {
      if (error instanceof TimeoutError) {
        abortController.abort();
      }

      throw error;
    })
    .then((response) => {
      clearTimeout(timerId);
      return response;
    }) as Promise<Response>;
}