Function withEmailTimeout

apps/api/src/lib/email/email.utils.ts:148–171

(
  operation: () => Promise<T>,
  timeoutMs: number = EMAIL_REQUEST_TIMEOUT_MS
)

 * treats it as transient and retries, mirroring an aborted fetch attempt.
 */
export const withEmailTimeout = async <T>(
  operation: () => Promise<T>,
  timeoutMs: number = EMAIL_REQUEST_TIMEOUT_MS
): Promise<T> => {
  let timer: ReturnType<typeof setTimeout> | undefined;

  const guard = new Promise<never>((_resolve, reject) => {
    timer = setTimeout(() => {
      reject(
        ApiErrors.externalService(
          `Email provider timeout after ${String(timeoutMs)}ms`
        )
      );
    }, timeoutMs);
  });

  try {
    return await Promise.race([operation(), guard]);
  } finally {
    if (timer !== undefined) {
      clearTimeout(timer);
    }
  }
};

/**
 * Retry an async function with exponential backoff. Only transient errors