displayIndex = 1;
displays = Config.Displays.ConnectingLoop;
prefix = Config.Displays.Prefix;
currentConnectors = 0;
maxConnectors = Config.AllowedPerTick;
hostname = GetConvar("sv_hostname")
slots = GetConvarInt('sv_maxclients', 32)

StopResource('hardcap')

AddEventHandler('onResourceStop', function(resource)
  if resource == GetCurrentResourceName() then
    if GetResourceState('hardcap') == 'stopped' then
      StartResource('hardcap')
    end
  end
end)

webhookURL = Config.Webhook;
function sendToDisc(title, message, footer)
	local embed = {}
	embed = {
		{
			["color"] = 65280, -- GREEN = 65280 --- RED = 16711680
			["title"] = "**".. title .."**",
			["description"] = "" .. message ..  "",
			["footer"] = {
				["text"] = footer,
			},
		}
	}
	-- Start
	-- TODO Input Webhook
	PerformHttpRequest(webhookURL, 
	function(err, text, headers) end, 'POST', json.encode({username = name, embeds = embed}), { ['Content-Type'] = 'application/json' })
  -- END
end
function ExtractIdentifiers(src)
  local identifiers = {
      steam = "",
      ip = "",
      discord = "",
      license = "",
      xbl = "",
      live = ""
  }

  --Loop over all identifiers
  for i = 0, GetNumPlayerIdentifiers(src) - 1 do
      local id = GetPlayerIdentifier(src, i)

      --Convert it to a nice table.
      if string.find(id, "steam") then
          identifiers.steam = id
      elseif string.find(id, "ip") then
          identifiers.ip = id
      elseif string.find(id, "discord") then
          identifiers.discord = id
      elseif string.find(id, "license") then
          identifiers.license = id
      elseif string.find(id, "xbl") then
          identifiers.xbl = id
      elseif string.find(id, "live") then
          identifiers.live = id
      end
  end

  return identifiers
end
function sendToDiscQueue(title, message, footer)
	local embed = {}
	embed = {
		{
			["color"] = 16711680, -- GREEN = 65280 --- RED = 16711680
			["title"] = "**".. title .."**",
			["description"] = "" .. message ..  "",
			["footer"] = {
				["text"] = footer,
			},
		}
	}
	-- Start
	-- TODO Input Webhook
	PerformHttpRequest(webhookURL, 
	function(err, text, headers) end, 'POST', json.encode({username = name, embeds = embed}), { ['Content-Type'] = 'application/json' })
  -- END
end

Citizen.CreateThread(function()
  while true do 
    Wait((1000 * 30)); -- Every 30 seconds
    --print("sv_maxclients is set to: " .. tostring(slots));
    --print("Queue:GetMax() is set to: " .. tostring(Queue:GetMax())); 
    if Config.HostDisplayQueue then 
      if hostname ~= "default FXServer" and Queue:GetMax() > 0 then 
        SetConvar("sv_hostname", "[" .. Queue:GetMax() .. "/" .. (Queue:GetMax() + 1) .. "] " .. hostname);
        --print(prefix .. " Set server title: '" .. "[" .. "1" .. "/" .. (Queue:GetMax() + 1) .. "] " .. hostname .. "'")
      end
      if hostname ~= "default FXServer" and Queue:GetMax() == 0 then 
        SetConvar("sv_hostname", hostname);
        --print(prefix .. " Set server title: '" .. hostname .. "'")
      end
    end
  end
end)
notSet = true;
Citizen.CreateThread(function()
  while notSet do 
    if hostname == "default FXServer" then 
      hostname = GetConvar("sv_hostname");
    else 
      notSet = false;
    end
  end 
end)

function GetPlayerCount() 
  return GetNumPlayerIndices();
end
local connecting = {}
local playerConnecting = {}

function CheckForGhostUsers()
  for license, data in pairs(playerConnecting) do 
    local found = false;
    local user = data.ID;
    local name = data.PlayerName;
    local connectingg = data.Connection;
    --[[ MASS DEBUG 
    if Config.Debug then 
      print("[Bad-DiscordQueue] (MASS DEBUG)")
      print("[Bad-DiscordQueue] PlayerName: " .. tostring(name) .. " || ID:" .. tostring(user) .. " || GetPlayerName(user): " .. tostring(GetPlayerName(user) ) );
    end
    --[[ MASS DEBUG END ]]--
    if GetPlayerName(user) == nil or GetPlayerName(user) ~= name then 
      -- They no longer exist
      Queue:PopLicense(license)
      if Config.Debug then 
        print(prefix .. " (Thread : NO LONGER EXISTS) Popped player " .. name .. " from queue...");
      end
      if connecting[license] ~= nil then 
        if (currentConnectors > 0) then 
          currentConnectors = currentConnectors - 1;
        end
        if Config.Debug then 
          print(prefix .. " (Thread : NO LONGER EXISTS) currentConnectors was decremented... FROM: " .. tostring(currentConnectors + 1) .. " -- TO: " .. 
          tostring(currentConnectors));
        end
        connecting[license] = nil;
      end
      if Config.Debug then 
        print(prefix .. " (Thread : NO LONGER EXISTS) currentConnectors is == " .. tostring(currentConnectors) )
      end
      playerConnecting[license] = nil;
    end
  end
end

--[[
Citizen.CreateThread(function()
  while true do 
    Citizen.Wait((1000 * 20));
    for license, data in pairs(playerConnecting) do 
      local found = false;
      local user = data.ID;
      local name = data.PlayerName;
      local connectingg = data.Connection;
      -- MASS DEBUG 
      if Config.Debug then 
        print("[Bad-DiscordQueue] (MASS DEBUG)")
        print("[Bad-DiscordQueue] PlayerName: " .. tostring(name) .. " || ID:" .. tostring(user) .. " || GetPlayerName(user): " .. tostring(GetPlayerName(user) ) );
      end
      -- MASS DEBUG END 
      if GetPlayerName(user) ~= name and GetPlayerName(user) == nil then 
        -- They no longer exist
        Queue:PopLicense(license)
        if Config.Debug then 
          print("[Bad-DiscordQueue] (Thread : NO LONGER EXISTS) Popped player " .. name .. " from queue...");
        end
        if connecting[license] ~= nil then 
          connecting[license] = nil;
          if (currentConnectors > 0) then 
            currentConnectors = currentConnectors - 1;
          end
        end
        if Config.Debug then 
          print("[Bad-DiscordQueue] (Thread : NO LONGER EXISTS) currentConnectors is == " .. tostring(currentConnectors) )
        end
        playerConnecting[license] = nil;
      end
    end
  end
end)
]]--
Citizen.CreateThread(function()
  while true do 
    Wait((40 * 1000));
    CheckForGhostUsers();
  end
end)

AddEventHandler('playerConnecting', function(name, setKickReason, deferrals) 
  deferrals.defer();
  local user = source;
  local license = ExtractIdentifiers(user).license:gsub("license:", "");
  local ids = ExtractIdentifiers(user);
  local playerName = GetPlayerName(user);
  local allowed = true;
  if Config.Requirements.Steam then 
    -- Check if they have Steam
    if #ids.steam <= 1 then 
      deferrals.done(Config.Displays.Prefix .. " " .. Config.Displays.Messages.MSG_STEAM_REQUIRED);
      allowed = false;
      CancelEvent();
      return;
    end
  end
  if Config.Requirements.Discord then 
    -- Check if they have Discord
    if #ids.discord <= 1 then 
      deferrals.done(Config.Displays.Prefix .. " " .. Config.Displays.Messages.MSG_DISCORD_REQUIRED);
      allowed = false;
      CancelEvent();
      return;
    end
  end
  if Config.WhitelistRequired then 
    if not Queue:IsWhitelisted(user) then 
      -- Not whitelisted, return 
      deferrals.done(Config.Displays.Prefix .. " " .. Config.Displays.Messages.MSG_NOT_WHITELISTED);
      allowed = false;
      CancelEvent();
      return;
    end
  end
  if allowed then 
    playerConnecting[license] = {Connection = false, ID = user, PlayerName = playerName, Timeout = 0};
    if Config.onlyActiveWhenFull == true then 
      -- It's only active when server is full so lets check 
      if (GetPlayerCount() + 1) > slots or (GetPlayerCount() + Queue:GetMax()) > slots then  
        -- It's full, activate
        if not Queue:IsSetUp(user) then 
          -- Set them up 
          Queue:SetupPriority(user);
          if GetPlayerName(user) ~= nil then 
            sendToDiscQueue("QUEUED USER", "Player `" .. GetPlayerName(user):gsub("`", "") .. "` has been added to the queue...", "Bad-DiscordQueue created by Badger");
          end
          local message = GetMessage(user);
          local msg = message:gsub("{QUEUE_NUM}", Queue:GetQueueNum(user)):gsub("{QUEUE_MAX}", Queue:GetMax());
          if GetPlayerName(user) ~= nil then
            print(prefix .. " " .. "Player " .. GetPlayerName(user) .. " has been set to the QUEUE [" .. msg .. "]");
          end
        end
        while ( ( (not Queue:CheckQueue(user, currentConnectors, slots)) or (currentConnectors == maxConnectors) ) or (GetPlayerCount() == slots) or 
        ((GetPlayerCount() + currentConnectors + 1) > slots) or ( (GetPlayerCount() + currentConnectors ) >= slots) ) do 
          -- They are still in the queue 
          Wait(1000);
          if displayIndex > #displays then
            displayIndex = 1;
          end 
          local message = GetMessage(user);
          local msg = message:gsub("{QUEUE_NUM}", Queue:GetQueueNum(user)):gsub("{QUEUE_MAX}", Queue:GetMax());
          deferrals.update(prefix .. " " .. msg .. displays[displayIndex]);
          displayIndex = displayIndex + 1;
        end
        -- If it got down here, they are now allowed to join the server 
        if connecting[license] == nil or connecting[license] ~= true then 
          Queue:PopLicense(license)
          currentConnectors = currentConnectors + 1;
          connecting[license] = true;
          if GetPlayerName(user) ~= nil then
            print(prefix .. " " .. "Player " .. GetPlayerName(user) .. " is allowed to join now!");
          end
          Wait(1000);
          if GetPlayerName(user) ~= nil then
            sendToDisc("NEW CONNECTOR", "Player `" .. GetPlayerName(user):gsub("`", "") .. "` is allowed to join now!", "Bad-DiscordQueue created by Badger");
          end
          if playerConnecting[license] ~= nil then 
            playerConnecting[license].Timeout = Config.Timeout;
            playerConnecting[license].Connection = true;
          end
          if Config.Debug then 
            print(prefix .. " (playerConnecting) currentConnectors is == " .. tostring(currentConnectors) )
          end
        end -- connecting[license] == nil
        deferrals.done();
      else	 
        deferrals.done();--deferrals done if server is not full as we don't want the queue
      end
    else 
      if not Queue:IsSetUp(user) then 
        -- Set them up 
        Queue:SetupPriority(user);
        if GetPlayerName(user) ~= nil then
          sendToDiscQueue("QUEUED USER", "Player `" .. GetPlayerName(user):gsub("`", "") .. "` has been added to the queue...", "Bad-DiscordQueue created by Badger");
        end
        local message = GetMessage(user);
        local msg = message:gsub("{QUEUE_NUM}", Queue:GetQueueNum(user)):gsub("{QUEUE_MAX}", Queue:GetMax());
        if GetPlayerName(user) ~= nil then
          print(prefix .. " " .. "Player " .. GetPlayerName(user) .. " has been set to the QUEUE [" .. msg .. "]");
        end
      end
      while ( ( (not Queue:CheckQueue(user, currentConnectors, slots)) or (currentConnectors == maxConnectors) ) or (GetPlayerCount() == slots) or 
        ((GetPlayerCount() + currentConnectors + 1) > slots) or ( (GetPlayerCount() + currentConnectors ) >= slots) ) do 
        -- They are still in the queue 
        Wait(1000);
        if displayIndex > #displays then
          displayIndex = 1;
        end 
        local message = GetMessage(user);
        local msg = message:gsub("{QUEUE_NUM}", Queue:GetQueueNum(user)):gsub("{QUEUE_MAX}", Queue:GetMax());
        deferrals.update(prefix .. " " .. msg .. displays[displayIndex]);
        displayIndex = displayIndex + 1;
      end
      -- If it got down here, they are now allowed to join the server 
      if connecting[license] == nil or connecting[license] ~= true then 
        Queue:PopLicense(license)
        currentConnectors = currentConnectors + 1;
        connecting[license] = true;
        if GetPlayerName(user) ~= nil then
          print(prefix .. " " .. "Player " .. GetPlayerName(user) .. " is allowed to join now!");
        end 
        Wait(1000);
        if GetPlayerName(user) ~= nil then
          sendToDisc("NEW CONNECTOR", "Player `" .. GetPlayerName(user):gsub("`", "") .. "` is allowed to join now!", "Bad-DiscordQueue created by Badger");
        end
        if playerConnecting[license] ~= nil then 
          playerConnecting[license].Timeout = Config.Timeout;
          playerConnecting[license].Connection = true;
        end
        if Config.Debug then 
          print(prefix .. " (playerConnecting) currentConnectors is == " .. tostring(currentConnectors) )
        end
      end -- connecting[license] == nil;
      deferrals.done();
    end
  end
end)
AddEventHandler('playerDropped', function (reason)
  local user = source;
  local license = ExtractIdentifiers(user).license:gsub("license:", "");
  if (connecting[license] ~= nil) then 
    if (currentConnectors > 0) then 
      currentConnectors = currentConnectors - 1;
      if Config.Debug then 
        print(prefix .. " (playerDropped) currentConnectors was decremented... FROM: " .. tostring(currentConnectors + 1) .. " -- TO: " .. 
        tostring(currentConnectors));
      end
    end
    connecting[license] = nil;
  end
  playerConnecting[license] = nil;
  if (Queue:IsSetUp(user)) then 
    Queue:Pop(user);
    sendToDiscQueue("REMOVED QUEUE USER", "Player `" .. GetPlayerName(user):gsub("`", "") .. "` has been removed from the queue...", "Bad-DiscordQueue created by Badger");
    print(prefix .. " (playerDropped) " .. "Player " .. GetPlayerName(user) .. " has been removed from QUEUE");
  end
end)

RegisterNetEvent('DiscordQueue:Activated')
AddEventHandler('DiscordQueue:Activated', function()
  -- They were activated, pop them from Queue 
  Queue:Pop(source);
  local user = source;
  local license = ExtractIdentifiers(user).license:gsub("license:", "");
  connecting[license] = nil;
  playerConnecting[license] = nil;
  sendToDiscQueue("REMOVED QUEUE USER", "Player `" .. GetPlayerName(user):gsub("`", "") .. "` has been removed from the queue...", "Bad-DiscordQueue created by Badger");
  if (currentConnectors > 0) then 
    currentConnectors = currentConnectors - 1;
    if Config.Debug then 
      print(prefix .. " (DiscordQueue:Activated) currentConnectors was decremented... FROM: " .. tostring(currentConnectors + 1) .. " -- TO: " .. 
      tostring(currentConnectors));
    end
  end
  if Config.Debug then 
    print(prefix .. " (DiscordQueue:Activated) " .. "Player " .. GetPlayerName(user) .. " has been removed from QUEUE");
    print(prefix .. " (DiscordQueue:Activated) currentConnectors is == " .. tostring(currentConnectors) )
  end
end)