mirror of
https://github.com/mamedev/mame.git
synced 2024-11-16 07:48:32 +01:00
b67b969bf0
* Moved several machine lifecycle callbacks to the notifier/subscriber model. The old callback registration model is still available for them for now, but prints a deprecation warning. * Added pre-save/post-load notifications. * Use a single allocated timer rather than one anonymous timer per waiter. Waiters no longer prevent saved states from being loaded. * Clean up outstanding waiters on stop or state load rather than just leaking them. * Started documenting parts of the emulator interface object that should be relatively stable. -imagedev/avivideo.cpp: Fixed an object leak on unload. Also changed some other media image devices to use smart pointers.
117 lines
2.8 KiB
Lua
117 lines
2.8 KiB
Lua
-- license:BSD-3-Clause
|
|
-- copyright-holders:Carl
|
|
local exports = {
|
|
name = "discord",
|
|
version = "0.0.1",
|
|
description = "Discord presence",
|
|
license = "BSD-3-Clause",
|
|
author = { name = "Carl" } }
|
|
|
|
local discord = exports
|
|
|
|
local reset_subscription, pause_subscription, resume_subscription
|
|
|
|
function discord.startplugin()
|
|
local pipe = emu.file("rw")
|
|
local json = require("json")
|
|
local nonce = 1
|
|
local starttime = 0
|
|
|
|
local function init()
|
|
local path
|
|
if package.config:sub(1,1) == '\\' then
|
|
path = "\\\\.\\pipe\\discord-ipc-0"
|
|
else
|
|
path = os.getenv("XDG_RUNTIME_DIR") or os.getenv("TMPDIR") or os.getenv("TMP") or os.getenv("TEMP") or '/tmp'
|
|
path = "domain." .. path .. "/discord-ipc-0"
|
|
end
|
|
local err = pipe:open(path)
|
|
if err then
|
|
error("discord: unable to connect, " .. err .. "\n")
|
|
end
|
|
local output = json.stringify({v = 1, client_id = "453309506152169472"})
|
|
--print(output)
|
|
pipe:write(string.pack("<I4I4", 0, #output) .. output)
|
|
local time = os.time()
|
|
local data = ""
|
|
repeat
|
|
local res = pipe:read(100)
|
|
data = data .. res
|
|
until #res == 0 and #data > 0 or time + 1 < os.time()
|
|
--print(data)
|
|
if data:find("code", 1, true) then
|
|
error("discord: bad RPC reply, " .. data:sub(8) .. "\n")
|
|
end
|
|
if #data == 0 then
|
|
error("discord: timed out waiting for response\n");
|
|
end
|
|
end
|
|
|
|
local function update(status)
|
|
if not pipe then return end
|
|
local running = emu.romname() ~= "___empty"
|
|
local state = not running and "In menu" or status
|
|
local details = running and manager.machine.system.description or nil
|
|
if emu.softname() ~= "" then
|
|
for name, dev in pairs(manager.machine.images) do
|
|
if dev.software_longname then
|
|
details = details .. " (" .. dev.software_longname .. ")"
|
|
break
|
|
end
|
|
end
|
|
end
|
|
local status = {
|
|
cmd = "SET_ACTIVITY",
|
|
args = {
|
|
pid = emu.pid(),
|
|
activity = {
|
|
state = state,
|
|
details = details,
|
|
timestamps = {
|
|
start = starttime
|
|
}
|
|
}
|
|
},
|
|
nonce = nonce
|
|
}
|
|
nonce = nonce + 1
|
|
local output = json.stringify(status)
|
|
--print(output)
|
|
pipe:write(string.pack("<I4I4", 1, #output) .. output)
|
|
local time = os.time()
|
|
local data = ""
|
|
repeat
|
|
local res = pipe:read(100)
|
|
data = data .. res
|
|
until #res == 0 and #data > 0 or time + 1 < os.time()
|
|
if #data == 0 then
|
|
emu.print_verbose("discord: timed out waiting for response, closing connection");
|
|
pipe = nil
|
|
end
|
|
--print(data)
|
|
end
|
|
|
|
do
|
|
local stat, err = pcall(init)
|
|
if not stat then
|
|
emu.print_verbose(err)
|
|
pipe = nil
|
|
return
|
|
end
|
|
end
|
|
|
|
reset_subscription = emu.add_machine_reset_notifier(function ()
|
|
starttime = os.time()
|
|
update("Playing")
|
|
end)
|
|
|
|
pause_subscription = emu.add_machine_pause_notifier(function ()
|
|
update("Paused")
|
|
end)
|
|
|
|
resume_subscription = emu.add_machine_resume_notifier(function ()
|
|
update("Playing")
|
|
end)
|
|
end
|
|
|
|
return exports
|