import { apiRequest } from '../lib/api'
import { getActiveBusinessId } from '../lib/businessContext'
import type {
  ShippingCostGroup,
  ShippingCostGroupFormPayload,
  ShippingCostGroupsListResponse,
} from '../types/shippingCostGroup'

function businessPath(suffix = '') {
  const businessId = getActiveBusinessId()
  if (!businessId) {
    throw new Error('No active business selected. Please sign in again.')
  }
  return `/businesses/${businessId}/shipping-cost-groups${suffix}`
}

export async function listShippingCostGroups(
  page = 1,
  pageSize = 100,
  signal?: AbortSignal,
) {
  const params = new URLSearchParams({
    page: String(page),
    pageSize: String(pageSize),
  })

  return apiRequest<ShippingCostGroupsListResponse>(
    `${businessPath()}?${params.toString()}`,
    { auth: true, signal },
  )
}

export async function listAllShippingCostGroups(signal?: AbortSignal) {
  const pageSize = 100
  let page = 1
  let items: ShippingCostGroup[] = []
  let total = Infinity

  while (items.length < total) {
    const data = await listShippingCostGroups(page, pageSize, signal)
    items = items.concat(data.items)
    total = data.total
    page += 1
  }

  return items
}

export async function getShippingCostGroup(groupId: string, signal?: AbortSignal) {
  return apiRequest<{ group: ShippingCostGroup }>(businessPath(`/${groupId}`), {
    auth: true,
    signal,
  })
}

export async function createShippingCostGroup(payload: ShippingCostGroupFormPayload) {
  return apiRequest<{ message: string; group: ShippingCostGroup }>(businessPath(), {
    method: 'POST',
    auth: true,
    body: payload,
  })
}

export async function updateShippingCostGroup(
  groupId: string,
  payload: Partial<ShippingCostGroupFormPayload>,
) {
  return apiRequest<{ message: string; group: ShippingCostGroup }>(
    businessPath(`/${groupId}`),
    {
      method: 'PATCH',
      auth: true,
      body: payload,
    },
  )
}

export function getGroupProvinceExceptions(group: ShippingCostGroup) {
  if (group.provinceExceptions?.length) return group.provinceExceptions
  return (group.cityRates ?? []).map((rate) => ({
    id: rate.id,
    provinceId: rate.cityId,
    amount: rate.amount,
  }))
}

export async function deleteShippingCostGroup(groupId: string) {
  return apiRequest<{ message: string }>(businessPath(`/${groupId}`), {
    method: 'DELETE',
    auth: true,
  })
}