datahub/frontend/src/utils/request.ts

import { ApiError } from '@/types/api'

const DEFAULT_TIMEOUT = 15000

// 允许外部注入 token 获取函数，避免与 store 循环依赖
let tokenGetter: (() => string | null) | null = null
export function setTokenGetter(fn: () => string | null) {
  tokenGetter = fn
}

interface RequestOptions extends RequestInit {
  params?: Record<string, unknown>
  timeout?: number
}

async function request<T = unknown>(url: string, options: RequestOptions = {}): Promise<T> {
  const token = tokenGetter?.() ?? localStorage.getItem('access_token')

  const headers: Record<string, string> = {
    'Content-Type': 'application/json',
    ...(options.headers as Record<string, string>),
  }

  if (token) {
    headers['Authorization'] = `Bearer ${token}`
  }

  // 拼接查询参数
  if (options.params) {
    const query = new URLSearchParams(
      Object.entries(options.params)
        .filter(([, v]) => v !== undefined && v !== null && v !== '')
        .map(([k, v]) => [k, String(v)])
    )
    const separator = url.includes('?') ? '&' : '?'
    url = `${url}${separator}${query}`
  }

  const { params: _params, timeout: _timeout, ...fetchOptions } = options

  // 超时控制
  const controller = new AbortController()
  const timeoutId = setTimeout(() => controller.abort(), options.timeout ?? DEFAULT_TIMEOUT)

  try {
    const response = await fetch(url, {
      ...fetchOptions,
      headers,
      signal: controller.signal,
    })

    // 401 未授权：保留当前路径作为 redirect 参数
    if (response.status === 401) {
      localStorage.removeItem('access_token')
      localStorage.removeItem('refresh_token')
      localStorage.removeItem('user')
      const redirect = encodeURIComponent(
        window.location.pathname + window.location.search,
      )
      window.location.href = `/login?redirect=${redirect}`
      throw new ApiError('登录已过期，请重新登录', 401)
    }

    // 防护非 JSON 响应（如网关 HTML 错误页）
    let result
    try {
      result = await response.json()
    } catch {
      throw new ApiError('服务器返回了非预期的响应格式', response.status)
    }

    // 业务错误
    if (result.code !== 0) {
      throw new ApiError(result.message || '请求失败', result.code)
    }

    return result.data
  } catch (error) {
    if (error instanceof ApiError) throw error
    if (error instanceof DOMException && error.name === 'AbortError') {
      throw new ApiError('请求超时，请检查网络连接', 0)
    }
    throw error
  } finally {
    clearTimeout(timeoutId)
  }
}

export const api = {
  get: <T = unknown>(url: string, params?: Record<string, unknown>) =>
    request<T>(url, { method: 'GET', params }),

  post: <T = unknown>(url: string, data?: unknown) =>
    request<T>(url, { method: 'POST', body: JSON.stringify(data) }),

  put: <T = unknown>(url: string, data?: unknown) =>
    request<T>(url, { method: 'PUT', body: JSON.stringify(data) }),

  patch: <T = unknown>(url: string, data?: unknown) =>
    request<T>(url, { method: 'PATCH', body: JSON.stringify(data) }),

  delete: <T = unknown>(url: string) =>
    request<T>(url, { method: 'DELETE' }),
}