338 lines
9.6 KiB
Plaintext
338 lines
9.6 KiB
Plaintext
boot_timestamp = interactive.string("boot_timestamp", string_of(gettimeofday()))
|
|
|
|
web_stream_enabled = ref false
|
|
web_stream_id = ref '-1'
|
|
|
|
show_name = interactive.string("show_name", "")
|
|
|
|
dynamic_metadata_callback = ref fun (~new_track=false, s) -> begin () end
|
|
|
|
just_switched = ref false
|
|
|
|
%include "ls_lib.liq"
|
|
|
|
sources = ref []
|
|
source_id = ref 0
|
|
|
|
def create_source()
|
|
l = request.equeue(id="s#{!source_id}", length=0.5)
|
|
|
|
l = audio_to_stereo(id="queue_src", l)
|
|
l = cue_cut(l)
|
|
l = amplify(1., override="replay_gain", l)
|
|
|
|
# the crossfade function controls fade in/out
|
|
l = crossfade(duration=0., smart=true, l)
|
|
|
|
l = on_metadata(notify_queue, l)
|
|
|
|
sources := list.append([l], !sources)
|
|
server.register(namespace="queues",
|
|
"s#{!source_id}_skip",
|
|
fun (s) -> begin log("queues.s#{!source_id}_skip")
|
|
clear_queue(l)
|
|
"Done"
|
|
end)
|
|
source_id := !source_id + 1
|
|
end
|
|
|
|
create_source()
|
|
create_source()
|
|
create_source()
|
|
create_source()
|
|
|
|
create_source()
|
|
create_source()
|
|
create_source()
|
|
create_source()
|
|
|
|
queue = add(!sources, normalize=false)
|
|
pair = insert_metadata(queue)
|
|
dynamic_metadata_callback := fst(pair)
|
|
queue = snd(pair)
|
|
|
|
output.dummy(fallible=true, queue)
|
|
|
|
http = input.http_restart(id="http")
|
|
http = cross_http(http_input_id="http",http)
|
|
output.dummy(fallible=true, http)
|
|
stream_queue = http_fallback(http_input_id="http", http=http, default=queue)
|
|
stream_queue = map_metadata(update=false, append_title, stream_queue)
|
|
|
|
ignore(output.dummy(stream_queue, fallible=true))
|
|
|
|
server.register(namespace="dynamic_source",
|
|
description="Enable webstream output",
|
|
usage='start',
|
|
"output_start",
|
|
fun (s) -> begin log("dynamic_source.output_start")
|
|
notify([("schedule_table_id", !web_stream_id)])
|
|
web_stream_enabled := true "enabled" end)
|
|
server.register(namespace="dynamic_source",
|
|
description="Enable webstream output",
|
|
usage='stop',
|
|
"output_stop",
|
|
fun (s) -> begin log("dynamic_source.output_stop") web_stream_enabled := false "disabled" end)
|
|
|
|
server.register(namespace="dynamic_source",
|
|
description="Set the streams cc_schedule row id",
|
|
usage="id <id>",
|
|
"id",
|
|
fun (s) -> begin log("dynamic_source.id") set_dynamic_source_id(s) end)
|
|
|
|
server.register(namespace="dynamic_source",
|
|
description="Get the streams cc_schedule row id",
|
|
usage="get_id",
|
|
"get_id",
|
|
fun (s) -> begin log("dynamic_source.get_id") get_dynamic_source_id() end)
|
|
|
|
default = amplify(id="silence_src", 0.00001, noise())
|
|
|
|
def map_message_offline(m) =
|
|
[("title", message_offline())]
|
|
end
|
|
|
|
default = map_metadata(map_message_offline, default)
|
|
ignore(output.dummy(default, fallible=true))
|
|
|
|
master_dj_enabled = ref false
|
|
live_dj_enabled = ref false
|
|
scheduled_play_enabled = ref false
|
|
|
|
def make_master_dj_available()
|
|
master_dj_enabled := true
|
|
end
|
|
|
|
def make_master_dj_unavailable()
|
|
master_dj_enabled := false
|
|
end
|
|
|
|
def make_live_dj_available()
|
|
live_dj_enabled := true
|
|
end
|
|
|
|
def make_live_dj_unavailable()
|
|
live_dj_enabled := false
|
|
end
|
|
|
|
def make_scheduled_play_available()
|
|
scheduled_play_enabled := true
|
|
just_switched := true
|
|
end
|
|
|
|
def make_scheduled_play_unavailable()
|
|
scheduled_play_enabled := false
|
|
end
|
|
|
|
def update_source_status(sourcename, status) =
|
|
gateway("live '#{sourcename}' '#{status}'")
|
|
end
|
|
|
|
def live_dj_connect(header) =
|
|
update_source_status("live_dj", true)
|
|
end
|
|
|
|
def live_dj_disconnect() =
|
|
update_source_status("live_dj", false)
|
|
end
|
|
|
|
def master_dj_connect(header) =
|
|
update_source_status("master_dj", true)
|
|
end
|
|
|
|
def master_dj_disconnect() =
|
|
update_source_status("master_dj", false)
|
|
end
|
|
|
|
# Auth function for live stream
|
|
# @Category LiveStream
|
|
# @param user Username to check against LibreTime API
|
|
# @param password Password to check against LibreTime API
|
|
# @param ~type Type of password to check, "dj" or "master, default: "master"
|
|
def check_auth(user="", password="", ~type="master") =
|
|
log("#{type} user #{user} connected",label="#{type}_source")
|
|
|
|
# Check auth based on return value from auth script
|
|
ret = test_process("python3 #{auth_path} --#{type} #{user} #{password}")
|
|
|
|
if ret then
|
|
log("#{type} user #{user} authenticated",label="#{type}_source")
|
|
else
|
|
log("#{type} user #{user} auth failed",label="#{type}_source",level=2)
|
|
end
|
|
|
|
ret
|
|
end
|
|
|
|
# Check master source auth
|
|
# @Category LiveStream
|
|
# @param user Username to check against LibreTime API
|
|
# @param password Password to check against LibreTime API
|
|
def check_master_dj_client(user, password) =
|
|
check_auth(user, password)
|
|
end
|
|
|
|
# Check dj/show source auth
|
|
# @Category LiveStream
|
|
# @param user Username to check against LibreTime API
|
|
# @param password Password to check against LibreTime API
|
|
def check_dj_client(user, password) =
|
|
check_auth(user, password, type="dj")
|
|
end
|
|
|
|
s = switch(id="schedule_noise_switch",
|
|
track_sensitive=false,
|
|
transitions=[transition_default, transition],
|
|
[({!scheduled_play_enabled}, stream_queue), ({true}, default)]
|
|
)
|
|
|
|
s = if dj_live_stream_port != 0 and dj_live_stream_mp != "" then
|
|
dj_live =
|
|
audio_to_stereo(
|
|
input.harbor(id="live_dj_harbor",
|
|
dj_live_stream_mp,
|
|
port=dj_live_stream_port,
|
|
auth=check_dj_client,
|
|
max=40.,
|
|
on_connect=live_dj_connect,
|
|
on_disconnect=live_dj_disconnect))
|
|
|
|
ignore(output.dummy(dj_live, fallible=true))
|
|
|
|
switch(id="show_schedule_noise_switch",
|
|
track_sensitive=false,
|
|
transitions=[transition, transition],
|
|
[({!live_dj_enabled}, dj_live), ({true}, s)]
|
|
)
|
|
else
|
|
s
|
|
end
|
|
|
|
s = if master_live_stream_port != 0 and master_live_stream_mp != "" then
|
|
master_dj =
|
|
audio_to_stereo(
|
|
input.harbor(id="master_harbor",
|
|
master_live_stream_mp,
|
|
port=master_live_stream_port,
|
|
auth=check_master_dj_client,
|
|
max=40.,
|
|
on_connect=master_dj_connect,
|
|
on_disconnect=master_dj_disconnect))
|
|
|
|
ignore(output.dummy(master_dj, fallible=true))
|
|
|
|
switch(id="master_show_schedule_noise_switch",
|
|
track_sensitive=false,
|
|
transitions=[transition, transition],
|
|
[({!master_dj_enabled}, master_dj), ({true}, s)]
|
|
)
|
|
else
|
|
s
|
|
end
|
|
|
|
server.register(namespace="streams",
|
|
description="Stop Master DJ source.",
|
|
usage="master_dj_stop",
|
|
"master_dj_stop",
|
|
fun (s) -> begin log("streams.master_dj_stop") make_master_dj_unavailable() "Done." end)
|
|
server.register(namespace="streams",
|
|
description="Start Master DJ source.",
|
|
usage="master_dj_start",
|
|
"master_dj_start",
|
|
fun (s) -> begin log("streams.master_dj_start") make_master_dj_available() "Done." end)
|
|
server.register(namespace="streams",
|
|
description="Stop Live DJ source.",
|
|
usage="live_dj_stop",
|
|
"live_dj_stop",
|
|
fun (s) -> begin log("streams.live_dj_stop") make_live_dj_unavailable() "Done." end)
|
|
server.register(namespace="streams",
|
|
description="Start Live DJ source.",
|
|
usage="live_dj_start",
|
|
"live_dj_start",
|
|
fun (s) -> begin log("streams.live_dj_start") make_live_dj_available() "Done." end)
|
|
server.register(namespace="streams",
|
|
description="Stop Scheduled Play source.",
|
|
usage="scheduled_play_stop",
|
|
"scheduled_play_stop",
|
|
fun (s) -> begin log("streams.scheduled_play_stop") make_scheduled_play_unavailable() "Done." end)
|
|
server.register(namespace="streams",
|
|
description="Start Scheduled Play source.",
|
|
usage="scheduled_play_start",
|
|
"scheduled_play_start",
|
|
fun (s) -> begin log("streams.scheduled_play_start") make_scheduled_play_available() "Done." end)
|
|
|
|
if output_sound_device then
|
|
success = ref false
|
|
|
|
log(output_sound_device_type)
|
|
|
|
%ifdef output.alsa
|
|
if output_sound_device_type == "ALSA" then
|
|
ignore(output.alsa(s))
|
|
success := true
|
|
end
|
|
%endif
|
|
|
|
%ifdef output.ao
|
|
if output_sound_device_type == "AO" then
|
|
ignore(output.ao(s))
|
|
success := true
|
|
end
|
|
%endif
|
|
|
|
%ifdef output.oss
|
|
if output_sound_device_type == "OSS" then
|
|
ignore(output.oss(s))
|
|
success := true
|
|
end
|
|
%endif
|
|
|
|
%ifdef output.portaudio
|
|
if output_sound_device_type == "Portaudio" then
|
|
ignore(output.portaudio(s))
|
|
success := true
|
|
end
|
|
%endif
|
|
|
|
%ifdef output.pulseaudio
|
|
if output_sound_device_type == "Pulseaudio" then
|
|
ignore(output.pulseaudio(s))
|
|
success := true
|
|
end
|
|
%endif
|
|
|
|
if (!success == false) then
|
|
ignore(output.prefered(s))
|
|
end
|
|
|
|
end
|
|
|
|
if s1_enable == true then
|
|
output_to(s1_output, s1_type, s1_bitrate, s1_host, s1_port, s1_pass,
|
|
s1_mount, s1_url, s1_description, s1_genre, s1_user, s, "1",
|
|
s1_name, s1_channels)
|
|
end
|
|
|
|
if s2_enable == true then
|
|
output_to(s2_output, s2_type, s2_bitrate, s2_host, s2_port, s2_pass,
|
|
s2_mount, s2_url, s2_description, s2_genre, s2_user, s, "2",
|
|
s2_name, s2_channels)
|
|
|
|
end
|
|
|
|
if s3_enable == true then
|
|
output_to(s3_output, s3_type, s3_bitrate, s3_host, s3_port, s3_pass,
|
|
s3_mount, s3_url, s3_description, s3_genre, s3_user, s, "3",
|
|
s3_name, s3_channels)
|
|
end
|
|
|
|
if s4_enable == true then
|
|
log("Stream 4 Enabled")
|
|
output_to(s4_output, s4_type, s4_bitrate, s4_host, s4_port, s4_pass,
|
|
s4_mount, s4_url, s4_name, s4_genre, s4_user, s, "4",
|
|
s4_description, s4_channels)
|
|
end
|
|
|
|
|
|
gateway("started")
|