QBCore = exports[Config.qbPrefix.."-core"]:GetCoreObject()

Webhook = ''

function getMoney(type, xPlayer)
	local moneyCount = 0
	if type == "cash" then
		moneyCount = xPlayer.PlayerData.money.cash
	else
		moneyCount = xPlayer.PlayerData.money.bank
	end
	
	return moneyCount
end

function addMoney(type, value, xPlayer)
	xPlayer.Functions.AddMoney(type, value)
end

function removeMoney(type, value, xPlayer)
	xPlayer.Functions.RemoveMoney(type, value)
end

function addItem(xPlayer, item, amount, data)
	xPlayer.Functions.AddItem(item, tonumber(amount))
end

function removeItem(xPlayer, item, amount)
	xPlayer.Functions.RemoveItem(item, tonumber(amount))
end

function canCarryIt(item, amount, xPlayer)
	if Config.UseOx_inventory then
		return exports.ox_inventory:CanCarryItem(xPlayer.PlayerData.source, item, amount)
	end
	
	local totalWeight = QBCore.Player.GetTotalWeight(xPlayer.PlayerData.items)
	local itemInfo = QBCore.Shared.Items[item:lower()]
	if not itemInfo then
		TriggerClientEvent('QBCore:Notify', xPlayer.PlayerData.source, 'This item doesn\'t exits', 'error')
		return
	end
	amount = tonumber(amount)
	if (totalWeight + (itemInfo['weight'] * amount)) <= 120000 then
		return true
	else
		return false
	end
end

function hasPermission(source)
	local staff = false
	for k,v in ipairs(Config.AdminGroups) do
		if QBCore.Functions.HasPermission(source, v) then
			staff = true
			break
		end
	end

	return staff
end

function MySQLexecute(query, values, func)
	return MySQL.query(query, values, func)
end

function MySQLfetchAll(query, values, func)
	return MySQL.query(query, values, func)
end

function giveXP(xPlayer, xp, workbench)
	if Config.SameLevelForAllTables then
		MySQLexecute('UPDATE players SET '..Config.xpColumnsName..' = xp+@xp WHERE citizenid = @identifier', {
			['@identifier'] = xPlayer.PlayerData.citizenid,
			['@xp'] = Config.DoubleXP and xp*2 or xp,
		}, function (result)
			TriggerClientEvent(Config.EventPrefix..':updateXP', xPlayer.PlayerData.source)
		end)
	else
		MySQLexecute('UPDATE players SET '..Config.xpColumnsName..' = JSON_SET(xp, @table, JSON_EXTRACT(xp, @table) + @xp) WHERE citizenid = @identifier', {
			['@identifier'] = xPlayer.PlayerData.citizenid,
			['@xp'] = Config.DoubleXP and xp*2 or xp,
			['@table'] = "$."..workbench,
		}, function (result)
			TriggerClientEvent(Config.EventPrefix..':updateXP', xPlayer.PlayerData.source)
		end)
	end
end

QBCore.Functions.CreateCallback(Config.EventPrefix..":inv2", function(source, cb, item, isMoney)
	local xPlayer = QBCore.Functions.GetPlayer(source)
	local itemS = {}
	if isMoney == "false" then
		isMoney = false
	elseif isMoney == "true" then
		isMoney = true
	end

	if isMoney then
		local playerMoney = getMoney(item, xPlayer)
		itemS.name = item
		itemS.amount = playerMoney
	else
		itemS = xPlayer.Functions.GetItemByName(item)
		if itemS == nil then
			itemS = {
				name = item,
				amount = 0
			}
		end
		if itemS.count ~= nil then
			itemS.amount = itemS.count
		end
	end

	cb(itemS)
end)

QBCore.Functions.CreateCallback(Config.EventPrefix..":maxCraft", function(source, cb, recipe, maxCraftAmount, isDisassemble, itemC, itmNeeded)
	local _source = source
	local xPlayer = QBCore.Functions.GetPlayer(_source)
	local maxCraft = maxCraftAmount
	local itemAmt = 0 

	if not isDisassemble then
		for k,v in ipairs(recipe) do
			local item = {}
			local itemCount = 0

			if v[4] then
				itemCount = getMoney(v[1], xPlayer)
			else
				item = xPlayer.Functions.GetItemByName(v[1])
				if item == nil then
					item = {
						name = v[1],
						amount = 0
					}
				end
				if item.count ~= nil then
					item.amount = item.count
				end
				itemCount = item.amount
			end

			if itemCount > 0 then
				local possibleToCraft = itemCount/tonumber(v[2])
				if possibleToCraft > 0 then
					if maxCraft > possibleToCraft then
						maxCraft = possibleToCraft
					end
				else
					maxCraft = 0
					break
				end
			else
				maxCraft = 0
				break
			end
		end
	else
		local item = xPlayer.Functions.GetItemByName(itemC)
		if item == nil then
			item = {
				name = itemC,
				amount = 0
			}
		end
		if item.count ~= nil then
			item.amount = item.count
		end
		itemAmt = item.amount

		if itemAmt > 0 then
			local possibleToCraft = itemAmt/tonumber(itmNeeded)
			if possibleToCraft > 0 then
				if maxCraft > possibleToCraft then
					maxCraft = possibleToCraft
				end
			else
				maxCraft = 0
			end
		else
			maxCraft = 0
		end
	end
	
	cb(math.floor(maxCraft), itemAmt)
end)

local function normalizeRecipe(recipe)
    local normalized = {}
    for _, item in ipairs(recipe) do
        local normalizedItem = { item[1], tonumber(item[2]), item[3] == "true" or item[3] == true, item[4] == "true" or item[4] == true }
        table.insert(normalized, normalizedItem)
    end
    return normalized
end

local function compareRecipes(recipe1, recipe2)
    if #recipe1 ~= #recipe2 then
        return false
    end
    for i, item1 in ipairs(recipe1) do
        local item2 = recipe2[i]
        if item1[1] ~= item2[1] and item1[2] <= item2[2] then
            return false
        end
    end
    return true
end

function craftExistsInWorkbench(workbenchID, itemID, recipe)
    for _, workbench in pairs(Config.Crafting) do
        if workbench.tableID == workbenchID then
            for _, craft in pairs(workbench.crafts) do
				if Config.Crafts[craft] == nil then
					print("Craft "..craft.." does not exist in Config.Crafts")
					return false
				end
                if Config.Crafts[craft].item == itemID then
                    local normalizedCraftRecipe = normalizeRecipe(Config.Crafts[craft].recipe)
                    local normalizedInputRecipe = normalizeRecipe(recipe)
                    if compareRecipes(normalizedCraftRecipe, normalizedInputRecipe) then
                        return true
                    end
                end
            end
        end
    end
    return false
end

QBCore.Functions.CreateCallback(Config.EventPrefix..":CanCraftItem", function(source, cb, itemID, recipe, itemName, amount, isItem, workbench, timeCraft, CraftQueues, xp, pc, isDis, itemData)
	local xPlayer = QBCore.Functions.GetPlayer(source)
	local canCraft = true
	if not craftExistsInWorkbench(workbench, itemID, recipe) then
        canCraft = false
    end

	if not isDis then
		for k,v in pairs(recipe) do
			if v[4] == "false" then
				local item = xPlayer.Functions.GetItemByName(v[1])
				if item == nil then
					item = {
						name = v[1],
						amount = 0
					}
				end
				if item.count ~= nil then
					item.amount = item.count
				end
				if item.amount < v[2] then
					canCraft = false
				end
			else
				local playerMoney = getMoney(v[1], xPlayer)
				if playerMoney < v[2] then
					canCraft = false
				end
			end
		end
	else
		local item = xPlayer.Functions.GetItemByName(itemID)
		if item == nil then
			item = {
				name = itemID,
				amount = 0
			}
		end
		if item.count ~= nil then
			item.amount = item.count
		end
		if tonumber(item.amount) < tonumber(amount) then
			canCraft = false
		end
	end

	if canCraft then
		if not isDis then
			for k,v in pairs(recipe) do
				if v[3] == "true" then
					if v[4] == "true" then
						removeMoney(v[1], v[2], xPlayer)
					else
						removeItem(xPlayer, v[1], v[2])
					end
				end
			end
		else
			removeItem(xPlayer, itemID, tonumber(amount))
		end

		local queue = CraftQueues
		if queue ~= nil and queue[workbench] ~= nil then
			queue[workbench][#queue[workbench]+1] = {
				item = itemID,
				recipe = recipe,
				amount = amount,
				isItem = isItem,
				time = timeCraft,
				itemName = itemName[itemID],
				isDone = false,
				isPending = true,
				randomID = math.random(100000000, 999999999),
				xp = xp,
				sucPC = pc,
				suc = true,
				isDis = isDis,
				data = itemData
			}
			
			MySQLexecute('UPDATE players SET '..Config.craftQueryColumnName..' = @okokcrafts WHERE citizenid = @identifier', {
				['@identifier'] = xPlayer.PlayerData.citizenid,
				['@okokcrafts'] = json.encode(queue),
			}, function (result)
				TriggerClientEvent(Config.EventPrefix..':notification', xPlayer.PlayerData.source, _L('added_to_queue').title, interp(_L('added_to_queue').text, {s1 = itemName[itemID]}), _L('added_to_queue').time, _L('added_to_queue').type)

				if Webhook ~= "" then
					data = {
						playerid = xPlayer.PlayerData.source,
						type = "start-craft",
						item = itemName[itemID],
						amount = amount,
					}

					discordWebhook(data)
				end

				cb(queue)
			end)
		else
			if queue == nil then
				queue = {}
			end
			queue[workbench] = {}
			queue[workbench] = {
				[1] = {
					item = itemID,
					recipe = recipe,
					amount = amount,
					isItem = isItem,
					time = timeCraft,
					itemName = itemName[itemID],
					isDone = false,
					isPending = true,
					randomID = math.random(100000000, 999999999),
					xp = xp,
					sucPC = pc,
					suc = true,
					isDis = isDis,
					data = itemData
				}
			}
			
			MySQLexecute('UPDATE players SET '..Config.craftQueryColumnName..' = @okokcrafts WHERE citizenid = @identifier', {
				['@identifier'] = xPlayer.PlayerData.citizenid,
				['@okokcrafts'] = json.encode(queue),
			}, function (result)
				TriggerClientEvent(Config.EventPrefix..':notification', xPlayer.PlayerData.source, _L('added_to_queue').title, interp(_L('added_to_queue').text, {s1 = itemName[itemID]}), _L('added_to_queue').time, _L('added_to_queue').type)
				
				if Webhook ~= "" then
					data = {
						playerid = xPlayer.PlayerData.source,
						type = "start-craft",
						item = itemName[itemID],
						amount = amount,
					}
					discordWebhook(data)
				end

				cb(queue)
			end)
		end
	else
		TriggerClientEvent(Config.EventPrefix..':notification', xPlayer.PlayerData.source, _L('cant_craft').title, interp(_L('cant_craft').text, {s1 = itemName[itemID]}), _L('cant_craft').time, _L('cant_craft').type)
		cb(false)
	end
end)

RegisterServerEvent(Config.EventPrefix..':claimAll')
AddEventHandler(Config.EventPrefix..':claimAll', function(workbench, AllQueues)
	local xPlayer = QBCore.Functions.GetPlayer(source)
	local gotQueue = false
	local CraftsQueue = {}
	
	MySQLfetchAll('SELECT okokcrafts FROM players WHERE citizenid = @identifier', {
		['@identifier'] = xPlayer.PlayerData.citizenid,
	}, function (result)
		if result[1] ~= nil then
			local data = json.decode(result[1].okokcrafts)
			if data ~= nil then
				CraftsQueue = data
				gotQueue = true
			end
		end
	end)
	
	while not gotQueue do
		Citizen.Wait(100)
	end

	local queue = CraftsQueue[workbench]
	local v = queue[1]
	
	if v ~= nil then
		if v.isDone then
			if v.suc then
				if not v.isDis then
					local canCarry = false
					if v.isItem then
						if canCarryIt(v.item, v.amount, xPlayer) then
							addItem(xPlayer, v.item, v.amount, v.data)
							canCarry = true
						end
					else
						if canCarryIt(v.item, v.amount, xPlayer) then
							addItem(xPlayer, v.item, v.amount)
							canCarry = true
						end
					end

					if canCarry then
						if Webhook ~= "" then
							data = {
								playerid = xPlayer.PlayerData.source,
								type = "claim-craft",
								item = v.itemName,
								amount = v.amount,
							}

							discordWebhook(data)
						end

						if Config.UseXP then
							giveXP(xPlayer, v.xp, workbench)
						end
						TriggerClientEvent(Config.EventPrefix..':removeItemsFromQueue', xPlayer.PlayerData.source, 1, workbench)
					else
						TriggerClientEvent(Config.EventPrefix..':notification', xPlayer.PlayerData.source, _L('cant_carry').title, _L('cant_carry').text, _L('cant_carry').time, _L('cant_carry').type)
						TriggerClientEvent(Config.EventPrefix..':notification', xPlayer.PlayerData.source, _L('claimed_all_items').title, _L('claimed_all_items').text, _L('claimed_all_items').time, _L('claimed_all_items').type)
						TriggerClientEvent(Config.EventPrefix..':resetClaimAllButton', xPlayer.PlayerData.source)
					end
				else
					local canCarry = true
					for k2,v2 in ipairs(v.recipe) do
						if v2[4] == "false" or v2[4] == false then
							if not canCarryIt(v2[1], v2[2], xPlayer) then
								canCarry = false
							end
						end
					end

					if canCarry then
						for k2,v2 in ipairs(v.recipe) do
							if v2[4] == "true" or v2[4] == true then
								addMoney(v2[1], v2[2], xPlayer)
							else
								addItem(xPlayer, v2[1], v2[2])
							end
						end

						if Webhook ~= "" then
							data = {
								playerid = xPlayer.PlayerData.source,
								type = "claim-craft",
								item = v.itemName,
								amount = v.amount,
							}

							discordWebhook(data)
						end
						

						if Config.UseXP then
							giveXP(xPlayer, v.xp, workbench)
						end
						TriggerClientEvent(Config.EventPrefix..':removeItemsFromQueue', xPlayer.PlayerData.source, 1, workbench)
					else
						TriggerClientEvent(Config.EventPrefix..':notification', xPlayer.PlayerData.source, _L('cant_carry').title, _L('cant_carry').text, _L('cant_carry').time, _L('cant_carry').type)
						TriggerClientEvent(Config.EventPrefix..':notification', xPlayer.PlayerData.source, _L('claimed_all_items').title, _L('claimed_all_items').text, _L('claimed_all_items').time, _L('claimed_all_items').type)
						TriggerClientEvent(Config.EventPrefix..':resetClaimAllButton', xPlayer.PlayerData.source)
					end
				end
			else
				if Webhook ~= "" then
					data = {
						playerid = xPlayer.PlayerData.source,
						type = "failed-craft",
						item = v.itemName,
						amount = v.amount,
					}

					discordWebhook(data)
				end
				if Config.GiveXPOnCraftFailed and Config.UseXP then
					if Config.UseXP then
						giveXP(xPlayer, v.xp, workbench)
					end
				end
				TriggerClientEvent(Config.EventPrefix..':removeItemsFromQueue', xPlayer.PlayerData.source, 1, workbench)
			end
		end
	end
end)

-------------------------- IDENTIFIERS

function ExtractIdentifiers(id)
	local identifiers = {
		steam = "",
		ip = "",
		discord = "",
		license = "",
		xbl = "",
		live = ""
	}

	for i = 0, GetNumPlayerIdentifiers(id) - 1 do
		local playerID = GetPlayerIdentifier(id, i)

		if string.find(playerID, "steam") then
			identifiers.steam = playerID
		elseif string.find(playerID, "ip") then
			identifiers.ip = playerID
		elseif string.find(playerID, "discord") then
			identifiers.discord = playerID
		elseif string.find(playerID, "license") then
			identifiers.license = playerID
		elseif string.find(playerID, "xbl") then
			identifiers.xbl = playerID
		elseif string.find(playerID, "live") then
			identifiers.live = playerID
		end
	end

	return identifiers
end

-------------------------- WEBHOOK

function discordWebhook(data)
	local color = '65352'
	local category = 'default'
	local item = ''
	local amount = ''
	local identifierlist = ExtractIdentifiers(data.playerid)
	local identifier = identifierlist.license:gsub("license2:", "")
	local discord = "<@"..identifierlist.discord:gsub("discord:", "")..">"

	if data.type == 'start-craft' then
		color = Config.StartCraftWebhookColor
		category = 'Started a craft'
		item = data.item
		amount = data.amount
	elseif data.type == 'cancel-craft' then
		color = Config.CancelWebhookColor
		category = 'Canceled a craft'
		item = data.item
		amount = data.amount
	elseif data.type == 'claim-craft' then
		color = Config.ClaimCraftWebhookColor
		category = 'Claimed'
		item = data.item
		amount = data.amount
	elseif data.type == 'failed-craft' then
		color = Config.FailedCraftWebhookColor
		category = 'Failed a craft'
		item = data.item
		amount = data.amount
	end

	local information = {
		{
			["color"] = color,
			["author"] = {
				["icon_url"] = Config.IconURL,
				["name"] = Config.ServerName..' - Logs',
			},
			["title"] = 'CRAFTING',
			["description"] = '**Action:** '..category..'\n**Item:** '..item..'\n**Amount:** '..amount..'\n\n**ID:** '..data.playerid..'\n**Identifier:** '..identifier..'\n**Discord:** '..discord,
			["footer"] = {
				["text"] = os.date(Config.DateFormat),
			}
		}
	}

	PerformHttpRequest(Webhook, function(err, text, headers) end, 'POST', json.encode({username = Config.BotName, embeds = information}), {['Content-Type'] = 'application/json'})
end