Added experimental VLC Syncplay connector
This commit is contained in:
Etoh
parent
98c63b7db9
commit
1a3b56c140
289
resources/syncplay.lua
Normal file
289
resources/syncplay.lua
Normal file
@ -0,0 +1,289 @@
|
||||
--[==========================================================================[
|
||||
syncplay.lua: Syncplay interface module
|
||||
--[==========================================================================[
|
||||
|
||||
Author: Etoh
|
||||
|
||||
--]==========================================================================]
|
||||
require "common"
|
||||
require "host"
|
||||
|
||||
local connectorversion = "0.0.1"
|
||||
|
||||
local port
|
||||
|
||||
local msgterminator = "\n"
|
||||
local msgseperator = ": "
|
||||
local argseperator = ", "
|
||||
|
||||
local responsemarker = "-response"
|
||||
local errormarker = "-error"
|
||||
|
||||
local noinput = "no-input"
|
||||
local notimplemented = "not-implemented"
|
||||
local unknowncommand = "unknown-command"
|
||||
|
||||
function get_args (argument, argcount)
|
||||
local argarray = {}
|
||||
local index
|
||||
local i
|
||||
local argbuffer
|
||||
|
||||
argbuffer = argument
|
||||
|
||||
for i = 1, argcount,1 do
|
||||
if i == argcount then
|
||||
argarray[i] = argbuffer
|
||||
else
|
||||
if string.find(argbuffer, argseperator) then
|
||||
index = string.find(argbuffer, argseperator)
|
||||
argarray[i] = string.sub(argbuffer, 0, index - 1)
|
||||
argbuffer = string.sub(argbuffer, index + string.len(argseperator))
|
||||
else
|
||||
argarray[i] = ""
|
||||
end
|
||||
end
|
||||
|
||||
end
|
||||
|
||||
return argarray
|
||||
|
||||
end
|
||||
|
||||
|
||||
port = tonumber(config["port"])
|
||||
if (port == nil or port < 1) then port = 4123 end
|
||||
|
||||
vlc.msg.info("Hosting Syncplay interface on port: "..port)
|
||||
|
||||
h = host.host()
|
||||
|
||||
-- Bypass any authentication
|
||||
function on_password( client )
|
||||
client:switch_status( host.status.read )
|
||||
end
|
||||
|
||||
function get_var( vartoget )
|
||||
local response
|
||||
local errormsg
|
||||
local input = vlc.object.input()
|
||||
|
||||
if input then
|
||||
response = vlc.var.get(input,tostring(vartoget))
|
||||
else
|
||||
errormsg = noinput
|
||||
end
|
||||
|
||||
vlc.msg.info("getvar `"..tostring(vartoget).."`: '"..tostring(response).."'")
|
||||
|
||||
return response, errormsg
|
||||
end
|
||||
|
||||
function set_var(vartoset, varvalue)
|
||||
local errormsg
|
||||
local input = vlc.object.input()
|
||||
|
||||
if input then
|
||||
vlc.var.set(input,tostring(vartoset),tostring(varvalue))
|
||||
else
|
||||
errormsg = noinput
|
||||
end
|
||||
vlc.msg.info("setvar: '"..tostring(vartoset).."' = '"..tostring(varvalue).."'")
|
||||
return errormsg
|
||||
end
|
||||
|
||||
h:listen( "localhost:"..port)
|
||||
--h:listen( "*console" )
|
||||
|
||||
function get_play_state()
|
||||
local response
|
||||
local errormsg
|
||||
local input = vlc.object.input()
|
||||
|
||||
if input then
|
||||
response = vlc.playlist.status()
|
||||
else
|
||||
errormsg = noinput
|
||||
end
|
||||
|
||||
vlc.msg.info("get play state: '"..tostring(response).."'")
|
||||
|
||||
return response, errormsg
|
||||
|
||||
end
|
||||
|
||||
function get_filepath ()
|
||||
local response
|
||||
local errormsg
|
||||
local item
|
||||
local input = vlc.object.input()
|
||||
|
||||
if input then
|
||||
local item = vlc.input.item()
|
||||
if item then
|
||||
response = vlc.strings.decode_uri(item:uri())
|
||||
else
|
||||
errormsg = noinput
|
||||
end
|
||||
else
|
||||
errormsg = noinput
|
||||
end
|
||||
|
||||
return response, errormsg
|
||||
end
|
||||
|
||||
function display_osd ( argument )
|
||||
local errormsg
|
||||
local osdarray
|
||||
osdarray = get_args(argument,3)
|
||||
--position, duration ms, message
|
||||
vlc.osd.message(osdarray[3],channel1,osdarray[1],osdarray[2])
|
||||
return errormsg
|
||||
end
|
||||
|
||||
|
||||
function do_command ( command, argument)
|
||||
|
||||
local command = tostring(command)
|
||||
local argument = tostring(argument)
|
||||
local errormsg = ""
|
||||
local response = ""
|
||||
|
||||
vlc.msg.info("Command: '"..command.."'")
|
||||
vlc.msg.info("Argument: '"..argument.."'")
|
||||
|
||||
local input = vlc.object.input()
|
||||
|
||||
if command == "get-playstate" then response, errormsg = get_play_state()
|
||||
elseif command == "get-time" then response, errormsg = get_var("time")
|
||||
elseif command == "get-filename" then response, errormsg = get_var("title")
|
||||
elseif command == "get-file-length" then response, errormsg = get_var("length")
|
||||
elseif command == "get-filepath" then response, errormsg = get_filepath()
|
||||
elseif command == "get-vlc-version" then response = vlc.misc.version()
|
||||
elseif command == "get-version" then response = connectorversion
|
||||
elseif command == "play" then errormsg = playfile()
|
||||
elseif command == "pause" then errormsg = pausefile()
|
||||
elseif command == "playpause" then errormsg = playpausefile()
|
||||
elseif command == "seek" then errormsg = set_var("time", tonumber(argument))
|
||||
elseif command == "set-rate" then errormsg = set_var("rate", tonumber(argument))
|
||||
elseif command == "display-osd" then errormsg = display_osd(argument)
|
||||
else errormsg = unknowncommand
|
||||
end
|
||||
|
||||
if (tostring(errormsg) == "" or errormsg == nil) then
|
||||
if (tostring(response) == "") then
|
||||
response = command..responsemarker..msgterminator
|
||||
else
|
||||
response = command..responsemarker..msgseperator..tostring(response)..msgterminator
|
||||
end
|
||||
else
|
||||
response = command..errormarker..msgseperator..tostring(errormsg)..msgterminator
|
||||
end
|
||||
|
||||
vlc.msg.info("Response: '"..tostring(response).."'")
|
||||
|
||||
return response
|
||||
|
||||
end
|
||||
|
||||
function playfile()
|
||||
local errormsg
|
||||
|
||||
if input then
|
||||
common.hotkey("key-pause")
|
||||
else
|
||||
errormsg = noinput
|
||||
end
|
||||
|
||||
return errormsg
|
||||
end
|
||||
|
||||
|
||||
function pausefile()
|
||||
local errormsg
|
||||
|
||||
if input then
|
||||
common.hotkey("key-play")
|
||||
else
|
||||
errormsg = noinput
|
||||
end
|
||||
|
||||
return errormsg
|
||||
end
|
||||
|
||||
function playpausefile()
|
||||
local errormsg
|
||||
|
||||
if input then
|
||||
vlc.playlist.pause()
|
||||
else
|
||||
errormsg = noinput
|
||||
end
|
||||
|
||||
return errormsg
|
||||
end
|
||||
|
||||
-- main loop
|
||||
while not vlc.misc.should_die() do
|
||||
-- accept new connections and select active clients
|
||||
local write, read = h:accept_and_select()
|
||||
|
||||
-- handle clients in write mode
|
||||
for _, client in pairs(write) do
|
||||
client:send()
|
||||
client.buffer = ""
|
||||
client:switch_status( host.status.read )
|
||||
end
|
||||
|
||||
-- handle clients in read mode
|
||||
|
||||
for _, client in pairs(read) do
|
||||
local str = client:recv(1000)
|
||||
local responsebuffer
|
||||
if not str then break end
|
||||
|
||||
local safestr = string.gsub(tostring(str), "\r", "")
|
||||
|
||||
if client.inputbuffer == nil then
|
||||
client.inputbuffer = ""
|
||||
end
|
||||
|
||||
client.inputbuffer = client.inputbuffer .. safestr
|
||||
|
||||
vlc.msg.info("Str: '" .. safestr.."'")
|
||||
vlc.msg.info("Input buffer: '" .. client.inputbuffer.."'")
|
||||
|
||||
while string.find(client.inputbuffer, msgterminator) do
|
||||
local index = string.find(client.inputbuffer, msgterminator)
|
||||
local request = string.sub(client.inputbuffer, 0, index - 1)
|
||||
local command
|
||||
local argument
|
||||
client.inputbuffer = string.sub(client.inputbuffer, index + string.len(msgterminator))
|
||||
|
||||
if (string.find(request, msgseperator)) then
|
||||
index = string.find(request, msgseperator)
|
||||
command = string.sub(request, 0, index - 1)
|
||||
argument = string.sub(request, index + string.len(msgseperator))
|
||||
|
||||
else
|
||||
command = request
|
||||
end
|
||||
|
||||
if (responsebuffer) then
|
||||
responsebuffer = responsebuffer .. do_command(command,argument)
|
||||
else
|
||||
responsebuffer = do_command(command,argument)
|
||||
end
|
||||
|
||||
end
|
||||
|
||||
client.buffer = ""
|
||||
if (responsebuffer) then
|
||||
client:send(responsebuffer)
|
||||
end
|
||||
client.buffer = ""
|
||||
client:switch_status( host.status.write )
|
||||
end
|
||||
|
||||
end
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user