import test from 'node:test'
import assert from 'node:assert/strict'
import { ensureAppointmentDeparture } from './phase4-overseas-inbound-operations.mjs'

const producer = { marker: 'RUN', carrierScheduleQueryId: '10', tenantId: '20', containerBookingId: '30', containerNo: 'BOX' }
function fixture(fault = '', departed = false) {
  const calls = [], task = { id: '10', customerId: fault === 'foreign-customer' ? 'OTHER' : '20',
    containerBookingId: '30', trackingNo: 'BOX', version: '0', latestActualNode: departed ? 'DEPARTED_ORIGIN_PORT' : null }
  const context = { marker: 'RUN', createdResources: {}, async checkpoint() {}, addStep() {},
    async request(method, path, body) {
      calls.push({ method, path, body })
      if (method === 'POST') {
        if (fault === 'unknown') throw Error('unknown write result')
        assert.equal(body.expectedVersion, Number(task.version))
        task.version = String(Number(task.version) + 1); task.latestActualNode = body.standardNode; task.latestActualAt = body.actualAt
      }
      const data = path.includes('/last-leg/orders/') ? { order: { customerId: '20', sourceContainerBookingId: '30',
        containerNode: task.latestActualNode, manualNodeOverride: false } } : { query: { query: structuredClone(task) } }
      return { http: 200, body: { code: '200', data } }
    } }
  return { context, calls }
}
test('appointment source advances native container shipping and proves Lastleg consumption before appointment writes', async () => {
  const { context, calls } = fixture()
  assert.equal((await ensureAppointmentDeparture(context, producer, '40')).status, 'CONSUMED')
  assert.deepEqual(calls.filter(call => call.method === 'POST').map(call => call.body.standardNode),
    ['DEPARTED_WAREHOUSE', 'AT_ORIGIN_PORT', 'LOADED_ON_VESSEL', 'DEPARTED_ORIGIN_PORT'])
  assert.ok(calls.filter(call => call.method === 'POST').every(call => call.path.startsWith('/api/platform/v1/carrier-schedule-queries/10/manual-nodes')))
})
test('already departed source is reused without adding shipping nodes', async () => {
  const { context, calls } = fixture('', true)
  await ensureAppointmentDeparture(context, producer, '40')
  assert.ok(calls.every(call => call.method === 'GET'))
})
test('foreign source and unknown write stop without further mutation', async () => {
  const foreign = fixture('foreign-customer')
  await assert.rejects(ensureAppointmentDeparture(foreign.context, producer, '40'), /身份/)
  assert.ok(foreign.calls.every(call => call.method === 'GET'))
  const unknown = fixture('unknown')
  await assert.rejects(ensureAppointmentDeparture(unknown.context, producer, '40'), /unknown/)
  assert.equal(unknown.calls.filter(call => call.method === 'POST').length, 1)
  assert.equal(unknown.context.createdResources.appointmentDeparturePrerequisite.commands[0].status, 'UNKNOWN_RESULT')
})