Flight booking

import { createJinkoClient } from '@gojinko/api-client'

const client = await createJinkoClient({ apiKey: process.env.JINKO_API_KEY })

const { destinations } = await client.findDestination({
  origins: ['JFK'],
  destinations: ['CDG'],          // filter discovery to your target airport
  origin_type: 'airport',
  destination_type: 'airport',
  trip_type: 'roundtrip',
  departure_dates: ['2026-06-15'],
  return_dates: ['2026-06-22'],
})

// Each destination comes back with itineraries that carry an offer_token
// you can re-price with flight_search.
const candidate = destinations[0].flights[0]
console.log(candidate.offer_token, candidate.total)

// Search mode — no offer_token.
const priced = await client.flightSearch({
  origin: 'JFK',
  destination: 'CDG',
  departure_date: '2026-06-15',
  return_date: '2026-06-22',
  trip_type: 'roundtrip',
})

// Price-check mode — offer_token ALONE. Adding origin/destination/dates here
// returns 422.
const repriced = await client.flightSearch({
  offer_token: candidate.offer_token,
})

const offer = repriced.offers[0]
const tripItemToken = offer.fares[0].trip_item_token

const trip = await client.trip({
  add_item: { trip_item_token: tripItemToken },
  upsert_travelers: {
    travelers: [{
      first_name: 'Jane',
      last_name: 'Doe',
      date_of_birth: '1990-01-15',
      gender: 'FEMALE',
      passenger_type: 'ADULT',
    }],
    contact: {
      email: 'jane@example.com',
      phone: '+33612345678',
    },
  },
})
const tripId = trip.trip_id

// List ancillaries: runs a price quote behind the scenes, no checkout URL.
let ancillaries = await client.getAncillaries(tripId)

// The quote may still be pricing; poll until it's ready.
while (ancillaries.status === 'pricing') {
  await new Promise(r => setTimeout(r, (ancillaries.retry_after_seconds ?? 2) * 1000))
  ancillaries = await client.getAncillaries(tripId)
}

// Pick an ancillary offer
const item = ancillaries.items[0]
const bagOffer = item.available_ancillaries.find(a => a.type === 'bag')
await client.selectAncillaries({
  trip_id: tripId,
  item_id: item.item_id,
  selections: [{ offer_id: bagOffer.offer_id }],
})

const { checkout_url } = await client.checkout(tripId)
console.log('Open in browser:', checkout_url)

const TERMINAL = [
  'completed',
  'partial',
  'failed',
  'cancelled',
  'expired_quote',
  'exchange_partial_failure',
]

async function waitForBooking(client, tripId: string) {
  while (true) {
    const trip = await client.getTrip(tripId)
    const status = trip.fulfillment?.status

    if (status && TERMINAL.includes(status)) {
      if (status === 'completed') {
        console.log('Booked! Ref:', trip.bookings[0].booking_reference)
      } else if (status === 'partial') {
        // Some items booked, some didn't. Only the ones that booked were charged.
        for (const b of trip.bookings ?? []) {
          console.log(b.kind, b.booking_reference, b.provider_status)
        }
      } else {
        console.error('Booking did not complete:', status, trip.fulfillment?.failure_reason)
      }
      return trip
    }

    // No fulfillment record yet means the customer hasn't paid. Keep waiting.
    await new Promise(r => setTimeout(r, 5000))
  }
}