aboutsummaryrefslogtreecommitdiff
path: root/advtrains/atc.lua
blob: f070b20636590ff197d346a387983b777bad6ca7 (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
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
--atc.lua
--registers and controls the ATC system

local atc={}
-- ATC persistence table
atc.controllers = {}
--contents: {command="...", arrowconn=0-15 where arrow points}

advtrains.fpath_atc=minetest.get_worldpath().."/advtrains_atc"
local file, err = io.open(advtrains.fpath_atc, "r")
if not file then
	local er=err or "Unknown Error"
	print("[advtrains]Failed loading advtrains atc save file "..er)
else
	local tbl = minetest.deserialize(file:read("*a"))
	if type(tbl) == "table" then
		atc.controllers=tbl.controllers
	end
	file:close()
end
function atc.save()
	--leave space for more save data.
	local datastr = minetest.serialize({controllers = atc.controllers})
	if not datastr then
		minetest.log("error", "[advtrains] Failed to serialize trackdb data!")
		return
	end
	local file, err = io.open(advtrains.fpath_atc, "w")
	if err then
		return err
	end
	file:write(datastr)
	file:close()
end

--call from advtrains.detector subprogram

function atc.trigger_controller_train_enter(pos, train_id)
	atc.send_command(pos)
end

--general

function atc.send_command(pos)
	local pts=minetest.pos_to_string(pos)
	if atc.controllers[pts] then
		print("Called send_command at "..pts)
		local train_id = advtrains.detector.on_node[pts]
		if train_id then
			if advtrains.trains[train_id] then
				print("send_command inside if: "..sid(train_id))
				atc.train_reset_command(train_id)
				local arrowconn=atc.controllers[pts].arrowconn
				local train=advtrains.trains[train_id]
				for index, ppos in pairs(train.path) do
					if vector.equals(advtrains.round_vector_floor_y(ppos), pos) then
						advtrains.trains[train_id].atc_arrow =
								vector.equals(
										advtrains.dirCoordSet(pos, arrowconn),
										advtrains.round_vector_floor_y(train.path[index+train.movedir])
								)
						advtrains.trains[train_id].atc_command=atc.controllers[pts].command
						print("Sending ATC Command: "..atc.controllers[pts].command)
					end
				end
			end
		end
	end
	return false
end

function atc.train_reset_command(train_id)
	advtrains.trains[train_id].atc_command=nil
	advtrains.trains[train_id].atc_delay=0
	advtrains.trains[train_id].atc_brake_target=nil
	advtrains.trains[train_id].atc_wait_finish=nil
	advtrains.trains[train_id].atc_arrow=nil
end

--nodes
local idxtrans={static=1, mesecon=2, digiline=3}
local apn_func=function(pos)
	advtrains.reset_trackdb_position(pos)
	local meta=minetest.get_meta(pos)
	if meta then
		meta:set_string("infotext", "ATC controller, unconfigured.")
		meta:set_string("formspec", atc.get_atc_controller_formspec(pos, meta))
	end
end

advtrains.register_tracks("default", {
	nodename_prefix="advtrains:dtrack_atc",
	texture_prefix="advtrains_dtrack_atc",
	models_prefix="advtrains_dtrack_detector",
	models_suffix=".b3d",
	shared_texture="advtrains_dtrack_rail_atc.png",
	description="ATC controller",
	formats={},
	get_additional_definiton = function(def, preset, suffix, rotation)
		return {
			after_place_node=apn_func,
			on_place_rail=apn_func,
			after_dig_node=function(pos)
				advtrains.invalidate_all_paths()
				advtrains.reset_trackdb_position(pos)
				local pts=minetest.pos_to_string(pos)
				atc.controllers[pts]=nil
			end,
			on_receive_fields = function(pos, formname, fields, player)
				if minetest.is_protected(pos, player:get_player_name()) then
					minetest.chat_send_player(player:get_player_name(), "This position is protected!")
					return
				end
				local meta=minetest.get_meta(pos)
				if meta then
					if not fields.save then 
						--maybe only the dropdown changed
						if fields.mode then
							meta:set_string("mode", idxtrans[fields.mode])
							meta:set_string("infotext", "ATC controller, mode "..fields.mode.."\n"..( fields.mode=="digiline" and "Channel: "..meta:get_string("channel") or "Command: "..meta:get_string("command") ) )
							meta:set_string("formspec", atc.get_atc_controller_formspec(pos, meta))
						end
						return
					end
					meta:set_string("mode", idxtrans[fields.mode])
					meta:set_string("command", fields.command)
					meta:set_string("command_on", fields.command_on)
					meta:set_string("channel", fields.channel)
					meta:set_string("infotext", "ATC controller, mode "..fields.mode.."\n"..( fields.mode=="digiline" and "Channel: "..meta:get_string("channel") or "Command: "..meta:get_string("command") ) )
					meta:set_string("formspec", atc.get_atc_controller_formspec(pos, meta))
					
					local pts=minetest.pos_to_string(pos)
					local _, conn1=advtrains.get_rail_info_at(pos, advtrains.all_tracktypes)
					atc.controllers[pts]={command=fields.command, arrowconn=conn1}
					atc.send_command(pos)
				end
			end,
		}
	end
}, advtrains.trackpresets.t_30deg_straightonly)


function atc.get_atc_controller_formspec(pos, meta)
	local mode=tonumber(meta:get_string("mode")) or 1
	local command=meta:get_string("command")
	local command_on=meta:get_string("command_on")
	local channel=meta:get_string("channel")
	local formspec="size[8,6]"..
		"dropdown[0,0;3;mode;static,mesecon,digiline;"..mode.."]"
	if mode<3 then
		formspec=formspec.."field[0.5,1.5;7,1;command;Command;"..minetest.formspec_escape(command).."]"
		if tonumber(mode)==2 then
			formspec=formspec.."field[0.5,3;7,1;command_on;Command (on);"..minetest.formspec_escape(command_on).."]"
		end
	else
		formspec=formspec.."field[0.5,1.5;7,1;channel;Digiline channel;"..minetest.formspec_escape(channel).."]"
	end
	return formspec.."button_exit[0.5,4.5;7,1;save;Save]"
end

--from trainlogic.lua train step
local matchptn={
	["SM"]=function(id, train)
		train.tarvelocity=train.max_speed
		return 2
	end,
	["S([0-9]+)"]=function(id, train, match)
		train.tarvelocity=tonumber(match)
		return #match+1
	end,
	["B([0-9]+)"]=function(id, train, match)
		if train.velocity>tonumber(match) then
			train.atc_brake_target=tonumber(match)
			if train.tarvelocity>train.atc_brake_target then
				train.tarvelocity=train.atc_brake_target
			end
		end
		return #match+1
	end,
	["W"]=function(id, train)
		train.atc_wait_finish=true
		return 1
	end,
	["D([0-9]+)"]=function(id, train, match)
		train.atc_delay=tonumber(match)
		return #match+1
	end,
	["R"]=function(id, train)
		if train.velocity<=0 then
			train.movedir=train.movedir*-1
			train.atc_arrow = not train.atc_arrow
		else
			print("ATC Reverse command warning: didn't reverse train!")
		end
		return 1
	end,
}

function atc.execute_atc_command(id, train)
	--strip whitespaces
	local command=string.match(train.atc_command, "^%s*(.*)$")
	
	
	if string.match(command, "^%s*$") then
		train.atc_command=nil
		return
	end
	--conditional statement?
	local is_cond, cond_applies
	local cond, rest=string.match(command, "^I([%+%-])(.+)$")
	if cond then
		is_cond=true
		if cond=="+" then
			cond_applies=train.atc_arrow
		end
		if cond=="-" then
			cond_applies=not train.atc_arrow
		end
	else 
		cond, compare, rest=string.match(command, "^I([<>]=?)([0-9]+)(.+)$")
		if cond and compare then
			is_cond=true
			if cond=="<" then
				cond_applies=train.velocity<tonumber(compare)
			end
			if cond==">" then
				cond_applies=train.velocity>tonumber(compare)
			end
			if cond=="<=" then
				cond_applies=train.velocity<=tonumber(compare)
			end
			if cond==">=" then
				cond_applies=train.velocity>=tonumber(compare)
			end
		end
	end	
	if is_cond then
		print("Evaluating if statement: "..command)
		print("Cond: "..(cond or "nil"))
		print("Applies: "..(cond_applies and "true" or "false"))
		print("Rest: "..rest)
		--find end of conditional statement
		local nest, pos, elsepos=0, 1
		while nest>=0 do
			if pos>#rest then
				print("ATC command syntax error: I statement not closed: "..command)
				atc.train_reset_command(id)
				return
			end
			local char=string.sub(rest, pos, pos)
			if char=="I" then
				nest=nest+1
			end
			if char==";" then
				nest=nest-1
			end
			if nest==0 and char=="E" then
				elsepos=pos+0
			end
			pos=pos+1
		end
		if not elsepos then elsepos=pos-1 end
		if cond_applies then
			command=string.sub(rest, 1, elsepos-1)..string.sub(rest, pos)
		else
			command=string.sub(rest, elsepos+1, pos-2)..string.sub(rest, pos)
		end
		print("Result: "..command)
		train.atc_command=command
		atc.execute_atc_command(id, train)
		return
	else
		for pattern, func in pairs(matchptn) do
			local match=string.match(command, "^"..pattern)
			if match then
				local patlen=func(id, train, match)
				
				print("Executing: "..string.sub(command, 1, patlen))
				
				train.atc_command=string.sub(command, patlen+1)
				if train.atc_delay<=0 and not train.atc_wait_finish then
					--continue (recursive, cmds shouldn't get too long, and it's a end-recursion.)
					atc.execute_atc_command(id, train)
				end
				return
			end
		end
	end
	print("ATC command parse error: "..command)
	atc.train_reset_command(id)
end

--move table to desired place
advtrains.atc=atc