mirror of
https://github.com/clusterio/clusterio.git
synced 2026-11-11 23:04:52 +09:00
bbassieandClaude Opus 5.5
0a6f614074
send_udp and get_host_udp_port indexed script data that is only created on the first tick after patching, so calling them from on_init stopped the server. They now return nothing until then. Received packets were only polled once the host port was known, which needs script commands. Poll whenever recv_udp exists instead, it does nothing when the server runs without --enable-lua-udp. Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
58 lines
1.7 KiB
Lua
58 lines
1.7 KiB
Lua
-- Important: Keep this API in sync with mod/api.lua
|
|
local compat = require("modules/clusterio/compat")
|
|
local api = {}
|
|
|
|
clusterio_patch_number = clusterio_patch_number or 0 --- @type number
|
|
|
|
api.events = {
|
|
on_instance_updated = script.generate_event_name(),
|
|
on_server_startup = script.generate_event_name(),
|
|
}
|
|
|
|
function api.get_instance_name()
|
|
return compat.script_data.clusterio.instance_name
|
|
end
|
|
|
|
function api.get_instance_id()
|
|
return compat.script_data.clusterio.instance_id
|
|
end
|
|
|
|
local function escape_channel(channel)
|
|
-- Escape bad characters. The question mark is used for separating the
|
|
-- channel name from the payload.
|
|
return channel:gsub("([\x00-\x1f?\\])", function(match)
|
|
return "\\x" .. string.format("%02x", match:byte())
|
|
end)
|
|
end
|
|
|
|
function api.send_json(channel, data)
|
|
channel = escape_channel(channel)
|
|
data = compat.table_to_json(data)
|
|
|
|
-- If there's more than about 4kB of data users running with the Windows
|
|
-- console open will start to experience stuttering, otherwise we could
|
|
-- output about 1 MB of data at a time through stdout.
|
|
if #data < 4000 then
|
|
print("\f$ipc:" .. channel .. "?j" .. data)
|
|
else
|
|
local script_data = compat.script_data
|
|
script_data.clusterio_file_no = (script_data.clusterio_file_no or 0) + 1
|
|
local file_name = "clst_" .. script_data.clusterio_file_no .. ".json"
|
|
compat.write_file(file_name, data, false, 0)
|
|
print("\f$ipc:" .. channel .. "?f" .. file_name)
|
|
end
|
|
end
|
|
|
|
function api.send_udp(channel, data)
|
|
local clusterio = compat.script_data.clusterio
|
|
local port = clusterio and clusterio.host_udp_port
|
|
if not port then
|
|
return -- Lua UDP is not enabled for this instance
|
|
end
|
|
|
|
helpers.send_udp(port, escape_channel(channel) .. "?" .. data, 0)
|
|
end
|
|
|
|
|
|
return api
|