modules/liquidsoap/out_filesystem.liq

+#
+#  engine
+#
+#  Playout Daemon for autoradio project
+#
+#
+#  Copyright (C) 2017-2018 Gottfried Gaisbauer <gottfried.gaisbauer@servus.at>
+#
+#  This file is part of engine.
+#
+#  engine is free software: you can redistribute it and/or modify
+#  it under the terms of the GNU General Public License as published by
+#  the Free Software Foundation, either version 3 of the License, or
+#  any later version.
+#
+#  engine 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 General Public License for more details.
+#
+#  You should have received a copy of the GNU General Public License
+#  along with engine. If not, see <http://www.gnu.org/licenses/>.
+#
+
+r0_enable = list.assoc("rec_0", ini) == "y"
+r1_enable = list.assoc("rec_1", ini) == "y"
+r2_enable = list.assoc("rec_2", ini) == "y"
+r3_enable = list.assoc("rec_3", ini) == "y"
+r4_enable = list.assoc("rec_4", ini) == "y"
+
+r0_folder = list.assoc("rec_0_folder", ini)
+r0_duration = int_of_string(list.assoc("rec_0_duration", ini))
+r0_encoding = list.assoc("rec_0_encoding", ini)
+r0_bitrate = int_of_string(list.assoc("rec_0_bitrate", ini))
+r0_channels = list.assoc("rec_0_channels", ini)
+r0_filenamepattern = r0_folder^"/%Y-%m-%d/%Y-%m-%d-%H-%M."^r0_encoding
+
+r1_folder = list.assoc("rec_1_folder", ini)
+r1_duration = int_of_string(list.assoc("rec_1_duration", ini))
+r1_encoding = list.assoc("rec_1_encoding", ini)
+r1_bitrate = int_of_string(list.assoc("rec_1_bitrate", ini))
+r1_channels = list.assoc("rec_1_channels", ini)
+r1_filenamepattern = r1_folder^"/%Y-%m-%d/%Y-%m-%d-%H-%M."^r1_encoding
+
+r2_folder = list.assoc("rec_2_folder", ini)
+r2_duration = int_of_string(list.assoc("rec_2_duration", ini))
+r2_encoding = list.assoc("rec_2_encoding", ini)
+r2_bitrate = int_of_string(list.assoc("rec_2_bitrate", ini))
+r2_channels = list.assoc("rec_2_channels", ini)
+r2_filenamepattern = r2_folder^"/%Y-%m-%d/%Y-%m-%d-%H-%M."^r2_encoding
+
+r3_folder = list.assoc("rec_3_folder", ini)
+r3_duration = int_of_string(list.assoc("rec_3_duration", ini))
+r3_encoding = list.assoc("rec_3_encoding", ini)
+r3_bitrate = int_of_string(list.assoc("rec_3_bitrate", ini))
+r3_channels = list.assoc("rec_3_channels", ini)
+r3_filenamepattern = r3_folder^"/%Y-%m-%d/%Y-%m-%d-%H-%M."^r3_encoding
+
+r4_folder = list.assoc("rec_4_folder", ini)
+r4_duration = int_of_string(list.assoc("rec_4_duration", ini))
+r4_encoding = list.assoc("rec_4_encoding", ini)
+r4_bitrate = int_of_string(list.assoc("rec_4_bitrate", ini))
+r4_channels = list.assoc("rec_4_channels", ini)
+r4_filenamepattern = r4_folder^"/%Y-%m-%d/%Y-%m-%d-%H-%M."^r4_encoding
+
+r0_is_recording = ref false
+r1_is_recording = ref false
+r2_is_recording = ref false
+r3_is_recording = ref false
+r4_is_recording = ref false
+
+if r0_enable == true then
+    # enable recording status for that recorder
+    server.register(namespace="recorder_0", "recording", fun (s) -> begin if !r0_is_recording == false then "false" else "true" end end)
+
+    # start the recorder
+    start_recorder(r0_folder, r0_duration, r0_encoding, r0_bitrate, r0_channels, r0_filenamepattern, r0_is_recording, output_source, "0")
+end
+
+if r1_enable == true then
+    server.register(namespace="recorder_1", "recording", fun (s) -> begin if !r1_is_recording == false then "false" else "true" end  end)
+    start_recorder(r1_folder, r1_duration, r1_encoding, r1_bitrate, r1_channels, r1_filenamepattern, r1_is_recording, output_source, "1")
+end
+
+if r2_enable == true then
+    server.register(namespace="recorder_2", "recording", fun (s) -> begin if !r2_is_recording == false then "false" else "true" end  end)
+    start_recorder(r2_folder, r2_duration, r2_encoding, r2_bitrate, r2_channels, r2_filenamepattern, r2_is_recording, output_source, "2")
+end
+
+if r3_enable == true then
+    server.register(namespace="recorder_3", "recording", fun (s) -> begin if !r3_is_recording == false then "false" else "true" end  end)
+    start_recorder(r3_folder, r3_duration, r3_encoding, r3_bitrate, r3_channels, r3_filenamepattern, r3_is_recording, output_source, "3")
+end
+
+if r4_enable == true then
+    server.register(namespace="recorder_4", "recording", fun (s) -> begin if !r4_is_recording == false then "false" else "true" end  end)
+    start_recorder(r4_folder, r4_duration, r4_encoding, r4_bitrate, r4_channels, r4_filenamepattern, r4_is_recording, output_source, "4")
+end
\ No newline at end of file

modules/liquidsoap/out_soundcard.liq

+#
+#  engine
+#
+#  Playout Daemon for autoradio project
+#
+#
+#  Copyright (C) 2017-2018 Gottfried Gaisbauer <gottfried.gaisbauer@servus.at>
+#
+#  This file is part of engine.
+#
+#  engine is free software: you can redistribute it and/or modify
+#  it under the terms of the GNU General Public License as published by
+#  the Free Software Foundation, either version 3 of the License, or
+#  any later version.
+#
+#  engine 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 General Public License for more details.
+#
+#  You should have received a copy of the GNU General Public License
+#  along with engine. If not, see <http://www.gnu.org/licenses/>.
+#
+
+if a0_out != "" then
+    ignore(get_output(output_source, a0_out, "aura_lineout_0"))
+end
+
+if a1_out != "" then
+    ignore(get_output(output_source, a1_out, "aura_lineout_1"))
+end
+
+if a2_out != "" then
+    ignore(get_output(output_source, a2_out, "aura_lineout_2"))
+end
+
+if a3_out != "" then
+    ignore(get_output(output_source, a3_out, "aura_lineout_3"))
+end
+
+if a4_out != "" then
+    ignore(get_output(output_source, a4_out, "aura_lineout_4"))
+
+    #output_4 = ref output.dummy(blank())
+    #get_output(output_4, output_source, a4_out, "aura_lineout_4")
+
+    #output_4 := get_output(output_source, a4_out, "aura_lineout_4")
+    #get_output(output_source, a4_out, "aura_lineout_4")
+end

modules/liquidsoap/out_stream.liq

+#
+#  engine
+#
+#  Playout Daemon for autoradio project
+#
+#
+#  Copyright (C) 2017-2018 Gottfried Gaisbauer <gottfried.gaisbauer@servus.at>
+#
+#  This file is part of engine.
+#
+#  engine is free software: you can redistribute it and/or modify
+#  it under the terms of the GNU General Public License as published by
+#  the Free Software Foundation, either version 3 of the License, or
+#  any later version.
+#
+#  engine 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 General Public License for more details.
+#
+#  You should have received a copy of the GNU General Public License
+#  along with engine. If not, see <http://www.gnu.org/licenses/>.
+#
+
+# Output streaming settings
+# What a mess...
+s0_enable = list.assoc("stream_0", ini) == "y"
+s1_enable = list.assoc("stream_1", ini) == "y"
+s2_enable = list.assoc("stream_2", ini) == "y"
+s3_enable = list.assoc("stream_3", ini) == "y"
+s4_enable = list.assoc("stream_4", ini) == "y"
+
+s0_encoding = list.assoc("stream_0_encoding", ini)
+s0_bitrate = int_of_string(list.assoc("stream_0_bitrate", ini))
+s0_host = list.assoc("stream_0_host", ini)
+s0_port = int_of_string(list.assoc("stream_0_port", ini))
+s0_user = list.assoc("stream_0_user", ini)
+s0_pass = list.assoc("stream_0_password", ini)
+s0_mount = list.assoc("stream_0_mountpoint", ini)
+s0_url = list.assoc("stream_0_displayurl", ini)
+s0_desc = list.assoc("stream_0_description", ini)
+s0_genre = list.assoc("stream_0_genre", ini)
+s0_name = list.assoc("stream_0_name", ini)
+s0_channels = list.assoc("stream_0_channels", ini)
+
+s1_encoding = list.assoc("stream_1_encoding", ini)
+s1_bitrate = int_of_string(list.assoc("stream_1_bitrate", ini))
+s1_host = list.assoc("stream_1_host", ini)
+s1_port = int_of_string(list.assoc("stream_1_port", ini))
+s1_user = list.assoc("stream_1_user", ini)
+s1_pass = list.assoc("stream_1_password", ini)
+s1_mount = list.assoc("stream_1_mountpoint", ini)
+s1_url = list.assoc("stream_1_displayurl", ini)
+s1_desc = list.assoc("stream_1_description", ini)
+s1_genre = list.assoc("stream_1_genre", ini)
+s1_name = list.assoc("stream_1_name", ini)
+s1_channels = list.assoc("stream_1_channels", ini)
+
+s2_encoding = list.assoc("stream_2_encoding", ini)
+s2_bitrate = int_of_string(list.assoc("stream_2_bitrate", ini))
+s2_host = list.assoc("stream_2_host", ini)
+s2_port = int_of_string(list.assoc("stream_2_port", ini))
+s2_user = list.assoc("stream_2_user", ini)
+s2_pass = list.assoc("stream_2_password", ini)
+s2_mount = list.assoc("stream_2_mountpoint", ini)
+s2_url = list.assoc("stream_2_displayurl", ini)
+s2_desc = list.assoc("stream_2_description", ini)
+s2_genre = list.assoc("stream_2_genre", ini)
+s2_name = list.assoc("stream_2_name", ini)
+s2_channels = list.assoc("stream_2_channels", ini)
+
+s3_encoding = list.assoc("stream_3_encoding", ini)
+s3_bitrate = int_of_string(list.assoc("stream_3_bitrate", ini))
+s3_host = list.assoc("stream_3_host", ini)
+s3_port = int_of_string(list.assoc("stream_3_port", ini))
+s3_user = list.assoc("stream_3_user", ini)
+s3_pass = list.assoc("stream_3_password", ini)
+s3_mount = list.assoc("stream_3_mountpoint", ini)
+s3_url = list.assoc("stream_3_displayurl", ini)
+s3_desc = list.assoc("stream_3_description", ini)
+s3_genre = list.assoc("stream_3_genre", ini)
+s3_name = list.assoc("stream_3_name", ini)
+s3_channels = list.assoc("stream_3_channels", ini)
+
+s4_encoding = list.assoc("stream_4_encoding", ini)
+s4_bitrate = int_of_string(list.assoc("stream_4_bitrate", ini))
+s4_host = list.assoc("stream_4_host", ini)
+s4_port = int_of_string(list.assoc("stream_4_port", ini))
+s4_user = list.assoc("stream_4_user", ini)
+s4_pass = list.assoc("stream_4_password", ini)
+s4_mount = list.assoc("stream_4_mountpoint", ini)
+s4_url = list.assoc("stream_4_displayurl", ini)
+s4_desc = list.assoc("stream_4_description", ini)
+s4_genre = list.assoc("stream_4_genre", ini)
+s4_name = list.assoc("stream_4_name", ini)
+s4_channels = list.assoc("stream_4_channels", ini)
+
+s0_connected = ref ''
+s1_connected = ref ''
+s2_connected = ref ''
+s3_connected = ref ''
+s4_connected = ref ''
+
+if s0_enable == true then
+    # enable connection status for that stream
+    server.register(namespace="stream_0", "connected", fun (s) -> begin !s0_connected end)
+
+    # aaand stream
+    stream_to_icecast("stream_0", s0_encoding, s0_bitrate, s0_host, s0_port, s0_pass, s0_mount, s0_url, s0_desc, s0_genre, s0_user, output_source, "0", s0_connected, s0_name, s0_channels)
+end
+
+if s1_enable == true then
+    server.register(namespace="stream_1", "connected", fun (s) -> begin !s1_connected end)
+    stream_to_icecast("stream_1", s1_encoding, s1_bitrate, s1_host, s1_port, s1_pass, s1_mount, s1_url, s1_desc, s1_genre, s1_user, output_source, "1", s1_connected, s1_name, s1_channels)
+end
+
+if s2_enable == true then
+    server.register(namespace="stream_2", "connected", fun (s) -> begin !s2_connected end)
+    stream_to_icecast("stream_2", s2_encoding, s2_bitrate, s2_host, s2_port, s2_pass, s2_mount, s2_url, s2_desc, s2_genre, s2_user, output_source, "2", s2_connected, s2_name, s2_channels)
+end
+
+if s3_enable == true then
+    server.register(namespace="stream_3", "connected", fun (s) -> begin !s3_connected end)
+    stream_to_icecast("stream_3", s3_encoding, s3_bitrate, s3_host, s3_port, s3_pass, s3_mount, s3_url, s3_desc, s3_genre, s3_user, output_source, "3", s3_connected, s3_name, s3_channels)
+end
+
+if s4_enable == true then
+    server.register(namespace="stream_4", "connected", fun (s) -> begin !s4_connected end)
+    stream_to_icecast("stream_4", s4_encoding, s4_bitrate, s4_host, s4_port, s4_pass, s4_mount, s4_url, s4_desc, s4_genre, s4_user, output_source, "4", s4_connected, s4_name, s4_channels)
+end

modules/liquidsoap/outgoing_recordings/aac.liq

+if bitrate == 24 then 
+    if stereo then
+        ignore(output_filesystem_stereo(%aac(bitrate = 24, channels = 2), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%aac(bitrate = 24, channels = 1), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 32 then
+    if stereo then
+        ignore(output_filesystem_stereo(%aac(bitrate = 32, channels = 2), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%aac(bitrate = 32, channels = 1), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 48 then
+    if stereo then
+        ignore(output_filesystem_stereo(%aac(bitrate = 48, channels = 2), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%aac(bitrate = 48, channels = 1), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 64 then
+    if stereo then
+        ignore(output_filesystem_stereo(%aac(bitrate = 64, channels = 2), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%aac(bitrate = 64, channels = 1), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 96 then
+    if stereo then
+        ignore(output_filesystem_stereo(%aac(bitrate = 96, channels = 2), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%aac(bitrate = 96, channels = 1), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 128 then
+    if stereo then
+        ignore(output_filesystem_stereo(%aac(bitrate = 128, channels = 2), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%aac(bitrate = 128, channels = 1), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 160 then
+    if stereo then
+        ignore(output_filesystem_stereo(%aac(bitrate = 160, channels = 2), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%aac(bitrate = 160, channels = 1), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 192 then
+    if stereo then
+        ignore(output_filesystem_stereo(%aac(bitrate = 192, channels = 2), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%aac(bitrate = 192, channels = 1), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 224 then
+    if stereo then
+        ignore(output_filesystem_stereo(%aac(bitrate = 224, channels = 2), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%aac(bitrate = 224, channels = 1), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 256 then
+    if stereo then
+        ignore(output_filesystem_stereo(%aac(bitrate = 256, channels = 2), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%aac(bitrate = 256, channels = 1), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 320 then
+    if stereo then
+        ignore(output_filesystem_stereo(%aac(bitrate = 320, channels = 2), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%aac(bitrate = 320, channels = 1), filenamepattern, mean(!source)))
+    end
+end
+

modules/liquidsoap/outgoing_recordings/flac.liq

+if bitrate == 24 or bitrate == 32 or bitrate == 48 then
+    if stereo then
+        ignore(output_filesystem_stereo(%flac(samplerate=44100, channels = 2, compression = 7, bits_per_sample=8), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%flac(samplerate=44100, channels = 1, compression = 7, bits_per_sample=8), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 64 then
+    if stereo then
+        ignore(output_filesystem_stereo(%flac(samplerate=44100, channels = 2, compression = 7, bits_per_sample=8), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%flac(samplerate=44100, channels = 1, compression = 7, bits_per_sample=8), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 96 then
+    if stereo then
+        ignore(output_filesystem_stereo(%flac(samplerate=44100, channels = 2, compression = 7, bits_per_sample=8), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%flac(samplerate=44100, channels = 1, compression = 7, bits_per_sample=8), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 128 then
+    if stereo then
+        ignore(output_filesystem_stereo(%flac(samplerate=44100, channels = 2, compression = 6, bits_per_sample=16), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%flac(samplerate=44100, channels = 1, compression = 6, bits_per_sample=16), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 160 then
+    if stereo then
+        ignore(output_filesystem_stereo(%flac(samplerate=44100, channels = 2, compression = 5, bits_per_sample=16), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%flac(samplerate=44100, channels = 1, compression = 5, bits_per_sample=16), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 192 then
+    if stereo then
+        ignore(output_filesystem_stereo(%flac(samplerate=44100, channels = 2, compression = 4, bits_per_sample=16), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%flac(samplerate=44100, channels = 1, compression = 4, bits_per_sample=16), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 224 then
+    if stereo then
+        ignore(output_filesystem_stereo(%flac(samplerate=44100, channels = 2, compression = 3, bits_per_sample=32), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%flac(samplerate=44100, channels = 1, compression = 3, bits_per_sample=32), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 256 then
+    if stereo then
+        ignore(output_filesystem_stereo(%flac(samplerate=44100, channels = 2, compression = 2, bits_per_sample=32), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%flac(samplerate=44100, channels = 1, compression = 2, bits_per_sample=32), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 320 then
+    if stereo then
+        ignore(output_filesystem_stereo(%flac(samplerate=44100, channels = 2, compression = 1, bits_per_sample=32), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%flac(samplerate=44100, channels = 1, compression = 1, bits_per_sample=32), filenamepattern, mean(!source)))
+    end
+end
+

modules/liquidsoap/outgoing_recordings/mp3.liq

+if bitrate == 24 then
+    if stereo then
+        ignore(output_filesystem_stereo(%mp3(bitrate = 24, stereo = true), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%mp3(bitrate = 24, stereo = false), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 32 then
+    if stereo then
+        ignore(output_filesystem_stereo(%mp3(bitrate = 32, stereo = true), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%mp3(bitrate = 32, stereo = false), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 48 then
+    if stereo then
+        ignore(output_filesystem_stereo(%mp3(bitrate = 48, stereo = true), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%mp3(bitrate = 48, stereo = false), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 64 then
+    if stereo then
+        ignore(output_filesystem_stereo(%mp3(bitrate = 64, stereo = true), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%mp3(bitrate = 64, stereo = false), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 96 then
+    if stereo then
+        ignore(output_filesystem_stereo(%mp3(bitrate = 96, stereo = true), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%mp3(bitrate = 96, stereo = false), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 128 then
+    if stereo then
+        ignore(output_filesystem_stereo(%mp3(bitrate = 128, stereo = true), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%mp3(bitrate = 128, stereo = false), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 160 then
+    if stereo then
+        ignore(output_filesystem_stereo(%mp3(bitrate = 160, stereo = true), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%mp3(bitrate = 160, stereo = false), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 192 then
+    if stereo then
+        ignore(output_filesystem_stereo(%mp3(bitrate = 192, stereo = true), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%mp3(bitrate = 192, stereo = false), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 224 then
+    if stereo then
+        ignore(output_filesystem_stereo(%mp3(bitrate = 224, stereo = true), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%mp3(bitrate = 224, stereo = false), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 256 then
+    if stereo then
+        ignore(output_filesystem_stereo(%mp3(bitrate = 256, stereo = true), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%mp3(bitrate = 256, stereo = false), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 320 then
+    if stereo then
+        ignore(output_filesystem_stereo(%mp3(bitrate = 320, stereo = true), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%mp3(bitrate = 320, stereo = false), filenamepattern, mean(!source)))
+    end
+end
+

modules/liquidsoap/outgoing_recordings/ogg.liq

+if bitrate == 24 or bitrate == 32 or bitrate == 48 then
+    if stereo then
+        ignore(output_filesystem_stereo(%vorbis(quality=-0.1, channels = 2), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%vorbis(quality=-0.1, channels = 1), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 64 then
+    if stereo then
+        ignore(output_filesystem_stereo(%vorbis(quality=0, channels = 2), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%vorbis(quality=0, channels = 1), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 96 then
+    if stereo then
+        ignore(output_filesystem_stereo(%vorbis(quality=0.2, channels = 2), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%vorbis(quality=0.2, channels = 1), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 128 then
+    if stereo then
+        ignore(output_filesystem_stereo(%vorbis(quality=0.4, channels = 2), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%vorbis(quality=0.4, channels = 1), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 160 then
+    if stereo then
+        ignore(output_filesystem_stereo(%vorbis(quality=0.5, channels = 2), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%vorbis(quality=0.5, channels = 1), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 192 then
+    if stereo then
+        ignore(output_filesystem_stereo(%vorbis(quality=0.6, channels = 2), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%vorbis(quality=0.6, channels = 1), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 224 then
+    if stereo then
+        ignore(output_filesystem_stereo(%vorbis(quality=0.7, channels = 2), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%vorbis(quality=0.7, channels = 1), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 256 then
+    if stereo then
+        ignore(output_filesystem_stereo(%vorbis(quality=0.8, channels = 2), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%vorbis(quality=0.8, channels = 1), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 320 then
+    if stereo then
+        ignore(output_filesystem_stereo(%vorbis(quality=0.9, channels = 2), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%vorbis(quality=0.9, channels = 1), filenamepattern, mean(!source)))
+    end
+end
+

modules/liquidsoap/outgoing_recordings/opus.liq

+if bitrate == 24 then 
+    if stereo then
+        ignore(output_filesystem_stereo(%opus(bitrate = 24, channels = 2, signal="music", application="audio", complexity=10, vbr="constrained"), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%opus(bitrate = 24, channels = 1, signal="music", application="audio", complexity=10, vbr="constrained"), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 32 then
+    if stereo then
+        ignore(output_filesystem_stereo(%opus(bitrate = 32, channels = 2, signal="music", application="audio", complexity=10, vbr="constrained"), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%opus(bitrate = 32, channels = 1, signal="music", application="audio", complexity=10, vbr="constrained"), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 48 then
+    if stereo then
+        ignore(output_filesystem_stereo(%opus(bitrate = 48, channels = 2, signal="music", application="audio", complexity=10, vbr="constrained"), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%opus(bitrate = 48, channels = 1, signal="music", application="audio", complexity=10, vbr="constrained"), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 64 then
+    if stereo then
+        ignore(output_filesystem_stereo(%opus(bitrate = 64, channels = 2, signal="music", application="audio", complexity=10, vbr="constrained"), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%opus(bitrate = 64, channels = 1, signal="music", application="audio", complexity=10, vbr="constrained"), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 96 then
+    if stereo then
+        ignore(output_filesystem_stereo(%opus(bitrate = 96, channels = 2, signal="music", application="audio", complexity=10, vbr="constrained"), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%opus(bitrate = 96, channels = 1, signal="music", application="audio", complexity=10, vbr="constrained"), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 128 then
+    if stereo then
+        ignore(output_filesystem_stereo(%opus(bitrate = 128, channels = 2, signal="music", application="audio", complexity=10, vbr="constrained"), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%opus(bitrate = 128, channels = 1, signal="music", application="audio", complexity=10, vbr="constrained"), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 160 then
+    if stereo then
+        ignore(output_filesystem_stereo(%opus(bitrate = 160, channels = 2, signal="music", application="audio", complexity=10, vbr="constrained"), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%opus(bitrate = 160, channels = 1, signal="music", application="audio", complexity=10, vbr="constrained"), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 192 then
+    if stereo then
+        ignore(output_filesystem_stereo(%opus(bitrate = 192, channels = 2, signal="music", application="audio", complexity=10, vbr="constrained"), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%opus(bitrate = 192, channels = 1, signal="music", application="audio", complexity=10, vbr="constrained"), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 224 then
+    if stereo then
+        ignore(output_filesystem_stereo(%opus(bitrate = 224, channels = 2, signal="music", application="audio", complexity=10, vbr="constrained"), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%opus(bitrate = 224, channels = 1, signal="music", application="audio", complexity=10, vbr="constrained"), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 256 then
+    if stereo then
+        ignore(output_filesystem_stereo(%opus(bitrate = 256, channels = 2, signal="music", application="audio", complexity=10, vbr="constrained"), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%opus(bitrate = 256, channels = 1, signal="music", application="audio", complexity=10, vbr="constrained"), filenamepattern, mean(!source)))
+    end
+elsif bitrate == 320 then
+    if stereo then
+        ignore(output_filesystem_stereo(%opus(bitrate = 320, channels = 2, signal="music", application="audio", complexity=10, vbr="constrained"), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%opus(bitrate = 320, channels = 1, signal="music", application="audio", complexity=10, vbr="constrained"), filenamepattern, mean(!source)))
+    end
+end
+

modules/liquidsoap/outgoing_recordings/wav.liq

+if bitrate <= 128 then
+    if stereo then
+        ignore(output_filesystem_stereo(%wav(stereo=true, channels=2, samplesize=8, header=true, duration=30.), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%wav(stereo=false, channels=1, samplesize=8, header=true, duration=30.), filenamepattern, mean(!source)))
+    end
+else
+    if stereo then
+        ignore(output_filesystem_stereo(%wav(stereo=true, channels=2, samplesize=16, header=true, duration=30.), filenamepattern, !source))
+    else
+        ignore(output_filesystem_mono(%wav(stereo=false, channels=1, samplesize=16, header=true, duration=30.), filenamepattern, mean(!source)))
+    end
+end
\ No newline at end of file

modules/liquidsoap/outgoing_streams/aac.liq

+if bitrate == 24 then 
+    if stereo then
+        ignore(output_icecast_stereo(%aac(bitrate = 24, channels = 2), !source))
+    else
+        ignore(output_icecast_mono(%aac(bitrate = 24, channels = 1), mean(!source)))
+    end
+elsif bitrate == 32 then
+    if stereo then
+        ignore(output_icecast_stereo(%aac(bitrate = 32, channels = 2), !source))
+    else
+        ignore(output_icecast_mono(%aac(bitrate = 32, channels = 1), mean(!source)))
+    end
+elsif bitrate == 48 then
+    if stereo then
+        ignore(output_icecast_stereo(%aac(bitrate = 48, channels = 2), !source))
+    else
+        ignore(output_icecast_mono(%aac(bitrate = 48, channels = 1), mean(!source)))
+    end
+elsif bitrate == 64 then
+    if stereo then
+        ignore(output_icecast_stereo(%aac(bitrate = 64, channels = 2), !source))
+    else
+        ignore(output_icecast_mono(%aac(bitrate = 64, channels = 1), mean(!source)))
+    end
+elsif bitrate == 96 then
+    if stereo then
+        ignore(output_icecast_stereo(%aac(bitrate = 96, channels = 2), !source))
+    else
+        ignore(output_icecast_mono(%aac(bitrate = 96, channels = 1), mean(!source)))
+    end
+elsif bitrate == 128 then
+    if stereo then
+        ignore(output_icecast_stereo(%aac(bitrate = 128, channels = 2), !source))
+    else
+        ignore(output_icecast_mono(%aac(bitrate = 128, channels = 1), mean(!source)))
+    end
+elsif bitrate == 160 then
+    if stereo then
+        ignore(output_icecast_stereo(%aac(bitrate = 160, channels = 2), !source))
+    else
+        ignore(output_icecast_mono(%aac(bitrate = 160, channels = 1), mean(!source)))
+    end
+elsif bitrate == 192 then
+    if stereo then
+        ignore(output_icecast_stereo(%aac(bitrate = 192, channels = 2), !source))
+    else
+        ignore(output_icecast_mono(%aac(bitrate = 192, channels = 1), mean(!source)))
+    end
+elsif bitrate == 224 then
+    if stereo then
+        ignore(output_icecast_stereo(%aac(bitrate = 224, channels = 2), !source))
+    else
+        ignore(output_icecast_mono(%aac(bitrate = 224, channels = 1), mean(!source)))
+    end
+elsif bitrate == 256 then
+    if stereo then
+        ignore(output_icecast_stereo(%aac(bitrate = 256, channels = 2), !source))
+    else
+        ignore(output_icecast_mono(%aac(bitrate = 256, channels = 1), mean(!source)))
+    end
+elsif bitrate == 320 then
+    if stereo then
+        ignore(output_icecast_stereo(%aac(bitrate = 320, channels = 2), !source))
+    else
+        ignore(output_icecast_mono(%aac(bitrate = 320, channels = 1), mean(!source)))
+    end
+end
+

modules/liquidsoap/outgoing_streams/flac.liq

+if not icecast_vorbis_metadata then
+    source := add(normalize=false, [amplify(0.00001, noise()), !source])
+end
+
+if bitrate == 24 or bitrate == 32 or bitrate == 48 then
+    if stereo then
+        ignore(output_icecast_stereo(%flac(samplerate=44100, channels = 2, compression = 7, bits_per_sample=8), !source))
+    else
+        ignore(output_icecast_mono(%flac(samplerate=44100, channels = 1, compression = 7, bits_per_sample=8), mean(!source)))
+    end
+elsif bitrate == 64 then
+    if stereo then
+        ignore(output_icecast_stereo(%flac(samplerate=44100, channels = 2, compression = 7, bits_per_sample=8), !source))
+    else
+        ignore(output_icecast_mono(%flac(samplerate=44100, channels = 1, compression = 7, bits_per_sample=8), mean(!source)))
+    end
+elsif bitrate == 96 then
+    if stereo then
+        ignore(output_icecast_stereo(%flac(samplerate=44100, channels = 2, compression = 7, bits_per_sample=8), !source))
+    else
+        ignore(output_icecast_mono(%flac(samplerate=44100, channels = 1, compression = 7, bits_per_sample=8), mean(!source)))
+    end
+elsif bitrate == 128 then
+    if stereo then
+        ignore(output_icecast_stereo(%flac(samplerate=44100, channels = 2, compression = 6, bits_per_sample=16), !source))
+    else
+        ignore(output_icecast_mono(%flac(samplerate=44100, channels = 1, compression = 6, bits_per_sample=16), mean(!source)))
+    end
+elsif bitrate == 160 then
+    if stereo then
+        ignore(output_icecast_stereo(%flac(samplerate=44100, channels = 2, compression = 5, bits_per_sample=16), !source))
+    else
+        ignore(output_icecast_mono(%flac(samplerate=44100, channels = 1, compression = 5, bits_per_sample=16), mean(!source)))
+    end
+elsif bitrate == 192 then
+    if stereo then
+        ignore(output_icecast_stereo(%flac(samplerate=44100, channels = 2, compression = 4, bits_per_sample=16), !source))
+    else
+        ignore(output_icecast_mono(%flac(samplerate=44100, channels = 1, compression = 4, bits_per_sample=16), mean(!source)))
+    end
+elsif bitrate == 224 then
+    if stereo then
+        ignore(output_icecast_stereo(%flac(samplerate=44100, channels = 2, compression = 3, bits_per_sample=32), !source))
+    else
+        ignore(output_icecast_mono(%flac(samplerate=44100, channels = 1, compression = 3, bits_per_sample=32), mean(!source)))
+    end
+elsif bitrate == 256 then
+    if stereo then
+        ignore(output_icecast_stereo(%flac(samplerate=44100, channels = 2, compression = 2, bits_per_sample=32), !source))
+    else
+        ignore(output_icecast_mono(%flac(samplerate=44100, channels = 1, compression = 2, bits_per_sample=32), mean(!source)))
+    end
+elsif bitrate == 320 then
+    if stereo then
+        ignore(output_icecast_stereo(%flac(samplerate=44100, channels = 2, compression = 1, bits_per_sample=32), !source))
+    else
+        ignore(output_icecast_mono(%flac(samplerate=44100, channels = 1, compression = 1, bits_per_sample=32), mean(!source)))
+    end
+end
+

modules/liquidsoap/outgoing_streams/mp3.liq

+if bitrate == 24 then
+    if stereo then
+        ignore(output_icecast_stereo(%mp3(bitrate = 24, stereo = true), !source))
+    else
+        ignore(output_icecast_mono(%mp3(bitrate = 24, stereo = false), mean(!source)))
+    end
+elsif bitrate == 32 then
+    if stereo then
+        ignore(output_icecast_stereo(%mp3(bitrate = 32, stereo = true), !source))
+    else
+        ignore(output_icecast_mono(%mp3(bitrate = 32, stereo = false), mean(!source)))
+    end
+elsif bitrate == 48 then
+    if stereo then
+        ignore(output_icecast_stereo(%mp3(bitrate = 48, stereo = true), !source))
+    else
+        ignore(output_icecast_mono(%mp3(bitrate = 48, stereo = false), mean(!source)))
+    end
+elsif bitrate == 64 then
+    if stereo then
+        ignore(output_icecast_stereo(%mp3(bitrate = 64, stereo = true), !source))
+    else
+        ignore(output_icecast_mono(%mp3(bitrate = 64, stereo = false), mean(!source)))
+    end
+elsif bitrate == 96 then
+    if stereo then
+        ignore(output_icecast_stereo(%mp3(bitrate = 96, stereo = true), !source))
+    else
+        ignore(output_icecast_mono(%mp3(bitrate = 96, stereo = false), mean(!source)))
+    end
+elsif bitrate == 128 then
+    if stereo then
+        ignore(output_icecast_stereo(%mp3(bitrate = 128, stereo = true), !source))
+    else
+        ignore(output_icecast_mono(%mp3(bitrate = 128, stereo = false), mean(!source)))
+    end
+elsif bitrate == 160 then
+    if stereo then
+        ignore(output_icecast_stereo(%mp3(bitrate = 160, stereo = true), !source))
+    else
+        ignore(output_icecast_mono(%mp3(bitrate = 160, stereo = false), mean(!source)))
+    end
+elsif bitrate == 192 then
+    if stereo then
+        ignore(output_icecast_stereo(%mp3(bitrate = 192, stereo = true), !source))
+    else
+        ignore(output_icecast_mono(%mp3(bitrate = 192, stereo = false), mean(!source)))
+    end
+elsif bitrate == 224 then
+    if stereo then
+        ignore(output_icecast_stereo(%mp3(bitrate = 224, stereo = true), !source))
+    else
+        ignore(output_icecast_mono(%mp3(bitrate = 224, stereo = false), mean(!source)))
+    end
+elsif bitrate == 256 then
+    if stereo then
+        ignore(output_icecast_stereo(%mp3(bitrate = 256, stereo = true), !source))
+    else
+        ignore(output_icecast_mono(%mp3(bitrate = 256, stereo = false), mean(!source)))
+    end
+elsif bitrate == 320 then
+    if stereo then
+        ignore(output_icecast_stereo(%mp3(bitrate = 320, stereo = true), !source))
+    else
+        ignore(output_icecast_mono(%mp3(bitrate = 320, stereo = false), mean(!source)))
+    end
+end
+

modules/liquidsoap/outgoing_streams/ogg.liq

+if not icecast_vorbis_metadata then
+    source := add(normalize=false, [amplify(0.00001, noise()), !source])
+end
+
+if bitrate == 24 or bitrate == 32 or bitrate == 48 then
+    if stereo then
+        ignore(output_icecast_stereo(%vorbis(quality=-0.1, channels = 2), !source))
+    else
+        ignore(output_icecast_mono(%vorbis(quality=-0.1, channels = 1), mean(!source)))
+    end
+elsif bitrate == 64 then
+    if stereo then
+        ignore(output_icecast_stereo(%vorbis(quality=0, channels = 2), !source))
+    else
+        ignore(output_icecast_mono(%vorbis(quality=0, channels = 1), mean(!source)))
+    end
+elsif bitrate == 96 then
+    if stereo then
+        ignore(output_icecast_stereo(%vorbis(quality=0.2, channels = 2), !source))
+    else
+        ignore(output_icecast_mono(%vorbis(quality=0.2, channels = 1), mean(!source)))
+    end
+elsif bitrate == 128 then
+    if stereo then
+        ignore(output_icecast_stereo(%vorbis(quality=0.4, channels = 2), !source))
+    else
+        ignore(output_icecast_mono(%vorbis(quality=0.4, channels = 1), mean(!source)))
+    end
+elsif bitrate == 160 then
+    if stereo then
+        ignore(output_icecast_stereo(%vorbis(quality=0.5, channels = 2), !source))
+    else
+        ignore(output_icecast_mono(%vorbis(quality=0.5, channels = 1), mean(!source)))
+    end
+elsif bitrate == 192 then
+    if stereo then
+        ignore(output_icecast_stereo(%vorbis(quality=0.6, channels = 2), !source))
+    else
+        ignore(output_icecast_mono(%vorbis(quality=0.6, channels = 1), mean(!source)))
+    end
+elsif bitrate == 224 then
+    if stereo then
+        ignore(output_icecast_stereo(%vorbis(quality=0.7, channels = 2), !source))
+    else
+        ignore(output_icecast_mono(%vorbis(quality=0.7, channels = 1), mean(!source)))
+    end
+elsif bitrate == 256 then
+    if stereo then
+        ignore(output_icecast_stereo(%vorbis(quality=0.8, channels = 2), !source))
+    else
+        ignore(output_icecast_mono(%vorbis(quality=0.8, channels = 1), mean(!source)))
+    end
+elsif bitrate == 320 then
+    if stereo then
+        ignore(output_icecast_stereo(%vorbis(quality=0.9, channels = 2), !source))
+    else
+        ignore(output_icecast_mono(%vorbis(quality=0.9, channels = 1), mean(!source)))
+    end
+end
+

modules/liquidsoap/outgoing_streams/opus.liq

+if bitrate == 24 then 
+    if stereo then
+        ignore(output_icecast_stereo(%opus(bitrate = 24, channels = 2, signal="music", application="audio", complexity=10, vbr="constrained"), !source))
+    else
+        ignore(output_icecast_mono(%opus(bitrate = 24, channels = 1, signal="music", application="audio", complexity=10, vbr="constrained"), mean(!source)))
+    end
+elsif bitrate == 32 then
+    if stereo then
+        ignore(output_icecast_stereo(%opus(bitrate = 32, channels = 2, signal="music", application="audio", complexity=10, vbr="constrained"), !source))
+    else
+        ignore(output_icecast_mono(%opus(bitrate = 32, channels = 1, signal="music", application="audio", complexity=10, vbr="constrained"), mean(!source)))
+    end
+elsif bitrate == 48 then
+    if stereo then
+        ignore(output_icecast_stereo(%opus(bitrate = 48, channels = 2, signal="music", application="audio", complexity=10, vbr="constrained"), !source))
+    else
+        ignore(output_icecast_mono(%opus(bitrate = 48, channels = 1, signal="music", application="audio", complexity=10, vbr="constrained"), mean(!source)))
+    end
+elsif bitrate == 64 then
+    if stereo then
+        ignore(output_icecast_stereo(%opus(bitrate = 64, channels = 2, signal="music", application="audio", complexity=10, vbr="constrained"), !source))
+    else
+        ignore(output_icecast_mono(%opus(bitrate = 64, channels = 1, signal="music", application="audio", complexity=10, vbr="constrained"), mean(!source)))
+    end
+elsif bitrate == 96 then
+    if stereo then
+        ignore(output_icecast_stereo(%opus(bitrate = 96, channels = 2, signal="music", application="audio", complexity=10, vbr="constrained"), !source))
+    else
+        ignore(output_icecast_mono(%opus(bitrate = 96, channels = 1, signal="music", application="audio", complexity=10, vbr="constrained"), mean(!source)))
+    end
+elsif bitrate == 128 then
+    if stereo then
+        ignore(output_icecast_stereo(%opus(bitrate = 128, channels = 2, signal="music", application="audio", complexity=10, vbr="constrained"), !source))
+    else
+        ignore(output_icecast_mono(%opus(bitrate = 128, channels = 1, signal="music", application="audio", complexity=10, vbr="constrained"), mean(!source)))
+    end
+elsif bitrate == 160 then
+    if stereo then
+        ignore(output_icecast_stereo(%opus(bitrate = 160, channels = 2, signal="music", application="audio", complexity=10, vbr="constrained"), !source))
+    else
+        ignore(output_icecast_mono(%opus(bitrate = 160, channels = 1, signal="music", application="audio", complexity=10, vbr="constrained"), mean(!source)))
+    end
+elsif bitrate == 192 then
+    if stereo then
+        ignore(output_icecast_stereo(%opus(bitrate = 192, channels = 2, signal="music", application="audio", complexity=10, vbr="constrained"), !source))
+    else
+        ignore(output_icecast_mono(%opus(bitrate = 192, channels = 1, signal="music", application="audio", complexity=10, vbr="constrained"), mean(!source)))
+    end
+elsif bitrate == 224 then
+    if stereo then
+        ignore(output_icecast_stereo(%opus(bitrate = 224, channels = 2, signal="music", application="audio", complexity=10, vbr="constrained"), !source))
+    else
+        ignore(output_icecast_mono(%opus(bitrate = 224, channels = 1, signal="music", application="audio", complexity=10, vbr="constrained"), mean(!source)))
+    end
+elsif bitrate == 256 then
+    if stereo then
+        ignore(output_icecast_stereo(%opus(bitrate = 256, channels = 2, signal="music", application="audio", complexity=10, vbr="constrained"), !source))
+    else
+        ignore(output_icecast_mono(%opus(bitrate = 256, channels = 1, signal="music", application="audio", complexity=10, vbr="constrained"), mean(!source)))
+    end
+elsif bitrate == 320 then
+    if stereo then
+        ignore(output_icecast_stereo(%opus(bitrate = 320, channels = 2, signal="music", application="audio", complexity=10, vbr="constrained"), !source))
+    else
+        ignore(output_icecast_mono(%opus(bitrate = 320, channels = 1, signal="music", application="audio", complexity=10, vbr="constrained"), mean(!source)))
+    end
+end
+

modules/liquidsoap/readini.liq

+#
+#  engine
+#
+#  Playout Daemon for autoradio project
+#
+#
+#  Copyright (C) 2017-2018 Gottfried Gaisbauer <gottfried.gaisbauer@servus.at>
+#
+#  This file is part of engine.
+#
+#  engine is free software: you can redistribute it and/or modify
+#  it under the terms of the GNU General Public License as published by
+#  the Free Software Foundation, either version 3 of the License, or
+#  any later version.
+#
+#  engine 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 General Public License for more details.
+#
+#  You should have received a copy of the GNU General Public License
+#  along with engine. If not, see <http://www.gnu.org/licenses/>.
+#
+
+#################
+# Read INI File #
+#################
+
+def read_ini(file)
+  ret = get_process_lines("cat "^file )
+  ret = list.map(string.split(separator="="), ret)
+
+  # l' => the filling list
+  def f(l',l) =
+    if list.length(l) >= 2 then
+      line = string.extract(pattern='"(.*)"', list.nth(l,1))
+
+      #print(line)
+      #print((list.hd(l),line['1']))
+
+      list.append([(list.hd(l),line['1'])],l')
+    else
+      if list.length(l) >= 1 then
+        list.append([(list.hd(l),"")],l')
+      else
+        l'
+      end
+    end
+  end
+
+  # append install dir
+  pwd = get_process_lines("pwd")
+  install_dir = dirname(dirname(list.hd(pwd)))
+
+  list.fold(f, [("install_dir", install_dir)], ret)
+end
\ No newline at end of file

modules/liquidsoap/serverfunctions.liq

+#
+#  engine
+#
+#  Playout Daemon for autoradio project
+#
+#
+#  Copyright (C) 2017-2018 Gottfried Gaisbauer <gottfried.gaisbauer@servus.at>
+#
+#  This file is part of engine.
+#
+#  engine is free software: you can redistribute it and/or modify
+#  it under the terms of the GNU General Public License as published by
+#  the Free Software Foundation, either version 3 of the License, or
+#  any later version.
+#
+#  engine 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 General Public License for more details.
+#
+#  You should have received a copy of the GNU General Public License
+#  along with engine. If not, see <http://www.gnu.org/licenses/>.
+#
+
+# shutdown server function
+#server.register(namespace='server',
+#    description="shutdown server",
+#    usage="stop",
+#    "stop",
+#    fun(x,y) -> shutdown )
+
+
+
+#
+# to reduce complexity of lqs => query 'mixer.inputs' over socket and parse it in python
+#server.register(namespace="auraengine",
+#    "enabled_lineins",
+#    fun (s) -> begin
+#        log("auraengine.enabled_lineins")
+#        "0:#{!linein_0_enabled}, 1:#{!linein_1_enabled}, 2:#{!linein_2_enabled}, 3:#{!linein_3_enabled}, 4:#{!linein_4_enabled}"
+#    end
+#)
+
+#server.register(namespace="auraengine",
+#    "enabled_lineouts",
+#    fun(s) -> begin
+#        log("auraengine.enabled_lineouts")
+#        "0:#{!lineout_0_enabled}, 1:#{!lineout_1_enabled}, 2:#{!lineout_2_enabled}, 3:#{!lineout_3_enabled}, 4:#{!lineout_4_enabled}"
+#    end
+#)
+
+# are outgoing streams connected?
+server.register(namespace="auraengine",
+    description="returns if outgoing streams are connected",
+    usage="out_streams_connected",
+    "out_streams_connected",
+    fun (s) -> begin
+        log("streams.connection_status")
+        "0:#{!s0_connected}, 1:#{!s1_connected}, 2:#{!s2_connected}, 3:#{!s3_connected}, 4:#{!s4_connected}"
+    end
+)
+
+# return a state of the inputs/outputs of the soundserver as JSON
+server.register(namespace = "auraengine",
+    description="returns enabled lineouts/lineins, connected outgoing streams, and recorder. Also returns fallbacksettings.",
+    usage="state",
+    "state",
+    fun(s) -> begin
+        log("auraengine.state")
+
+        ret = '{'
+        ret = ret^'"streams": {'
+        ret = ret^'"stream_0": {"enabled": #{s0_enable}, "connected": #{!s0_connected}},'
+        ret = ret^'"stream_1": {"enabled": #{s1_enable}, "connected": #{!s1_connected}},'
+        ret = ret^'"stream_2": {"enabled": #{s2_enable}, "connected": #{!s2_connected}},'
+        ret = ret^'"stream_3": {"enabled": #{s3_enable}, "connected": #{!s3_connected}},'
+        ret = ret^'"stream_4": {"enabled": #{s4_enable}, "connected": #{!s4_connected}}'
+        ret = ret^'},'
+        ret = ret^'"recorder": {'
+        ret = ret^'"recorder_0": {"enabled": #{r0_enable}, "recording": #{!r0_is_recording}},'
+        ret = ret^'"recorder_1": {"enabled": #{r1_enable}, "recording": #{!r1_is_recording}},'
+        ret = ret^'"recorder_2": {"enabled": #{r2_enable}, "recording": #{!r2_is_recording}},'
+        ret = ret^'"recorder_3": {"enabled": #{r3_enable}, "recording": #{!r3_is_recording}},'
+        ret = ret^'"recorder_4": {"enabled": #{r4_enable}, "recording": #{!r4_is_recording}}'
+        ret = ret^'},'
+        ret = ret^'"linein": {'
+        ret = ret^'"linein_0": {"enabled": #{a0_in != ""}},'
+        ret = ret^'"linein_1": {"enabled": #{a1_in != ""}},'
+        ret = ret^'"linein_2": {"enabled": #{a2_in != ""}},'
+        ret = ret^'"linein_3": {"enabled": #{a3_in != ""}},'
+        ret = ret^'"linein_4": {"enabled": #{a4_in != ""}}'
+        ret = ret^'},'
+        ret = ret^'"lineout": {'
+        ret = ret^'"lineout_0": {"enabled": #{a0_out != ""}},'
+        ret = ret^'"lineout_1": {"enabled": #{a1_out != ""}},'
+        ret = ret^'"lineout_2": {"enabled": #{a2_out != ""}},'
+        ret = ret^'"lineout_3": {"enabled": #{a3_out != ""}},'
+        ret = ret^'"lineout_4": {"enabled": #{a4_out != ""}}'
+        ret = ret^'}'
+        ret = ret^'}'
+        ret
+
+        # outgoing streams enabled?
+        #ret = "stream_0_enabled:#{!s0_enable}, stream_1_enabled:#{!s1_enable}, stream_2_enabled:#{!s2_enable}, stream_3_enabled:#{!s3_enable}, stream_4_enabled:#{!s4_enable}, "
+        # outgoing recorder enabled
+        #ret = ret^"recorder_0_enabled:#{r0_enable}, recorder_1_enabled:#{r1_enable}, recorder_2_enabled:#{r2_enable}, recorder_3_enabled:#{r3_enable}, recorder_4_enabled:#{r4_enable}, "
+        #ret = ret^"linein_0_enabled:#{a0_in != ''}, linein_1_enabled:#{a1_in != ''}, linein_2_enabled:#{a2_in != ''}, linein_3_enabled:#{a3_in != ''}, linein_4_enabled:#{a4_in != ''}, "
+        #ret = ret^"lineout_0_enabled:#{a0_out != ''}, lineout_1_enabled:#{a1_out != ''}, lineout_2_enabled:#{a2_out != ''}, lineout_3_enabled:#{a3_out != ''}, lineout_4_enabled:#{a4_out != ''}, "
+        #ret = ret^"fallback_max_blank:#{fallback_max_blank}, fallback_min_noise:#{fallback_min_noise}, fallback_threshold:#{fallback_threshold}"
+
+    end
+)
+
+# enable the seek function for the input from the filesystem
+server.register(namespace = source.id(input_fs),
+    description="seek to relative position in #{source.id(input_fs)}",
+    usage = "seek <duration in seconds>",
+    "seek",
+    fun(t) -> begin
+        log("Seeking #{t} sec")
+        t = float_of_string(default=0.,t)
+        ret = source.seek(input_fs, t)
+        "Seeked #{ret} seconds."
+    end
+)
+
+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)
+        "Donee!"
+    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
+)
+
+ignore(fade_in_time)
+ignore(fade_out_time)
\ No newline at end of file

modules/liquidsoap/settings.liq

+#
+#  engine
+#
+#  Playout Daemon for autoradio project
+#
+#
+#  Copyright (C) 2017-2018 Gottfried Gaisbauer <gottfried.gaisbauer@servus.at>
+#
+#  This file is part of engine.
+#
+#  engine is free software: you can redistribute it and/or modify
+#  it under the terms of the GNU General Public License as published by
+#  the Free Software Foundation, either version 3 of the License, or
+#  any later version.
+#
+#  engine 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 General Public License for more details.
+#
+#  You should have received a copy of the GNU General Public License
+#  along with engine. If not, see <http://www.gnu.org/licenses/>.
+#
+
+# READ INI FILE
+%include "readini.liq"
+ini = read_ini("../../configuration/engine.ini")
+
+# TELNET SETTINGS
+set("server.telnet", true)
+set("server.telnet.bind_addr", "0.0.0.0")
+set("server.telnet.port", 1234)
+
+# LOG FILE SETTINGS
+set("log.file.path", "./<script>.log")
+
+# SOCKET SETTINGS
+set("server.socket", true)
+set("server.socket.path", "./<script>.sock")
+
+# SOUND CARD SETTINGS
+a0_in = list.assoc("input_device_0", ini)
+a1_in = list.assoc("input_device_1", ini)
+a2_in = list.assoc("input_device_2", ini)
+a3_in = list.assoc("input_device_3", ini)
+a4_in = list.assoc("input_device_4", ini)
+a0_out = list.assoc("output_device_0", ini)
+a1_out = list.assoc("output_device_1", ini)
+a2_out = list.assoc("output_device_2", ini)
+a3_out = list.assoc("output_device_3", ini)
+a4_out = list.assoc("output_device_4", ini)
+
+# FALLBACK SETTINGS
+fallback_max_blank = float_of_string(list.assoc("fallback_max_blank", ini))
+fallback_min_noise = float_of_string(list.assoc("fallback_min_noise", ini))
+fallback_threshold = float_of_string(list.assoc("fallback_threshold", ini))
+
+# FADING SETTINGS
+fade_in_time = list.assoc("fade_in_time", ini) #int_of_string(list.assoc("fade_in_time", ini))
+fade_out_time = list.assoc("fade_out_time", ini) #int_of_string(list.assoc("fade_out_time", ini))
+
+# RECORDER SETTINGS
+#rec_0_filetype = list.assoc("rec_0_filetype", ini)
+#rec_1_filetype = list.assoc("rec_1_filetype", ini)
+#rec_2_filetype = list.assoc("rec_2_filetype", ini)
+#rec_3_filetype = list.assoc("rec_3_filetype", ini)
+#rec_4_filetype = list.assoc("rec_4_filetype", ini)
+
+# ALSA / pulse settings
+soundsystem = list.assoc("soundsystem", ini)
+use_alsa    = soundsystem == "alsa"
+use_jack    = soundsystem == "jack"
+
+if use_alsa then
+    frame_duration     = float_of_string(list.assoc("frame_duration", ini))
+    frame_size         = int_of_string(list.assoc("frame_size", ini))
+    alsa_buffer        = int_of_string(list.assoc("alsa_buffer", ini))
+    alsa_buffer_length = int_of_string(list.assoc("alsa_buffer_length", ini))
+    alsa_periods       = int_of_string(list.assoc("alsa_periods", ini))
+
+    if frame_duration > 0.0 then
+        print("setting frame.duration to #{frame_duration}s")
+        set("frame.duration", frame_duration)
+    end
+    if frame_size > 0 then
+        print("setting frame.size to #{frame_size}")
+        set("frame.audio.size", frame_size)
+    end
+    if alsa_buffer > 0 then
+        print("setting alsa.buffer to #{alsa_buffer}")
+        set("alsa.alsa_buffer", alsa_buffer)
+    end
+    if alsa_buffer > 0 then
+        print("setting alsa.buffer_length to #{alsa_buffer_length}")
+        set("alsa.buffer_length", alsa_buffer_length)
+    end
+    if alsa_periods > 0 then
+        print("setting alsa.periods to #{alsa_periods}")
+        set("alsa.periods", alsa_periods) # assertion error when setting periods other than 0 => alsa default
+    end
+end
+

modules/liquidsoap/unused_record.liq

+
+# %include "readini.liq"
+# ini = read_ini("/etc/aura/engine.ini")
+
+# %include "settings.liq"
+
+# TELNET SETTINGS
+# set("server.telnet", true)
+# set("server.telnet.bind_addr", "0.0.0.0")
+# set("server.telnet.port", 2345)
+
+inst = if argv(1) != "" then string_of(argv(1)) else 'record' end
+instance = ref inst
+
+audiobase = if !instance == 'record' then list.assoc("audiobase", ini) else list.assoc("altaudiobase", ini)  end
+rec_filetype = list.assoc("rec_filetype", ini)
+
+filenamepattern = ref audiobase^"/%Y-%m-%d/%Y-%m-%d-%H-%M.flac"
+
+# Der aktuelle Dateiname für die Aufnahme
+recordingfile = ref ""
+
+# wir definieren eine Referenz für die Stop-Funktion, die aber bisher noch nichts tun kann
+stop_f = ref (fun () -> ())
+
+# bewahre uns davor, dass zweimal gleichzeitig die gleiche Date aufgenommen wird
+is_record_active = ref false
+
+# Stop dump - wir definieren die Funktion, die stop_f ausführt
+def stop_dump() =
+  f = !stop_f
+  f ()
+end
+
+def on_start()
+    recordingfile := list.hd(get_process_lines("date +#{!filenamepattern}"))
+end
+
+# Wav header fixen und ggf. die Aufzeichnung beenden
+def on_close(filename)
+    # es darf wieder aufgenommen werden
+    is_record_active := false
+
+    # if list.assoc("rec_filetype", ini) == 'wav'
+    #     # Korrekten WAV-Header schreiben
+    #     system("qwavheaderdump -F #{filename}")
+
+    # Naechsten Dateinamen vormerken
+    recordingfile := list.hd(get_process_lines("date +#{!filenamepattern}"))
+end
+
+# Der input wie oben definiert
+def get_input()
+    output_source
+    # input.alsa()
+end
+
+def get_output()
+    input = get_input()
+    d = int_of_string(list.assoc("rec_duration", ini))
+    if rec_filetype == 'flac' then
+        log("output file type is FLAC")
+        output.file(
+            id="recorder",
+            %flac(samplerate=44100, channels=2, compression=5, bits_per_sample=16),
+            perm = 0o664,
+            on_start=on_start,
+            !filenamepattern,
+            on_close=on_close,
+            reopen_when={ if !instance == 'record' then int_of_float(gettimeofday()/60.) mod 30 == 0  else false end },
+            input
+        )
+    else
+        # record in WAV
+        log("output file type is WAV")
+        output.file(
+            id="recorder",
+            %wav(stereo=true, channels=2, samplesize=16, header=true),
+            perm = 0o664,
+            on_start=on_start,
+            !filenamepattern,
+            on_close=on_close,
+            reopen_when={ if !instance == 'record' then int_of_float(gettimeofday()/60.) mod d == 0  else false end },
+            input
+        )
+    end
+end
+
+# Funktion gibt Auskunft welches File aktuell ist und wieviel Prozent bereits aufgenommen werden
+def currecording()
+    curfile = !recordingfile
+    if curfile != "" then
+        percent_done = list.hd(get_process_lines("echo $(($(stat -c%s "^curfile^")/3174777))"))
+        "#{curfile}, #{percent_done}%"
+    else
+        "Nothing is being recorded now"
+    end
+end
+
+#Funktion zum Start der Aufzeichnung
+def start_dump() =
+    log('start dump')
+
+    # don't record twice is_record_active
+    if !is_record_active == false then
+        is_record_active := true
+        
+        log('starting to record')
+
+        record = get_output()
+        
+        log('record defined')
+        # Die Stopfunkton zeigt nun auf die Shutdown-Funktion der aktuellen Source
+        stop_f := fun () -> begin
+                                log('stop recording')
+                                # Aufnahme sauber beenden
+                                ignore(server.execute('recorder.stop'))
+                                # Source zerstören
+                                source.shutdown(record)
+                                # Variable zurücksetzen
+                                recordingfile := ""
+                            end
+    else 
+        log("recorder already active")
+    end
+end
+
+
+# Der Server wird durch 3 Funktionen bereichert
+# Der User darf die Aufzeichnung manuell starten
+server.register(namespace="record",
+                description="Start recording.",
+                usage="start",
+                "start",
+                fun (s) ->  begin start_dump() "OK" end)
+
+# Der User darf die Aufzeichnung manuell stoppen
+server.register(namespace="record",
+                description="Stop recording.",
+                usage="stop",
+                "stop",
+                fun (s) -> begin stop_dump() "OK" end)
+
+if !instance != 'record' then
+    # Der User darf einen Dateinamen für die Aufnahme definieren
+    server.register(namespace="record",
+                    description="Define filename for output.",
+                    usage="setfilename",
+                    "setfilename",
+                    fun (s) -> begin filenamepattern := audiobase^"/"^string_of(s)  "OK" end)
+end
+
+# Der User kann sich über den Fortschritt der Aufnahme informieren
+server.register(namespace="record",
+                description="Show current file.",
+                usage="curfile",
+                "curfile",
+                fun (s) -> currecording() )
+
+output.dummy(blank(id="serve"))

modules/liquidsoap/unused_recorder.liq

+# define file name pattern
+filenamepattern = ref audiobase^"/%Y-%m-%d/%Y-%m-%d-%H-%M.flac"
+
+# Der aktuelle Dateiname für die Aufnahme
+recordingfile = ref ""
+
+# bewahre uns davor, dass zweimal gleichzeitig die gleiche Date aufgenommen wird
+is_record_active = ref false
+
+#wir definieren eine Referenz für die Stop-Funktion, die aber bisher noch nichts tun kann
+stop_f = ref (fun () -> ())
+
+
+
+def start_wav_output(recfile, filenamepattern, recorder_number)
+    duration   = int_of_string(list.assoc("rec_"^recorder_number^"_duration",     ini))
+    channels   = int_of_string(list.assoc("rec_"^recorder_number^"_channels",     ini))
+    samplesize = int_of_string(list.assoc("rec_"^recorder_number^"_samplesize",     ini))
+
+    ignore(duration)
+    ignore(channels)
+    ignore(samplesize)
+
+#    def on_start()
+#        recfile := list.hd(get_process_lines("date +#{!filenamepattern}"))
+#    end
+#    def on_close(filename)
+#        recordingfile := list.hd(get_process_lines("date +#{!filenamepattern}"))
+#    end
+
+    print(channels)
+    print(samplesize)
+    #out_wav = output.file(id="recorder", perm = 0o664, on_start=on_start, on_close=on_close, reopen_when={ int_of_float(gettimeofday()/60.) mod duration == 0 })
+    #out_wav(%wav(stereo=true, channels=2, samplesize=8, header=true, !filenamepattern, output_source)
+    #ignore(out_wav)
+
+    output.dummy(id="wav_dummy_recording", blank())
+
+#    if channels == 2 then
+#        output.file(id="recorder", %wav(stereo=true, channels=2, samplesize=8, header=true), perm = 0o664, on_start=on_start, on_close=on_close, reopen_when={ int_of_float(gettimeofday()/60.) mod duration == 0 }, !filenamepattern, audio_to_stereo(output_source))
+##        out_wav(output_source)
+#    else
+#        output.file(id="recorder", %wav(stereo=true, channels=1, samplesize=8, header=true), perm = 0o664, on_start=on_start, on_close=on_close, reopen_when={ int_of_float(gettimeofday()/60.) mod duration == 0 }, !filenamepattern, output_source)
+    #    out_wav(output_source)
+#    end
+
+    #if channels == 2 then
+    #    if samplesize < 12 then
+    #        ignore(out_wav(%wav(stereo=true, channels=2, samplesize=8, header=true), !filenamepattern, output_source))
+    #    else
+    #        ignore(out_wav(%wav(stereo=true, channels=2, samplesize=16, header=true), !filenamepattern, output_source))
+    #    end
+    #else
+    #    if samplesize < 12 then
+    #        ignore(out_wav(%wav(stereo=true, channels=1, samplesize=8, header=true), !filenamepattern, output_source))
+    #    else
+    #        ignore(out_wav(%wav(stereo=true, channels=1, samplesize=16, header=true), !filenamepattern, output_source))
+    #    end
+    #end
+end
+
+def start_flac_output(recorder_number, filenamepattern, duration)
+#    duration        = int_of_string(list.assoc("rec_"^recorder_number^"_samplerate",     ini))
+#    samplerate      = list.assoc("rec_"^recorder_number^"_samplerate",      ini)
+    channels        = int_of_string(list.assoc("rec_"^recorder_number^"_channels",        ini))
+#    compression     = int_of_string(list.assoc("rec_"^recorder_number^"_compression",     ini))
+#    bits_per_sample = int_of_string(list.assoc("rec_"^recorder_number^"_bits_per_sample", ini))
+    #output.file(id="recorder", %flac(samplerate=44100, channels=1, compression=7, bits_per_sample=32), perm = 0o664, on_start=on_start, !filenamepattern, on_close=on_close, reopen_when={ int_of_float(gettimeofday()/60.) mod duration == 0 }, output_source)
+
+    recfile = ref ''
+
+    def on_start()
+        recfile := list.hd(get_process_lines("date +#{filenamepattern}"))
+    end
+    def on_close(filename)
+        recfile := list.hd(get_process_lines("date +#{filenamepattern}"))
+    end
+
+    # dumbass liquidsoap cannot handle one output definition for mono and stereo
+    output_filesystem_mono   = output.file(id="recorder", perm = 0o664, on_start=on_start, on_close=on_close, reopen_when={ int_of_float(gettimeofday()/60.) mod duration == 0 })
+    output_filesystem_stereo = output.file(id="recorder", perm = 0o664, on_start=on_start, on_close=on_close, reopen_when={ int_of_float(gettimeofday()/60.) mod duration == 0 })
+
+    ignore(output_filesystem_mono)
+    ignore(output_filesystem_stereo)
+
+    if channels == 2 then
+        output.dummy(id="flac_dummy_recording_stereo", blank())
+#        output_stereof(%flac(samplerate=44100, channels=1, compression=1, bits_per_sample=16), !filenamepattern, output_source)
+    else
+        output.dummy(id="flac_dummy_recording_mono", blank())
+#        output_icecast_monof(%flac(samplerate=44100, channels=1, compression=1, bits_per_sample=16), !filenamepattern, output_source)
+    end
+
+
+end
+
+
+
+
+
+def enable_stop_function(record)
+    # Die Stopfunkton zeigt nun auf die Shutdown-Funktion der aktuellen Source
+    stop_f := fun () -> begin
+                            log('stop recording')
+                            # Aufnahme sauber beenden
+                            ignore(server.execute('recorder.stop'))
+                            # Source zerstören
+                            source.shutdown(record)
+                            # Variable zurücksetzen
+                            recordingfile := ""
+                        end
+end
+
+def set_recorder_output(rec_filetype, recorder_number)
+    # flac output
+    if rec_filetype == 'flac' then
+        log("output file type is FLAC")
+        record = start_flac_output(recorder_number)
+        enable_stop_function(record)
+
+    # WAV output
+    else
+        log("output file type is WAV")
+        record = start_wav_output(recorder_number)
+        enable_stop_function(record)
+    end
+end
+
+# shows current file and how many bytes were written so far
+def currecording()
+    curfile = !recordingfile
+    if curfile != "" then
+        bytes_written = list.hd(get_process_lines("echo $(($(stat -c%s "^curfile^")))"))
+        "#{curfile}, #{bytes_written}B"
+    else
+        ""
+    end
+end
\ No newline at end of file

modules/liquidsoap/unused_stream.liq

+
+def get_icecast_mp3_stream(number)
+    stream_bitrate = int_of_string(list.assoc("stream_#{number}_bitrate", ini))
+    stream_mountpoint = list.assoc("stream_#{number}_mountpoint", ini)
+    stream_host = list.assoc("stream_#{number}_host", ini)
+    stream_port = int_of_string(list.assoc("stream_#{number}_port", ini))
+    stream_name = list.assoc("stream_#{number}_name", ini)
+    stream_url = list.assoc("stream_#{number}_url", ini)
+    stream_genre = list.assoc("stream_#{number}_genre", ini)
+    stream_description = list.assoc("stream_#{number}_description", ini)
+    stream_user = list.assoc("stream_#{number}_user", ini)
+    stream_password = list.assoc("stream_#{number}_password", ini)
+
+
+
+    if stream_bitrate == 24 then
+        icecast_stream = output.icecast(%mp3(bitrate = 24, samplerate = 22050), mount=stream_mountpoint, host=stream_host, port=stream_port, name=stream_name, url=stream_url, genre=stream_genre, description=stream_description, user=stream_user, password=stream_password, icy_metadata="true", fallible=true, buffer(output_source))
+        clock.assign_new(id="stream_#{number}",
+            [icecast_stream]
+        )
+        icecast_stream
+    else
+        icecast_stream = output.icecast(%mp3(samplerate = 44100), mount=stream_mountpoint, host=stream_host, port=stream_port, name=stream_name, url=stream_url, genre=stream_genre, description=stream_description, user=stream_user, password=stream_password, icy_metadata="true", fallible=true, buffer(output_source))
+        clock.assign_new(id="stream_#{number}",
+            [icecast_stream]
+        )
+        icecast_stream
+    end
+end
+
+def get_icecast_ogg_stream(number)
+    stream_quality = float_of_string(list.assoc("stream_#{number}_quality", ini))
+
+    stream_mountpoint = list.assoc("stream_#{number}_mountpoint", ini)
+    stream_host = list.assoc("stream_#{number}_host", ini)
+    stream_port = int_of_string(list.assoc("stream_#{number}_port", ini))
+    stream_name = list.assoc("stream_#{number}_name", ini)
+    stream_url = list.assoc("stream_#{number}_url", ini)
+    stream_genre = list.assoc("stream_#{number}_genre", ini)
+    stream_description = list.assoc("stream_#{number}_description", ini)
+    stream_user = list.assoc("stream_#{number}_user", ini)
+    stream_password = list.assoc("stream_#{number}_password", ini)
+
+    if stream_quality >= 0.5 then
+        icecast_stream = output.icecast(%vorbis(quality = 1.0), mount=stream_mountpoint, host=stream_host, port=stream_port, name=stream_name, url=stream_url, genre=stream_genre, description=stream_description, user=stream_user, password=stream_password, icy_metadata="true", fallible=true, buffer(output_source))
+        clock.assign_new(id="stream_#{number}",
+            [icecast_stream]
+        )
+        icecast_stream
+    else
+        icecast_stream = output.icecast(%vorbis(quality = 0.1), mount=stream_mountpoint, host=stream_host, port=stream_port, name=stream_name, url=stream_url, genre=stream_genre, description=stream_description, user=stream_user, password=stream_password, icy_metadata="true", fallible=true, buffer(output_source))
+        clock.assign_new(id="stream_#{number}",
+            [icecast_stream]
+        )
+        icecast_stream
+    end
+end
+
+def get_harbour_mp3_stream(number)
+
+    stream_bitrate = int_of_string(list.assoc("stream_#{number}_bitrate", ini))
+    stream_user = list.assoc("stream_#{number}_user", ini)
+    stream_password =  list.assoc("stream_#{number}_password", ini)
+    stream_port = int_of_string(list.assoc("stream_#{number}_port", ini))
+    stream_url = list.assoc("stream_#{number}_url", ini)
+    stream_mountpoint = list.assoc("stream_#{number}_mountpoint", ini)
+
+    if stream_bitrate == 24 then
+        harbourstream = output.harbor(%mp3(bitrate = 24, samplerate = 22050), user=stream_user, password=stream_password, id="stream", port=stream_port, url=stream_url, mount=stream_mountpoint, icy_metadata="true", fallible=true, buffer(output_source))
+        clock.assign_new(id="stream_#{number}",
+            [harbourstream]
+        )
+        harbourstream
+    else
+        harbourstream = output.harbor(%mp3, user=stream_user, password=stream_password, id="stream", port=stream_port, url=stream_url, mount=stream_mountpoint, icy_metadata="true", fallible=true, buffer(output_source))
+        clock.assign_new(id="stream_#{number}",
+            [harbourstream]
+        )
+        harbourstream
+    end
+end
+
+def get_stream(number)
+    stream = list.assoc("stream_#{number}", ini)
+    stream_type = list.assoc("stream_#{number}_type", ini)
+    stream_format = list.assoc("stream_#{number}_format", ini)
+
+    # is stream enabled?
+    if stream == "y" then
+        log("activating stream #{number}")
+        if stream_type == "icecast" then
+            log("its an icecast stream")
+            if stream_format == "mp3" then
+                log("filled with mp3")
+                get_icecast_mp3_stream(number)
+            elsif stream_format == "vorbis" then
+                log("filled with ogg")
+                get_icecast_ogg_stream(number)
+            else
+                output.dummy(id="no_valid_stream_format_DUMMY_ICECAST", blank())
+            end
+
+        elsif stream_type == "harbor" then
+            log("its an harbor stream")
+            if stream_format == "mp3" then
+                get_harbour_mp3_stream(number)
+            else
+                output.dummy(id="no_valid_stream_format_DUMMY_HARBOUR", blank())
+            end
+        else
+            output.dummy(id="no_valid_stream_type_DUMMY", blank())
+        end
+    else
+        output.dummy(id="no_stream_enabled_DUMMY", blank())
+    end
+end
+
+def set_streams()
+    stream_0 = get_stream(0)
+    #stream_1 = get_stream(1)
+    #stream_2 = get_stream(2)
+    #stream_3 = get_stream(3)
+    #stream_4 = get_stream(4)
+end
+