messenger = {}
messenger.version = "3.1.0"
messenger.verbose = false 
messenger.requiredLibs = {
	"dcsCommon", -- always
	"cfxZones", -- Zones, of course 
}
messenger.messengers = {} 
--[[--
	Version History
	2.3.0 - cfxZones OOP switch
	2.3.1 - triggering message AFTER the on/off switches are tested
	3.0.0 - removed messenger, in?, f? attributes, harmonized on messenger?
	3.1.0 - msgGroup supports multiple groups, separated by comma 
		  - msgUnit supports multiple units, separated by comma
--]]--

function messenger.addMessenger(theZone)
	table.insert(messenger.messengers, theZone)
end

function messenger.getMessengerByName(aName) 
	for idx, aZone in pairs(messenger.messengers) do 
		if aName == aZone.name then return aZone end 
	end
	if messenger.verbose then 
		trigger.action.outText("+++msgr: no messenger with name <" .. aName ..">", 30)
	end 
	
	return nil 
end


--
-- Dynamic Group and Dynamic Unit processing are 
-- unique to messenger, and are not available via 
-- cfxZones or dcsCommon 
--

function messenger.dynamicGroupProcessing(msg, theZone, theGroup)
	if not theGroup then return msg end 
	-- access first unit 
	local theUnit = theGroup:getUnit(1) 
	if not theUnit then return msg end 
	if not Unit.isExist(theUnit) then return msg end 
	-- we always use unit 1 as reference 
	return messenger.dynamicUnitProcessing(msg, theZone, theUnit)
end

function messenger.dynamicUnitProcessing(inMsg, theZone, theUnit)
-- replace all occurences of <bae/rng/asp/cls/clk: unit/zone> with their values 
-- bae = bearingInDegreesFromAtoB
-- rng = range 

-- asp = aspect (not yet implemented)
-- cls = closing velocity (not yet implemented) 
-- clk = o'clock 
-- hnd = handedness (left/right/ahead/behind
-- sde = side (starboard / port / ahead / aft)
-- rbea = responses mapped to bearing. maps all responses like clock, with "12" being the first response. requires msgResponses set

	local here = theUnit:getPoint()
	local uHead = dcsCommon.getUnitHeading(theUnit) * 57.2958 -- to degrees. 
	local locales = {"bea", "rng", "clk", "hnd", "sde", "rbea", "cls", "pcls", "asp"}
	local outMsg = inMsg
	for idx, aLocale in pairs(locales) do 
		local pattern = "<" .. aLocale .. ":%s*[%s%w%*%d%.%-_]+>"
		repeat -- iterate all patterns one by one 
			local startLoc, endLoc = string.find(outMsg, pattern)
			if startLoc then
				local theValParam = string.sub(outMsg, startLoc, endLoc)
				-- strip lead and trailer 
				local param = string.gsub(theValParam, "<" .. aLocale .. ":%s*", "")
				param = string.gsub(param, ">","")
				-- find zone or unit
				param = dcsCommon.trim(param)
				local thePoint = nil 
				local cls = 0 
				local aspct = 0
				local tZone = cfxZones.getZoneByName(param)
				local tUnit = Unit.getByName(param)
				local aspect = 0
				local tHead = 0
				
				if tZone then 
					thePoint = tZone:getPoint()
					-- if this zone follows a unit, get the master units elevaltion
					if tZone.linkedUnit and Unit.isExist(tZone.linkedUnit) then 
						local lU = tZone.linkedUnit
						local masterPoint = lU:getPoint()
						thePoint.y = masterPoint.y 
						cls = -dcsCommon.getClosingVelocity(theUnit, lU)
						tHead = dcsCommon.getUnitHeading(lU) * 57.2958
					else 
						-- since zones always have elevation of 0, 
						-- now get the elevation from the map 
						thePoint.y = land.getHeight({x = thePoint.x, y = thePoint.z})
					end
				elseif tUnit then 
					if Unit.isExist(tUnit) then 
						thePoint = tUnit:getPoint()
						cls = -dcsCommon.getClosingVelocity(theUnit, tUnit)
						tHead = dcsCommon.getUnitHeading(tUnit) * 57.2958
					end
				else 
					-- nothing to do, remove me.
				end

				local locString = theZone.errString
				if thePoint then 
					-- now that we have a point, we can do locale-specific
					-- processing. return result in locString
					local pcls = cls
					local r = dcsCommon.dist(here, thePoint)
					--local alt = thePoint.y
					local uSize = "m"
					if theZone.imperialUnits then 
						r = math.floor(r * 3.28084) -- feet 
						uSize = "ft"
						if r > 1000 then 
						-- convert to nautical mile
							r = math.floor(r * 10 / 6076.12) / 10
							uSize = "nm"
						end
						cls = math.floor(cls * 1.9438452) -- m/s to knots
						pcls = math.floor(pcls * 32.8084) / 10 -- ft/s
					else 
						r = math.floor(r) -- meters 
						if r > 1000 then  
							r = math.floor (r /	100) / 10
							uSize = "km"
						end
						cls = math.floor(cls * 3.6) -- m/s to km/h
						pcls = math.floor(pcls * 10) / 10 -- m/s
					end 

					local bea = dcsCommon.bearingInDegreesFromAtoB(here, thePoint)
					local beaInv = 360 - bea -- from tUnit to player
					local direction = bea - uHead  -- tUnit as seen from player heading uHead
					if direction < 0 then direction = direction + 360 end 
					aspect = beaInv - tHead 
					-- set up locale exchange string
					if aLocale == "bea" then locString = tostring(bea)
					elseif aLocale == "asp" then locString = dcsCommon.aspectByDirection(aspect)
					elseif aLocale == "clk" then 
						locString = tostring(dcsCommon.getClockDirection(direction))
					elseif aLocale == "rng" then locString = tostring(r)..uSize
					elseif aLocale == "cls" then locString = tostring(cls)
					elseif aLocale == "pcls" then locString = tostring(pcls)
					elseif aLocale == "hnd" then locString = dcsCommon.getGeneralDirection(direction)
					elseif aLocale == "sde" then locString = dcsCommon.getNauticalDirection(direction) 
					elseif aLocale == "rbea" and (theZone.msgResponses) then 
						local offset = cfxZones.rspMapper360(direction, #theZone.msgResponses)
						locString = dcsCommon.trim(theZone.msgResponses[offset])
					else locString = "<locale " .. aLocale .. " err: undefined params>"
					end
				end
				-- replace pattern in original with new val 
				outMsg = string.gsub(outMsg, pattern, locString, 1) -- only one sub!
			end -- if startloc
		until not startLoc
	end -- for all locales 
	return outMsg
end


--
-- reat attributes
--
function messenger.createMessengerWithZone(theZone)
	local aMessage = theZone:getStringFromZoneProperty("message", "") 
	theZone.message = aMessage  
	theZone.spaceBefore = theZone:getBoolFromZoneProperty("spaceBefore", false)
	theZone.spaceAfter = theZone:getBoolFromZoneProperty("spaceAfter", false)
	theZone.soundFile = theZone:getStringFromZoneProperty("soundFile", "<none>") 
	theZone.clearScreen = theZone:getBoolFromZoneProperty("clearScreen", false)
	theZone.duration = theZone:getNumberFromZoneProperty("duration", 30)
	if theZone:hasProperty("messageDuration") then 
		theZone.duration = theZone:getNumberFromZoneProperty( "messageDuration", 30)
	end 
	
	-- msgTriggerMethod
	theZone.msgTriggerMethod = theZone:getStringFromZoneProperty( "triggerMethod", "change")
	if theZone:hasProperty("msgTriggerMethod") then 
		theZone.msgTriggerMethod = theZone:getStringFromZoneProperty("msgTriggerMethod", "change")
	end 
	theZone.triggerMessagerFlag = theZone:getStringFromZoneProperty( "messenger?", "none")
	theZone.lastMessageTriggerValue = theZone:getFlagValue(theZone.triggerMessagerFlag) -- save last value	

	theZone.messageOff = theZone:getBoolFromZoneProperty("mute", false) --false 
	if theZone:hasProperty("messageMute") then
		theZone.messageOff = theZone:getBoolFromZoneProperty( "messageMute", false)
	end
	
	-- advisory: messageOff, messageOffFlag and lastMessageOff are all distinct 	
	if theZone:hasProperty("messageOff?") then 
		theZone.messageOffFlag = theZone:getStringFromZoneProperty("messageOff?", "*none")
		theZone.lastMessageOff = theZone:getFlagValue(theZone.messageOffFlag)
	end
	
	if theZone:hasProperty("messageOn?") then 
		theZone.messageOnFlag = theZone:getStringFromZoneProperty( "messageOn?", "*none")
		theZone.lastMessageOn = theZone:getFlagValue(theZone.messageOnFlag)
	end
	
	-- reveiver: coalition, group, unit 
	if theZone:hasProperty("coalition") then 
		theZone.msgCoalition = theZone:getCoalitionFromZoneProperty("coalition", 0)
	elseif theZone:hasProperty("msgCoalition") then 
		theZone.msgCoalition = theZone:getCoalitionFromZoneProperty("msgCoalition", 0)
	end 
	
	if theZone:hasProperty("group") then 
		-- now supporting multiple groups 
		local theGroups = {}
		local rawGroups = theZone:getStringFromZoneProperty("group", "<none>")
		if dcsCommon.containsString(rawGroups, ",") then 
			theGroups = dcsCommon.splitString(rawGroups, ",")
			theGroups = dcsCommon.trimArray(theGroups)
			theZone.msgGroup = theGroups
		else 
			theZone.msgGroup = {rawGroups}
		end 
		
	elseif theZone:hasProperty("msgGroup") then 
		local rawGroups = theZone:getStringFromZoneProperty("msgGroup", "<none>")
		if dcsCommon.containsString(rawGroups, ",") then 
			theGroups = dcsCommon.splitString(rawGroups, ",")
			theGroups = dcsCommon.trimArray(theGroups)
			theZone.msgGroup = theGroups
		else 
			theZone.msgGroup = {rawGroups,}
		end 
	end
	
	if theZone:hasProperty("unit") or theZone:hasProperty("msgUnit") then
		local rawUnits = "err"
		if theZone:hasProperty("unit") then 
			rawUnits = theZone:getStringFromZoneProperty("unit", "<none>")
		else 
			rawUnits = theZone:getStringFromZoneProperty("msgUnit", "<none>")
		end 
		if dcsCommon.containsString(rawUnits, ",") then 
			local theUnits = dcsCommon.splitString(rawUnits, ",")
			theUnits = dcsCommon.trimArray(theUnits)
			theZone.msgUnit = theUnits
		else 
			theZone.msgUnit = {rawUnits,}
		end 
	end
	
	if (theZone.msgGroup and theZone.msgUnit) or 
	   (theZone.msgGroup and theZone.msgCoalition) or
	   (theZone.msgUnit and theZone.msgCoalition)
	then 
		trigger.action.outText("+++msg: WARNING - messenger in <" .. theZone.name .. "> has conflicting coalition, group and unit, use only one.", 30)
	end
	
	-- flag whose value can be read: to be deprecated
	if theZone:hasProperty("messageValue?") then 
		theZone.messageValue = theZone:getStringFromZoneProperty( "messageValue?", "<none>") 
		trigger.action.outText("+++Msg: Warning - zone <" .. theZone.name .. "> uses 'messageValue' attribute. Migrate to <v:<flag> now!", 30)
	end
	
	-- time format for new <t: flagname>
	theZone.msgTimeFormat = theZone:getStringFromZoneProperty( "timeFormat", "<:h>:<:m>:<:s>")
	
	theZone.imperialUnits = theZone:getBoolFromZoneProperty("imperial", false)
	if theZone:hasProperty("imperialUnits") then 
		theZone.imperialUnits = theZone:getBoolFromZoneProperty( "imperialUnits", false)
	end
	
	theZone.errString = theZone:getStringFromZoneProperty("error", "")
	if theZone:hasProperty("messageError") then 
		theZone.errString = theZone:getStringFromZoneProperty( "messageError", "")
	end
	
	-- possible responses for mapping
	if theZone:hasProperty("responses") then 
		local resp = theZone:getStringFromZoneProperty("responses", "none")
		theZone.msgResponses = dcsCommon.string2Array(resp, ",")
	end
	
	if messenger.verbose or theZone.verbose then 
		trigger.action.outText("+++Msg: new messenger in <".. theZone.name .."> will say '".. theZone.message .. "' (raw)", 30)
	end
end

--
-- Update 
--
function messenger.getMessage(theZone)
	local msg = theZone.message
	-- see if it has a "$val" in there 
	local zName = theZone.name 
	if not zName then zName = "<strange!>" end 
	local zVal = "<n/a>"
	if theZone.messageValue then 
		trigger.action.outText("+++Msg: Warning - zone <" .. theZone.name .. "> uses 'messageValue' attribute. Migrate to <v:<flag> now!")
		zVal = theZone:getFlagValue(theZone.messageValue)
		zVal = tostring(zVal)
		if not zVal then zVal = "<err>" end 
	end 
	
	-- old-school <v> to provide value from messageValue
	-- to be removed mid-2023
	msg = string.gsub(msg, "<v>", zVal) 
	local z = tonumber(zVal)
	if not z then z = 0 end  
	msg = dcsCommon.processHMS(msg, z)
	
	-- remainder hand-off to cfxZones (refactoring of messenger code 
	msg = cfxZones.processStringWildcards(msg, theZone, theZone.msgTimeFormat, theZone.imperialUnits, theZone.msgResponses)
	
	
	return msg 
end

function messenger.isTriggered(theZone)
	-- this module has triggered 
	if theZone.messageOff then 
		if messenger.verbose or theZone.verbose then 
			trigger.action.outFlag("msg: message for <".. theZone.name .."> is OFF",30)
		end
		return 
	end
	
	local fileName = "l10n/DEFAULT/" .. theZone.soundFile
	local msg = messenger.getMessage(theZone)
	if messenger.verbose or theZone.verbose then 
		trigger.action.outText("+++Msg: <".. theZone.name .."> will say <".. msg .. ">", 30)
	end
	
	if theZone.spaceBefore then msg = "\n"..msg end 
	if theZone.spaceAfter then msg = msg .. "\n" end 
	
	if theZone.msgCoalition then 
		if #msg > 0 or theZone.clearScreen then 
			trigger.action.outTextForCoalition(theZone.msgCoalition, msg, theZone.duration, theZone.clearScreen)
		end
		trigger.action.outSoundForCoalition(theZone.msgCoalition, fileName)
	elseif theZone.msgGroup then 
		for idx, aGroupName in pairs(theZone.msgGroup) do 
			local theGroup = Group.getByName(aGroupName)
			if theGroup and Group.isExist(theGroup) then 
				local ID = theGroup:getID()
				msg = messenger.dynamicGroupProcessing(msg, theZone, theGroup)
				if #msg > 0 or theZone.clearScreen then 
					trigger.action.outTextForGroup(ID, msg, theZone.duration, theZone.clearScreen)
				end
				trigger.action.outSoundForGroup(ID, fileName)
			end
		end
	elseif theZone.msgUnit then 
		for idx, aUnitName in pairs (theZone.msgUnit) do 
			local theUnit = Unit.getByName(aUnitName)
			if theUnit and Unit.isExist(theUnit) then 
				local ID = theUnit:getID()
				msg = messenger.dynamicUnitProcessing(msg, theZone, theUnit)
				if #msg > 0 or theZone.clearScreen then 
					trigger.action.outTextForUnit(ID, msg, theZone.duration, theZone.clearScreen)
				end
				trigger.action.outSoundForUnit(ID, fileName)
			end 
		end
	elseif theZone:getLinkedUnit() then 
		-- this only works if the zone is linked to a unit 
		-- and not using group or unit 
		-- the linked unit is then used as reference 
		-- outputs to all of same coalition as the linked 
		-- unit 
		local theUnit = theZone:getLinkedUnit()
		local ID = theUnit:getID()
		local coa = theUnit:getCoalition()
		msg = messenger.dynamicUnitProcessing(msg, theZone, theUnit)
		if #msg > 0 or theZone.clearScreen then 
			trigger.action.outTextForCoalition(coa, msg, theZone.duration, theZone.clearScreen)
		end
		trigger.action.outSoundForCoalition(coa, fileName)
	else 
		-- out to all 
		if #msg > 0 or theZone.clearScreen then 
			trigger.action.outText(msg, theZone.duration, theZone.clearScreen)
		end
		trigger.action.outSound(fileName)
	end
end

function messenger.update()
	-- call me in a second to poll triggers
	timer.scheduleFunction(messenger.update, {}, timer.getTime() + 1)
		
	for idx, aZone in pairs(messenger.messengers) do
		-- make sure to re-start before reading time limit
		-- new trigger code 
		
		if aZone:testZoneFlag(aZone.messageOffFlag, aZone.msgTriggerMethod, "lastMessageOff") then 
			aZone.messageOff = true
			if messenger.verbose or aZone.verbose then 
				trigger.action.outText("+++msg: messenger <" .. aZone.name .. "> turned ***OFF***", 30)
			end 
		end
		
		if aZone:testZoneFlag(aZone.messageOnFlag, aZone.msgTriggerMethod, "lastMessageOn") then 
			aZone.messageOff = false
			if messenger.verbose or aZone.verbose then 
				trigger.action.outText("+++msg: messenger <" .. aZone.name .. "> turned ON", 30)
			end
		end

		if aZone:testZoneFlag(aZone.triggerMessagerFlag, aZone.msgTriggerMethod, "lastMessageTriggerValue") then 
			if messenger.verbose or aZone.verbose then 
					trigger.action.outText("+++msgr: triggered on in? for <".. aZone.name ..">", 30)
				end
			messenger.isTriggered(aZone)
		end 


	end
end

--
-- Config & Start
--
function messenger.readConfigZone()
	local theZone = cfxZones.getZoneByName("messengerConfig") 
	if not theZone then 
		if messenger.verbose then 
			trigger.action.outText("+++msgr: NO config zone!", 30)
		end 
		theZone =  cfxZones.createSimpleZone("messengerConfig")
	end 
	
	messenger.verbose = theZone:getBoolFromZoneProperty("verbose", false)
	
	if messenger.verbose then 
		trigger.action.outText("+++msgr: read config", 30)
	end 
end

function messenger.start()
	-- lib check
	if not dcsCommon.libCheck then 
		trigger.action.outText("cfx Messenger requires dcsCommon", 30)
		return false 
	end 
	if not dcsCommon.libCheck("cfx Messenger", messenger.requiredLibs) then
		return false 
	end
	
	-- read config 
	messenger.readConfigZone()
	
	-- process messenger Zones 
	-- old style
--[[--	
	local attrZones = cfxZones.getZonesWithAttributeNamed("messenger")
	for k, aZone in pairs(attrZones) do 
		messenger.createMessengerWithZone(aZone) -- process attributes
		messenger.addMessenger(aZone) -- add to list
	end
--]]--	
	-- new style that saves messageOut? flag by reading flags
	attrZones = cfxZones.getZonesWithAttributeNamed("messenger?")
	for k, aZone in pairs(attrZones) do 
		messenger.createMessengerWithZone(aZone) -- process attributes
		messenger.addMessenger(aZone) -- add to list
	end
	
	-- start update 
	messenger.update()
	
	trigger.action.outText("cfx Messenger v" .. messenger.version .. " started.", 30)
	return true 
end

-- let's go!
if not messenger.start() then 
	trigger.action.outText("cfx Messenger aborted: missing libraries", 30)
	messenger = nil 
end


--[[--
Ideas:
  - when messenger is ties to a unit, that unit can also be base for all relative references. Only checked if neither group nor unit is set
--]]--