#ifndef AUDIOHANDLERRTOUTPUT_H
#define AUDIOHANDLERRTOUTPUT_H

#include "audiohandlerbase.h"

#ifndef Q_OS_LINUX
#include "RtAudio.h"
#else
#include "rtaudio/RtAudio.h"
#endif
#include <memory>
#include "bytering.h"


class audioHandlerRtOutput : public audioHandlerBase {
    Q_OBJECT

public:
    explicit audioHandlerRtOutput(QObject* parent=nullptr);
    ~audioHandlerRtOutput() override { dispose(); } // ensure close on destruction
    QString role() const override { return QStringLiteral("Output"); }

public slots:
    void incomingAudio(audioPacket packet);

protected:
    bool openDevice() noexcept override;
    void closeDevice() noexcept override;
    virtual QAudioFormat getNativeFormat() override;
    virtual bool isFormatSupported(QAudioFormat f) override;

private slots:
    void onConverted(audioPacket pkt);

private:
    static int rtCallback(void* out, void* in, unsigned nFrames, double, RtAudioStreamStatus st, void* u);
    void handleCallbackOutput(void* out, unsigned nFrames, RtAudioStreamStatus st);
    void prefillRingBuffer();

private:
    QElapsedTimer lastRecovery;
    std::atomic<int> underrunCount{0};
#if defined(Q_OS_LINUX)
    RtAudio rtaudio{RtAudio::Api::LINUX_ALSA};
#elif defined(Q_OS_WIN)
    RtAudio rtaudio{RtAudio::Api::WINDOWS_WASAPI};
#elif defined(Q_OS_MACOS)
    RtAudio rtaudio{RtAudio::Api::MACOSX_CORE};
#else
    RtAudio rtaudio;
#endif
    RtAudioFormat fmt{RTAUDIO_SINT16};
    unsigned bytesPerSample{2};
    unsigned bytesPerFrame{2};
    std::unique_ptr<ByteRing> outRB;
};

#endif // AUDIOHANDLERRTOUTPUT_H