invoke-rc.d airtime-playout restart
################################################ # THIS FILE IS AUTO GENERATED. DO NOT CHANGE!! # ################################################ output_sound_device = false icecast_vorbis_metadata = false s1_enable = true s1_output = "icecast" s1_pass = "%пароль%" s2_output = "icecast" s2_user = "" s2_description = "" s2_genre = "" s3_output = "icecast" s3_user = "" s3_description = "" s3_genre = "" s1_channels = "stereo" s2_channels = "stereo" s3_channels = "stereo" s1_type = "mp3" s1_description = "" s1_genre = "" s2_type = "ogg" s3_url = "%домен%" s3_mount = "live_aac" output_sound_device_type = "None" s1_user = "" s2_port = 8000 master_live_stream_port = 7998 master_live_stream_mp = "master" dj_live_stream_port = 7999 dj_live_stream_mp = "show" off_air_meta = "Airtime - offline" s1_bitrate = 192 s2_enable = true s1_mount = "live" s3_enable = true s1_url = "%домен%" s1_name = "%название станции%" s2_bitrate = 96 s2_pass = "%пароль%" s2_name = "%название станции%" s2_url = "%домен%" s2_mount = "live_ogg" s3_type = "aac" s3_bitrate = 96 s1_host = "src.%домен%" s3_port = 8000 s3_pass = "%пароль%" s3_name = "%название станции%" s2_host = "src.%домен%" s3_host = "src.%домен%" s1_port = 8000 log_file = "/var/log/airtime/pypo-liquidsoap/<script>.log"
%include "/etc/airtime/liquidsoap.cfg" set("log.file.path", log_file) set("server.telnet", true) set("server.telnet.port", 1234) set("init.daemon.pidfile.path", "/var/run/airtime-liquidsoap.pid") %include "library/pervasives.liq" #Dynamic source list #dyn_sources = ref [] webstream_enabled = ref false time = ref string_of(gettimeofday()) #live stream setup set("harbor.bind_addr", "0.0.0.0") current_dyn_id = ref '-1' pypo_data = ref '0' stream_metadata_type = ref 0 default_dj_fade = ref 0. station_name = ref '' show_name = ref '' dynamic_metadata_callback = ref fun (s) -> begin () end s1_connected = ref '' s2_connected = ref '' s3_connected = ref '' s1_namespace = ref '' s2_namespace = ref '' s3_namespace = ref '' 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_airtime(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="vars", "pypo_data", fun (s) -> begin log("vars.pypo_data") pypo_data := s "Done" end) server.register(namespace="vars", "stream_metadata_type", fun (s) -> begin log("vars.stream_metadata_type") stream_metadata_type := int_of_string(s) s end) server.register(namespace="vars", "show_name", fun (s) -> begin log("vars.show_name") show_name := s s end) server.register(namespace="vars", "station_name", fun (s) -> begin log("vars.station_name") station_name := s s end) server.register(namespace="vars", "bootup_time", fun (s) -> begin log("vars.bootup_time") time := s s end) server.register(namespace="streams", "connection_status", fun (s) -> begin log("streams.connection_status") "1:#{!s1_connected},2:#{!s2_connected},3:#{!s3_connected}" end) server.register(namespace="vars", "default_dj_fade", fun (s) -> begin log("vars.default_dj_fade") default_dj_fade := float_of_string(s) s end) 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", !current_dyn_id)]) webstream_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") webstream_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) #server.register(namespace="dynamic_source", # description="Start a new dynamic source.", # usage="start <uri>", # "read_start", # fun (uri) -> begin log("dynamic_source.read_start") begin_stream_read(uri) end) #server.register(namespace="dynamic_source", # description="Stop a dynamic source.", # usage="stop <id>", # "read_stop", # fun (s) -> begin log("dynamic_source.read_stop") stop_stream_read(s) end) #server.register(namespace="dynamic_source", # description="Stop a dynamic source.", # usage="stop <id>", # "read_stop_all", # fun (s) -> begin log("dynamic_source.read_stop") destroy_dynamic_source_all() end) default = amplify(id="silence_src", 0.00001, noise()) ref_off_air_meta = ref off_air_meta if !ref_off_air_meta == "" then ref_off_air_meta := "Airtime - offline" end default = rewrite_metadata([("title", !ref_off_air_meta)], 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) = command = "/usr/lib/airtime/pypo/bin/liquidsoap_scripts/notify.sh --source-name=#{sourcename} --source-status=#{status} &" system(command) log(command) 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 def check_master_dj_client(user,password) = log("master connected") #get the output of the php script ret = get_process_lines("python /usr/lib/airtime/pypo/bin/liquidsoap_scripts/liquidsoap_auth.py --master #{user} #{password}") #ret has now the value of the live client (dj1,dj2, or djx), or "ERROR"/"unknown" ... ret = list.hd(ret) #return true to let the client transmit data, or false to tell harbor to decline ret == "True" end def check_dj_client(user,password) = log("live dj connected") #get the output of the php script ret = get_process_lines("python /usr/lib/airtime/pypo/bin/liquidsoap_scripts/liquidsoap_auth.py --dj #{user} #{password}") #ret has now the value of the live client (dj1,dj2, or djx), or "ERROR"/"unknown" ... hd = list.hd(ret) log("Live DJ authenticated: #{hd}") hd == "True" 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 # Attach a skip command to the source s: #add_skip_command(s) 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 if s1_output == 'shoutcast' then s1_namespace := "shoutcast_stream_1" else s1_namespace := s1_mount end server.register(namespace=!s1_namespace, "connected", fun (s) -> begin log("#{!s1_namespace}.connected") !s1_connected end) 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_connected, s1_name, s1_channels) end if s2_enable == true then if s2_output == 'shoutcast' then s2_namespace := "shoutcast_stream_2" else s2_namespace := s2_mount end server.register(namespace=!s2_namespace, "connected", fun (s) -> begin log("#{!s2_namespace}.connected") !s2_connected end) 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_connected, s2_name, s2_channels) end if s3_enable == true then if s3_output == 'shoutcast' then s3_namespace := "shoutcast_stream_3" else s3_namespace := s3_mount end server.register(namespace=!s3_namespace, "connected", fun (s) -> begin log("#{!s3_namespace}.connected") !s3_connected end) output_to(s3_output, s3_type, s3_bitrate, s3_host, s3_port, s3_pass, s3_mount, s3_url, s3_name, s3_genre, s3_user, s, "3", s3_connected, s3_description, s3_channels) end command = "/usr/lib/airtime/pypo/bin/liquidsoap_scripts/notify.sh --liquidsoap-started &" log(command) system(command)
2016/12/05 10:27:58 [server:3] New client: localhost. 2016/12/05 10:27:58 [server:3] Client localhost disconnected. 2016/12/05 10:28:08 [server:3] New client: localhost. 2016/12/05 10:28:08 [server:3] Client localhost disconnected. 2016/12/05 10:28:17 [lang:3] live dj connected 2016/12/05 10:28:18 [lang:3] Live DJ authenticated: True 2016/12/05 10:28:18 [decoder:3] Method "MAD" accepted "audio/mpeg". 2016/12/05 10:28:18 [lang:3] /usr/lib/airtime/pypo/bin/liquidsoap_scripts/notify.sh --source-name=live_dj --source-status=true & 2016/12/05 10:28:18 [threads:3] Created thread "harbor source feeding" (3 total). 2016/12/05 10:28:18 [live_dj_harbor:3] Decoding... 2016/12/05 10:28:18 [stdout:3] 2016/12/05 10:28:18 [stdout:3] ######################################### 2016/12/05 10:28:18 [stdout:3] # *** pypo *** # 2016/12/05 10:28:18 [stdout:3] # pypo notification gateway # 2016/12/05 10:28:18 [stdout:3] ######################################### 2016/12/05 10:28:18 [server:3] New client: localhost. 2016/12/05 10:28:18 [server:3] Client localhost disconnected. 2016/12/05 10:28:19 [show_schedule_noise_switch:3] Switch to audio_to_stereo_5647 with transition. 2016/12/05 10:28:19 [lang:3] transition called... 2016/12/05 10:28:23 [lang:3] live dj connected 2016/12/05 10:28:23 [lang:3] Live DJ authenticated: True 2016/12/05 10:28:23 [live_dj_harbor:3] New metadata chunk ? -- . 2016/12/05 10:28:28 [server:3] New client: localhost. 2016/12/05 10:28:28 [server:3] Client localhost disconnected. 2016/12/05 10:28:38 [server:3] New client: localhost. 2016/12/05 10:28:38 [server:3] Client localhost disconnected. 2016/12/05 10:28:48 [server:3] New client: localhost. 2016/12/05 10:28:48 [server:3] Client localhost disconnected. 2016/12/05 10:28:59 [server:3] New client: localhost. 2016/12/05 10:28:59 [server:3] Client localhost disconnected. 2016/12/05 10:29:09 [server:3] New client: localhost. 2016/12/05 10:29:09 [server:3] Client localhost disconnected.
6 •