mirror of
https://github.com/ksyasuda/SubMiner.git
synced 2026-03-20 03:16:46 -07:00
806 lines
22 KiB
Lua
806 lines
22 KiB
Lua
local function run_plugin_scenario(config)
|
||
config = config or {}
|
||
|
||
local recorded = {
|
||
async_calls = {},
|
||
sync_calls = {},
|
||
script_messages = {},
|
||
events = {},
|
||
osd = {},
|
||
logs = {},
|
||
property_sets = {},
|
||
periodic_timers = {},
|
||
}
|
||
|
||
local function make_mp_stub()
|
||
local mp = {}
|
||
|
||
function mp.get_property(name)
|
||
if name == "platform" then
|
||
return config.platform or "linux"
|
||
end
|
||
if name == "input-ipc-server" then
|
||
return config.input_ipc_server or ""
|
||
end
|
||
if name == "filename/no-ext" then
|
||
return config.filename_no_ext or ""
|
||
end
|
||
if name == "filename" then
|
||
return config.filename or ""
|
||
end
|
||
if name == "path" then
|
||
return config.path or ""
|
||
end
|
||
if name == "media-title" then
|
||
return config.media_title or ""
|
||
end
|
||
return ""
|
||
end
|
||
|
||
function mp.get_property_native(_name)
|
||
return config.chapter_list or {}
|
||
end
|
||
|
||
function mp.get_script_directory()
|
||
return "plugin/subminer"
|
||
end
|
||
|
||
function mp.command_native(command)
|
||
recorded.sync_calls[#recorded.sync_calls + 1] = command
|
||
local args = command.args or {}
|
||
if args[1] == "ps" then
|
||
return {
|
||
status = 0,
|
||
stdout = config.process_list or "",
|
||
stderr = "",
|
||
}
|
||
end
|
||
if args[1] == "curl" then
|
||
local url = args[#args] or ""
|
||
if type(url) == "string" and url:find("myanimelist", 1, true) then
|
||
return { status = 0, stdout = config.mal_lookup_stdout or "{}", stderr = "" }
|
||
end
|
||
if type(url) == "string" and url:find("api.aniskip.com", 1, true) then
|
||
return { status = 0, stdout = config.aniskip_stdout or "{}", stderr = "" }
|
||
end
|
||
return { status = 0, stdout = "{}", stderr = "" }
|
||
end
|
||
return { status = 0, stdout = "", stderr = "" }
|
||
end
|
||
|
||
function mp.command_native_async(command, callback)
|
||
recorded.async_calls[#recorded.async_calls + 1] = command
|
||
if callback then
|
||
local args = command.args or {}
|
||
if args[1] == "ps" then
|
||
callback(true, { status = 0, stdout = config.process_list or "", stderr = "" }, nil)
|
||
return
|
||
end
|
||
if args[1] == "curl" then
|
||
local url = args[#args] or ""
|
||
if type(url) == "string" and url:find("myanimelist", 1, true) then
|
||
callback(true, { status = 0, stdout = config.mal_lookup_stdout or "{}", stderr = "" }, nil)
|
||
return
|
||
end
|
||
if type(url) == "string" and url:find("api.aniskip.com", 1, true) then
|
||
callback(true, { status = 0, stdout = config.aniskip_stdout or "{}", stderr = "" }, nil)
|
||
return
|
||
end
|
||
end
|
||
callback(true, { status = 0, stdout = "", stderr = "" }, nil)
|
||
end
|
||
end
|
||
|
||
function mp.add_timeout(seconds, callback)
|
||
local timeout = {
|
||
killed = false,
|
||
}
|
||
function timeout:kill()
|
||
self.killed = true
|
||
end
|
||
|
||
local delay = tonumber(seconds) or 0
|
||
if callback and delay < 5 then
|
||
callback()
|
||
end
|
||
return timeout
|
||
end
|
||
|
||
function mp.add_periodic_timer(seconds, callback)
|
||
local timer = {
|
||
seconds = seconds,
|
||
killed = false,
|
||
callback = callback,
|
||
}
|
||
function timer:kill()
|
||
self.killed = true
|
||
end
|
||
recorded.periodic_timers[#recorded.periodic_timers + 1] = timer
|
||
return timer
|
||
end
|
||
|
||
function mp.register_script_message(name, fn)
|
||
recorded.script_messages[name] = fn
|
||
end
|
||
|
||
function mp.add_key_binding(_keys, _name, _fn) end
|
||
function mp.register_event(name, fn)
|
||
if recorded.events[name] == nil then
|
||
recorded.events[name] = {}
|
||
end
|
||
recorded.events[name][#recorded.events[name] + 1] = fn
|
||
end
|
||
function mp.add_hook(_name, _prio, _fn) end
|
||
function mp.observe_property(_name, _kind, _fn) end
|
||
function mp.osd_message(message, _duration)
|
||
recorded.osd[#recorded.osd + 1] = message
|
||
end
|
||
function mp.set_osd_ass(...) end
|
||
function mp.get_time()
|
||
return 0
|
||
end
|
||
function mp.commandv(...) end
|
||
function mp.set_property_native(name, value)
|
||
recorded.property_sets[#recorded.property_sets + 1] = {
|
||
name = name,
|
||
value = value,
|
||
}
|
||
end
|
||
function mp.get_script_name()
|
||
return "subminer"
|
||
end
|
||
|
||
return mp
|
||
end
|
||
|
||
local mp = make_mp_stub()
|
||
local options = {}
|
||
local utils = {}
|
||
|
||
function options.read_options(target, _name)
|
||
for key, value in pairs(config.option_overrides or {}) do
|
||
target[key] = value
|
||
end
|
||
end
|
||
|
||
function utils.file_info(path)
|
||
local exists = config.files and config.files[path]
|
||
if exists then
|
||
return { is_dir = false }
|
||
end
|
||
return nil
|
||
end
|
||
|
||
function utils.join_path(...)
|
||
local parts = { ... }
|
||
return table.concat(parts, "/")
|
||
end
|
||
|
||
function utils.parse_json(json)
|
||
if json == "__MAL_FOUND__" then
|
||
return {
|
||
categories = {
|
||
{
|
||
items = {
|
||
{
|
||
id = 99,
|
||
name = "Sample Show",
|
||
},
|
||
},
|
||
},
|
||
},
|
||
}, nil
|
||
end
|
||
if json == "__ANISKIP_FOUND__" then
|
||
return {
|
||
found = true,
|
||
results = {
|
||
{
|
||
skip_type = "op",
|
||
interval = {
|
||
start_time = 12.3,
|
||
end_time = 45.6,
|
||
},
|
||
},
|
||
},
|
||
}, nil
|
||
end
|
||
return {}, nil
|
||
end
|
||
|
||
package.loaded["mp"] = nil
|
||
package.loaded["mp.input"] = nil
|
||
package.loaded["mp.msg"] = nil
|
||
package.loaded["mp.options"] = nil
|
||
package.loaded["mp.utils"] = nil
|
||
|
||
package.preload["mp"] = function()
|
||
return mp
|
||
end
|
||
package.preload["mp.input"] = function()
|
||
return {
|
||
select = function(_) end,
|
||
}
|
||
end
|
||
package.preload["mp.msg"] = function()
|
||
return {
|
||
info = function(line)
|
||
recorded.logs[#recorded.logs + 1] = line
|
||
end,
|
||
warn = function(line)
|
||
recorded.logs[#recorded.logs + 1] = line
|
||
end,
|
||
error = function(line)
|
||
recorded.logs[#recorded.logs + 1] = line
|
||
end,
|
||
debug = function(line)
|
||
recorded.logs[#recorded.logs + 1] = line
|
||
end,
|
||
}
|
||
end
|
||
package.preload["mp.options"] = function()
|
||
return options
|
||
end
|
||
package.preload["mp.utils"] = function()
|
||
return utils
|
||
end
|
||
|
||
local ok, err = pcall(dofile, "plugin/subminer/main.lua")
|
||
if not ok then
|
||
return nil, err, recorded
|
||
end
|
||
return recorded, nil, recorded
|
||
end
|
||
|
||
local function assert_true(condition, message)
|
||
if condition then
|
||
return
|
||
end
|
||
error(message)
|
||
end
|
||
|
||
local function find_start_call(async_calls)
|
||
for _, call in ipairs(async_calls) do
|
||
local args = call.args or {}
|
||
for i = 1, #args do
|
||
if args[i] == "--start" then
|
||
return call
|
||
end
|
||
end
|
||
end
|
||
return nil
|
||
end
|
||
|
||
local function count_start_calls(async_calls)
|
||
local count = 0
|
||
for _, call in ipairs(async_calls) do
|
||
local args = call.args or {}
|
||
for _, value in ipairs(args) do
|
||
if value == "--start" then
|
||
count = count + 1
|
||
break
|
||
end
|
||
end
|
||
end
|
||
return count
|
||
end
|
||
|
||
local function find_control_call(async_calls, flag)
|
||
for _, call in ipairs(async_calls) do
|
||
local args = call.args or {}
|
||
local has_flag = false
|
||
local has_start = false
|
||
for _, value in ipairs(args) do
|
||
if value == flag then
|
||
has_flag = true
|
||
elseif value == "--start" then
|
||
has_start = true
|
||
end
|
||
end
|
||
if has_flag and not has_start then
|
||
return call
|
||
end
|
||
end
|
||
return nil
|
||
end
|
||
|
||
local function count_control_calls(async_calls, flag)
|
||
local count = 0
|
||
for _, call in ipairs(async_calls) do
|
||
local args = call.args or {}
|
||
local has_flag = false
|
||
local has_start = false
|
||
for _, value in ipairs(args) do
|
||
if value == flag then
|
||
has_flag = true
|
||
elseif value == "--start" then
|
||
has_start = true
|
||
end
|
||
end
|
||
if has_flag and not has_start then
|
||
count = count + 1
|
||
end
|
||
end
|
||
return count
|
||
end
|
||
|
||
local function call_has_arg(call, target)
|
||
local args = (call and call.args) or {}
|
||
for _, value in ipairs(args) do
|
||
if value == target then
|
||
return true
|
||
end
|
||
end
|
||
return false
|
||
end
|
||
|
||
local function has_sync_command(sync_calls, executable)
|
||
for _, call in ipairs(sync_calls) do
|
||
local args = call.args or {}
|
||
if args[1] == executable then
|
||
return true
|
||
end
|
||
end
|
||
return false
|
||
end
|
||
|
||
local function has_async_command(async_calls, executable)
|
||
for _, call in ipairs(async_calls) do
|
||
local args = call.args or {}
|
||
if args[1] == executable then
|
||
return true
|
||
end
|
||
end
|
||
return false
|
||
end
|
||
|
||
local function has_async_curl_for(async_calls, needle)
|
||
for _, call in ipairs(async_calls) do
|
||
local args = call.args or {}
|
||
if args[1] == "curl" then
|
||
local url = args[#args] or ""
|
||
if type(url) == "string" and url:find(needle, 1, true) then
|
||
return true
|
||
end
|
||
end
|
||
end
|
||
return false
|
||
end
|
||
|
||
local function has_property_set(property_sets, name, value)
|
||
for _, call in ipairs(property_sets) do
|
||
if call.name == name and call.value == value then
|
||
return true
|
||
end
|
||
end
|
||
return false
|
||
end
|
||
|
||
local function has_osd_message(messages, target)
|
||
for _, message in ipairs(messages) do
|
||
if message == target then
|
||
return true
|
||
end
|
||
end
|
||
return false
|
||
end
|
||
|
||
local function count_osd_message(messages, target)
|
||
local count = 0
|
||
for _, message in ipairs(messages) do
|
||
if message == target then
|
||
count = count + 1
|
||
end
|
||
end
|
||
return count
|
||
end
|
||
|
||
local function count_property_set(property_sets, name, value)
|
||
local count = 0
|
||
for _, call in ipairs(property_sets) do
|
||
if call.name == name and call.value == value then
|
||
count = count + 1
|
||
end
|
||
end
|
||
return count
|
||
end
|
||
|
||
local function fire_event(recorded, name)
|
||
local listeners = recorded.events[name] or {}
|
||
for _, listener in ipairs(listeners) do
|
||
listener()
|
||
end
|
||
end
|
||
|
||
local binary_path = "/tmp/subminer-binary"
|
||
|
||
do
|
||
local recorded, err = run_plugin_scenario({
|
||
process_list = "",
|
||
option_overrides = {
|
||
binary_path = binary_path,
|
||
auto_start = "no",
|
||
},
|
||
files = {
|
||
[binary_path] = true,
|
||
},
|
||
})
|
||
assert_true(recorded ~= nil, "plugin failed to load for cold-start scenario: " .. tostring(err))
|
||
assert_true(recorded.script_messages["subminer-start"] ~= nil, "subminer-start script message not registered")
|
||
recorded.script_messages["subminer-start"]("texthooker=no")
|
||
assert_true(find_start_call(recorded.async_calls) ~= nil, "expected cold-start to invoke --start command when process is absent")
|
||
assert_true(
|
||
not has_sync_command(recorded.sync_calls, "ps"),
|
||
"expected cold-start start command to avoid synchronous process list scan"
|
||
)
|
||
end
|
||
|
||
do
|
||
local recorded, err = run_plugin_scenario({
|
||
process_list = "",
|
||
option_overrides = {
|
||
binary_path = binary_path,
|
||
auto_start = "no",
|
||
},
|
||
media_title = "Random Movie",
|
||
files = {
|
||
[binary_path] = true,
|
||
},
|
||
})
|
||
assert_true(recorded ~= nil, "plugin failed to load for non-subminer file-load scenario: " .. tostring(err))
|
||
fire_event(recorded, "file-loaded")
|
||
assert_true(not has_sync_command(recorded.sync_calls, "ps"), "file-loaded should avoid synchronous process checks")
|
||
assert_true(not has_sync_command(recorded.sync_calls, "curl"), "file-loaded should avoid synchronous AniSkip network calls")
|
||
assert_true(
|
||
not has_async_curl_for(recorded.async_calls, "myanimelist.net/search/prefix.json"),
|
||
"file-loaded without SubMiner context should skip AniSkip MAL lookup"
|
||
)
|
||
assert_true(
|
||
not has_async_curl_for(recorded.async_calls, "api.aniskip.com"),
|
||
"file-loaded without SubMiner context should skip AniSkip API lookup"
|
||
)
|
||
end
|
||
|
||
do
|
||
local recorded, err = run_plugin_scenario({
|
||
process_list = "",
|
||
option_overrides = {
|
||
binary_path = binary_path,
|
||
auto_start = "yes",
|
||
auto_start_visible_overlay = "yes",
|
||
auto_start_pause_until_ready = "no",
|
||
socket_path = "/tmp/subminer-socket",
|
||
},
|
||
input_ipc_server = "/tmp/subminer-socket",
|
||
path = "https://www.youtube.com/watch?v=lJI7uL4JDkE",
|
||
media_title = "【文字起こし】マジで役立つ！！恋愛術！【告radio】",
|
||
files = {
|
||
[binary_path] = true,
|
||
},
|
||
})
|
||
assert_true(recorded ~= nil, "plugin failed to load for URL overlay-start AniSkip scenario: " .. tostring(err))
|
||
fire_event(recorded, "file-loaded")
|
||
assert_true(find_start_call(recorded.async_calls) ~= nil, "URL auto-start should still invoke --start command")
|
||
assert_true(
|
||
not has_async_curl_for(recorded.async_calls, "myanimelist.net/search/prefix.json"),
|
||
"URL playback should skip AniSkip MAL lookup even after overlay-start"
|
||
)
|
||
assert_true(
|
||
not has_async_curl_for(recorded.async_calls, "api.aniskip.com"),
|
||
"URL playback should skip AniSkip API lookup even after overlay-start"
|
||
)
|
||
end
|
||
|
||
do
|
||
local recorded, err = run_plugin_scenario({
|
||
process_list = "",
|
||
option_overrides = {
|
||
binary_path = binary_path,
|
||
auto_start = "no",
|
||
},
|
||
media_title = "Sample Show S01E01",
|
||
mal_lookup_stdout = "__MAL_FOUND__",
|
||
aniskip_stdout = "__ANISKIP_FOUND__",
|
||
files = {
|
||
[binary_path] = true,
|
||
},
|
||
})
|
||
assert_true(recorded ~= nil, "plugin failed to load for script-message AniSkip scenario: " .. tostring(err))
|
||
assert_true(recorded.script_messages["subminer-aniskip-refresh"] ~= nil, "subminer-aniskip-refresh script message not registered")
|
||
recorded.script_messages["subminer-aniskip-refresh"]()
|
||
assert_true(not has_sync_command(recorded.sync_calls, "curl"), "AniSkip refresh should not perform synchronous curl calls")
|
||
assert_true(has_async_command(recorded.async_calls, "curl"), "AniSkip refresh should perform async curl calls")
|
||
assert_true(
|
||
has_async_curl_for(recorded.async_calls, "myanimelist.net/search/prefix.json"),
|
||
"AniSkip refresh should perform MAL lookup even when app is not running"
|
||
)
|
||
end
|
||
|
||
do
|
||
local recorded, err = run_plugin_scenario({
|
||
process_list = "",
|
||
option_overrides = {
|
||
binary_path = binary_path,
|
||
auto_start = "yes",
|
||
auto_start_visible_overlay = "yes",
|
||
auto_start_pause_until_ready = "no",
|
||
socket_path = "/tmp/subminer-socket",
|
||
},
|
||
input_ipc_server = "/tmp/subminer-socket",
|
||
media_title = "Random Movie",
|
||
files = {
|
||
[binary_path] = true,
|
||
},
|
||
})
|
||
assert_true(recorded ~= nil, "plugin failed to load for visible auto-start scenario: " .. tostring(err))
|
||
fire_event(recorded, "file-loaded")
|
||
local start_call = find_start_call(recorded.async_calls)
|
||
assert_true(start_call ~= nil, "auto-start should issue --start command")
|
||
assert_true(
|
||
call_has_arg(start_call, "--show-visible-overlay"),
|
||
"auto-start with visible overlay enabled should include --show-visible-overlay on --start"
|
||
)
|
||
assert_true(
|
||
not call_has_arg(start_call, "--hide-visible-overlay"),
|
||
"auto-start with visible overlay enabled should not include --hide-visible-overlay on --start"
|
||
)
|
||
assert_true(
|
||
find_control_call(recorded.async_calls, "--show-visible-overlay") ~= nil,
|
||
"auto-start with visible overlay enabled should issue a separate --show-visible-overlay command"
|
||
)
|
||
assert_true(
|
||
not has_property_set(recorded.property_sets, "pause", true),
|
||
"auto-start visible overlay should not force pause without explicit pause-until-ready option"
|
||
)
|
||
end
|
||
|
||
do
|
||
local recorded, err = run_plugin_scenario({
|
||
process_list = "",
|
||
option_overrides = {
|
||
binary_path = binary_path,
|
||
auto_start = "yes",
|
||
auto_start_visible_overlay = "yes",
|
||
socket_path = "/tmp/subminer-socket",
|
||
},
|
||
input_ipc_server = "/tmp/subminer-socket",
|
||
media_title = "Random Movie",
|
||
files = {
|
||
[binary_path] = true,
|
||
},
|
||
})
|
||
assert_true(recorded ~= nil, "plugin failed to load for duplicate auto-start scenario: " .. tostring(err))
|
||
fire_event(recorded, "file-loaded")
|
||
fire_event(recorded, "file-loaded")
|
||
assert_true(
|
||
count_start_calls(recorded.async_calls) == 1,
|
||
"duplicate file-loaded events should not issue duplicate --start commands while overlay is already running"
|
||
)
|
||
assert_true(
|
||
count_control_calls(recorded.async_calls, "--show-visible-overlay") == 2,
|
||
"duplicate auto-start should re-assert visible overlay state when overlay is already running"
|
||
)
|
||
assert_true(
|
||
count_osd_message(recorded.osd, "SubMiner: Already running") == 0,
|
||
"duplicate auto-start events should not show Already running OSD"
|
||
)
|
||
end
|
||
|
||
do
|
||
local recorded, err = run_plugin_scenario({
|
||
process_list = "",
|
||
option_overrides = {
|
||
binary_path = binary_path,
|
||
auto_start = "yes",
|
||
auto_start_visible_overlay = "yes",
|
||
auto_start_pause_until_ready = "yes",
|
||
socket_path = "/tmp/subminer-socket",
|
||
},
|
||
input_ipc_server = "/tmp/subminer-socket",
|
||
media_title = "Random Movie",
|
||
files = {
|
||
[binary_path] = true,
|
||
},
|
||
})
|
||
assert_true(recorded ~= nil, "plugin failed to load for duplicate auto-start pause-until-ready scenario: " .. tostring(err))
|
||
fire_event(recorded, "file-loaded")
|
||
assert_true(recorded.script_messages["subminer-autoplay-ready"] ~= nil, "subminer-autoplay-ready script message not registered")
|
||
recorded.script_messages["subminer-autoplay-ready"]()
|
||
fire_event(recorded, "file-loaded")
|
||
recorded.script_messages["subminer-autoplay-ready"]()
|
||
assert_true(
|
||
count_start_calls(recorded.async_calls) == 1,
|
||
"duplicate pause-until-ready auto-start should not issue duplicate --start commands while overlay is already running"
|
||
)
|
||
assert_true(
|
||
count_control_calls(recorded.async_calls, "--show-visible-overlay") == 4,
|
||
"duplicate pause-until-ready auto-start should re-assert visible overlay on both start and ready events"
|
||
)
|
||
assert_true(
|
||
count_osd_message(recorded.osd, "SubMiner: Loading subtitle tokenization...") == 2,
|
||
"duplicate pause-until-ready auto-start should arm tokenization loading gate for each file"
|
||
)
|
||
assert_true(
|
||
count_osd_message(recorded.osd, "SubMiner: Subtitle tokenization ready") == 2,
|
||
"duplicate pause-until-ready auto-start should release tokenization gate for each file"
|
||
)
|
||
assert_true(
|
||
count_property_set(recorded.property_sets, "pause", true) == 2,
|
||
"duplicate pause-until-ready auto-start should force pause for each file"
|
||
)
|
||
assert_true(
|
||
count_property_set(recorded.property_sets, "pause", false) == 2,
|
||
"duplicate pause-until-ready auto-start should resume playback for each file"
|
||
)
|
||
end
|
||
|
||
do
|
||
local recorded, err = run_plugin_scenario({
|
||
process_list = "",
|
||
option_overrides = {
|
||
binary_path = binary_path,
|
||
auto_start = "yes",
|
||
auto_start_visible_overlay = "yes",
|
||
auto_start_pause_until_ready = "yes",
|
||
socket_path = "/tmp/subminer-socket",
|
||
},
|
||
input_ipc_server = "/tmp/subminer-socket",
|
||
media_title = "Random Movie",
|
||
files = {
|
||
[binary_path] = true,
|
||
},
|
||
})
|
||
assert_true(recorded ~= nil, "plugin failed to load for pause-until-ready scenario: " .. tostring(err))
|
||
fire_event(recorded, "file-loaded")
|
||
assert_true(
|
||
has_property_set(recorded.property_sets, "pause", true),
|
||
"pause-until-ready auto-start should pause mpv before overlay ready"
|
||
)
|
||
assert_true(recorded.script_messages["subminer-autoplay-ready"] ~= nil, "subminer-autoplay-ready script message not registered")
|
||
recorded.script_messages["subminer-autoplay-ready"]()
|
||
assert_true(
|
||
has_property_set(recorded.property_sets, "pause", false),
|
||
"autoplay-ready script message should resume mpv playback"
|
||
)
|
||
assert_true(
|
||
has_osd_message(recorded.osd, "SubMiner: Loading subtitle tokenization..."),
|
||
"pause-until-ready auto-start should show loading OSD message"
|
||
)
|
||
assert_true(
|
||
not has_osd_message(recorded.osd, "SubMiner: Starting..."),
|
||
"pause-until-ready auto-start should avoid replacing loading OSD with generic starting OSD"
|
||
)
|
||
assert_true(
|
||
has_osd_message(recorded.osd, "SubMiner: Subtitle tokenization ready"),
|
||
"autoplay-ready should show loaded OSD message"
|
||
)
|
||
assert_true(
|
||
count_control_calls(recorded.async_calls, "--show-visible-overlay") == 2,
|
||
"autoplay-ready should re-assert visible overlay state"
|
||
)
|
||
assert_true(
|
||
#recorded.periodic_timers == 1,
|
||
"pause-until-ready auto-start should create periodic loading OSD refresher"
|
||
)
|
||
assert_true(
|
||
recorded.periodic_timers[1].killed == true,
|
||
"autoplay-ready should stop periodic loading OSD refresher"
|
||
)
|
||
end
|
||
|
||
do
|
||
local recorded, err = run_plugin_scenario({
|
||
process_list = "",
|
||
option_overrides = {
|
||
binary_path = binary_path,
|
||
auto_start = "yes",
|
||
auto_start_visible_overlay = "yes",
|
||
auto_start_pause_until_ready = "yes",
|
||
socket_path = "/tmp/subminer-socket",
|
||
},
|
||
input_ipc_server = "/tmp/subminer-socket",
|
||
media_title = "Random Movie",
|
||
files = {
|
||
[binary_path] = true,
|
||
},
|
||
})
|
||
assert_true(recorded ~= nil, "plugin failed to load for pause cleanup scenario: " .. tostring(err))
|
||
fire_event(recorded, "file-loaded")
|
||
fire_event(recorded, "end-file")
|
||
assert_true(
|
||
count_property_set(recorded.property_sets, "pause", true) == 1,
|
||
"pause cleanup scenario should force pause while waiting for tokenization"
|
||
)
|
||
assert_true(
|
||
count_property_set(recorded.property_sets, "pause", false) == 1,
|
||
"ending file while gate is armed should clear forced pause state"
|
||
)
|
||
end
|
||
|
||
do
|
||
local recorded, err = run_plugin_scenario({
|
||
process_list = "",
|
||
option_overrides = {
|
||
binary_path = binary_path,
|
||
auto_start = "yes",
|
||
auto_start_visible_overlay = "yes",
|
||
socket_path = "/tmp/subminer-socket",
|
||
},
|
||
input_ipc_server = "/tmp/subminer-socket",
|
||
media_title = "Random Movie",
|
||
files = {
|
||
[binary_path] = true,
|
||
},
|
||
})
|
||
assert_true(recorded ~= nil, "plugin failed to load for shutdown-preserve-background scenario: " .. tostring(err))
|
||
fire_event(recorded, "file-loaded")
|
||
fire_event(recorded, "shutdown")
|
||
assert_true(
|
||
find_control_call(recorded.async_calls, "--stop") == nil,
|
||
"mpv shutdown should not stop the background SubMiner process"
|
||
)
|
||
end
|
||
|
||
do
|
||
local recorded, err = run_plugin_scenario({
|
||
process_list = "",
|
||
option_overrides = {
|
||
binary_path = binary_path,
|
||
auto_start = "yes",
|
||
auto_start_visible_overlay = "no",
|
||
socket_path = "/tmp/subminer-socket",
|
||
},
|
||
input_ipc_server = "/tmp/subminer-socket",
|
||
media_title = "Random Movie",
|
||
files = {
|
||
[binary_path] = true,
|
||
},
|
||
})
|
||
assert_true(recorded ~= nil, "plugin failed to load for hidden auto-start scenario: " .. tostring(err))
|
||
fire_event(recorded, "file-loaded")
|
||
local start_call = find_start_call(recorded.async_calls)
|
||
assert_true(start_call ~= nil, "auto-start should issue --start command")
|
||
assert_true(
|
||
call_has_arg(start_call, "--hide-visible-overlay"),
|
||
"auto-start with visible overlay disabled should include --hide-visible-overlay on --start"
|
||
)
|
||
assert_true(
|
||
not call_has_arg(start_call, "--show-visible-overlay"),
|
||
"auto-start with visible overlay disabled should not include --show-visible-overlay on --start"
|
||
)
|
||
assert_true(
|
||
find_control_call(recorded.async_calls, "--hide-visible-overlay") ~= nil,
|
||
"auto-start with visible overlay disabled should issue a separate --hide-visible-overlay command"
|
||
)
|
||
end
|
||
|
||
do
|
||
local recorded, err = run_plugin_scenario({
|
||
process_list = "",
|
||
option_overrides = {
|
||
binary_path = binary_path,
|
||
auto_start = "yes",
|
||
auto_start_visible_overlay = "yes",
|
||
socket_path = "/tmp/subminer-socket",
|
||
},
|
||
input_ipc_server = "/tmp/other.sock",
|
||
media_title = "Random Movie",
|
||
files = {
|
||
[binary_path] = true,
|
||
},
|
||
})
|
||
assert_true(recorded ~= nil, "plugin failed to load for mismatched socket auto-start scenario: " .. tostring(err))
|
||
fire_event(recorded, "file-loaded")
|
||
local start_call = find_start_call(recorded.async_calls)
|
||
assert_true(
|
||
start_call == nil,
|
||
"auto-start should be skipped when mpv input-ipc-server does not match configured socket_path"
|
||
)
|
||
assert_true(
|
||
not has_property_set(recorded.property_sets, "pause", true),
|
||
"pause-until-ready gate should not arm when socket_path does not match"
|
||
)
|
||
end
|
||
|
||
print("plugin start gate regression tests: OK")
|