Function fetchWithAuth

lib/api.ts:220–301

(
  url: string,
  options: RequestInit = {}
)

 * 当遇到 401 错误时，自动尝试刷新 token 并重试请求
 */
export async function fetchWithAuth<T>(
  url: string,
  options: RequestInit = {}
): Promise<T> {
  const token = typeof window !== 'undefined' ? localStorage.getItem('access_token') : null;
  
  const headers: HeadersInit = {
    'Content-Type': 'application/json',
    ...options.headers,
    ...(token && { 'Authorization': `Bearer ${token}` })
  };
  
  const response = await fetch(url, { ...options, headers });
  
  // 如果不是 401 或 403 错误，直接处理响应
  if (response.status !== 401 && response.status !== 403) {
    return handleResponse<T>(response);
  }
  
  // 处理 401/403 错误 - 尝试刷新 token
  console.log(`[fetchWithAuth] 检测到 ${response.status} 错误，准备刷新 token...`);
  // 注意：不需要检查 refresh_token 是否存在，因为它在 httpOnly cookie 中
  // 后端会自动从 cookie 读取
  
  // 如果正在刷新，将请求加入队列
  console.log('[fetchWithAuth] 检查是否正在刷新:', isRefreshing);
  if (isRefreshing) {
    console.log('[fetchWithAuth] 正在刷新中，将请求加入队列');
    return new Promise<T>((resolve, reject) => {
      failedQueue.push({
        resolve: async (newToken) => {
          if (newToken) {
            const retryHeaders: HeadersInit = {
              ...headers,
              'Authorization': `Bearer ${newToken}`
            };
            try {
              const retryResponse = await fetch(url, { ...options, headers: retryHeaders });
              resolve(await handleResponse<T>(retryResponse));
            } catch (error) {
              reject(error);
            }
          } else {
            reject(new Error('Token refresh failed'));
          }
        },
        reject
      });
    });
  }
  
  isRefreshing = true;
  
  try {
    console.log('[fetchWithAuth] 正在调用刷新接口...');
    const refreshData = await refreshToken();
    console.log('[fetchWithAuth] Token 刷新成功');