/* ------------------------------------------------------------------
 * Copyright (C) 2019 Matthias P. Braendli
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *    http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
 * express or implied.
 * See the License for the specific language governing permissions
 * and limitations under the License.
 * -------------------------------------------------------------------
 */
/*! \file GSTInput.h
 *
 * This input uses GStreamer to get audio data.
 */

#pragma once

#include "config.h"

#if HAVE_GST

#include <string>
#include <atomic>
#include <thread>
#include <vector>
#include <cstddef>
#include <cstdint>

#include <gst/gst.h>

#include "SampleQueue.h"
#include "common.h"
#include "InputInterface.h"
#include "utils.h"

struct GSTData {
    GSTData(SampleQueue<uint8_t>& samplequeue);

    // When using URL and uridecodebin
    GstElement *pipeline = nullptr;
    GstElement *uridecodebin = nullptr;
    GstElement *audio_convert = nullptr;
    GstElement *audio_resample = nullptr;
    GstElement *caps_filter = nullptr;
    GstElement *app_sink = nullptr;

    // When using pipeline
    GstElement *custom_bin = nullptr;

    GstBus *bus = nullptr;

    SampleQueue<uint8_t>& samplequeue;
};

class GSTInput : public InputInterface
{
    public:
        GSTInput(const std::string& uri,
                 const std::string& pipeline,
                 int rate,
                 unsigned channels,
                 SampleQueue<uint8_t>& queue);

        GSTInput(const GSTInput& other) = delete;
        GSTInput& operator=(const GSTInput& other) = delete;
        virtual ~GSTInput();

        virtual void prepare() override;

        virtual bool read_source(size_t num_bytes) override;

        ICY_TEXT_t get_icy_text() const;

        int getRate() { return m_rate; }

        virtual bool fault_detected(void) const override { return m_fault; };
    private:
        std::string m_uri;
        std::string m_pipeline;
        unsigned m_channels;
        int m_rate;

        GSTData m_gst_data;

        mutable std::mutex m_nowplaying_mutex;
        ICY_TEXT_t m_nowplaying;

        void process();
        std::atomic<bool> m_fault = ATOMIC_VAR_INIT(false);
        std::atomic<bool> m_running;
        std::thread m_thread;
};

#endif // HAVE_GST