SubMiner/scripts/test-plugin-process-start-retries.lua

local function assert_true(condition, message)
	if condition then
		return
	end
	error(message)
end

local function has_flag(call, flag)
	local args = call.args or {}
	for _, arg in ipairs(args) do
		if arg == flag then
			return true
		end
	end
	return false
end

local function has_timeout(timeouts, target)
	for _, value in ipairs(timeouts) do
		if math.abs(value - target) < 0.0001 then
			return true
		end
	end
	return false
end

local recorded = {
	async_calls = {},
	timeouts = {},
	logs = {},
}

local start_attempts = 0

local mp = {}

function mp.command_native_async(command, callback)
	recorded.async_calls[#recorded.async_calls + 1] = command

	local success = true
	local result = { status = 0, stdout = "", stderr = "" }
	local err = nil

	if has_flag(command, "--start") then
		start_attempts = start_attempts + 1
		if start_attempts == 1 then
			success = false
			result = { status = 1, stdout = "", stderr = "startup-not-ready" }
			err = "startup-not-ready"
		end
	end

	if callback then
		callback(success, result, err)
	end
end

function mp.add_timeout(seconds, callback)
	recorded.timeouts[#recorded.timeouts + 1] = seconds
	if callback then
		callback()
	end
end

local process_module = dofile("plugin/subminer/process.lua")
local process = process_module.create({
	mp = mp,
	opts = {
		backend = "x11",
		socket_path = "/tmp/subminer.sock",
		log_level = "debug",
		texthooker_enabled = true,
		texthooker_port = 5174,
		auto_start_visible_overlay = false,
	},
	state = {
		binary_path = "/tmp/subminer",
		overlay_running = false,
		texthooker_running = false,
	},
	binary = {
		ensure_binary_available = function()
			return true
		end,
	},
	environment = {
		detect_backend = function()
			return "x11"
		end,
	},
	options_helper = {
		coerce_bool = function(value, default_value)
			if value == true or value == "yes" or value == "true" then
				return true
			end
			if value == false or value == "no" or value == "false" then
				return false
			end
			return default_value
		end,
	},
	log = {
		subminer_log = function(_level, _scope, line)
			recorded.logs[#recorded.logs + 1] = line
		end,
		show_osd = function(_) end,
		normalize_log_level = function(value)
			return value or "info"
		end,
	},
})

process.start_overlay()

assert_true(start_attempts == 2, "expected start overlay command retry after readiness failure")
assert_true(not has_timeout(recorded.timeouts, 0.35), "fixed texthooker wait (0.35s) should be removed")
assert_true(not has_timeout(recorded.timeouts, 0.6), "fixed startup visibility delay (0.6s) should be removed")

local retry_timeout_seen = false
for _, timeout_seconds in ipairs(recorded.timeouts) do
	if timeout_seconds > 0 and timeout_seconds <= 0.25 then
		retry_timeout_seen = true
		break
	end
end
assert_true(retry_timeout_seen, "expected shorter bounded retry timeout")

print("plugin process retry regression tests: OK")