2021-11-06 18:30:57 +01:00
|
|
|
local dir_delim = ...
|
2021-06-11 20:47:29 +02:00
|
|
|
-- Localize globals
|
|
|
|
local io, minetest, modlib, string = io, minetest, modlib, string
|
|
|
|
|
2021-06-17 19:45:08 +02:00
|
|
|
-- Set environment
|
|
|
|
local _ENV = {}
|
|
|
|
setfenv(1, _ENV)
|
|
|
|
|
2021-11-06 18:30:57 +01:00
|
|
|
_ENV.dir_delim = dir_delim
|
|
|
|
|
2021-11-04 17:03:41 +01:00
|
|
|
function get_name(filepath)
|
2021-12-30 18:49:35 +01:00
|
|
|
return filepath:match("([^%" .. dir_delim .. "]+)$") or filepath
|
2021-11-04 17:03:41 +01:00
|
|
|
end
|
2021-11-06 18:30:57 +01:00
|
|
|
|
2021-11-06 14:28:27 +01:00
|
|
|
function split_extension(filename)
|
|
|
|
return filename:match"^(.*)%.(.*)$"
|
2021-09-01 17:07:26 +02:00
|
|
|
end
|
2021-11-06 14:28:27 +01:00
|
|
|
--! deprecated
|
|
|
|
get_extension = split_extension
|
2021-09-01 17:07:26 +02:00
|
|
|
|
2021-11-06 18:32:58 +01:00
|
|
|
function split_path(filepath)
|
|
|
|
return modlib.text.split(filepath, dir_delim)
|
|
|
|
end
|
|
|
|
|
|
|
|
-- concat_path is set by init.lua to avoid code duplication
|
|
|
|
|
2020-02-09 01:39:54 +01:00
|
|
|
function read(filename)
|
2022-01-08 13:32:12 +01:00
|
|
|
local file, err = io.open(filename, "r")
|
|
|
|
if file == nil then return nil, err end
|
2020-12-22 11:32:35 +01:00
|
|
|
local content = file:read"*a"
|
|
|
|
file:close()
|
|
|
|
return content
|
2020-02-09 01:39:54 +01:00
|
|
|
end
|
2020-12-22 11:32:35 +01:00
|
|
|
|
2021-03-30 22:26:30 +02:00
|
|
|
function write_unsafe(filename, new_content)
|
2022-01-08 13:32:12 +01:00
|
|
|
local file, err = io.open(filename, "w")
|
|
|
|
if file == nil then return false, err end
|
2020-12-22 11:32:35 +01:00
|
|
|
file:write(new_content)
|
|
|
|
file:close()
|
|
|
|
return true
|
2020-02-09 01:39:54 +01:00
|
|
|
end
|
2020-12-22 11:32:35 +01:00
|
|
|
|
2021-03-30 22:26:30 +02:00
|
|
|
write = minetest and minetest.safe_file_write or write_unsafe
|
|
|
|
|
2022-01-08 13:32:12 +01:00
|
|
|
function write_binary_unsafe(filename, new_content)
|
|
|
|
local file, err = io.open(filename, "wb")
|
|
|
|
if file == nil then return false, err end
|
2021-12-28 00:04:58 +01:00
|
|
|
file:write(new_content)
|
|
|
|
file:close()
|
|
|
|
return true
|
|
|
|
end
|
|
|
|
|
2022-01-08 13:30:54 +01:00
|
|
|
write_binary = minetest and minetest.safe_file_write or write_binary_unsafe
|
|
|
|
|
2020-12-22 11:36:58 +01:00
|
|
|
function ensure_content(filename, ensured_content)
|
2021-03-27 20:10:49 +01:00
|
|
|
local content = read(filename)
|
|
|
|
if content ~= ensured_content then
|
|
|
|
return write(filename, ensured_content)
|
|
|
|
end
|
|
|
|
return true
|
2020-12-22 11:36:58 +01:00
|
|
|
end
|
|
|
|
|
2020-02-09 01:39:54 +01:00
|
|
|
function append(filename, new_content)
|
2022-01-08 13:32:12 +01:00
|
|
|
local file, err = io.open(filename, "a")
|
|
|
|
if file == nil then return false, err end
|
2020-12-22 11:32:35 +01:00
|
|
|
file:write(new_content)
|
|
|
|
file:close()
|
|
|
|
return true
|
2020-02-09 01:39:54 +01:00
|
|
|
end
|
2020-12-22 11:32:35 +01:00
|
|
|
|
2020-02-09 01:39:54 +01:00
|
|
|
function exists(filename)
|
2022-01-08 13:32:12 +01:00
|
|
|
local file, err = io.open(filename, "r")
|
|
|
|
if file == nil then return false, err end
|
2020-12-22 11:32:35 +01:00
|
|
|
file:close()
|
|
|
|
return true
|
2020-02-09 01:39:54 +01:00
|
|
|
end
|
2020-12-22 11:32:35 +01:00
|
|
|
|
2020-02-09 01:39:54 +01:00
|
|
|
function create_if_not_exists(filename, content)
|
2020-12-22 11:32:35 +01:00
|
|
|
if not exists(filename) then
|
2022-01-08 13:32:12 +01:00
|
|
|
return write(filename, content or "")
|
2020-12-22 11:32:35 +01:00
|
|
|
end
|
|
|
|
return false
|
2020-02-09 01:39:54 +01:00
|
|
|
end
|
|
|
|
|
2020-12-22 11:32:35 +01:00
|
|
|
function create_if_not_exists_from_file(filename, src_filename) return create_if_not_exists(filename, read(src_filename)) end
|
|
|
|
|
2021-03-04 12:18:26 +01:00
|
|
|
if not minetest then return end
|
|
|
|
|
2020-02-09 01:39:54 +01:00
|
|
|
-- Process Bridge Helpers
|
2020-12-22 11:32:35 +01:00
|
|
|
process_bridges = {}
|
2020-02-09 01:39:54 +01:00
|
|
|
|
|
|
|
function process_bridge_build(name, input, output, logs)
|
2020-12-22 11:32:35 +01:00
|
|
|
if not input or not output or not logs then
|
|
|
|
minetest.mkdir(minetest.get_worldpath() .. "/bridges/" .. name)
|
|
|
|
end
|
|
|
|
input = input or minetest.get_worldpath() .. "/bridges/" .. name .. "/input.txt"
|
|
|
|
output = output or minetest.get_worldpath() .. "/bridges/" .. name .. "/output.txt"
|
|
|
|
logs = logs or minetest.get_worldpath() .. "/bridges/" .. name .. "/logs.txt"
|
|
|
|
-- Clear input
|
|
|
|
write(input, "")
|
|
|
|
-- Clear output
|
|
|
|
write(output, "")
|
|
|
|
-- Create logs if not exists
|
|
|
|
create_if_not_exists(logs, "")
|
|
|
|
process_bridges[name] = {
|
|
|
|
input = input,
|
|
|
|
output = output,
|
|
|
|
logs = logs,
|
|
|
|
output_file = io.open(output, "a")
|
|
|
|
}
|
2020-02-09 01:39:54 +01:00
|
|
|
end
|
2020-12-22 11:32:35 +01:00
|
|
|
|
2020-02-09 01:39:54 +01:00
|
|
|
function process_bridge_listen(name, line_consumer, step)
|
2020-12-22 11:32:35 +01:00
|
|
|
local bridge = process_bridges[name]
|
2021-03-04 12:18:26 +01:00
|
|
|
modlib.minetest.register_globalstep(step or 0.1, function()
|
2020-12-22 11:32:35 +01:00
|
|
|
local content = io.open(bridge.input, "r")
|
|
|
|
local line = content:read()
|
|
|
|
while line do
|
|
|
|
line_consumer(line)
|
|
|
|
line = content:read()
|
|
|
|
end
|
|
|
|
write(bridge.input, "")
|
|
|
|
end)
|
2020-02-09 01:39:54 +01:00
|
|
|
end
|
2020-12-22 11:32:35 +01:00
|
|
|
|
2020-02-09 01:39:54 +01:00
|
|
|
function process_bridge_serve(name, step)
|
2020-12-22 11:32:35 +01:00
|
|
|
local bridge = process_bridges[name]
|
2021-03-04 12:18:26 +01:00
|
|
|
modlib.minetest.register_globalstep(step or 0.1, function()
|
2020-12-22 11:32:35 +01:00
|
|
|
bridge.output_file:close()
|
|
|
|
process_bridges[name].output_file = io.open(bridge.output, "a")
|
|
|
|
end)
|
2020-02-09 01:39:54 +01:00
|
|
|
end
|
2020-12-22 11:32:35 +01:00
|
|
|
|
2020-02-09 01:39:54 +01:00
|
|
|
function process_bridge_write(name, message)
|
2020-12-22 11:32:35 +01:00
|
|
|
local bridge = process_bridges[name]
|
|
|
|
bridge.output_file:write(message .. "\n")
|
2020-02-09 01:39:54 +01:00
|
|
|
end
|
2020-12-22 11:32:35 +01:00
|
|
|
|
2020-02-09 01:39:54 +01:00
|
|
|
function process_bridge_start(name, command, os_execute)
|
2020-12-22 11:32:35 +01:00
|
|
|
local bridge = process_bridges[name]
|
|
|
|
os_execute(string.format(command, bridge.output, bridge.input, bridge.logs))
|
2021-06-17 19:45:08 +02:00
|
|
|
end
|
|
|
|
|
|
|
|
-- Export environment
|
|
|
|
return _ENV
|