Subversion Repositories tpanel

Rev

Rev 449 | Blame | Compare with Previous | Last modification | View Log | RSS feed

/*
 * Copyright (C) 2020 to 2025 by Andreas Theofilu <andreas@theosys.at>
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software Foundation,
 * Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301  USA
 */

#include "tamxcommands.h"
#include "tpagemanager.h"
#include "terror.h"
#include "tresources.h"
#include "tconfig.h"
#include "texpat++.h"
#if TESTMODE == 1
#include "testmode.h"
#endif

#include <string>
#include <vector>

#if __cplusplus < 201402L
#   error "This module requires at least C++14 standard!"
#else
#   if __cplusplus < 201703L
#       include <experimental/filesystem>
namespace fs = std::experimental::filesystem;
#       warning "Support for C++14 and experimental filesystem will be removed in a future version!"
#   else
#       include <filesystem>
#       ifdef __ANDROID__
namespace fs = std::__fs::filesystem;
#       else
namespace fs = std::filesystem;
#       endif
#   endif
#endif

using std::string;
using std::vector;
using namespace Expat;

typedef struct CMD_DEFINATIONS
{
    string cmd;
    bool hasChannels{false};
    bool hasPars{false};
    char separator{0};
}CMD_DEFINATIONS;

CMD_DEFINATIONS cmdDefinations[] = {
    { "@WLD", false, true, ',' },
    { "@AFP", false, true, ',' },
    { "^AFP", false, true, ',' },
    { "@GCE", false, true, ',' },
    { "^GCE", false, true, ',' },
    { "@APG", false, true, ';' },
    { "@CPG", false, true, ',' },
    { "@DPG", false, true, ';' },
    { "@PDR", false, true, ';' },
    { "@PHE", false, true, ';' },
    { "@PHP", false, true, ';' },
    { "@PHT", false, true, ';' },
    { "@PPA", false, true, ',' },
    { "^PPA", false, true, ',' },
    { "@PPF", false, true, ';' },
    { "^PPF", false, true, ';' },
    { "@PPG", false, true, ';' },
    { "^PPG", false, true, ';' },
    { "@PPK", false, true, ',' },
    { "^PPK", false, true, ',' },
    { "@PPM", false, true, ';' },
    { "^PPM", false, true, ';' },
    { "@PPN", false, true, ';' },
    { "^PPN", false, true, ';' },
    { "@PPT", false, true, ';' },
    { "^PPT", false, true, ';' },
    { "@PPX", false, false, '\0' },
    { "^PPX", false, false, '\0' },
    { "@PSE", false, true, ';' },
    { "@PSP", false, true, ';' },
    { "@PST", false, true, ';' },
    { "PAGE", false, true, ',' },
    { "^PGE", false, true, ',' },
    { "PPOF", false, true, ';' },
    { "PPOG", false, true, ';' },
    { "PPON", false, true, ';' },
    { "^ANI", true, true, ',' },
    { "^APF", true, true, ',' },
    { "^BAT", true, true, ',' },
    { "^BAU", true, true, ',' },
    { "^BCB", true, true, ',' },
    { "?BCB", true, true, ',' },
    { "^BCF", true, true, ',' },
    { "?BCF", true, true, ',' },
    { "^BCT", true, true, ',' },
    { "?BCT", true, true, ',' },
    { "^BDO", true, true, ',' },
    { "^BFB", true, true, ',' },
    { "^BIM", true, true, ',' },
    { "^BLN", true, true, ',' },
    { "^BMC", true, true, ',' },
    { "^BMF", true, true, ',' },
    { "^BMI", true, true, ',' },
    { "^BML", true, true, ',' },
    { "^BMP", true, true, ',' },
    { "?BMP", true, true, ',' },
    { "^BNC", true, true, ',' },
    { "^BNN", true, true, ',' },
    { "^BNT", true, true, ',' },
    { "^BOP", true, true, ',' },
    { "?BOP", true, true, ',' },
    { "^BOR", true, true, ',' },
    { "^BOS", true, true, ',' },
    { "^BPP", true, true, ',' },
    { "^BRD", true, true, ',' },
    { "?BRD", true, true, ',' },
    { "^BSF", true, true, ',' },
    { "^BSP", true, true, ',' },
    { "^BSM", true, false, ',' },
    { "^BSO", true, true, ',' },
    { "^BVL", true, true, ',' },
    { "^BVN", false, true, ',' },
    { "^BVP", true, true, ',' },
    { "^BVT", true, true, ',' },
    { "^BWW", true, true, ',' },
    { "?BWW", true, true, ',' },
    { "^CPF", true, false, ',' },
    { "^DLD", false, false, ',' },
    { "^DPF", true, true, ',' },
    { "^ENA", true, true, ',' },
    { "^FON", true, true, ',' },
    { "?FON", true, true, ',' },
    { "^GDI", true, true, ',' },
    { "^GIV", true, true, ',' },
    { "^GLH", true, true, ',' },
    { "^GLL", true, true, ',' },
    { "^GRD", true, true, ',' },
    { "^GRU", true, true, ',' },
    { "^GSC", true, true, ',' },
    { "^GSN", true, true, ',' },
    { "^ICO", true, true, ',' },
    { "?ICO", true, true, ',' },
    { "^IRM", false, true, ',' },
    { "^JSB", true, true, ',' },
    { "?JSB", true, true, ',' },
    { "^JSI", true, true, ',' },
    { "?JSI", true, true, ',' },
    { "^JST", true, true, ',' },
    { "?JST", true, true, ',' },
    { "^MSP", true, true, ',' },
    { "^MBT", false, false, ',' },
    { "^MDC", false, false, ',' },
    { "^SHO", true, true, ',' },
    { "^TEC", true, true, ',' },
    { "?TEC", true, true, ',' },
    { "^TEF", true, true, ',' },
    { "?TEF", true, true, ',' },
    { "^TOP", false, true, ',' },
    { "^TXT", true, true, ',' },
    { "?TXT", true, true, ',' },
    { "^UNI", true, true, ',' },
    { "^UTF", true, true, ',' },
    { "^LPB", true, true, ',' },
    { "^LPC", false, false, ',' },
    { "^LPR", false, true, ',' },
    { "^LPS", false, true, ',' },
    { "ABEEP", false, false, ',' },
    { "ADBEEP", false, false, ',' },
    { "@AKB", false, true, ';' },
    { "AKEYB", false, true, ',' },
    { "AKEYP", false, true, ',' },
    { "AKEYR", false, true, ',' },
    { "@AKP", false, true, ';' },
    { "@AKR", false, false, ',' },
    { "BEEP", false, false, ',' },
    { "^ABP", false, false, ',' },
    { "BRIT", false, true, ',' },
    { "@BRT", false, true, ',' },
    { "DBEEP", false, false, ',' },
    { "^ADP", false, false, ',' },
    { "@EKP", false, true, ';' },
    { "PKEYP", false, true, ',' },
    { "@PKB", false, true, ';' },
    { "^PKB", false, true, ';' },
    { "@PKP", false, true, ';' },
    { "^PKP", false, true, ';' },
    { "^RPP", false, false, ',' },
    { "SETUP", false, false, ',' },
    { "^STP", false, false, ',' },
    { "SHUTDOWN", false, false, ',' },
    { "SLEEP", false, false, ',' },
    { "@SOU", false, true, ',' },
    { "^SOU", false, true, ',' },
    { "@TKP", false, true, ';' },
    { "^TKP", false, true, ';' },
    { "TPAGEON", false, false, ',' },
    { "TPAGEOFF", false, false, ',' },
    { "@VKB", false, false, ',' },
    { "^VKB", false, false, ',' },
    { "WAKE", false, false, ',' },
    { "^CAL", false, false, ',' },
    { "^KPS", false, true, ',' },
    { "^VKS", false, true, ',' },
    { "^WCN?", false, true, ',' },
    { "@PWD", false, true, ',' },
    { "^PWD", false, true, ',' },
    { "^BBR", true, true, ',' },
    { "^RAF", false, true, ',' },
    { "^RFR", false, true, ',' },
    { "^RMF", false, true, ',' },
    { "^RSR", false, true, ',' },
    { "^MODEL?", false, false, ',' },
    { "^MOD", false, false, ',' },
    { "^VER?", false, false, ',' },
    { "^ICS", false, true, ',' },
    { "^ICE", false, false, ',' },
    { "^ICM", false, true, ',' },
    { "^PHN", false, true, ',' },
    { "?PHN", false, true, ',' },
    { "^LVC", false, true, ',' },
    { "^LVD", true, true, ',' },
    { "^LVE", true, true, ',' },
    { "^LVF", true, true, ',' },
    { "^LVL", true, true, ',' },
    { "^LVM", true, true, '|' },
    { "^LVN", true, true, ',' },
    { "^LVR", true, true, ',' },
    { "^LVS", true, true, ',' },
    { "GET ", false, false, ',' },
    { "SET ", false, false, ',' },
    { "LEVON", false, false, ',' },
    { "LEVOF", false, false, ',' },
    { "RXON", false, false, ',' },
    { "ON", false, true, ',' },
    { "OFF", false, true, ',' },
    { "LEVEL", false, true, ',' },
    { "BLINK", false, true, ',' },
    { "#FTR", false, true, ':' },
    { "TPCCMD", false, true, ',' },
    { "TPCACC", false, true, ',' },
    { "TPCSIP", false, true, ',' },
    { "^EPR", true, true, ',' },
    { "^SCE", true, true, ',' },
    { "^SDR", true, true, ',' },
    { "^SHA", true, false, ',' },
    { "^SHD", true, true, ',' },
    { "^SSH", true, true, ',' },
    { "^STG", true, true, ',' },
    { "^MUT", false, true, ',' },
    { "", false, false, '\0' }
};

CMD_DEFINATIONS& findCmdDefines(const string& cmd)
{
    DECL_TRACER("findCmdDefines(const string& cmd)");

    int i = 0;
    string uCmd = cmd;
    uCmd = toUpper(uCmd);

    while (cmdDefinations[i].cmd.length() > 0)
    {
        if (cmdDefinations[i].cmd.compare(uCmd) == 0)
            return cmdDefinations[i];

        i++;
    }

    return cmdDefinations[i];
}

TAmxCommands::TAmxCommands()
{
    DECL_TRACER("TAmxCommands::TAmxCommands()");
}

TAmxCommands::~TAmxCommands()
{
    DECL_TRACER("TAmxCommands::~TAmxCommands()");

    if (mMap && mSystemMap && mMap != mSystemMap)
    {
        delete mMap;
        delete mSystemMap;
    }
    else if (mMap)
        delete mMap;
    else if (mSystemMap)
        delete mSystemMap;
}

bool TAmxCommands::readMap(bool tp5)
{
    DECL_TRACER("TAmxCommands::readMap(bool tp5)");

    bool err = false;
    string projectPath = TConfig::getProjectPath();

    if (fs::exists(projectPath + "/prj.xma"))
    {
        mMap = new TMap(projectPath, tp5);
        err = mMap->haveError();
    }

    projectPath += "/__system";

    if (fs::exists(projectPath + "/prj.xma"))
    {
        mSystemMap = new TMap(projectPath, tp5);

        if (!err)
            err = mSystemMap->haveError();
    }

    if (!mMap)
        mMap = mSystemMap;

    return !err;
}

vector<string> TAmxCommands::getFields(string& msg, char sep)
{
    DECL_TRACER("TAmxCommands::getFields(string& msg, char sep)");

    vector<string> flds;
    bool bStr = false;
    string part;

    for (size_t i = 0; i < msg.length(); i++)
    {
        if (msg.at(i) == sep && !bStr)
        {
            flds.push_back(part);
            part.clear();
            continue;
        }
        else if (msg.at(i) == '\'' && !bStr)
            bStr = true;
        else if (msg.at(i) == '\'' && bStr)
            bStr = false;
        else
            part.append(msg.substr(i, 1));
    }

    if (!part.empty())
        flds.push_back(part);

    if (flds.size() > 0 && TStreamError::checkFilter(HLOG_DEBUG))
    {
        MSG_DEBUG("Found fields:");
        vector<string>::iterator iter;
        int i = 1;

        for (iter = flds.begin(); iter != flds.end(); ++iter)
        {
            MSG_DEBUG("    " << i << ": " << *iter);
            i++;
        }
    }

    return flds;
}

vector<TMap::MAP_T> TAmxCommands::findButtons(int port, vector<int>& channels, TMap::MAP_TYPE mt)
{
    DECL_TRACER("TAmxCommands::findButtons(int port, vector<int>& channels, TMap::MAP_TYPE mt)");

    vector<TMap::MAP_T> map;

    map = mMap->findButtons(port, channels, mt);
    return map;
}

string TAmxCommands::findImage(int bt, int page, int instance)
{
    DECL_TRACER("TAmxCommands::findImage(int bt, int page, int instance)");

    if (page < SYSTEM_PAGE_START)
        return mMap->findImage(bt, page, instance);

    return mSystemMap->findImage(bt, page, instance);
}

string TAmxCommands::findImage(const string& name)
{
    DECL_TRACER("TAmxCommands::findImage(const string& name)");

    string str = mMap->findImage(name);

    if (str.empty() && mSystemMap)
        return mSystemMap->findImage(name);

    return str;
}

vector<TMap::MAP_T> TAmxCommands::findButtonByName(const string& name)
{
    DECL_TRACER("TAmxCommands::findButtonByName(const string& name)");

    vector<TMap::MAP_T> map = mMap->findButtonByName(name);

    if (map.empty() && mSystemMap)
        return mSystemMap->findButtonByName(name);

    return map;
}

vector<TMap::MAP_T> TAmxCommands::findBargraphs(int port, vector<int>& channels)
{
    DECL_TRACER("TAmxCommands::findBargraphs(int port, vector<int>& channels)");

    vector<TMap::MAP_T> map = mMap->findBargraphs(port, channels);

    if (map.empty() && mSystemMap)
        return mSystemMap->findBargraphs(port, channels);

    return map;
}

vector<string> TAmxCommands::findSounds()
{
    DECL_TRACER("TAmxCommands::findSounds()");

    return mMap->findSounds();      // This is enough because there are no sounds in the system settings
}

bool TAmxCommands::soundExist(const string& sname)
{
    DECL_TRACER("TAmxCommands::soundExist(const string sname)");

    return mMap->soundExist(sname);
}

bool TAmxCommands::parseCommand(int device, int port, const string& cmd)
{
    DECL_TRACER("TAmxCommands::parseCommand(int device, int port, const string& cmd)");

    vector<CMD_TABLE>::iterator iter;
    size_t pos = cmd.find_first_of("-");
    int system = TConfig::getSystem();
    string scmd = getCommand(cmd);

    MSG_TRACE("Parsing for device <" << device << ":" << port << ":" << system << "> the command: " << scmd);

    if (pos != string::npos)    // Command with parameters
    {
        string rest = cmd.substr(pos + 1);

        for (iter = mCmdTable.begin(); iter != mCmdTable.end(); ++iter)
        {
            iter->channels.clear();
            iter->pars.clear();

            if (iter->cmd.compare(scmd) == 0 && iter->command)
            {
                CMD_DEFINATIONS cdef = findCmdDefines(scmd);

                if (cdef.cmd.empty())
                {
                    MSG_WARNING("Command \"" << scmd << "\" not found in command table! Ignoring it.");
                    continue;
                }

                if (cdef.hasChannels || cdef.hasPars)
                {
                    vector<string> parts = getFields(rest, cdef.separator);

                    if (cdef.hasChannels && !parts.empty())
                        extractChannels(parts[0], &iter->channels);
                    else if (parts.empty())
                    {
                        MSG_WARNING("Malformed command " << scmd << ". Ignoring it!");
                        continue;
                    }

                    if (cdef.hasPars)
                    {
                        MSG_DEBUG("Command may have parameters. Found " << parts.size() << " parameters.");

                        if (parts.size() > 0)
                        {
                            vector<string>::iterator piter;
                            int cnt = 0;

                            for (piter = parts.begin(); piter != parts.end(); ++piter)
                            {
                                if (cdef.hasChannels && !cnt)
                                {
                                    cnt++;
                                    continue;
                                }

                                iter->pars.push_back(*piter);
                                cnt++;
                            }
                        }
                        else
                            iter->pars.push_back(rest);
                    }
                }

                iter->command(port, iter->channels, iter->pars);
                return true;
            }
        }
    }
    else        // Command without parameter
    {
        for (iter = mCmdTable.begin(); iter != mCmdTable.end(); ++iter)
        {
            if (iter->cmd.compare(scmd) == 0 && iter->command)
            {
                iter->command(port, iter->channels, iter->pars);
                return true;
            }
        }
    }

    MSG_WARNING("Command \"" << cmd << "\" currently not supported!");
#if TESTMODE == 1
    __done = true;
#endif
    return false;
}

bool TAmxCommands::extractChannels(const string& schan, vector<int>* ch)
{
    DECL_TRACER("TAmxCommands::extractChannels(const string& schan, vector<int>* ch)");

    if (!ch || schan.empty())
        return false;

    if (schan.find("&") == string::npos && schan.find(".") == string::npos)
    {
        int c = atoi(schan.c_str());
        ch->push_back(c);
        return true;
    }

    if (schan.find("&") != string::npos)
    {
        vector<string> parts = StrSplit(schan, "&");
        vector<string>::iterator iter;

        if (parts.size() > 0)
        {
            for (iter = parts.begin(); iter != parts.end(); ++iter)
            {
                if (iter->find(".") != string::npos)
                {
                    vector<string> p2 = StrSplit(*iter, ".");

                    if (p2.size() >= 2)
                    {
                        for (int i = atoi(p2[0].c_str()); i <= atoi(p2[1].c_str()); i++)
                            ch->push_back(i);
                    }
                    else if (p2.size() > 0)
                        ch->push_back(atoi(p2[0].c_str()));
                }
                else
                    ch->push_back(atoi(iter->c_str()));
            }
        }
    }
    else
    {
        vector<string> parts = StrSplit(schan, ".");

        if (parts.size() >= 2)
        {
            for (int i = atoi(parts[0].c_str()); i <= atoi(parts[1].c_str()); i++)
                ch->push_back(i);
        }
        else if (parts.size() > 0)
            ch->push_back(atoi(parts[0].c_str()));
    }

    return true;
}

void TAmxCommands::registerCommand(std::function<void (int port, vector<int>& channels, vector<string>& pars)> command, const string& name)
{
    DECL_TRACER("TAmxCommands::registerCommand(std::function<void (vector<int>& channels, vector<string>& pars)> command, const string& name)");

    vector<CMD_TABLE>::iterator iter;

    for (iter = mCmdTable.begin(); iter != mCmdTable.end(); ++iter)
    {
        if (iter->cmd.compare(name) == 0)
        {
            iter->command = command;
            iter->channels.clear();
            iter->pars.clear();
            return;
        }
    }

    CMD_TABLE ctbl;
    ctbl.cmd = name;
    ctbl.command = command;
    mCmdTable.push_back(ctbl);
}