aboutsummaryrefslogtreecommitdiff
path: root/advtrains_luaautomation/interrupt.lua
blob: 525c3b4e157151ef0488394381d95e0e43a04a3e (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
-- interrupt.lua
-- implements interrupt queue

--to be saved: pos and evtdata
local iq={}
local queue={}
local timer=0
local run=false

function iq.load(data)
	local d=data or {}
	queue = d.queue or {}
	timer = d.timer or 0
end
function iq.save()
	return {queue = queue, timer=timer}
end

function iq.add(t, pos, evtdata)
	queue[#queue+1]={t=t+timer, p=pos, e=evtdata}
	run=true
end

function iq.mainloop(dtime)
	timer=timer + math.min(dtime, 0.2)
	for i=1,#queue do
		local qe=queue[i]
		if not qe then
			table.remove(queue, i)
			i=i-1
		elseif timer>qe.t then
			local pos, evtdata=queue[i].p, queue[i].e
			local node=advtrains.ndb.get_node(pos)
			local ndef=minetest.registered_nodes[node.name]
			if ndef and ndef.luaautomation and ndef.luaautomation.fire_event then
				ndef.luaautomation.fire_event(pos, evtdata)
			else
				atwarn("[atlatc][interrupt] Couldn't run event",evtdata.type,"on",pos,", something wrong with the node",node)
			end
			table.remove(queue, i)
			i=i-1
		end
	end
end



atlatc.interrupt=iq
unction(pos, _, name) N.swap_node(pos, {name = "advtrains_interlocking:" .. name}) end, } }) end local origin = vector.new(0, 0, 0) local dstpos = vector.new(0, 0, 1) world.layout { {origin, "advtrains_interlocking:danger"}, {dstpos, "advtrains_interlocking:proceed"}, } describe("signal group registration", function() it("should work", function() A.register_group(groupdef) assert(A.get_group_definition("foo")) end) it("should only be allowed once for the same group", function() assert.has.errors(function() A.register_group(type2def) end) end) it("should handle nonexistant groups", function() assert.is_nil(A.get_group_definition("something_else")) end) it("should reject invalid definitions", function() assert.has.errors(function() A.register_group({}) end) assert.has.errors(function() A.register_group({name="",label={}}) end) assert.has.errors(function() A.register_group({name="",aspects={}}) end) end) end) describe("signal aspect", function() it("should handle empty fields properly", function() assert.equal(A{main = 0}, A{group="foo", name="danger"}:to_group()) end) it("should be converted properly", function() assert.equal(A{main = 0}, A{group="foo", name="danger"}) assert.equal(A{}, A{group="foo", name="caution"}) assert.equal(A{main = -1}, A{group="foo", name="proceed"}) end) end) describe("signals in groups", function() it("should support distant signaling", function() assert.equal("caution", A():adjust_distant(A{group="foo",name="danger"}).name) assert.equal("proceed", A():adjust_distant(A{group="foo",name="caution"}).name) assert.equal("proceed", A():adjust_distant(A{group="foo",name="proceed"}).name) assert.equal("danger", A{group="foo",name="danger"}:adjust_distant{}.name) end) end)