local playercount = 0
Core.IdentifierIndex = {}

function ESX.Trace(msg)
	if Config.EnableDebug then
		print(('[^2TRACE^7] %s^7'):format(msg))
	end
end

function ESX.ChatMessage(id, msgtype, title, text)
	TriggerClientEvent('chatMessage', id, title, msgtype, text)
end

function ESX.SetTimeout(msec, cb)
	local id = Core.TimeoutCount + 1

	SetTimeout(msec, function()
		if Core.CancelledTimeouts[id] then
			Core.CancelledTimeouts[id] = nil
		else
			cb()
		end
	end)

	Core.TimeoutCount = id

	return id
end

function ESX.RegisterCommand(name, group, cb, allowConsole, suggestion)
	if type(name) == 'table' then
		for k,v in ipairs(name) do
			ESX.RegisterCommand(v, group, cb, allowConsole, suggestion)
		end

		return
	end

	if Core.RegisteredCommands[name] then
		if Core.RegisteredCommands[name].suggestion then
			TriggerClientEvent('chat:removeSuggestion', -1, ('/%s'):format(name))
		end
	end

	if suggestion then
		if not suggestion.arguments then suggestion.arguments = {} end
		if not suggestion.help then suggestion.help = '' end

		TriggerClientEvent('chat:addSuggestion', -1, ('/%s'):format(name), suggestion.help, suggestion.arguments)
	end

	Core.RegisteredCommands[name] = {group = group, cb = cb, allowConsole = allowConsole, suggestion = suggestion}

	RegisterCommand(name, function(playerId, args, rawCommand)
		local command = Core.RegisteredCommands[name]

		if not command.allowConsole and playerId == 0 then
			return
		else
			local xPlayer, error = ESX.GetPlayerFromId(playerId), nil

			if command.suggestion then
				if command.suggestion.validate then
					if #args ~= #command.suggestion.arguments then
						error = _U('commanderror_argumentmismatch', #args, #command.suggestion.arguments)
					end
				end

				if not error and command.suggestion.arguments then
					local newArgs = {}

					for k,v in ipairs(command.suggestion.arguments) do
						if v.type then
							if v.type == 'number' then
								local newArg = tonumber(args[k])

								if newArg then
									newArgs[v.name] = newArg
								else
									error = _U('commanderror_argumentmismatch_number', k)
								end
							elseif v.type == 'player' or v.type == 'playerId' then
								local targetPlayer = tonumber(args[k])

								if args[k] == 'me' then targetPlayer = playerId end

								if targetPlayer then
									local xTargetPlayer = ESX.GetPlayerFromId(targetPlayer)

									if xTargetPlayer then
										if v.type == 'player' then
											newArgs[v.name] = xTargetPlayer
										else
											newArgs[v.name] = targetPlayer
										end
									else
										error = _U('commanderror_invalidplayerid')
									end
								else
									error = _U('commanderror_argumentmismatch_number', k)
								end
							elseif v.type == 'string' then
								newArgs[v.name] = args[k]
							elseif v.type == 'item' then
								if ESX.Items[args[k]] then
									newArgs[v.name] = args[k]
								else
									error = _U('commanderror_invaliditem')
								end
							elseif v.type == 'weapon' then
								if ESX.GetWeapon(args[k]) then
									newArgs[v.name] = string.upper(args[k])
								else
									error = _U('commanderror_invalidweapon')
								end
							elseif v.type == 'any' then
								newArgs[v.name] = args[k]
							end
						end

						if error then break end
					end

					args = newArgs
				end
			end

			if error then
				if playerId ~= 0 and xPlayer then
					xPlayer.sendChatMessage('error', error)
				end
			else
				cb(xPlayer or false, args, function(msg)
					if playerId ~= 0 and xPlayer then
						xPlayer.sendChatMessage('error', msg)
						xPlayer.showNotification(msg)
					end
				end)
			end
		end
	end, true)

	if type(group) == 'table' then
		for k,v in ipairs(group) do
			ExecuteCommand(('add_ace group.%s command.%s allow'):format(v, name))
		end
	else
		ExecuteCommand(('add_ace group.%s command.%s allow'):format(group, name))
	end
end

function ESX.ClearTimeout(id)
	Core.CancelledTimeouts[id] = true
end

function ESX.RegisterServerCallback(name, cb)
	Core.ServerCallbacks[name] = cb
end

function ESX.TriggerServerCallback(name, requestId, source, cb, ...)
	if Core.ServerCallbacks[name] then
		Core.ServerCallbacks[name](source, cb, ...)
	else
		print(('[^3WARNING^7] Server callback ^5"%s"^0 does not exist. ^1Please Check The Server File for Errors!'):format(name))
	end
end

local flags = {}
local alreadyBanned = {}

function ESX.FlagPlayer(Player, reason, autoban)
    local src = Player

    if not flags[src] then
        flags[src] = { count = 0 }
    end

    local xPlayer = ESX.GetPlayerFromId(src)
    if not xPlayer then return end

    flags[src].count = flags[src].count + 1
end
exports('savePlayer', function(xPlayer) Core.SavePlayer(xPlayer) end)

function Core.SavePlayer(xPlayer, cb)
	local timejoined = xPlayer.get('sessiontime')
	local timenow = os.time()
	local seconds = math.floor(os.difftime(timenow, timejoined))
	local oldsec = xPlayer.get('playtime') and math.floor(xPlayer.get('playtime'))

	xPlayer.set('sessiontime', os.time())

	if oldsec then
		seconds = oldsec + seconds
	end

	xPlayer.set('playtime', seconds)

	MySQL.prepare('UPDATE `users` SET `accounts` = ?, `job` = ?, `job2` = ?, `job2_grade` = ?, `job_grade` = ?, `group` = ?, `position` = ?, `inventory` = ?, `loadout` = ?, `level` = ?, `invoices` = ?, `playtime` = ? WHERE `identifier` = ? LIMIT 1', {
		json.encode(xPlayer.getAccounts(true)),
		xPlayer.job.name,
		xPlayer.job2.name,
		xPlayer.job2.grade,
		xPlayer.job.grade,
		xPlayer.group,
		json.encode(xPlayer.getCoords()),
		json.encode(xPlayer.getInventory(true)),
		json.encode(xPlayer.getLoadout(true)),
		xPlayer.getEXP(),
		json.encode(xPlayer.getInvoices()),
		seconds,
		xPlayer.identifier
	}, function(affectedRows)
		if affectedRows == 1 then
			TriggerEvent('esx:playerSaved', xPlayer.playerId, xPlayer)
		end
		if cb then cb() end
	end)
end

function Core.SavePlayers(cb)
	local xPlayers = ESX.GetExtendedPlayers()
	local count = #xPlayers
	if count > 0 then
		local parameters = {}
		for i=1, count do
			local xPlayer = xPlayers[i]
			local timejoined = xPlayer.get('sessiontime')
			local timenow = os.time()
			local seconds = math.floor(os.difftime(timenow, timejoined))
			local oldsec = xPlayer.get('playtime') ~= nil and math.floor(xPlayer.get('playtime')) or 0

			xPlayer.set('sessiontime', os.time())

			if oldsec then
				seconds = oldsec + seconds
			end

			xPlayer.set('playtime', seconds)

			parameters[#parameters+1] = {
				json.encode(xPlayer.getAccounts(true)),
				xPlayer.job.name,
				xPlayer.job2.name,
				xPlayer.job2.grade,
				xPlayer.job.grade,
				xPlayer.group,
				json.encode(xPlayer.getCoords()),
				json.encode(xPlayer.getInventory(true)),
				json.encode(xPlayer.getLoadout(true)),
				seconds,
				xPlayer.identifier
			}
		end
		MySQL.prepare("UPDATE `users` SET `accounts` = ?, `job` = ?, `job2` = ?, `job2_grade` = ?, `job_grade` = ?, `group` = ?, `position` = ?, `inventory` = ?, `loadout` = ?, `playtime` = ? WHERE `identifier` = ?", parameters, function(results)
			if results then
				if type(cb) == 'function' then cb() else print(('[^2INFO^7] %s %s opgeslagen!'):format(count, count > 1 and 'spelers' or 'speler')) end
			end
		end)
	end
end

function ESX.GetPlayers()
	local sources = {}

	for k,v in pairs(ESX.Players) do
		sources[#sources + 1] = k
	end

	return sources
end

function ESX.GetExtendedPlayers(key, val)
	local xPlayers = {}
	for k, v in pairs(ESX.Players) do
		if key then
			if (key == 'job' and v.job.name == val) or v[key] == val then
				xPlayers[#xPlayers + 1] = v
			end
		else
			xPlayers[#xPlayers + 1] = v
		end
	end
	return xPlayers
end

function ESX.GetPlayerFromId(source)
	return ESX.Players[tonumber(source)]
end

function ESX.GetPlayerFromIdentifier(identifier)
	if Core.IdentifierIndex[identifier] then
		return ESX.Players[Core.IdentifierIndex[identifier]]
	end
end

function ESX.GetIdentifier(playerId)
	for k,v in ipairs(GetPlayerIdentifiers(playerId)) do
		if string.match(v, 'steam:') then
			return v
		end
	end
end

function ESX.RegisterUsableItem(item, cb)
	Core.UsableItemsCallbacks[item] = cb
end

function ESX.UseItem(source, item, ...)
	if ESX.Items[item] then
		if Core.UsableItemsCallbacks[item] then
			Core.UsableItemsCallbacks[item](source, item, ...)
		end
	else
		print(('[^3WARNING^7] Item ^5"%s"^7 was used but does not exist!'):format(item))
	end
end

function ESX.RegisterPlayerFunctionOverrides(index,overrides)
	Core.PlayerFunctionOverrides[index] = overrides
end

function ESX.SetPlayerFunctionOverride(index)
	if not index
	or not Core.PlayerFunctionOverrides[index] 
	then
		return print('[^3WARNING^7] No valid index provided.')
	end

	Config.PlayerFunctionOverride = index
end

function ESX.GetItemLabel(item)
	if ESX.Items[item] then
		return ESX.Items[item].label
	end

	if Config.OxInventory then
		item = exports.ox_inventory:Items(item)
		if item then return item.label end
	end
end

function ESX.GetJobs()
	return ESX.Jobs
end

function ESX.GetUsableItems()
	local Usables = {}
	for k in pairs(Core.UsableItemsCallbacks) do
		Usables[k] = true
	end
	return Usables
end

if not Config.OxInventory then
	function ESX.CreatePickup(type, name, count, label, playerId, components, tintIndex)
		local pickupId = (Core.PickupId == 65635 and 0 or Core.PickupId + 1)
		local xPlayer = ESX.GetPlayerFromId(playerId)
		local coords = xPlayer.getCoords()

		Core.Pickups[pickupId] = {
			type = type, name = name,
			count = count, label = label,
			coords = coords
		}

		if type == 'item_weapon' then
			Core.Pickups[pickupId].components = components
			Core.Pickups[pickupId].tintIndex = tintIndex
		end

		TriggerClientEvent('esx:createPickup', -1, pickupId, label, coords, type, name, components, tintIndex)
		Core.PickupId = pickupId
	end
end

function ESX.DoesJobExist(job, grade)
	grade = tostring(grade)

	if job and grade then
		if ESX.Jobs[job] and ESX.Jobs[job].grades[grade] then
			return true
		end
	end

	return false
end

function ESX.DoesJob2Exist(job2, grade2)
	grade2 = tostring(grade2)

	if job2 and grade2 then
		if ESX.Jobs[job2] and ESX.Jobs[job2].grades[grade2] then
			return true
		end
	end

	return false
end

function Core.IsPlayerStaff(playerId)
	if (IsPlayerAceAllowed(playerId, 'command') or GetConvar('sv_lan', '') == 'true') and true or false then
		return true
	end

	local xPlayer = ESX.GetPlayerFromId(playerId)

	if xPlayer then
		if xPlayer.group ~= 'user' then
			return true
		end
	end

	return false
end


function Core.IsPlayerAdmin(playerId)
	if (IsPlayerAceAllowed(playerId, 'command') or GetConvar('sv_lan', '') == 'true') and true or false then
		return true
	end

	local xPlayer = ESX.GetPlayerFromId(playerId)

	if xPlayer then
		if xPlayer.group ~= 'user' then
			return true
		end
	end

	return false
end

exports('isPlayerStaff', Core.IsPlayerStaff)


function Core.GenerateCitizenId(identifier)
	local exists = true
	repeat
		newCitId = math.random(000000000, 999999999)

		local result = MySQL.Sync.fetchAll("SELECT users.identifier FROM users WHERE users.citizenid = @citizenid LIMIT 1", {
			['@citizenid'] = newCitId
		})
		if result[1] == nil then
			exists = false
		end
	until exists == false

	while newCitId == nil do Wait(0) end

	MySQL.prepare('UPDATE `users` SET `citizenid` = ? WHERE `identifier` = ? LIMIT 1', {
		newCitId,
		identifier,
	})

	return newCitId
end