in_queue.liq

#
# Aura Engine (https://gitlab.servus.at/aura/engine)
#
# Copyright (C) 2017-2020 - The Aura Engine Team.
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU Affero General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
# GNU Affero General Public License for more details.
#
# You should have received a copy of the GNU Affero General Public License
# along with this program.  If not, see <http://www.gnu.org/licenses/>.



#####################################
#           QUEUE SOURCES           #
#####################################

# Create Sources
input_filesystem_0 = request.queue(id="in_filesystem_0")
input_filesystem_1 = request.queue(id="in_filesystem_1")

# Apply ReplayGain normalization, if metadata available
input_filesystem_0 = amplify(id="in_filesystem_0", 1., override="replay_gain", input_filesystem_0)
input_filesystem_1 = amplify(id="in_filesystem_1", 1., override="replay_gain", input_filesystem_1)
# See https://github.com/savonet/liquidsoap/discussions/2537
# input_filesystem_0 = replaygain(input_filesystem_0)
# input_filesystem_1 = replaygain(input_filesystem_1)

# Add Event Handlers
input_filesystem_0.on_metadata(on_metadata_notification)
input_filesystem_1.on_metadata(on_metadata_notification)

#####################################
#          SERVER FUNCTIONS         #
#####################################


# Clear Default Queue A
server.register(namespace=source.id(input_filesystem_0),
        description="Clear all items of the default queue A.",
        usage="clear",
        "clear",

    fun (s) ->
        begin
            ignore(s)
            clear_queue(input_filesystem_0)
            "Clearing done."
        end
    )

# Clear Default Queue B
server.register(namespace=source.id(input_filesystem_1),
        description="Clear all items of the default queue B.",
        usage="clear",
        "clear",

    fun (s) ->
        begin
            ignore(s)
            clear_queue(input_filesystem_1)
            "Clearing done."
        end
    )

# Seek Filesystem Queue A
server.register(namespace = source.id(input_filesystem_0),
    description="Seek to relative position in #{source.id(input_filesystem_0)}",
    usage = "seek <duration in seconds>",
    "seek",

    fun (t) ->
        begin
            log("Seeking #{t} sec")
            t = float_of_string(default=0.,t)
            ret = source.seek(input_filesystem_0, t)
            "Seeked #{ret} seconds."
        end
    )

# Seek Filesystem Queue B
server.register(namespace = source.id(input_filesystem_1),
    description="Seek to relative position in #{source.id(input_filesystem_1)}",
    usage = "seek <duration in seconds>",
    "seek",

    fun (t) ->
        begin
            log("Seeking #{t} sec")
            t = float_of_string(default=0.,t)
            ret = source.seek(input_filesystem_1, t)
            "Seeked #{ret} seconds."
        end
    )