#include "audiooutput.h"

#include <QDebug>

AudioOutput::AudioOutput()
    : QThread(), m_despotifySession(0),
      frameSize(16 * 2 / 8), m_channels(2), m_bitrate(44100), m_state(Pause)
{
    int rc;
    snd_pcm_hw_params_t *params;
    int dir;
    /* Open PCM device for playback. */
    rc = snd_pcm_open(&m_alsaHandle, "default",
                      SND_PCM_STREAM_PLAYBACK, 0);
    if (rc < 0) {
      qWarning() << "unable to open pcm device: " << snd_strerror(rc);
    }

    /* Allocate a hardware parameters object. */
    snd_pcm_hw_params_alloca(&params);

    /* Fill it in with default values. */
    snd_pcm_hw_params_any(m_alsaHandle, params);

    /* Set the desired hardware parameters. */

    /* Interleaved mode */
    snd_pcm_hw_params_set_access(m_alsaHandle, params,
                        SND_PCM_ACCESS_RW_INTERLEAVED);

    /* Signed 16-bit little-endian format */
    snd_pcm_hw_params_set_format(m_alsaHandle, params,
                                SND_PCM_FORMAT_S16);

    /* Two channels (stereo) */
    snd_pcm_hw_params_set_channels(m_alsaHandle, params, m_channels);

    /* 44100 bits/second sampling rate (CD quality) */
    snd_pcm_hw_params_set_rate_near(m_alsaHandle, params,
                                    &m_bitrate, &dir);

    /* Write the parameters to the driver */
    rc = snd_pcm_hw_params(m_alsaHandle, params);
    if (rc < 0) {
        qWarning() << "unable to set hw parameters: " << snd_strerror(rc);
    }
    snd_pcm_prepare(m_alsaHandle);

    start();

}

AudioOutput::~AudioOutput()
{
    snd_pcm_close (m_alsaHandle);
}

void AudioOutput::setDespotifySession(despotify_session *ds)
{
    pause();
    m_despotifySession = ds;
}

void AudioOutput::play()
{
    if (m_state != Play) {
        m_state = Play;
        m_isPlaying.wakeAll();
    }
}

void AudioOutput::pause()
{
    if (m_state != Pause) {
        m_state = Pause;
        QMutex lock;
        lock.lock();
        m_isPause.wait(&lock);
    }
}

void AudioOutput::run()
{
    QMutex lock;
    lock.lock();
    forever {
        switch (m_state) {
        case Pause:
            m_isPause.wakeAll();
            m_isPlaying.wait(&lock);
            break;
        case Play:
            pcm_data pcm;
            despotify_get_pcm(m_despotifySession,&pcm);
            int frames = pcm.len / frameSize;
            int framesWritten = snd_pcm_writei(m_alsaHandle,pcm.buf,frames);
            if (framesWritten != frames)
                snd_pcm_prepare(m_alsaHandle);
            break;
        }
    }
}