# Register a command that outputs the RMS of the returned source.
# @flag extra
# @category Source / Visualization
# @param ~id Force the value of the source ID.
def server.rms(~id=null, s) =
let s = rms(id=id, s)
def rms(_) =
rms = s.rms()
"#{rms}"
end
s.register_command(
description=
"Return the current RMS of the source.",
usage="rms",
"rms",
rms
)
s
end
# Register a server/telnet command to update a source's metadata. Returns a new
# source, which will receive the updated metadata. The command has the following
# format: insert key1="val1",key2="val2",...
# @flag extra
# @category Source / Track processing
# @param ~id Force the value of the source ID.
def server.insert_metadata(~id=null, s) =
s = insert_metadata(id=id, s)
insert = s.insert_metadata
def insert(s) =
let (meta, _) = string.annotate.parse("#{s}:")
if
meta != []
then
insert(meta)
"Done"
else
"Syntax error or no metadata given. Use key1=\"val1\",key2=\"val2\",.."
end
end
s.register_command(
description=
"Insert a metadata chunk.",
usage=
"insert key1=\"val1\",key2=\"val2\",..",
"insert",
insert
)
s
end
# Start an interface for the "telnet" server over http.
# @category Internet
# @flag extra
# @param ~port Port of the server.
# @param ~transport Http transport. Use `http.transport.ssl` or http.transport.secure_transport`, when available, to enable HTTPS output
# @param ~uri URI of the server.
def server.harbor(~transport=http.transport.unix, ~port=8000, ~uri="/telnet") =
def webpage(_, response) =
response.html(
"
Liquidsoap telnet server
Liquidsoap telnet server
Type help if you are lost.
"
)
end
harbor.http.register(
transport=transport, port=port, method="GET", uri, webpage
)
def setter(request, response) =
log.info(
"Executing command: #{request.data}"
)
answer = server.execute(request.body())
answer = string.concat(separator="\n", answer) ^ "\n"
response.data(answer)
end
harbor.http.register(
transport=transport, port=port, method="POST", uri, setter
)
log.important(
label="server.harbor",
"Website should be ready at ."
)
end
# Add a skip telnet command to a source when it does not have one by default.
# @category Interaction
# @flag extra
# @param s The source to attach the command to.
def add_skip_command(s) =
# A command to skip
def skip(_) =
s.skip()
"Done!"
end
s.on_wake_up(
{
# Register the command:
server.register(
namespace="#{source.id(s)}",
usage="skip",
description=
"Skip the current song.",
"skip",
skip
)
}
)
end