-- Machine à états serveur pour un heist multi-étapes (source de vérité, le client ne fait qu'afficher)
local HeistStates = { IDLE = 'idle', HACKING = 'hacking', DRILLING = 'drilling', LOOTING = 'looting', ESCAPE = 'escape' }

local ActiveHeist = {
    state = HeistStates.IDLE,
    crew = {},          -- liste des sources des joueurs participants
    startedAt = nil,
    vaultLoot = 0,
}

local function transitionTo(newState)
    local validTransitions = {
        [HeistStates.IDLE] = { HeistStates.HACKING },
        [HeistStates.HACKING] = { HeistStates.DRILLING },
        [HeistStates.DRILLING] = { HeistStates.LOOTING },
        [HeistStates.LOOTING] = { HeistStates.ESCAPE },
        [HeistStates.ESCAPE] = { HeistStates.IDLE },
    }
    -- refuse toute transition non prévue explicitement : empêche un client de sauter une étape (skip du hack, ex.)
    local allowed = validTransitions[ActiveHeist.state] or {}
    if not TableContains(allowed, newState) then
        print(('[Heist] Transition invalide refusée: %s -> %s'):format(ActiveHeist.state, newState))
        return false
    end
    ActiveHeist.state = newState
    TriggerClientEvent('technologik:heist:stateChanged', -1, newState)
    return true
end

-- Étape de minijeu (hack) : le client joue le minijeu, mais le SERVEUR décide seul de la réussite finale
RegisterNetEvent('technologik:heist:hackAttempt', function(success, timeTaken)
    local src = source
    if ActiveHeist.state ~= HeistStates.HACKING then return end   -- refuse un event hors séquence
    if not IsPlayerInCrew(src, ActiveHeist.crew) then return end

    -- Validation anti-triche : un hack ne peut pas être résolu en moins d'un temps physiquement plausible
    if timeTaken < 3000 then
        LogSuspiciousActivity(src, ('hack résolu en %dms, suspect'):format(timeTaken))
        DropPlayer(src, 'Comportement anormal détecté')
        return
    end

    if success then
        transitionTo(HeistStates.DRILLING)
    else
        ActiveHeist.failedAttempts = (ActiveHeist.failedAttempts or 0) + 1
        if ActiveHeist.failedAttempts >= 3 then
            TriggerServerEvent('technologik:heist:triggerAlarm')   -- échec répété = conséquence scénarisée
        end
    end
end)

-- Points de non-retour et conséquences persistantes (cooldown, alerte police) attachés à la machine à états
local function onHeistCompleted()
    ActiveHeist.state = HeistStates.IDLE
    local lootPerPlayer = math.floor(ActiveHeist.vaultLoot / #ActiveHeist.crew)

    for _, src in ipairs(ActiveHeist.crew) do
        AddPlayerBalanceAtomic(src, lootPerPlayer)   -- réutilise la transaction atomique (voir leçon économie)
    end

    -- Cooldown persisté en DB pour empêcher un repeat immédiat (farming du heist)
    MySQL.insert('INSERT INTO heist_cooldowns (heist_id, completed_at) VALUES (?, NOW())', { 'fleeca_bank' })

    ActiveHeist.crew = {}
    ActiveHeist.vaultLoot = 0
end

local function canStartHeist()
    local lastCompletion = MySQL.scalar.await(
        'SELECT completed_at FROM heist_cooldowns WHERE heist_id = ? ORDER BY completed_at DESC LIMIT 1',
        { 'fleeca_bank' }
    )
    if not lastCompletion then return true end
    local elapsedMinutes = (os.time() - lastCompletion) / 60
    return elapsedMinutes >= 120   -- cooldown de 2h avant de pouvoir relancer ce heist
end