#
# 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/>.




#####################################
#         FALLBACK SOURCES          #
#####################################


# Create Sources
input_fallback_scheduled_0 = request.equeue(id="in_fallback_scheduled_0")
input_fallback_scheduled_1 = request.equeue(id="in_fallback_scheduled_1")

station_playlist = playlist(
    id="station_playlist", 
    fallback_station_playlist_path, 
    mode="randomize",    
    reload_mode="watch",
    reload=0)

station_folder = mksafe(
    playlist(id="station_folder", 
    fallback_station_dir, 
    mode="randomize", 
    reload=fallback_station_dir_reload, 
    reload_mode="seconds"))

# Apply ReplayGain Normalization
input_fallback_scheduled_0 = amplify(id="in_fallback_scheduled_0", 1., override="replay_gain", input_fallback_scheduled_0)
input_fallback_scheduled_1 = amplify(id="in_fallback_scheduled_1", 1., override="replay_gain", input_fallback_scheduled_1)
station_playlist = amplify(id="station_playlist", 1., override="replay_gain", station_playlist)
station_folder = amplify(id="station_folder", 1., override="replay_gain", station_folder)

# Add Event Handlers
input_fallback_scheduled_0 = on_metadata(id="in_fallback_scheduled_0", on_metadata_notification, input_fallback_scheduled_0)
input_fallback_scheduled_1 = on_metadata(id="in_fallback_scheduled_1", on_metadata_notification, input_fallback_scheduled_1)
station_playlist = on_metadata(id="station_playlist", on_metadata_notification, station_playlist)
station_folder = on_metadata(id="station_folder", on_metadata_notification, station_folder)


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



# Clear Fallback Queue A
server.register(namespace=source.id(input_fallback_scheduled_0),
        description="Clear all items of the scheduled fallback queue A.",
        usage="clear",
        "clear",

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

# Clear Fallback Queue B
server.register(namespace=source.id(input_fallback_scheduled_1),
        description="Clear all items of the scheduled fallback queue B.",
        usage="clear",
        "clear",

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

# Seek Fallback Queue A
server.register(namespace = source.id(input_fallback_scheduled_0),
    description="Seek to relative position in #{source.id(input_fallback_scheduled_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_fallback_scheduled_0, t)
            "Seeked #{ret} seconds."
        end
    )

# Seek Fallback Queue B
server.register(namespace = source.id(input_fallback_scheduled_1),
    description="Seek to relative position in #{source.id(input_fallback_scheduled_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_fallback_scheduled_1, t)
            "Seeked #{ret} seconds."
        end
    )