authFetch.ts

import { ApiError } from '../errors/ApiError';
import { getStorage } from '../storage';
import { apiFetch, RequestOptions } from './api';
import { apiRefreshToken } from './auth';

const AUTH_STORAGE_KEY = 'isAuthenticated';

let isRefreshing = false;
let refreshPromise: Promise<boolean> | null = null;

export async function authFetch<T>(endpoint: string, options?: RequestOptions): Promise<T> {
  try {
    return await apiFetch<T>(endpoint, options);
  } catch (err) {
    const error = err as ApiError;

    if (error.status === 401) {
      const refreshed = await tryRefresh();

      if (refreshed) {
        return apiFetch<T>(endpoint, options);
      }

      // Clear auth state before redirecting to prevent infinite loop
      clearAuthState();

      if (typeof window !== 'undefined') {
        window.location.href = '/public/login';
      }

      throw error;
    }

    throw error;
  }
}

function clearAuthState() {
  const storage = getStorage();
  if (storage) {
    storage.setItem(AUTH_STORAGE_KEY, JSON.stringify(false));
  }
}

async function tryRefresh(): Promise<boolean> {
  // If already refreshing, wait for the existing promise
  if (isRefreshing && refreshPromise) {
    return refreshPromise;
  }

  isRefreshing = true;
  refreshPromise = (async () => {
    try {
      await apiRefreshToken();
      return true;
    } catch {
      return false;
    } finally {
      isRefreshing = false;
      refreshPromise = null;
    }
  })();

  return refreshPromise;
}