dbox2epg.cpp

Go to the documentation of this file.

#include <qdeepcopy.h>
#include <qdatetime.h>
#include <qhttp.h>

#include "dbox2channel.h"
#include "dbox2epg.h"
#include "mythcontext.h"
#include "tv_rec.h"

#define DEBUG_DBOX2EPG
//#define DEBUG_DBOX2EPG_SHOWS
//#define DEBUG_DBOX2EPG_PARSER

#define LOC      QString("DBox2EPG(%1): ").arg(m_cardid)
#define LOC_WARN QString("DBox2EPG(%1) Warning: ").arg(m_cardid)
#define LOC_ERR  QString("DBox2EPG(%1) Error: ").arg(m_cardid)

DBox2EPG::DBox2EPG()
    : http(new QHttp()),
      m_dbox2options(NULL),
      m_dbox2channel(NULL),
      m_cardid(-1),
      m_channelCount(0),
      m_channelIndex(0),
      m_isRunning(true),
      m_inProgress(false),
      m_pendingRequest(false),
      m_requestedChannel(""),
      m_currentEPGRequestChannel(""),
      m_currentEPGRequestID(-1)
{
    connect(http, SIGNAL(requestFinished    (int,bool)),
            this, SLOT(  httpRequestFinished(int,bool)));
}

DBox2EPG::~DBox2EPG()
{
    TeardownAll();
}

void DBox2EPG::deleteLater(void)
{
    disconnect(); // disconnect signals we may be sending...
    TeardownAll();
    QObject::deleteLater();
}

void DBox2EPG::TeardownAll(void)
{
    if (http)
    {
        // Abort any pending http operation
        http->abort();
        // Disconnect from http
        disconnect(http, SIGNAL(requestFinished    (int,bool)),
                   this, SLOT(  httpRequestFinished(int,bool)));
        // Delete http
        http->deleteLater();
    }
}

void DBox2EPG::Init(DBox2DBOptions* dbox2_options, int cardid,
                    DBox2Channel* channel)
{
    VERBOSE(VB_EIT, LOC + "Init run");

    m_dbox2options = dbox2_options;
    m_dbox2channel = channel;
    m_cardid       = cardid;

    http->setHost(m_dbox2options->host, m_dbox2options->httpport);

    start();
}

void DBox2EPG::Shutdown()
{
    m_isRunning = false;
}

void DBox2EPG::run()
{
    VERBOSE(VB_EIT, LOC + "Starting Thread....");
    long waitTime = 15 * 1000 * 1000;

    // Process all channel ids and retrieve EPG
    while (m_isRunning)
    {
        usleep(1000);

        // If operation is in progress, do not request epg
        if (!m_pendingRequest)
            continue;

        // Wait before processing
        usleep(waitTime);

        int chanid = GetChannelID(m_requestedChannel);

        // if channel id is invalid, do not request epg
        if (chanid < 0)
            continue;

        // Only grab the EPG for this channel if useonairguide is set to 1
        if (UseOnAirGuide((uint)chanid))
        {
            RequestEPG(m_requestedChannel);
            m_pendingRequest = false;
        }
        else
        {
            VERBOSE(VB_EIT, LOC + QString("EPG disabled for %1.")
                    .arg(m_requestedChannel));
            m_dbox2channel->EPGFinished();
        }
    }
    VERBOSE(VB_EIT, LOC + "Exiting Thread....");
}


void DBox2EPG::ScheduleRequestEPG(const QString& channelNumber)
{
    m_requestedChannel = QDeepCopy<QString>(channelNumber);
    m_pendingRequest = true;
}

void DBox2EPG::RequestEPG(const QString& channelNumber)
{
    // Prepare request
    QString requestString, channelName, dbox2ChannelID;
    channelName    = m_dbox2channel->GetChannelNameFromNumber(channelNumber);
    dbox2ChannelID = m_dbox2channel->GetChannelID(channelName);
    requestString  = QString("/control/epg?id=%1").arg(dbox2ChannelID);

    VERBOSE(VB_EIT, LOC +
            QString("Requesting EPG for channel %2 (%3): %4%5")
            .arg(m_cardid)
            .arg(channelNumber)
            .arg(channelName)
            .arg(m_dbox2options->host)
            .arg(requestString));

    // Request EPG via http. Signal will be emmited when request is done.
    QHttpRequestHeader header("GET", requestString);
    header.setValue("Host", m_dbox2options->host);

    m_currentEPGRequestChannel = channelNumber;
    m_currentEPGRequestID      = http->request(header);
}


void DBox2EPG::UpdateDB(uint chanid,
                        const QDateTime &startTime,
                        const QDateTime &endTime,
                        const QString   &title,
                        const QString   &description,
                        const QString   &category)
{
    MSqlQuery query(MSqlQuery::InitCon());

    // Delete old info
    query.prepare("DELETE FROM program "
                  "WHERE chanid    = :CHANID AND "
                  "      starttime = :STARTTIME");

    query.bindValue(":CHANID", chanid);
    query.bindValue(":STARTTIME", startTime);

    if (!query.exec())
        MythContext::DBError("Deleting old program", query);

    // Inserting new info
    query.prepare("INSERT INTO program "
                  "    (chanid,   starttime,  endtime,      "
                  "     title,    subtitle,   description,  "
                  "     category, airdate,    stars)        "
                  "VALUES "
                  "    (:CHANID,  :STARTTIME, :ENDTIME,     "
                  "     :TITLE,   :SUBTITLE,  :DESCRIPTION, "
                  "     :CATEGORY,:AIRDATE,   :STARS)");

    query.bindValue(":CHANID",      chanid);
    query.bindValue(":STARTTIME",   startTime);
    query.bindValue(":ENDTIME",     endTime);
    query.bindValue(":TITLE",       title.utf8());
    query.bindValue(":SUBTITLE",    "");
    query.bindValue(":DESCRIPTION", description.utf8());
    query.bindValue(":CATEGORY",    category.utf8());
    query.bindValue(":AIRDATE",     "0");
    query.bindValue(":STARS",       "0");

    if (!query.exec())
        MythContext::DBError("Saving new program", query);
}

void DBox2EPG::httpRequestFinished(int requestID, bool error)
{
    if (error)
    {
        VERBOSE(VB_EIT, LOC + "Reading EPG failed.");
        m_dbox2channel->EPGFinished();
        return;
    }

    if (requestID != m_currentEPGRequestID)
    {
        VERBOSE(VB_EIT, LOC + "Got EPG for old channel. Ignoring");
        return;
    }

    QByteArray buffer = http->readAll();
    int size   = buffer.size();
    int chanid = GetChannelID(m_currentEPGRequestChannel);

    VERBOSE(VB_EIT, LOC + "EPG received. " +
            QString("Parsing %2 bytes...").arg(size));

    // Parse
    int showCount = 0;
    int index     = 0;

    QDateTime startTime;
    QDateTime endTime;
    QString epgID, title, category, desc;

    while (index < size)
    {
        // Next section must not start with an empty line
        QString line = ParseNextLine(buffer, index, size);

        if (line.isEmpty())
          continue;

        // Parse info
        epgID    = line.section(" ", 0, 0);
        startTime.setTime_t(line.section(" ", 1, 1).toInt());
        endTime  = startTime.addSecs(line.section(" ", 2, 2).toInt());

        title    = ParseNextLine(buffer, index, size);
        category = ParseNextLine(buffer, index, size);
        desc     = ParseNextLine(buffer, index, size);


        // Print debug
        VERBOSE(VB_EIT, LOC +
                QString("Found show. Start Time: %1, End Time: %2, "
                        "Title: %3, Description: %4.")
                .arg(m_cardid)
                .arg(startTime.toString()).arg(endTime.toString())
                .arg(title).arg(desc));

        // Update database
        UpdateDB(chanid, startTime, endTime, title, desc, category);

        showCount++;
    }

    VERBOSE(VB_EIT, LOC + "EPG parsing done. " +
            QString("Got %2 shows for channel %3.")
            .arg(showCount).arg(m_currentEPGRequestChannel));

    m_dbox2channel->EPGFinished();
}

QString DBox2EPG::ParseNextLine(const QByteArray &buf, int &pos, int size)
{
    QString string;
    while (pos < size)
    {
        char current = buf[pos];
        pos++;
        if (current == '\n')
            break;
        string += current;
    }
    return string;
}

int DBox2EPG::GetChannelID(const QString& channum)
{
    MSqlQuery query(MSqlQuery::InitCon());

    query.prepare(
        "SELECT chanid "
        "FROM channel, cardinput "
        "WHERE cardid  = :CARDID  AND "
        "      channum = :CHANNUM AND "
        "      channel.sourceid = cardinput.sourceid");

    query.bindValue(":CARDID",  m_cardid);
    query.bindValue(":CHANNUM", channum);

    if (query.exec() && query.isActive())
    {
        if (query.next())
            return query.value(0).toInt();

        VERBOSE(VB_IMPORTANT, QString("DBox2EPG::GetChannelID(): channum "
                                      "'%1' not found in DB").arg(channum));
    }
    else
    {
        MythContext::DBError("DBox2EPG::GetChannelID()", query);
    }
    return -1;
}

bool DBox2EPG::UseOnAirGuide(uint chanid)
{
    MSqlQuery query(MSqlQuery::InitCon());

    query.prepare(
        "SELECT useonairguide "
        "FROM channel "
        "WHERE chanid = :CHANID");

    query.bindValue(":CHANID", chanid);

    if (query.exec() && query.isActive())
    {
        if (query.next())
            return (bool) query.value(0).toInt();

        VERBOSE(VB_IMPORTANT, QString("DBox2EPG::UseOnAirGuide(): chanid "
                                      "'%1' not found in DB").arg(chanid));
    }
    else
    {
        MythContext::DBError("DBox2EPG::UseOnAirGuide()", query);
    }
    return false;
}

---