import apiClient, { apiEndpoints } from './index.js'

/**
 * 通用的获取所有分页数据的函数
 * @param {Function} apiCall - API调用函数
 * @param {Object} params - 查询参数
 * @returns {Promise<Array>} 所有页面的数据数组
 */
const fetchAllPages = async (apiCall, params = {}) => {
  let allData = []
  let page = 1
  let hasNext = true

  console.log('Starting to fetch all pages for API call...')

  while (hasNext) {
    try {
      const currentParams = { ...params, page, page_size: 100 } // 每页100条，减少请求次数
      console.log(`Fetching page ${page} with params:`, currentParams)

      const response = await apiCall(currentParams)

      if (response && response.results) {
        // 分页格式响应
        allData = [...allData, ...response.results]
        hasNext = !!response.next
        console.log(`Page ${page}: Got ${response.results.length} items, total so far: ${allData.length}, hasNext: ${hasNext}`)
      } else if (Array.isArray(response)) {
        // 非分页格式响应（向后兼容）
        allData = response
        hasNext = false
        console.log('Non-paginated response detected, got all data at once:', allData.length, 'items')
      } else {
        console.log('Unexpected response format, stopping pagination')
        hasNext = false
      }

      page++

      // 安全检查：防止无限循环
      if (page > 100) {
        console.warn('Reached maximum page limit (100), stopping pagination')
        break
      }
    } catch (error) {
      console.error(`Error fetching page ${page}:`, error)
      throw error
    }
  }

  console.log(`Finished fetching all pages. Total items: ${allData.length}`)
  return allData
}

/**
 * 单页API调用函数（内部使用）
 * @param {Object} params - 查询参数（包含分页参数）
 * @returns {Promise} API响应
 */
const getTermsPage = async (params = {}) => {
  const response = await apiClient.get(apiEndpoints.TERMS.LIST, { params })
  return response.data
}

export const getTerms = async () => {
  try {
    console.log('Fetching all terms with pagination support...')

    // 使用通用分页函数获取所有数据
    const allTerms = await fetchAllPages(getTermsPage)

    console.log('Terms API final result:', {
      totalCount: allTerms.length,
      sampleData: allTerms.slice(0, 3) // 显示前3条数据作为样例
    })

    return allTerms
  } catch (error) {
    console.error('Failed to fetch terms:', error)
    throw new Error(error?.response?.data?.detail || error?.message || 'Failed to fetch terms')
  }
}

export const createTerm = async (termData) => {
  try {
    const response = await apiClient.post(apiEndpoints.TERMS.CREATE, termData)
    return response.data
  } catch (error) {
    throw new Error(error?.response?.data?.message || 'Failed to create term')
  }
}

export const updateTerm = async (termId, termData) => {
  try {
    const response = await apiClient.patch(apiEndpoints.TERMS.UPDATE.replace('{termId}', termId), termData)
    return response.data
  } catch (error) {
    throw new Error(error?.response?.data?.message || 'Failed to update term')
  }
}

export const deleteTerm = async (termId) => {
  try {
    const response = await apiClient.delete(apiEndpoints.TERMS.DELETE.replace('{termId}', termId))
    return response.data
  } catch (error) {
    throw new Error(error?.response?.data?.message || 'Failed to delete term')
  }
}