-
David Trattnig authoredrequired by engine#110
David Trattnig authoredrequired by engine#110
serverfunctions.liq 6.74 KiB
#
# Aura Engine (https://gitlab.servus.at/aura/engine)
#
# Copyright (C) 2017-2020 - The Aura Engine Team.
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU Affero General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU Affero General Public License for more details.
#
# You should have received a copy of the GNU Affero General Public License
# along with this program. If not, see <http://www.gnu.org/licenses/>.
#
# Namespace: aura_engine
#
# Get state of the inputs/outputs as JSON
server.register(namespace = "aura_engine",
description="Get status info (uptime and fallback state)",
usage="status",
"status",
fun(s) -> begin
ignore(s)
uptime = list.nth(server.execute("uptime"), 0)
json_data = json()
json_data.add("uptime", uptime)
json_data.add("is_fallback", !engine_state.is_fallback)
json.stringify(json_data)
end
)
# Updates engine config
server.register(namespace="aura_engine",
description="Update the engine configuration",
usage="update_config { \
\"fallback_show_id\": \"-1\", \
\"fallback_show_name\": \"Station Fallback\" \
}",
"update_config",
fun (s) -> begin
log("Received JSON to update config: #{s}")
let json.parse (data : {
fallback_show_id: int,
fallback_show_name: string
}) = s
fallback_show_id := "#{data.fallback_show_id}"
log("Set Fallback Show ID to '#{!fallback_show_id}'")
fallback_show_name := data.fallback_show_name
log("Set Fallback Show Name to '#{!fallback_show_name}'")
"OK"
end
)
# Get version
server.register(namespace="aura_engine",
description="Return the version of Engine Core and Liquidsoap",
usage="version",
"version",
fun (s) -> begin
ignore(s) json_data = json()
json_data.add("core", engine_version)
json_data.add("liquidsoap", liquidsoap.version)
json.stringify(json_data)
end
)
# Shutdown server
server.register(namespace="aura_engine",
description="Shutdown play-out server",
usage="stop",
"stop",
fun (s) -> begin
ignore(s)
shutdown(code=0)
"OK"
end
)
#
# Namespace: mixer
#
# Get connection state of outgoing streams #TODO refactor
server.register(namespace="mixer",
description="Return all active outputs",
usage="outputs",
"outputs",
fun (s) -> begin
ignore(s)
log("executing: mixer.outputs")
so = []
so = s0_enable ? list.add(("out_line_0", ("connected", "#{!s0_connected")), so) : so
so = s1_enable ? list.add(("out_line_1", ("connected", "#{!s1_connected")), so) : so
so = s2_enable ? list.add(("out_line_2", ("connected", "#{!s2_connected")), so) : so
so = s3_enable ? list.add(("out_line_3", ("connected", "#{!s3_connected")), so) : so
so = s4_enable ? list.add(("out_line_4", ("connected", "#{!s4_connected")), so) : so
lo = []
lo = a0_out != '' ? list.add("out_line_0", lo) : lo
lo = a1_out != '' ? list.add("out_line_1", lo) : lo
lo = a2_out != '' ? list.add("out_line_2", lo) : lo
lo = a3_out != '' ? list.add("out_line_3", lo) : lo
lo = a4_out != '' ? list.add("out_line_4", lo) : lo
json_data = json()
json_data.add("line", lo)
json_data.add("stream", so)
json.stringify(json_data)
end
)
# Activate a source by selecting it and setting the volume to 100 (or vice versa)
server.register(namespace = "mixer",
description = "Select a source and set the volume to 100",
usage = "activate <source number> <true|false>",
"activate",
fun(p) -> begin
params=string.split(separator=" ", p)
if list.length(params) < 2 then
print(p)
"Usage: mixer.activate <source nb> <true|false>"
else
source_number = list.nth(default="0", params, 0)
source_enable = list.nth(default="false", params, 1)
if source_enable == "true" then
r = server.execute("mixer.select #{source_number} true") print(r)
r = server.execute("mixer.volume #{source_number} 1")
print(r)
else
r = server.execute("mixer.volume #{source_number} 0")
print(r)
r = server.execute("mixer.select #{source_number} false")
print(r)
end
"OK"
end
end
)
#
# Namespace: misc #TODO: refactor
#
def fadeTo(source_number) =
if source_number == "" then
print(source_number)
"Usage: mixer.fadeto <source nb> #{source_number}"
else
r = server.execute("mixer.select #{source_number} true")
print(r)
"OK"
end
end
# enable fadeTo for the mixer
server.register(namespace = "mixer",
description = "is fading from one mixer input to another",
usage = "fadeto <source number>",
"fadeto",
fadeTo
)
def icy_update(v) =
# Parse the argument
l = string.split(separator=",",v)
def split(l,v) =
v = string.split(separator="=",v)
if list.length(v) >= 2 then
list.append(l,[(list.nth(v,0,default=""),list.nth(v,1,default=""))])
else
l
end
end
meta = list.fold(split,[],l)
# Update metadata
if s0_enable == true then
icy.update_metadata(
mount=s0_mount,
user=s0_user,
password=s0_pass,
host=s0_host,
port=s0_port,
meta
)
end
if s1_enable == true then
icy.update_metadata(
mount=s1_mount,
user=s1_user,
password=s1_pass, host=s1_host,
port=s1_port,
meta
)
end
if s2_enable == true then
icy.update_metadata(
mount=s2_mount,
user=s2_user,
password=s2_pass,
host=s2_host,
port=s2_port,
meta
)
end
if s3_enable == true then
icy.update_metadata(
mount=s3_mount,
user=s3_user,
password=s3_pass,
host=s3_host,
port=s3_port,
meta
)
end
if s4_enable == true then
icy.update_metadata(
mount=s4_mount,
user=s4_user,
password=s4_pass,
host=s4_host,
port=s4_port,
meta
)
end
"OK"
end
server.register("update", namespace="metadata",
description="Update metadata",
usage="update title=foo,album=bar, ...",
icy_update)