celevator-cd2025/digilines.lua

local function handledigilines(pos,node,channel,msg)
	local multi = node.name == "celevator:digilines_multi_io"
	if msg == "GET" then msg = {command = "GET"} end
	if type(msg) ~= "table" or type(msg.command) ~= "string" then return end
	local meta = minetest.get_meta(pos)
	local setchannel = meta:get_string("channel")
	if setchannel ~= channel then return end
	if multi and type(msg.carid) ~= "number" then return end
	local carid = multi and msg.carid or meta:get_int("carid")
	if carid == 0 then return end
	local dmode = meta:get_int("dispatcher") == 1
	local carinfo = minetest.deserialize(celevator.storage:get_string(string.format("car%d",carid))) or {}
	if multi then
		dmode = carinfo.dispatcherpos
	end
	msg.command = string.lower(msg.command)
	if dmode then
		if not carinfo.dispatcherpos then return end
		if not celevator.dispatcher.isdispatcher(carinfo.dispatcherpos) then return end
		if msg.command == "get" then
			local mem = minetest.deserialize(minetest.get_meta(carinfo.dispatcherpos):get_string("mem"))
			if not mem then return end
			local ret = {
				upcalls = {},
				downcalls = {},
				fireserviceled = mem.fs1led,
			}
			for floor in pairs(mem.upcalls) do
				ret.upcalls[floor] = {
					eta = mem.upeta[floor]
				}
				if mem.assignedup[floor] then
					for k,v in ipairs(mem.params.carids) do
						if v == mem.assignedup[floor] then
							ret.upcalls[floor].assignedcar = k
						end
					end
				end
			end
			for floor in pairs(mem.dncalls) do
				ret.downcalls[floor] = {
					eta = mem.dneta[floor]
				}
				if mem.assigneddn[floor] then
					for k,v in ipairs(mem.params.carids) do
						if v == mem.assigneddn[floor] then
							ret.downcalls[floor].assignedcar = k
						end
					end
				end
			end
			digilines.receptor_send(pos,digilines.rules.default,channel,ret)
		elseif msg.command == "upcall" and type(msg.floor) == "number" then
			celevator.dispatcher.run(carinfo.dispatcherpos,{
				type = "remotemsg",
				channel = "upcall",
				msg = msg.floor,
			})
		elseif msg.command == "downcall" and type(msg.floor) == "number" then
			celevator.dispatcher.run(carinfo.dispatcherpos,{
				type = "remotemsg",
				channel = "dncall",
				msg = msg.floor,
			})
		end
	else
		if not carinfo.controllerpos then return end
		if not celevator.controller.iscontroller(carinfo.controllerpos) then return end
		if msg.command == "get" then
			local mem = minetest.deserialize(minetest.get_meta(carinfo.controllerpos):get_string("mem"))
			if not mem then return end
			local ret = {
				carstate = mem.carstate,
				doorstate = mem.doorstate,
				carcalls = mem.carcalls,
				upcalls = mem.upcalls,
				swingupcalls = mem.swingupcalls,
				groupupcalls = mem.groupupcalls,
				downcalls = mem.dncalls,
				swingdowncalls = mem.swingdncalls,
				groupdowncalls = mem.groupdncalls,
				fireserviceled = mem.fs1led,
				switches = {
					stop = mem.controllerstopsw,
					machineroominspection = mem.controllerinspectsw,
					cartopinspection = mem.cartopinspectsw,
					capture = mem.capturesw,
					test = mem.testsw,
					fireservice1 = mem.fs1switch,
					fireservice2 = mem.fs2sw,
					indpedendent = mem.indsw,
					light = mem.lightsw,
					fan = mem.fansw,
				},
				parameters = mem.params,
				drivestatus = mem.drive.status,
				direction = mem.direction,
			}
			digilines.receptor_send(pos,digilines.rules.default,channel,ret)
		elseif msg.command == "carcall" and type(msg.floor) == "number" then
			celevator.controller.run(carinfo.controllerpos,{
				type = "remotemsg",
				channel = "carcall",
				msg = msg.floor,
			})
		elseif msg.command == "upcall" and type(msg.floor) == "number" then
			celevator.controller.run(carinfo.controllerpos,{
				type = "remotemsg",
				channel = "upcall",
				msg = msg.floor,
			})
		elseif msg.command == "downcall" and type(msg.floor) == "number" then
			celevator.controller.run(carinfo.controllerpos,{
				type = "remotemsg",
				channel = "dncall",
				msg = msg.floor,
			})
		elseif msg.command == "swingupcall" and type(msg.floor) == "number" then
			celevator.controller.run(carinfo.controllerpos,{
				type = "remotemsg",
				channel = "swingupcall",
				msg = msg.floor,
			})
		elseif msg.command == "swingdowncall" and type(msg.floor) == "number" then
			celevator.controller.run(carinfo.controllerpos,{
				type = "remotemsg",
				channel = "swingdncall",
				msg = msg.floor,
			})
		elseif msg.command == "security" and type(msg.floor) == "number" then
			if msg.mode == "deny" or msg.mode == "auth" or not msg.mode then
				celevator.controller.run(carinfo.controllerpos,{
					type = "remotemsg",
					channel = "security",
					msg = {
						floor = msg.floor,
						mode = msg.mode,
					},
				})
			end
		elseif msg.command == "fs1off" then
			celevator.controller.run(carinfo.controllerpos,{
				type = "fs1switch",
				state = false,
			})
		elseif msg.command == "fs1on" then
			celevator.controller.run(carinfo.controllerpos,{
				type = "fs1switch",
				state = true,
			})
		elseif msg.command == "fs1alt" then
			celevator.controller.run(carinfo.controllerpos,{
				type = "fs1switch",
				state = true,
				mode = "alternate",
			})
		elseif msg.command == "mrsmoke" then
			celevator.controller.run(carinfo.controllerpos,{
				type = "mrsmoke",
			})
		end
	end
end

minetest.register_node("celevator:digilines_io",{
	description = "Elevator Digilines Input/Output",
	tiles = {
		"celevator_digilinesio_top.png",
		"celevator_cabinet_sides.png",
	},
	groups = {
		dig_immediate = 2,
	},
	paramtype = "light",
	drawtype = "nodebox",
	node_box = {
		type = "fixed",
		fixed = {
			{-0.5,-0.5,-0.5,0.5,-0.47,0.5},
			{-0.438,-0.47,-0.438,0.438,-0.42,0.438},
		},
	},
	digilines = {
		receptor = {},
		effector = {
			action = handledigilines,
		},
	},
	after_place_node = function(pos)
		local meta = minetest.get_meta(pos)
		local fs = "formspec_version[7]size[8,4.5]"
		fs = fs.."field[0.5,0.5;3,1;channel;Channel;${channel}]"
		fs = fs.."field[4.5,0.5;3,1;carid;Car ID;${carid}]"
		fs = fs.."button_exit[2.5,2;3,1;save;Save]"
		meta:set_string("formspec",fs)
	end,
	on_receive_fields = function(pos,_,fields,player)
		local meta = minetest.get_meta(pos)
		if not fields.save then return end
		local name = player:get_player_name()
		if minetest.is_protected(pos,name) and not minetest.check_player_privs(name,{protection_bypass=true}) then
			if player:is_player() then
				minetest.record_protection_violation(pos,name)
			end
			return
		end
		if not tonumber(fields.carid) then return end
		meta:set_int("carid",fields.carid)
		local carid = tonumber(fields.carid)
		local carinfo = minetest.deserialize(celevator.storage:get_string(string.format("car%d",carid))) or {}
		if not (carinfo.controllerpos or carinfo.dispatcherpos) then return end
		local dmode = false
		if carinfo.dispatcherpos then
			dmode = true
			if not celevator.dispatcher.isdispatcher(carinfo.dispatcherpos) then return end
		else
			if not celevator.controller.iscontroller(carinfo.controllerpos) then return end
		end
		if dmode then
			if minetest.is_protected(carinfo.dispatcherpos,name) and not minetest.check_player_privs(name,{protection_bypass=true}) then
				if player:is_player() then
					minetest.chat_send_player(name,"Can't connect to a dispatcher you don't have access to.")
					minetest.record_protection_violation(carinfo.dispatcherpos,name)
				end
				return
			end
		else
			if minetest.is_protected(carinfo.controllerpos,name) and not minetest.check_player_privs(name,{protection_bypass=true}) then
				if player:is_player() then
					minetest.chat_send_player(name,"Can't connect to a controller you don't have access to.")
					minetest.record_protection_violation(carinfo.controllerpos,name)
				end
				return
			end
		end
		meta:set_int("dispatcher",dmode and 1 or 0)
		meta:set_string("channel",fields.channel)
		local infotext = "Car: "..carid
		meta:set_string("infotext",infotext)
	end,
})

minetest.register_node("celevator:digilines_multi_io",{
	description = "Elevator Digilines Multi-Car Input/Output",
	tiles = {
		"celevator_digilinesio_multi_top.png",
		"celevator_cabinet_sides.png",
	},
	groups = {
		dig_immediate = 2,
		not_in_creative_inventory = 1,
	},
	paramtype = "light",
	drawtype = "nodebox",
	node_box = {
		type = "fixed",
		fixed = {
			{-0.5,-0.5,-0.5,0.5,-0.47,0.5},
			{-0.438,-0.47,-0.438,0.438,-0.42,0.438},
		},
	},
	digilines = {
		receptor = {},
		effector = {
			action = handledigilines,
		},
	},
	after_place_node = function(pos,player)
		local name = player:get_player_name()
		if not (minetest.check_player_privs(name,{protection_bypass=true}) or minetest.check_player_privs(name,{server=true})) then
			if player:is_player() then
				minetest.chat_send_player(name,"You need either the 'protection_bypass' or 'server' privilege to use this.")
				minetest.record_protection_violation(pos,name)
			end
			minetest.remove_node(pos)
			return
		end
		local meta = minetest.get_meta(pos)
		local fs = "formspec_version[7]size[8,4.5]"
		fs = fs.."field[0.5,0.5;7,1;channel;Channel;${channel}]"
		fs = fs.."button_exit[2.5,2;3,1;save;Save]"
		meta:set_string("formspec",fs)
	end,
	on_receive_fields = function(pos,_,fields,player)
		local meta = minetest.get_meta(pos)
		if not fields.save then return end
		local name = player:get_player_name()
		if not (minetest.check_player_privs(name,{protection_bypass=true}) or minetest.check_player_privs(name,{server=true})) then
			if player:is_player() then
				minetest.chat_send_player(name,"You need either the 'protection_bypass' or 'server' privilege to use this.")
				minetest.record_protection_violation(pos,name)
			end
			return
		end
		meta:set_string("channel",fields.channel)
	end,
})