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); an unbounded full-column m_inout list
// query 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('DPD_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 {
        const 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
})