UPK_ActivatorTrigger.lua

-- by mor2000

--------------------
-- ActivatorTrigger (enables children if keypressed)

local UPK_ActivatorTrigger_mt = ClassUPK(UPK_ActivatorTrigger,UniversalProcessKit)
InitObjectClass(UPK_ActivatorTrigger, "UPK_ActivatorTrigger")
UniversalProcessKit.addModule("activatortrigger",UPK_ActivatorTrigger)

UPK_ActivatorTrigger.MODE_SWITCH=1
UPK_ActivatorTrigger.MODE_BUTTON=2
UPK_ActivatorTrigger.MODE_ONETIME=3

function UPK_ActivatorTrigger:new(nodeId, parent)
	printFn('UPK_ActivatorTrigger:new(',nodeId,', ',parent,')')
	local self = UniversalProcessKit:new(nodeId, parent, UPK_ActivatorTrigger_mt)
	registerObjectClassName(self, "UPK_ActivatorTrigger")
	
	self.isActive=getBoolFromUserAttribute(nodeId, "isActive", false)
	
	self.activateText = returnNilIfEmptyString(self.i18n[getStringFromUserAttribute(nodeId, "activateTriggerText1")]) or "[activateText]"
	self.deactivateText = returnNilIfEmptyString(self.i18n[getStringFromUserAttribute(nodeId, "activateTriggerText2")]) or "[deactivateText]"
	
	-- general mode
	
	local mode = getStringFromUserAttribute(nodeId, "mode")
	if mode=="button" then
		self.mode=UPK_ActivatorTrigger.MODE_BUTTON
	elseif mode=="one-time" then
		self.mode=UPK_ActivatorTrigger.MODE_ONETIME
		self.onetimeused = false
	else
		self.mode=UPK_ActivatorTrigger.MODE_SWITCH
	end
	
	-- actions
	
	self:getActionUserAttributes('OnActivate',true,false)
	self:getActionUserAttributes('OnDeactivate',false,true)
	
	--
	
	self.activatorActivatable = UPK_ActivatorTriggerActivatable:new(self)
	self.activatorActivatableAdded=false

	self:addTrigger()

	self:printFn('UPK_ActivatorTrigger:new done')
	
	return self
end

function UPK_ActivatorTrigger:postLoad()
	self:printFn('UPK_ActivatorTrigger:postLoad()')
	UPK_ActivatorTrigger:superClass().postLoad(self)
	self:triggerUpdate(false,false)
end

function UPK_ActivatorTrigger:readStream(streamId, connection)
	self:printFn('UPK_ActivatorTrigger:readStream(',streamId,', ',connection,')')
	UPK_ActivatorTrigger:superClass().readStream(self, streamId, connection)
	if connection:getIsServer() then
		local isActive = streamReadBool(streamId)
		self:print('read from stream self.isActive = '..tostring(isActive))
		self:setIsActive(isActive,true)
	end
end;

function UPK_ActivatorTrigger:writeStream(streamId, connection)
	self:printFn('UPK_ActivatorTrigger:writeStream(',streamId,', ',connection,')')
	UPK_ActivatorTrigger:superClass().writeStream(self, streamId, connection)
	if not connection:getIsServer() then
		self:print('write to stream self.isActive = '..tostring(self.isActive))
		streamWriteBool(streamId,self.isActive)
	end
end;

function UPK_ActivatorTrigger:triggerUpdate(vehicle,isInTrigger)
	self:printFn('UPK_ActivatorTrigger:triggerUpdate(',vehicle,', ',isInTrigger,')')
	if self.isClient then
		self:printAll('self.entitiesInTrigger='..tostring(self.entitiesInTrigger))
		if self.entitiesInTrigger>0 and self:getShowInfo() then
			if not self.onetimeused and not self.activatorActivatableAdded then
				self:printAll('addActivatableObject')
				g_currentMission:addActivatableObject(self.activatorActivatable)
				self.activatorActivatableAdded=true
			end
		else
			if self.activatorActivatableAdded then
				self:printAll('removeActivatableObject')
				g_currentMission:removeActivatableObject(self.activatorActivatable)
				self.activatorActivatableAdded=false
			end
		end
	end
end

function UPK_ActivatorTrigger:setIsActive(isActive,alreadySent)
	self:printFn('UPK_ActivatorTrigger:setIsActive(',isActive,', ',alreadySent,')')
	if isActive~=nil and not self.onetimeused then
		self.isActive=isActive
		if self.isActive then
			self:operateAction('OnActivate')
		else
			self:operateAction('OnDeactivate')
		end
		
		if not alreadySent then
			UPK_ActivatorTriggerEvent.sendEvent(self,self.isActive, alreadySent)
		end
	end
end

function UPK_ActivatorTrigger:loadExtraNodes(xmlFile, key)
	self:printFn('UPK_ActivatorTrigger:loadExtraNodes(',xmlFile,', ',key,')')
	self.isActive=Utils.getNoNil(getXMLBool(xmlFile, key .. "#isActive"), false)
	self.onetimeused=getXMLBool(xmlFile, key .. "#onetimeused")
	return true
end;

function UPK_ActivatorTrigger:getSaveExtraNodes(nodeIdent)
	self:printFn('UPK_ActivatorTrigger:getSaveExtraNodes(',nodeIdent,')')
	local nodes=""
	if self.isActive then
		nodes=nodes.." isActive=\"true\""
	end
	if self.onetimeused then
		nodes=nodes.." onetimeused=\"true\""
	end
	return nodes
end;


UPK_ActivatorTriggerActivatable = {}
local UPK_ActivatorTriggerActivatable_mt = Class(UPK_ActivatorTriggerActivatable)

function UPK_ActivatorTriggerActivatable:new(upkmodule)
	printFn('UPK_ActivatorTriggerActivatable:new(',upkmodule,')')
	local self = {}
	setmetatable(self, UPK_ActivatorTriggerActivatable_mt)
	self.upkmodule = upkmodule or {}
	self.activateText = "unknown"
	return self
end;

function UPK_ActivatorTriggerActivatable:getIsActivatable()
	printAll('UPK_ActivatorTriggerActivatable:getIsActivatable()')
	if self.upkmodule.isEnabled then
		if self.upkmodule.onetimeused then
			return false
		end
		if self.upkmodule.mode==UPK_ActivatorTrigger.MODE_BUTTON then
			if self.upkmodule.hasAddOnActivate then
				for k,v in pairs(self.upkmodule.addOnActivate) do
					if self.upkmodule:getFillLevel(k)+v>self.upkmodule:getCapacity(k) then
						return false
					end
				end
			end
			if self.upkmodule.hasRemoveOnActivate then
				for k,v in pairs(self.upkmodule.removeOnActivate) do
					if self.upkmodule:getFillLevel(k)-v<0 then
						return false
					end
				end
			end
		else
			if self.upkmodule.isActive then
				if self.upkmodule.hasAddOnDeactivate then
					for k,v in pairs(self.upkmodule.addOnDeactivate) do
						if self.upkmodule:getFillLevel(k)+v>self.upkmodule:getCapacity(k) then
							return false
						end
					end
				end
				if self.upkmodule.hasRemoveOnDeactivate then
					for k,v in pairs(self.upkmodule.removeOnDeactivate) do
						if self.upkmodule:getFillLevel(k)-v<0 then
							return false
						end
					end
				end
			end
			if not self.upkmodule.isActive then
				if self.upkmodule.hasAddOnActivate then
					for k,v in pairs(self.upkmodule.addOnActivate) do
						if self.upkmodule:getFillLevel(k)+v>self.upkmodule:getCapacity(k) then
							return false
						end
					end
				end
				if self.upkmodule.hasRemoveOnActivate then
					for k,v in pairs(self.upkmodule.removeOnActivate) do
						if self.upkmodule:getFillLevel(k)-v<0 then
							return false
						end
					end
				end
			end
		end
		self:updateActivateText()
		return true
	end
	return false
end;

function UPK_ActivatorTriggerActivatable:onActivateObject()
	printFn('UPK_ActivatorTriggerActivatable:onActivateObject()')
	if self.upkmodule.isEnabled then
		if self.upkmodule.mode==UPK_ActivatorTrigger.MODE_BUTTON then
			self.upkmodule:setIsActive(true, false)
		elseif not self.onetimeused then
			self.upkmodule:setIsActive(not self.upkmodule.isActive, false)
			if self.upkmodule.mode==UPK_ActivatorTrigger.MODE_ONETIME then
				self.upkmodule.onetimeused = true
				g_currentMission:removeActivatableObject(self.upkmodule.activatorActivatable)
				return
			end
		end
		self:updateActivateText()
		g_currentMission:addActivatableObject(self)
	end
end;

UPK_ActivatorTriggerActivatable.drawActivate = emptyFunc

function UPK_ActivatorTriggerActivatable:updateActivateText()
	printAll('UPK_ActivatorTriggerActivatable:updateActivateText()')
	if not self.upkmodule.isActive or self.upkmodule.mode==UPK_ActivatorTrigger.MODE_BUTTON then
		self.activateText = self.upkmodule.activateText
	else
		self.activateText = self.upkmodule.deactivateText
	end
end;

UPK_ActivatorTriggerEvent = {}
UPK_ActivatorTriggerEvent_mt = Class(UPK_ActivatorTriggerEvent, Event);
InitEventClass(UPK_ActivatorTriggerEvent, "UPK_ActivatorTriggerEvent");

function UPK_ActivatorTriggerEvent:emptyNew()
	printFn('UPK_ActivatorTriggerEvent:emptyNew()')
    local self = Event:new(UPK_ActivatorTriggerEvent_mt)
    return self
end

function UPK_ActivatorTriggerEvent:new(upkmodule, isActive)
	printFn('UPK_ActivatorTriggerEvent:new(',upkmodule,', ',isActive,')')
	local self = UPK_ActivatorTriggerEvent:emptyNew()
	self.upkmodule = upkmodule
	self.isActive = isActive
	return self
end

function UPK_ActivatorTriggerEvent:writeStream(streamId, connection)
	printFn('UPK_ActivatorTriggerEvent:writeStream(',streamId,', ',connection,')')
	local syncObj = self.upkmodule.syncObj
	local syncObjId = networkGetObjectId(syncObj)
	printAll('syncObjId: ',syncObjId)
	streamWriteInt32(streamId, syncObjId)
	local syncId = self.upkmodule.syncId
	printAll('syncId: ',syncId)
	streamWriteInt32(streamId, syncId)
	printAll('isActive: ',self.isActive)
	streamWriteBool(streamId, self.isActive)
end

function UPK_ActivatorTriggerEvent:readStream(streamId, connection)
	printFn('UPK_ActivatorTriggerEvent:readStream(',streamId,', ',connection,')')
	local syncObjId = streamReadInt32(streamId)
	printAll('syncObjId: ',syncObjId)
	local syncObj = networkGetObject(syncObjId)
	local syncId = streamReadInt32(streamId)
	printAll('syncId: ',syncId)
	self.upkmodule=syncObj:getObjectToSync(syncId)
	printAll('upkmodule: ',self.upkmodule)
	self.isActive = streamReadBool(streamId)
	printAll('isActive: ',self.isActive)
	self:run(connection)
end;

function UPK_ActivatorTriggerEvent:run(connection)
	printFn('UPK_ActivatorTriggerEvent:run(',connection,')')
	if not connection:getIsServer() then -- if server: send after receiving
		g_server:broadcastEvent(self, false, connection)
	end
	printAll('running step a')
	if self.upkmodule ~= nil then
		printAll('running step b')
		self.upkmodule:setIsActive(self.isActive, true)
	end
end

function UPK_ActivatorTriggerEvent.sendEvent(upkmodule, isActive, alreadySent)
	printFn('UPK_ActivatorTriggerEvent.sendEvent('..tostring(upkmodule)..', '..tostring(isActive)..', '..tostring(alreadySent)..')')
	if not alreadySent then
		if g_server ~= nil then
			printAll('broadcasting isActive = '..tostring(isActive))
			g_server:broadcastEvent(UPK_ActivatorTriggerEvent:new(upkmodule, isActive))
		else
			printAll('sending to server isActive = '..tostring(isActive))
			g_client:getServerConnection():sendEvent(UPK_ActivatorTriggerEvent:new(upkmodule, isActive))
		end
	end
end