import { string } from 'alga-js'
import refreshTokenHelper from "../../../utils/refreshTokenHelper"
import forceLogoutHelper from "../../../utils/forceLogoutHelper"
import errorHandlingHelper from "../../../utils/errorHandlingHelper"
import fetchHelper from "../../../utils/fetchHelper"

/**
 * Look up a product by exact Value match
 * Used for CSV import to match SKUs to products
 */
const handleFunc = async (event: any, authToken: any = null) => {
  let data: any = { records: [] }
  const token = authToken ?? await getTokenHelper(event)
  const query = getQuery(event)
  const value = query.value || ''

  if (!value) {
    return data
  }

  // Escape single quotes in value
  const escapedValue = (value as string).replace(/'/g, "''")

  console.log('[by-value] Looking up product:', escapedValue)

  // First try exact match on Value field
  let searchFilter = `Value eq '${escapedValue}' and isActive eq true`
  let apiUrl = `models/m_product?$filter=${string.urlEncode(searchFilter)}&$select=m_product_id,Value,Name,SKU,mpn,UPC&$top=1`

  console.log('[by-value] Trying Value field first...')
  let res: any = await fetchHelper(event, apiUrl, 'GET', token, null)

  // If no match on Value, try SKU
  if (!res?.records?.length) {
    console.log('[by-value] No match on Value, trying SKU...')
    searchFilter = `SKU eq '${escapedValue}' and isActive eq true`
    apiUrl = `models/m_product?$filter=${string.urlEncode(searchFilter)}&$select=m_product_id,Value,Name,SKU,mpn,UPC&$top=1`
    res = await fetchHelper(event, apiUrl, 'GET', token, null)
  }

  // If no match on SKU, try MPN
  if (!res?.records?.length) {
    console.log('[by-value] No match on SKU, trying MPN...')
    searchFilter = `mpn eq '${escapedValue}' and isActive eq true`
    apiUrl = `models/m_product?$filter=${string.urlEncode(searchFilter)}&$select=m_product_id,Value,Name,SKU,mpn,UPC&$top=1`
    res = await fetchHelper(event, apiUrl, 'GET', token, null)
  }

  // If no match on MPN, try UPC
  if (!res?.records?.length) {
    console.log('[by-value] No match on MPN, trying UPC...')
    searchFilter = `UPC eq '${escapedValue}' and isActive eq true`
    apiUrl = `models/m_product?$filter=${string.urlEncode(searchFilter)}&$select=m_product_id,Value,Name,SKU,mpn,UPC&$top=1`
    res = await fetchHelper(event, apiUrl, 'GET', token, null)
  }

  console.log('[by-value] Response records:', res?.records?.length || 0)
  if (res?.records?.length > 0) {
    console.log('[by-value] Found:', res.records[0].Value, res.records[0].Name)
  } else {
    console.log('[by-value] No product found for:', escapedValue)
  }

  if (res?.records) {
    // Map m_product_id to id for consistency
    data.records = res.records.map((r: any) => ({
      id: r.m_product_id || r.M_Product_ID || r.id,
      Value: r.Value,
      Name: r.Name,
      SKU: r.SKU,
      MPN: r.mpn,
      UPC: r.UPC
    }))
  }

  return data
}

export default defineEventHandler(async (event) => {
  let data: any = {}

  try {
    data = await handleFunc(event)
  } catch (err: any) {
    try {
      let authToken: any = await refreshTokenHelper(event)
      data = await handleFunc(event, authToken)
    } catch (error: any) {
      data = errorHandlingHelper(err?.data ?? err, error?.data ?? error)
      forceLogoutHelper(event, data)
    }
  }

  return data
})