JavaScript integration

export XAPICHINA_API_KEY="xcn_YOUR_KEY"

const apiKey = process.env.XAPICHINA_API_KEY
if (!apiKey) throw new Error('Set XAPICHINA_API_KEY')

const sleep = milliseconds => new Promise(resolve => setTimeout(resolve, milliseconds))

async function getJson(path, params = {}) {
  const url = new URL(path, 'https://api.xapichina.com')
  url.search = new URLSearchParams(
    Object.entries(params).map(([name, value]) => [name, String(value)])
  )
  for (let attempt = 0; attempt < 3; attempt++) {
    const response = await fetch(url, {
      headers: { 'X-API-Key': apiKey },
      signal: AbortSignal.timeout(45_000)
    })
    const retryAfter = response.headers.get('Retry-After')
    const transient = [502, 503].includes(response.status)
    const throttled = response.status === 429 && retryAfter !== null
    if (attempt < 2 && (transient || throttled)) {
      const hinted = retryAfter !== null ? Number(retryAfter) : NaN
      const delay = Number.isFinite(hinted) ? Math.max(1, hinted) : 2 ** attempt
      await response.arrayBuffer()
      await sleep(delay * 1000 + Math.random() * 250)
      continue
    }
    const contentType = response.headers.get('Content-Type') ?? ''
    const body = contentType.includes('application/json')
      ? await response.json()
      : { detail: await response.text() }
    if (!response.ok) {
      throw new Error(`XAPI China HTTP ${response.status}: ${JSON.stringify(body.detail ?? body)}`)
    }
    return body
  }
}

const allowance = await getJson('/v1/me')
console.log(allowance.plan, allowance.remaining)

const result = await getJson('/v1/search', {
  brand: 'BMW', currency: 'eur', price_min: 15000, price_max: 30000,
  page: 1, lang: 'en'
})
for (const car of result.results) {
  console.log(car.id, car.title, car.price_cny, car.price_eur)
}

async function* searchPages(filters, maximumPages = 3, spacingMs = 12_000) {
  let page = 1
  const seen = new Set()
  for (let count = 0; count < maximumPages; count++) {
    const result = await getJson('/v1/search', { ...filters, page })
    for (const car of result.results) {
      if (!seen.has(car.id)) {
        seen.add(car.id)
        yield car
      }
    }
    page = result.next_page
    if (page === null) return
    await sleep(spacingMs)
  }
}

for await (const car of searchPages({ brand: 'BMW', lang: 'en' })) {
  console.log(car.id, car.title)
}

const carId = '59967821' // replace with a current search result
const detail = await getJson(`/v1/cars/${carId}`, { lang: 'en' })
console.log(detail.photos, detail.che168?.electric_vehicle)

const report = await getJson(`/v1/cars/${carId}/inspection`, {
  lang: 'en', view: 'full'
})
console.log(report.available, report.data_available, report.parse_status)
for (const category of report.categories) {
  for (const item of category.items) {
    console.log(category.name, item.name, item.status, item.source_status)
  }
}