mythsystemevent.cpp

Go to the documentation of this file.

#include <QApplication>
#include <QFileInfo>
#include <QRunnable>

#include "mythcorecontext.h"
#include "mthreadpool.h"
#include "mythsystem.h"
#include "mythsystemevent.h"
#include "programinfo.h"
#include "remoteutil.h"
#include "exitcodes.h"
#include "mythlogging.h"

#define LOC      QString("MythSystemEventHandler: ")

class SystemEventThread : public QRunnable
{
  public:
    SystemEventThread(const QString cmd, QString eventName = "")
      : m_command(cmd), m_event(eventName) {};

    void run(void)
    {
        uint flags = kMSDontBlockInputDevs;

        m_event.detach();
        m_command.detach();

        uint result = myth_system(m_command, flags);

        if (result != GENERIC_EXIT_OK)
            LOG(VB_GENERAL, LOG_WARNING, LOC +
                QString("Command '%1' returned %2")
                    .arg(m_command).arg(result));

        if (m_event.isEmpty()) 
            return;

        gCoreContext->SendMessage(
            QString("SYSTEM_EVENT_RESULT %1 SENDER %2 RESULT %3")
                    .arg(m_event).arg(gCoreContext->GetHostName()).arg(result));
    }

  private:
    // Private data storage
    QString m_command;
    QString m_event;
};


MythSystemEventHandler::MythSystemEventHandler(void)
{
    gCoreContext->addListener(this);
}

MythSystemEventHandler::~MythSystemEventHandler()
{
    gCoreContext->removeListener(this);
}

void MythSystemEventHandler::SubstituteMatches(const QStringList &tokens,
                                               QString &command)
{
    if (command.isEmpty())
        return;

    LOG(VB_FILE, LOG_DEBUG, LOC + QString("SubstituteMatches: BEFORE: %1")
                                            .arg(command));
    QString args;
    uint chanid = 0;
    QDateTime recstartts;
    QString sender;

    QStringList::const_iterator it = tokens.begin();
    ++it;
    command.replace(QString("%EVENTNAME%"), *it);

    ++it;
    while (it != tokens.end())
    {
        if (!args.isEmpty())
            args += " ";
        args += *it;

        // Check for some token names that we substitute one for one as
        // %MATCH% type variables.
        if ((*it == "CARDID") ||
            (*it == "RECSTATUS") ||
            (*it == "HOSTNAME") ||
            (*it == "SECS") ||
            (*it == "SENDER") ||
            (*it == "PATH"))
        {
            QString token = *it;

            if (++it == tokens.end())
                break;

            if (token == "SENDER")
                sender = *it;

            // The following string is broken up on purpose to indicate
            // what we're replacing is the token surrounded by percent signs
            command.replace(QString("%" "%1" "%").arg(token), *it);

            if (!args.isEmpty())
                args += " ";
            args += *it;
        }

        // Remember any chanid and starttime so we can lookup info about
        // the recording from the database.
        if (*it == "CHANID")
        {
            if (++it == tokens.end())
                break;

            chanid = (*it).toUInt();

            if (!args.isEmpty())
                args += " ";
            args += *it;
        }

        if (*it == "STARTTIME")
        {
            if (++it == tokens.end())
                break;

            recstartts = QDateTime::fromString(*it, Qt::ISODate);

            if (!args.isEmpty())
                args += " ";
            args += *it;
        }

        ++it;
    }

    command.replace(QString("%ARGS%"), args);

    ProgramInfo pginfo(chanid, recstartts);
    bool pginfo_loaded = pginfo.GetChanID();
    if (!pginfo_loaded)
    {
        RecordingInfo::LoadStatus status;
        pginfo = RecordingInfo(chanid, recstartts, false, 0, &status);
        pginfo_loaded = RecordingInfo::kFoundProgram == status;
    }

    if (pginfo_loaded)
    {
        pginfo.SubstituteMatches(command);
    }
    else
    {
        command.replace(QString("%CHANID%"), QString::number(chanid));
        command.replace(QString("%STARTTIME%"),
                        recstartts.toString("yyyyMMddhhmmss"));
        command.replace(QString("%STARTTIMEISO%"),
                        recstartts.toString(Qt::ISODate));
    }

    command.replace(QString("%VERBOSELEVEL%"), QString("%1").arg(verboseMask));

    LOG(VB_FILE, LOG_DEBUG, LOC + QString("SubstituteMatches: AFTER : %1")
                                            .arg(command));
}

QString MythSystemEventHandler::EventNameToSetting(const QString &name)
{
    QString result("EventCmd");
    QStringList parts = name.toLower().split('_', QString::SkipEmptyParts);

    QStringList::Iterator it = parts.begin();
    while (it != parts.end())
    {
        result += (*it).left(1).toUpper();
        result += (*it).mid(1);

        ++it;
    }

    return result;
}

void MythSystemEventHandler::customEvent(QEvent *e)
{
    if ((MythEvent::Type)(e->type()) == MythEvent::MythEventMessage)
    {
        MythEvent *me = (MythEvent *)e;
        QString msg = me->Message().simplified();

        if (msg == "CLEAR_SETTINGS_CACHE")
            msg = "SYSTEM_EVENT SETTINGS_CACHE_CLEARED";

        // Listen for any GLOBAL_SYSTEM_EVENT messages and resend to
        // the master backend as regular SYSTEM_EVENT messages.
        if (msg.startsWith("GLOBAL_SYSTEM_EVENT "))
        {
            gCoreContext->SendMessage(msg.mid(7) +
                QString(" SENDER %1").arg(gCoreContext->GetHostName()));
            return;
        }

        if ((!msg.startsWith("SYSTEM_EVENT ")) &&
            (!msg.startsWith("LOCAL_SYSTEM_EVENT ")))
            return;

        QStringList tokens = msg.split(' ', QString::SkipEmptyParts);

        // Return if this event is for another host
        if ((tokens.size() >= 4) &&
            (tokens[2] == "HOST") &&
            (tokens[3] != gCoreContext->GetHostName()))
            return;

        QString cmd;

        // See if this system has a command that runs for all system events
        cmd = gCoreContext->GetSetting("EventCmdAll");
        if (!cmd.isEmpty())
        {
            SubstituteMatches(tokens, cmd);

            SystemEventThread *eventThread = new SystemEventThread(cmd);
            MThreadPool::globalInstance()->startReserved(
                eventThread, "SystemEvent");
        }

        // Check for an EventCmd for this particular event
        cmd = gCoreContext->GetSetting(EventNameToSetting(tokens[1]));
        if (!cmd.isEmpty())
        {
            SubstituteMatches(tokens, cmd);

            SystemEventThread *eventThread =
                new SystemEventThread(cmd, tokens[1]);
            MThreadPool::globalInstance()->startReserved(
                eventThread, "SystemEvent");
        }
    }
}

/****************************************************************************/

void SendMythSystemRecEvent(const QString msg, const RecordingInfo *pginfo)
{
    if (pginfo)
        gCoreContext->SendSystemEvent(
            QString("%1 CARDID %2 CHANID %3 STARTTIME %4 RECSTATUS %5")
                    .arg(msg).arg(pginfo->GetCardID())
                    .arg(pginfo->GetChanID())
                    .arg(pginfo->GetRecordingStartTime(ISODate))
                    .arg(pginfo->GetRecordingStatus()));
    else
        LOG(VB_GENERAL, LOG_ERR, LOC + "SendMythSystemRecEvent() called with "
                                       "empty RecordingInfo");
}

void SendMythSystemPlayEvent(const QString msg, const ProgramInfo *pginfo)
{
    if (pginfo)
        gCoreContext->SendSystemEvent(
            QString("%1 HOSTNAME %2 CHANID %3 STARTTIME %4")
                    .arg(msg).arg(gCoreContext->GetHostName())
                    .arg(pginfo->GetChanID())
                    .arg(pginfo->GetRecordingStartTime(ISODate)));
    else
        LOG(VB_GENERAL, LOG_ERR, LOC + "SendMythSystemPlayEvent() called with "
                                       "empty ProgramInfo");
}

/****************************************************************************/

MythSystemEventEditor::MythSystemEventEditor(MythScreenStack *parent,
                                             const char *name)
  : RawSettingsEditor(parent, name)
{
    m_title = tr("System Event Command Editor");

    m_settings["EventCmdRecPending"]           = tr("Recording pending");
    m_settings["EventCmdRecStarted"]           = tr("Recording started");
    m_settings["EventCmdRecFinished"]          = tr("Recording finished");
    m_settings["EventCmdRecDeleted"]           = tr("Recording deleted");
    m_settings["EventCmdRecExpired"]           = tr("Recording expired");
    m_settings["EventCmdLivetvStarted"]        = tr("LiveTV started");
    m_settings["EventCmdPlayStarted"]          = tr("Playback started");
    m_settings["EventCmdPlayStopped"]          = tr("Playback stopped");
    m_settings["EventCmdPlayPaused"]           = tr("Playback paused");
    m_settings["EventCmdPlayUnpaused"]         = tr("Playback unpaused");
    m_settings["EventCmdPlayChanged"]          = tr("Playback program changed");
    m_settings["EventCmdMasterStarted"]        = tr("Master backend started");
    m_settings["EventCmdMasterShutdown"]       = tr("Master backend shutdown");
    m_settings["EventCmdClientConnected"]      = tr("Client connected to master backend");
    m_settings["EventCmdClientDisconnected"]   = tr("Client disconnected from master backend");
    m_settings["EventCmdSlaveConnected"]       = tr("Slave backend connected to master");
    m_settings["EventCmdSlaveDisconnected"]    = tr("Slave backend disconnected from master");
    m_settings["EventCmdNetCtrlConnected"]     = tr("Network Control client connected");
    m_settings["EventCmdNetCtrlDisconnected"]  = tr("Network Control client disconnected");
    m_settings["EventCmdMythfilldatabaseRan"]  = tr("mythfilldatabase ran");
    m_settings["EventCmdSchedulerRan"]         = tr("Scheduler ran");
    m_settings["EventCmdSettingsCacheCleared"] = tr("Settings cache cleared");
    m_settings["EventCmdScreenType"]           = tr("Screen created or destroyed");
    m_settings["EventCmdKey01"]                = tr("Keystroke event #1");
    m_settings["EventCmdKey02"]                = tr("Keystroke event #2");
    m_settings["EventCmdKey03"]                = tr("Keystroke event #3");
    m_settings["EventCmdKey04"]                = tr("Keystroke event #4");
    m_settings["EventCmdKey05"]                = tr("Keystroke event #5");
    m_settings["EventCmdKey06"]                = tr("Keystroke event #6");
    m_settings["EventCmdKey07"]                = tr("Keystroke event #7");
    m_settings["EventCmdKey08"]                = tr("Keystroke event #8");
    m_settings["EventCmdKey09"]                = tr("Keystroke event #9");
    m_settings["EventCmdKey10"]                = tr("Keystroke event #10");
    m_settings["EventCmdAll"]                  = tr("Any event");
}

/* vim: set expandtab tabstop=4 shiftwidth=4: */