import { getGameDb } from '@/lib/db/client'
import { parseCrewTeam } from '@/app/api/crew-team'
import { checkUpgradePreconditions, getShipState, ShipError } from '@/lib/game/ship'
import { queueStateFromSave, saveInventory, saveTaskRow } from '@/lib/game/save'
import { queueTask, TaskError } from '@/lib/game/tasks'

// Level up a built ship system by one (capped at max level): assign the crew team (lead +
// helpers) and queue the SHIP_UPGRADE task — the cost (`level` units of any resource) is
// deducted at queue time and the level-up lands when the task completes on the turn tick
// (runTurn). Body: { systemId, leadCrewId, helperCrewIds? }. Queueing spends no turn;
// returns the same fresh ship state the instant action returned.
export async function POST(req: Request) {
  let body: unknown
  try {
    body = await req.json()
  } catch {
    return Response.json({ error: 'Invalid JSON body' }, { status: 400 })
  }

  const systemId = (body as { systemId?: unknown }).systemId
  if (typeof systemId !== 'number' || !Number.isInteger(systemId)) {
    return Response.json({ error: 'systemId must be an integer' }, { status: 400 })
  }
  const team = parseCrewTeam(body)
  if ('error' in team) {
    return Response.json({ error: team.error }, { status: team.status })
  }

  try {
    const db = await getGameDb()
    await checkUpgradePreconditions(db, systemId) // existing pre-checks: 404 unknown · 409 not built / max level
    const state = await queueStateFromSave(db)
    const { task, inventory } = queueTask(state, { type: 'SHIP_UPGRADE', payload: { systemId }, leadCrewId: team.leadCrewId, helperCrewIds: team.helperCrewIds })
    await saveTaskRow(db, task)
    await saveInventory(db, inventory) // the cost was deducted at queue time
    return Response.json(await getShipState(db))
  } catch (err) {
    if (err instanceof ShipError || err instanceof TaskError) {
      return Response.json({ error: err.message }, { status: err.status })
    }
    throw err
  }
}