mpd.cpp

#include "mpdas.h"

CMPD* MPD = 0;

void CMPD::SetSong(const Song *song)
{
    _cached = false;
    if(song && !song->getArtist().empty() && !song->getTitle().empty()) {
        _song = *song;
        _gotsong = true;
        iprintf("New song: %s - %s", _song.getArtist().c_str(), _song.getTitle().c_str());
        AudioScrobbler->SendNowPlaying(*song);
    }
    else {
        _gotsong = false;
    }
    _starttime = time(NULL);
}

void CMPD::CheckSubmit(int curplaytime)
{
    if(!_gotsong || _cached || (_song.getArtist().empty() || _song.getTitle().empty())) return;
    if(curplaytime - _start >= 240 || curplaytime - _start >= _song.getDuration()/2) {
        Cache->AddToCache(_song, _starttime);
        _cached = true;
    }
}

CMPD::CMPD(CConfig *cfg)
{
    _cfg = cfg;
    _conn = NULL;
    _gotsong = false;
    _connected = false;
    _cached = false;
    _songid = -1;
    _songpos = -1;

    if(Connect())
        iprintf("%s", "Connected to MPD.");
    else
        eprintf("%s", "Could not connect to MPD.");
}

CMPD::~CMPD()
{
    if(_conn)
        mpd_connection_free(_conn);
}

bool CMPD::Connect()
{
    if(_conn)
        mpd_connection_free(_conn);

    _conn = mpd_connection_new(_cfg->Get("host").c_str(), _cfg->GetInt("port"), 0);
    _connected = _conn && mpd_connection_get_error(_conn) == MPD_ERROR_SUCCESS;

    if(_connected && _cfg->Get("mpdpassword").size() > 0) {
        _connected &= mpd_run_password(_conn, _cfg->Get("mpdpassword").c_str());
    }
    else if(!_connected) {
        eprintf("MPD connection error: %s", mpd_connection_get_error_message(_conn));
    }

    if(_connected)
        mpd_run_subscribe(_conn, "mpdas");

    return _connected;
}

void CMPD::GotNewSong(struct mpd_song *song)
{
    Song *s = new Song(song);
    SetSong(s);
    delete s;
}

void CMPD::Update()
{
    if(!_connected) {
        iprintf("Reconnecting in 10 seconds.");
        sleep(10);
        if(Connect())
            iprintf("%s", "Reconnected!");
        else {
            eprintf("%s", "Could not reconnect.");
            return;
        }
    }

    mpd_status *status = mpd_run_status(_conn);
    mpd_stats *stats = mpd_run_stats(_conn);

    if(status && stats) {
        int newsongid = mpd_status_get_song_id(status);
        int newsongpos = mpd_status_get_elapsed_time(status);
        int curplaytime = mpd_stats_get_play_time(stats);
        // new song (or the same song but from the beginning after it has been played long enough before)
        if(newsongid != _songid || (_song.getDuration() != -1 && _songpos > (_song.getDuration()/2) && newsongpos < _songpos && newsongpos < 10)) {
            _songid = newsongid;
            _songpos = newsongpos;
            _start = curplaytime;

            mpd_song *song = mpd_run_current_song(_conn);
            if(song) {
                GotNewSong(song);
                mpd_song_free(song);
            } else {
                _song = Song();
            }
        }

        // song playing
        if(newsongpos != _songpos) {
            _songpos = newsongpos;
            CheckSubmit(curplaytime);
        }

        // check for client-to-client messages
        if(mpd_send_read_messages(_conn)) {
            mpd_message *msg;
            while((msg = mpd_recv_message(_conn)) != NULL) {
                const char *text = mpd_message_get_text(msg);
                if(_gotsong && text) {
                    if(!strncmp(text, "love", 4)) {
                        AudioScrobbler->LoveTrack(_song);
                    }
                    else if(!strncmp(text, "unlove", 6)) {
                        AudioScrobbler->LoveTrack(_song, true);
                    }
                }
                mpd_message_free(msg);
            }
            mpd_response_finish(_conn);
        }

        mpd_status_free(status);
        mpd_stats_free(stats);
    }
    else { // we have most likely lost our connection
        eprintf("Could not query MPD server: %s", mpd_connection_get_error_message(_conn));
        _connected = false;
    }
}

Song::Song(struct mpd_song *song)
{
    const char* temp;

    temp = mpd_song_get_tag(song, MPD_TAG_ARTIST, 0);
    artist = temp ? temp : "";

    temp = mpd_song_get_tag(song, MPD_TAG_TITLE, 0);
    title = temp ? temp : "";

    temp = mpd_song_get_tag(song, MPD_TAG_ALBUM, 0);
    album = temp ? temp : "";

    temp = mpd_song_get_tag(song, MPD_TAG_ALBUM_ARTIST, 0);
    albumartist = temp ? temp : "";

    duration = mpd_song_get_duration(song);
}