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

// List columns only — never the blob columns (DHL_Label_Base64, DPD_Label_Base64,
// trackingnoarray, marketplace_confirm_log): this filter matches the whole DHL
// history (~25k rows) and fetching it with all columns OOM-crashed the ERP on
// 2026-07-07. Labels are fetched per record via /api/commission/parcels/label/[id].
// The FK columns must be listed here or the $expand is dropped by idempiere-rest.
const SELECT = 'DocumentNo,MovementDate,shipping_date,TrackingNo,DHL_Shipment_Code,DHL_Routing_Code,DPD_Shipment_Code,C_BPartner_ID,C_BPartner_Location_ID'

const handleFunc = async (event: any, authToken: any = null) => {
  let data: any = {}
  const token = authToken ?? await getTokenHelper(event)
  const query = getQuery(event)

  const limit = Math.min(Math.max(Number(query?.limit) || 200, 1), 200)
  const skip = Math.max(Number(query?.offset) || 0, 0)

  const res: any = await fetchHelper(event, `models/m_inout?$filter=${string.urlEncode('DHL_Shipment_Code neq null')}&$select=${SELECT}&$expand=C_BPartner_Location_ID&$orderby=${string.urlEncode('M_InOut_ID desc')}&$top=${limit}&$skip=${skip}`, 'GET', token, null)
  if(res) {
    data = res
  }

  return data
}

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

  try {
    data = await handleFunc(event)
  } catch(err: any) {
    // Refresh-retry only on auth failures — re-running a heavy query on a 5xx
    // multiplied the load during the 2026-07-07 incident.
    if((err?.status ?? err?.statusCode) === 401) {
      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)
      }
    } else {
      data = errorHandlingHelper(err?.data ?? err, err?.data ?? err)
    }
  }

  return data
})