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() this_source_id = !source_id l = request.equeue(id="s#{this_source_id}", length=0.5) l = audio_to_stereo(id="queue_src", l) l = cue_cut(l) l = amplify(1., override="replay_gain", l) # Fade the tracks to avoid hard cuts in between two tracks and at the end of the shows. # Liquidsoap reads the fade in/out durations from the annotation "liq_fade_in/out" which # value can be set via Libretime settings. l = fade.in(l) l = fade.out(l) l = on_metadata(notify_queue, l) sources := list.append([l], !sources) server.register(namespace="queues", "s#{this_source_id}_skip", fun (s) -> begin log("queues.s#{this_source_id}_skip") clear_queue(l) "Done" end) source_id := !source_id + 1 end 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(id="map_metadata:schedule", update=false, append_title, stream_queue) ignore(output.dummy(stream_queue, fallible=true)) def web_stream_set_id(value) web_stream_id := value string_of(!web_stream_id) end def web_stream_get_id() string_of(!web_stream_id) end server.register(namespace="sources", description="Start webstream source", "start_web_stream", fun (s) -> begin log("sources.start_web_stream") notify([("schedule_table_id", !web_stream_id)]) web_stream_enabled := true "enabled" end) server.register(namespace="sources", description="Stop webstream source", "stop_web_stream", fun (s) -> begin log("sources.stop_web_stream") web_stream_enabled := false "disabled" end) server.register(namespace="web_stream", description="Set the web stream id", "set_id", fun (s) -> begin log("web_stream.set_id") web_stream_set_id(s) end) server.register(namespace="web_stream", description="Get the web stream id", "get_id", fun (s) -> begin log("web_stream.get_id") web_stream_get_id() end) default = amplify(id="silence_src", 0.00001, noise()) def map_message_offline(m) = [("title", message_offline())] end default = map_metadata(id="map_metadata:offline", map_message_offline, default) ignore(output.dummy(default, fallible=true)) input_main_streaming = ref false input_show_streaming = ref false schedule_streaming = ref false def start_input_main() input_main_streaming := true end def stop_input_main() input_main_streaming := false end def start_input_show() input_show_streaming := true end def stop_input_show() input_show_streaming := false end def start_schedule() schedule_streaming := true; just_switched := true end def stop_schedule() schedule_streaming := false end def update_source_status(sourcename, status) = gateway("live '#{sourcename}' '#{status}'") end def input_main_on_connect(header) update_source_status("master_dj", true) end def input_main_on_disconnect() update_source_status("master_dj", false) end def input_show_on_connect(header) update_source_status("live_dj", true) end def input_show_on_disconnect() update_source_status("live_dj", false) end def make_input_func(secure) if secure then input.harbor.ssl else input.harbor end end def make_input_auth_handler(input_name) def auth_handler(user, password) log("user '#{user}' connected", label="#{input_name}_input") # Check auth based on return value from auth script ret = test_process("libretime-playout-notify live-auth '#{input_name}' '#{user}' '#{password}'") if ret then log("user '#{user}' authenticated", label="#{input_name}_input") else log("user '#{user}' auth failed", label="#{input_name}_input",level=2) end ret end auth_handler end s = switch(id="switch:blank+schedule", track_sensitive=false, transitions=[transition_default, transition], [({!schedule_streaming}, stream_queue), ({true}, default)] ) s = if input_show_port != 0 and input_show_mount != "" then input_show_func = make_input_func(input_show_secure) input_show_source = audio_to_stereo( input_show_func(id="harbor:input_show", input_show_mount, port=input_show_port, auth=make_input_auth_handler("show"), max=40., on_connect=input_show_on_connect, on_disconnect=input_show_on_disconnect)) ignore(output.dummy(input_show_source, fallible=true)) switch(id="switch:blank+schedule+show", track_sensitive=false, transitions=[transition, transition], [({!input_show_streaming}, input_show_source), ({true}, s)] ) else s end s = if input_main_port != 0 and input_main_mount != "" then input_main_func = make_input_func(input_main_secure) input_main_source = audio_to_stereo( input_main_func(id="harbor:input_main", input_main_mount, port=input_main_port, auth=make_input_auth_handler("main"), max=40., on_connect=input_main_on_connect, on_disconnect=input_main_on_disconnect)) ignore(output.dummy(input_main_source, fallible=true)) switch(id="switch:blank+schedule+show+main", track_sensitive=false, transitions=[transition, transition], [({!input_main_streaming}, input_main_source), ({true}, s)] ) else s end server.register(namespace="sources", description="Stop main input source.", usage="stop_input_main", "stop_input_main", fun (s) -> begin log("sources.stop_input_main") stop_input_main() "Done." end) server.register(namespace="sources", description="Start main input source.", usage="start_input_main", "start_input_main", fun (s) -> begin log("sources.start_input_main") start_input_main() "Done." end) server.register(namespace="sources", description="Stop show input source.", usage="stop_input_show", "stop_input_show", fun (s) -> begin log("sources.stop_input_show") stop_input_show() "Done." end) server.register(namespace="sources", description="Start show input source.", usage="start_input_show", "start_input_show", fun (s) -> begin log("sources.start_input_show") start_input_show() "Done." end) server.register(namespace="sources", description="Stop schedule source.", usage="stop_schedule", "stop_schedule", fun (s) -> begin log("sources.stop_schedule") stop_schedule() "Done." end) server.register(namespace="sources", description="Start schedule source.", usage="start_schedule", "start_schedule", fun (s) -> begin log("sources.start_schedule") start_schedule() "Done." end)