local _, GF = ...

local Scheduler = {}
GF.InvitationScheduler = Scheduler

local DEFAULT_STEP_SECONDS = 1
local LIMITED_STEP_SECONDS = 3
local AUTOMATIC_INVITE_OPTIONS = { respectMemberLimit = true }
local AUTHORITATIVE_APPLICANT_PROVENANCE = "LFG_LIST_APPLICANT_UPDATED"

local function getRecruitmentSession()
	return GF.RecruitmentSession
end

local function usesNativeQuestAutoAccept()
	local session = getRecruitmentSession()
	return session ~= nil
		and type(session.UsesNativeQuestAutoAccept) == "function"
		and session:UsesNativeQuestAutoAccept() == true
end

local function canPluginOwnActiveEntry()
	local session = getRecruitmentSession()
	if session == nil then
		return false
	end
	if type(session.CanPluginOwnAutoInvite) == "function" then
		return session:CanPluginOwnAutoInvite() == true
	end
	return not usesNativeQuestAutoAccept()
end

local function isActiveQuestEntry()
	local session = getRecruitmentSession()
	return session ~= nil
		and type(session.IsActiveQuestListing) == "function"
		and session:IsActiveQuestListing() == true
end

local function cancelTimer(timer)
	if timer and type(timer.Cancel) == "function" then
		timer:Cancel()
	end
end

local function currentStepSeconds()
	local database = GF.GetDB and GF.GetDB()
	if database and database.autoInviteMemberLimitEnabled == true then
		return LIMITED_STEP_SECONDS
	end
	return DEFAULT_STEP_SECONDS
end

local function currentEntrySignature()
	local session = getRecruitmentSession()
	if not (session and session.HasActive and session:HasActive()) then
		return nil
	end
	local entry = session.GetActive and session:GetActive()
	if type(entry) ~= "table" then
		return nil
	end
	local activityIDs = entry.activityIDs
	local activityID = type(activityIDs) == "table" and activityIDs[1]
		or entry.activityID or 0
	return table.concat({
		tostring(activityID),
		tostring(entry.questID or 0),
		entry.privateGroup == true and "1" or "0",
	}, ":")
end

local function activeEntryMatchesCreatedEntryArm(arm)
	if type(arm) ~= "table" then
		return false
	end
	local session = getRecruitmentSession()
	local entry = session and session.GetActive and session:GetActive()
	if type(entry) ~= "table" then
		return false
	end
	local ok, matches = pcall(function()
		local activityIDs = entry.activityIDs
		local activityID = type(activityIDs) == "table" and activityIDs[1]
			or entry.activityID
		return tonumber(activityID) == arm.activityID
			and tonumber(entry.questID) == arm.questID
	end)
	return ok and matches == true
end

local function refreshManagementControls()
	local panel = GF.ApplicantsPanel
	if panel and type(panel.UpdateManageState) == "function" then
		panel:UpdateManageState()
	end
end

local function applicantKey(applicantID)
	return tostring(applicantID)
end

local function resetGenerationRuntime(scheduler)
	scheduler._generation = (scheduler._generation or 0) + 1
	cancelTimer(scheduler._queueTimer)
	cancelTimer(scheduler._chainTimer)
	scheduler._queueTimer = nil
	scheduler._queueTicket = nil
	scheduler._queuePending = nil
	scheduler._chainTimer = nil
	scheduler._chainTicket = nil
	scheduler._cooldownUntil = nil
	scheduler._inFlightApplicantID = nil
	scheduler._candidateCursor = nil
	scheduler._submittedApplicants = {}
end

local function submittedApplicantCount(scheduler)
	local count = 0
	for _ in pairs(scheduler._submittedApplicants or {}) do
		count = count + 1
	end
	return count
end

function Scheduler:ReconcileApplicantLedger(authoritativeApplicantID, provenance)
	local submitted = self._submittedApplicants
	if type(submitted) ~= "table" or next(submitted) == nil then
		return false
	end
	local authoritativeKey
	if provenance == AUTHORITATIVE_APPLICANT_PROVENANCE
		and authoritativeApplicantID ~= nil
	then
		local keyOK, key = pcall(applicantKey, authoritativeApplicantID)
		if keyOK then
			authoritativeKey = key
		end
	end

	local presentApplicants = {}
	local listReadable = false
	local actionService = GF.ApplicantActionService
	if actionService and type(actionService.GetApplicantIDs) == "function" then
		local listOK, applicantIDs, providerReadable = pcall(
			actionService.GetApplicantIDs, actionService)
		if listOK and providerReadable == true and type(applicantIDs) == "table" then
			listReadable = pcall(function()
				for index = 1, #applicantIDs do
					local applicantID = applicantIDs[index]
					presentApplicants[applicantKey(applicantID)] = applicantID
				end
			end)
		end
	end

	local releaseKeys = {}
	for key, record in pairs(submitted) do
		local currentApplicantID = presentApplicants[key]
		local isAuthoritativeApplicant = authoritativeKey ~= nil
			and key == authoritativeKey
		local readApplicantID = currentApplicantID
			or (isAuthoritativeApplicant and authoritativeApplicantID)
		local wasArmed = record.missingObserved == true
			or record.nonAppliedObserved == true
		local statusKind
		if readApplicantID ~= nil and actionService
			and type(actionService.GetApplicantInfo) == "function"
		then
			local infoOK, info = pcall(
				actionService.GetApplicantInfo, actionService, readApplicantID)
			if infoOK and type(info) == "table" then
				local statusOK, kind = pcall(function()
					local status = info.applicationStatus
					if status == "applied" then
						if info.pendingApplicationStatus ~= nil
							or info.applicantInfo
						then
							return "applied_pending"
						end
						return "applied"
					end
					if status ~= nil then
						return "non_applied"
					end
				end)
				if statusOK then
					statusKind = kind
				end
			end
		end

		if statusKind == "applied" then
			if isAuthoritativeApplicant and wasArmed then
				releaseKeys[#releaseKeys + 1] = key
			elseif listReadable and currentApplicantID == nil then
				record.missingObserved = true
			end
		elseif statusKind == "non_applied" then
			record.nonAppliedObserved = true
		elseif statusKind == "applied_pending" then
			if listReadable and currentApplicantID == nil then
				record.missingObserved = true
			end
		elseif listReadable and currentApplicantID == nil then
			record.missingObserved = true
		end
	end
	for index = 1, #releaseKeys do
		submitted[releaseKeys[index]] = nil
	end
	return true
end

function Scheduler:RestoreSession()
	local session = getRecruitmentSession()
	local hasActive = session ~= nil
		and type(session.HasActive) == "function"
		and session:HasActive() == true
	if not hasActive then
		-- No active entry is an authoritative generation boundary, not an
		-- unreadable owner.  Discard an ordinary listing's stale signature, but
		-- keep the saved preference if this closes a session whose identity was
		-- unreadable on the preceding active snapshot.
		local preserveUnknownPreference =
			self._unknownOwnerSessionActive == true
		self:ClearSession({ preserveDatabase = preserveUnknownPreference })
		self._awaitingTaskPluginTakeover = nil
		return false
	end
	if canPluginOwnActiveEntry() ~= true then
		local taskEntry = isActiveQuestEntry()
		local nativeEntry = usesNativeQuestAutoAccept()
		-- Native auto-accept or an unreadable owner must clear scheduler residue
		-- so both engines can never run for the same listing.  Preserve the
		-- ordinary-listing preference even when questID itself is unreadable:
		-- fail closed on actions, not on the user's saved setting.
		self:ClearSession({ preserveDatabase = true })
		self._unknownOwnerSessionActive = not taskEntry
			and not nativeEntry or nil
		-- A later authoritative false may make this same task plugin-owned.
		-- Remember the transition even on cold restore or unreadable questID;
		-- the task branch will consume it, while ordinary listings never do.
		self._awaitingTaskPluginTakeover = true
		return false
	end
	self._unknownOwnerSessionActive = nil
	self._awaitingTaskPluginTakeover = nil
	resetGenerationRuntime(self)
	local database = GF.GetDB and GF.GetDB()
	if type(database) ~= "table" then
		self._enabled = false
		self._entrySignature = nil
		self._lastGroupSize = nil
		self._lastCanToggle = nil
		return false
	end
	local signature = currentEntrySignature()
	local taskOverride = isActiveQuestEntry()
	local shouldRestore = signature ~= nil
		and (taskOverride or (database.autoInviteEnabled == true
			and database.autoInviteEntrySig == signature))
	if shouldRestore then
		local actions = GF.ApplicantActionService
		self._enabled = true
		self._entrySignature = signature
		self._taskAutoInviteOverride = taskOverride
		self._taskSessionActive = taskOverride or nil
		self._lastGroupSize = actions and actions.GetGroupSize
			and actions:GetGroupSize() or nil
		self._lastCanToggle = self:CanToggle()
		self:Queue()
		return true
	end
	self._enabled = false
	self._entrySignature = nil
	self._taskAutoInviteOverride = nil
	self._taskSessionActive = taskOverride or nil
	self._lastGroupSize = nil
	self._lastCanToggle = nil
	if not taskOverride then
		database.autoInviteEnabled = false
		database.autoInviteEntrySig = nil
	end
	return false
end

function Scheduler:IsEnabled()
	if self._enabled == nil then
		self:RestoreSession()
	end
	return self._enabled == true
end

function Scheduler:CanToggle()
	local session = getRecruitmentSession()
	return session ~= nil
		and canPluginOwnActiveEntry()
		and session.HasActive ~= nil
		and session:HasActive() == true
		-- 只有拥有当前发布权限的会话才能执行自动动作。复用
		-- the session gate so a solo listing owner remains empowered even though
		-- UnitIsGroupLeader("player", HOME) is false before the first invite joins.
		and type(session.CanPublish) == "function"
		and session:CanPublish() == true
end

function Scheduler:ClearSession(options)
	local preserveCreatedEntryArm = type(options) == "table"
		and options.preserveCreatedEntryArm == true
	local taskStillActive = isActiveQuestEntry()
	local preserveDatabase = (type(options) == "table"
		and options.preserveDatabase == true)
		or self._taskAutoInviteOverride == true
		or self._taskSessionActive == true
		or taskStillActive
	resetGenerationRuntime(self)
	self._lastGroupSize = nil
	self._lastCanToggle = nil
	self._enabled = false
	self._entrySignature = nil
	self._taskAutoInviteOverride = nil
	self._taskSessionActive = taskStillActive or nil
	self._unknownOwnerSessionActive = nil
	if not preserveCreatedEntryArm then
		self._createdEntryArm = nil
	end

	local database = GF.GetDB and GF.GetDB()
	if type(database) == "table" and not preserveDatabase then
		database.autoInviteEnabled = false
		database.autoInviteEntrySig = nil
	end
end

function Scheduler:ArmForCreatedEntry(activityID, questID)
	activityID = tonumber(activityID)
	questID = tonumber(questID)
	if not activityID or activityID <= 0 or not questID or questID <= 0 then
		return false
	end
	self:ClearSession({ preserveDatabase = true })
	self._createdEntryArm = {
		activityID = activityID,
		questID = questID,
	}
	return true
end

function Scheduler:CancelCreatedEntryArm()
	local hadArm = self._createdEntryArm ~= nil
	self._createdEntryArm = nil
	return hadArm
end

function Scheduler:SetEnabled(enabled)
	if enabled ~= true then
		self:ClearSession()
		return true
	end
	local session = getRecruitmentSession()
	if not (session and session.HasActive and session:HasActive()) then
		return false
	end
	if self:CanToggle() ~= true then
		return false
	end

	local signature = currentEntrySignature()
	if signature == nil then
		return false
	end
	if self:IsEnabled() == true and self._entrySignature == signature then
		self:Queue()
		return true
	end
	resetGenerationRuntime(self)
	self._unknownOwnerSessionActive = nil
	self._awaitingTaskPluginTakeover = nil
	self._enabled = true
	self._entrySignature = signature
	self._taskAutoInviteOverride = isActiveQuestEntry()
	self._taskSessionActive = self._taskAutoInviteOverride or nil
	local actions = GF.ApplicantActionService
	self._lastGroupSize = actions and actions.GetGroupSize
		and actions:GetGroupSize() or nil
	self._lastCanToggle = true

	local database = GF.GetDB and GF.GetDB()
	if type(database) == "table" and not self._taskAutoInviteOverride then
		database.autoInviteEnabled = true
		database.autoInviteEntrySig = signature
	end
	self:Queue()
	return true
end

function Scheduler:StopAtMemberLimit()
	local database = GF.GetDB and GF.GetDB()
	if not database or database.autoInviteMemberLimitEnabled ~= true then
		return false
	end
	local actions = GF.ApplicantActionService
	local groupSize = actions and actions.GetGroupSize
		and actions:GetGroupSize() or 1
	local memberLimit = actions and actions.GetConfiguredMemberLimit
		and actions:GetConfiguredMemberLimit() or 0
	local invited = C_LFGList and C_LFGList.GetNumInvitedApplicantMembers
		and C_LFGList.GetNumInvitedApplicantMembers() or 0
	if groupSize + invited < memberLimit then
		return false
	end
	if self._taskAutoInviteOverride == true then
		-- The quest policy stays visibly enabled for the whole task listing.
		-- Reaching the configured limit only pauses submissions; a later roster
		-- change will queue the scheduler again when capacity is available.
		cancelTimer(self._chainTimer)
		self._chainTimer = nil
		self._chainTicket = nil
		self._cooldownUntil = nil
		refreshManagementControls()
		return true
	end
	self:ClearSession()
	refreshManagementControls()
	return true
end

function Scheduler:SelectNextCandidate(candidateIDs)
	local actions = GF.ApplicantActionService
	if not (actions and type(actions.CanInvite) == "function") then
		return nil, false
	end
	local candidates = type(candidateIDs) == "table" and candidateIDs or {}
	local count = #candidates
	if count == 0 then
		self._candidateCursor = nil
		return nil, false
	end

	local cursorIndex = 0
	for index = 1, count do
		if candidates[index] == self._candidateCursor then
			cursorIndex = index
			break
		end
	end

	local lastCandidate
	local retryNeeded = false
	for offset = 1, count do
		local index = ((cursorIndex + offset - 1) % count) + 1
		local applicantID = candidates[index]
		lastCandidate = applicantID
		local alreadySubmitted = self._submittedApplicants
			and self._submittedApplicants[applicantKey(applicantID)] ~= nil
		if not alreadySubmitted then
			local callOK, canInvite, reason = pcall(
				actions.CanInvite,
				actions,
				applicantID,
				AUTOMATIC_INVITE_OPTIONS)
			if callOK and canInvite == true then
				self._candidateCursor = applicantID
				return applicantID, false
			end
			if not callOK
				or reason == "api_error"
				or reason == "api_unreadable"
				or reason == "loading"
				or reason == "missing"
			then
				retryNeeded = true
			end
		end
	end
	self._candidateCursor = lastCandidate
	return nil, retryNeeded
end

function Scheduler:ScheduleNext(delaySeconds)
	cancelTimer(self._chainTimer)
	self._chainTimer = nil
	self._chainTicket = nil
	if not (C_Timer and type(C_Timer.NewTimer) == "function") then
		return false
	end
	local delay = tonumber(delaySeconds) or currentStepSeconds()
	delay = math.max(0, delay)
	local generation = self._generation or 0
	local ticket = {}
	self._chainTicket = ticket
	local timer
	timer = C_Timer.NewTimer(delay, function()
		if self._chainTicket ~= ticket then
			return
		end
		self._chainTicket = nil
		self._chainTimer = nil
		if generation == (self._generation or 0) then
			self:TryNext()
		end
	end)
	if self._chainTicket == ticket then
		self._chainTimer = timer
	end
	return true
end

function Scheduler:TryNext()
	local actions = GF.ApplicantActionService
	local now = GetTime and GetTime() or 0
	if self._inFlightApplicantID ~= nil
		or self:IsEnabled() ~= true
		or self:CanToggle() ~= true
		or not actions
	then
		return false
	end
	self:ReconcileApplicantLedger()
	if self._cooldownUntil and now < self._cooldownUntil then
		self:ScheduleNext(self._cooldownUntil - now)
		return false
	end
	self._cooldownUntil = nil
	if self:StopAtMemberLimit() then
		return false
	end

	local model = GF.ApplicantSnapshotBuilder
	local candidates, providerReadable
	if model and type(model.GetSortedApplicantIDs) == "function" then
		candidates, providerReadable = model:GetSortedApplicantIDs()
	elseif type(actions.GetApplicantIDs) == "function" then
		candidates, providerReadable = actions:GetApplicantIDs()
	end
	if providerReadable ~= true then
		-- A failed provider read is not an empty candidate set.  Keep the current
		-- generation alive and retry on the normal cadence even if no new event fires.
		self:ScheduleNext()
		return false
	end
	local applicantID, retryNeeded = self:SelectNextCandidate(candidates)
	if applicantID == nil then
		if retryNeeded == true then
			-- Per-applicant reads can be unavailable while the provider list itself is
			-- readable (notably during chat lockdown).  Keep the chain alive so recovery
			-- does not depend on Blizzard emitting another LFG event.
			self:ScheduleNext()
		end
		return false
	end

	local submittedKey = applicantKey(applicantID)
	local submittedRecord = {
		applicantID = applicantID,
		missingObserved = false,
		nonAppliedObserved = false,
	}
	self._submittedApplicants = self._submittedApplicants or {}
	self._submittedApplicants[submittedKey] = submittedRecord
	self._cooldownUntil = now + currentStepSeconds()
	self._inFlightApplicantID = applicantID
	local accepted, outcome = actions:Invite(
		applicantID, AUTOMATIC_INVITE_OPTIONS)
	self._inFlightApplicantID = nil
	if accepted ~= true then
		if self._submittedApplicants[submittedKey] == submittedRecord then
			self._submittedApplicants[submittedKey] = nil
		end
		self._cooldownUntil = nil
		return false
	end
	if outcome ~= "raid_conversion_popup" then
		self:ScheduleNext()
	end
	return true
end

function Scheduler:Queue(applicantID, provenance)
	if self:IsEnabled() ~= true then
		return false
	end
	-- Only the applicant-specific native event can prove that a later applied
	-- snapshot is a new generation. List-wide and roster passes may observe an
	-- omission edge, but cannot release duplicate protection on their own.
	self:ReconcileApplicantLedger(applicantID, provenance)
	if self._queuePending == true then
		return false
	end
	self._queuePending = true
	local generation = self._generation or 0
	local ticket = {}
	self._queueTicket = ticket
	local function run()
		if self._queueTicket ~= ticket then
			return
		end
		self._queueTicket = nil
		self._queueTimer = nil
		self._queuePending = nil
		if generation == (self._generation or 0) then
			self:TryNext()
		end
	end
	if C_Timer and type(C_Timer.NewTimer) == "function" then
		local timer = C_Timer.NewTimer(0, run)
		if self._queueTicket == ticket then
			self._queueTimer = timer
		end
	elseif C_Timer and type(C_Timer.After) == "function" then
		C_Timer.After(0, run)
	else
		run()
	end
	return true
end

function Scheduler:PauseForPermissionLoss()
	cancelTimer(self._queueTimer)
	cancelTimer(self._chainTimer)
	self._queueTimer = nil
	self._queueTicket = nil
	self._queuePending = nil
	self._chainTimer = nil
	self._chainTicket = nil
	self._candidateCursor = nil
	-- Keep the active-entry generation, submitted ledger, saved preference and
	-- cooldown. A later leader recovery resumes once without treating existing
	-- applicants as a new listing.
	return true
end

function Scheduler:HandleRosterChanged()
	local session = getRecruitmentSession()
	local actions = GF.ApplicantActionService
	local currentSize = actions and actions.GetGroupSize
		and actions:GetGroupSize() or 1
	local previousSize = self._lastGroupSize
	local canToggle = self:CanToggle()
	local previousCanToggle = self._lastCanToggle
	self._lastGroupSize = currentSize
	self._lastCanToggle = canToggle
	if canToggle ~= true and (previousCanToggle == true
		or self._queueTimer ~= nil or self._chainTimer ~= nil)
	then
		self:PauseForPermissionLoss()
	end
	if isActiveQuestEntry()
		and self:IsEnabled() ~= true
		and canToggle == true
	then
		self:ClearSession({ preserveDatabase = true })
		return self:SetEnabled(true)
	end
	if not (session and session.HasActive and session:HasActive())
		or self:IsEnabled() ~= true
	then
		return false
	end
	local rosterChanged = previousSize ~= nil and previousSize ~= currentSize
	local leaderRestored = previousCanToggle == false and canToggle == true
	return (rosterChanged or leaderRestored) and self:Queue() or false
end

function Scheduler:HandleActiveEntryChanged(hasActive, createdNew)
	-- A confirmed inactive event is not an unknown-owner state: there is no
	-- listing for either engine to own.  Resolve it before reading active-entry
	-- fields so ordinary delists clear their persisted signature, while a task
	-- session still restores the ordinary preference preserved underneath it.
	if hasActive ~= true then
		local preserveUnknownPreference =
			self._unknownOwnerSessionActive == true
		self:ClearSession({
			preserveCreatedEntryArm = true,
			preserveDatabase = preserveUnknownPreference,
		})
		self._awaitingTaskPluginTakeover = nil
		return true
	end
	if canPluginOwnActiveEntry() ~= true then
		local taskEntry = isActiveQuestEntry()
		local nativeEntry = usesNativeQuestAutoAccept()
		-- Native and unreadable ownership both stop the plugin runtime, but an
		-- unreadable questID must not erase the ordinary listing preference that
		-- was preserved before quest creation.  Fail closed on actions, not on the
		-- user's saved setting.
		self:ClearSession({ preserveDatabase = true })
		self._unknownOwnerSessionActive = not taskEntry
			and not nativeEntry or nil
		self._awaitingTaskPluginTakeover = true
		return true
	end
	local recoveredUnreadableIdentity =
		self._unknownOwnerSessionActive == true
	self._unknownOwnerSessionActive = nil
	if isActiveQuestEntry() then
		local shouldEnable = createdNew == true
			or self._enabled == nil
			or self._awaitingTaskPluginTakeover == true
			or recoveredUnreadableIdentity
			or activeEntryMatchesCreatedEntryArm(self._createdEntryArm)
		self._awaitingTaskPluginTakeover = nil
		self:CancelCreatedEntryArm()
		if shouldEnable and self:IsEnabled() ~= true then
			self:ClearSession({ preserveDatabase = true })
			self:SetEnabled(true)
		end
		return true
	end
	self._awaitingTaskPluginTakeover = nil
	if createdNew == true then
		local shouldEnable = activeEntryMatchesCreatedEntryArm(
			self._createdEntryArm)
		self:ClearSession()
		if shouldEnable then
			self:SetEnabled(true)
		end
		return true
	end
	if recoveredUnreadableIdentity then
		-- The active entry has become authoritatively ordinary.  Restore only an
		-- exact persisted signature; RestoreSession retires a mismatch instead of
		-- letting a task-era preference leak into another listing.
		self._enabled = nil
		self:RestoreSession()
		return true
	end
	local signature = currentEntrySignature()
	if self:IsEnabled() == true
		and self._entrySignature ~= nil
		and signature ~= nil
		and signature ~= self._entrySignature
	then
		self:ClearSession()
		return true
	end
	return false
end

function Scheduler:GetSnapshot()
	return {
		generation = self._generation or 0,
		enabled = self:IsEnabled(),
		entrySignature = self._entrySignature,
		candidateCursor = self._candidateCursor,
		cooldownUntil = self._cooldownUntil,
		inFlightApplicantID = self._inFlightApplicantID,
		lastGroupSize = self._lastGroupSize,
		lastCanToggle = self._lastCanToggle,
		queuePending = self._queuePending == true,
		submittedApplicantCount = submittedApplicantCount(self),
		createdEntryArmed = self._createdEntryArm ~= nil,
		taskAutoInviteOverride = self._taskAutoInviteOverride == true,
		taskSessionActive = self._taskSessionActive == true,
	}
end
