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"

const handleFunc = async (event: any, authToken: any = null) => {
  let data: any = { records: [] }
  const token = authToken ?? await getTokenHelper(event)
  const query = getQuery(event)
  const searchTerm = query.search || query.q || ''
  const limit = parseInt(query.limit as string) || 20

  if (!searchTerm || (searchTerm as string).length < 2) {
    return data
  }

  // Escape single quotes in search term
  const escapedSearchTerm = (searchTerm as string).replace(/'/g, "''")

  // Search by Value, Name, SKU, MPN (mpn), or UPC — all partial, case-insensitive
  const lowerSearchTerm = escapedSearchTerm.toLowerCase()
  let searchFilter = `(contains(tolower(Value),'${lowerSearchTerm}') OR contains(tolower(Name),'${lowerSearchTerm}') OR contains(tolower(SKU),'${lowerSearchTerm}') OR contains(tolower(mpn),'${lowerSearchTerm}') OR contains(tolower(UPC),'${lowerSearchTerm}') OR contains(tolower(fnsku),'${lowerSearchTerm}'))`

  // Filter by organization if provided
  const orgId = query.orgId
  if (orgId) {
    searchFilter = `(${searchFilter}) AND (AD_Org_ID eq ${orgId} OR AD_Org_ID eq 0)`
  }

  // Opt-in BOM exclusion (e.g. mobile receive) — off by default so the shared callers
  // (sales order import, transactions, other mobile pages) still see BOM/kit products.
  // IsBOM (standard flag) is filtered server-side; isJtlBom (custom column) is filtered
  // in JS, which requires the full record — so drop the lean $select when excluding,
  // since adding the optional column to $select would 500 envs that lack it.
  const excludeBom = query.excludeBom === 'true' || query.excludeBom === '1'
  if (excludeBom) {
    searchFilter = `${searchFilter} AND (IsBOM eq false)`
  }
  const selectClause = excludeBom ? '' : '&$select=m_product_id,Value,Name,SKU,mpn,UPC,fnsku'

  const res: any = await fetchHelper(
    event,
    `models/m_product?$filter=${string.urlEncode(searchFilter)}${selectClause}&$top=${limit}&$orderby=${string.urlEncode('Name asc')}`,
    'GET',
    token,
    null
  )

  if (res?.records) {
    let records = res.records
    if (excludeBom) {
      records = records.filter((r: any) =>
        !((r.isJtlBom ?? r.IsJtlBom) === true || (r.isJtlBom ?? r.IsJtlBom) === 'Y'))
    }
    // Map m_product_id to id for consistency
    data.records = 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,
      FNSKU: r.fnsku
    }))
  }

  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
})