WebSVN – tpanel – Diff – /trunk/tpagemanager.cpp

 /*
- * Copyright (C) 2020 by Andreas Theofilu <andreas@theosys.at>
+ * Copyright (C) 2020, 2021 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.
 using std::pair;
 using std::to_string;
 using std::thread;
 using std::atomic;
 using std::mutex;
+using std::bind;
 TIcons *gIcons = nullptr;
 TPrjResources *gPrjResources = nullptr;
 TPageManager *gPageManager = nullptr;
-thread::id gPageManagerId = (thread::id)0;
+thread::id gPageManagerId;
 extern amx::TAmxNet *gAmxNet;
 mutex surface_mutex;
-atomic<bool> runDoCommand = false;
+atomic<bool> runDoCommand;
+bool prg_stopped = false;
 TPageManager::TPageManager()
+{
     surface_mutex.lock();
     DECL_TRACER("TPageManager::TPageManager()");
     gPageManager = this;
     gPageManagerId = thread::id();
+    runDoCommand = false;
     mTSettings = new TSettings(TConfig::getProjectPath());
     if (TError::isError())
+    {
         surface_mutex.unlock();
     REG_CMD(doFON, "^FON");
     REG_CMD(doICO, "^ICO");
     REG_CMD(doSHO, "^SHO");
     REG_CMD(doTXT, "^TXT");
+    REG_CMD(doBBR, "^BBR");
+    REG_CMD(doRMF, "^RMF");
     REG_CMD(doON, "ON");
     REG_CMD(doOFF, "OFF");
     REG_CMD(doLEVEL, "LEVEL");
     REG_CMD(doBLINK, "BLINK");
     surface_mutex.lock();
     TPage *pg = getPage(mActualPage);
     pg->setFonts(mFonts);
     pg->registerCallback(_setBackground);
     pg->registerCallbackFT(_setText);
+    pg->regCallPlayVideo(_callPlayVideo);
     if (!pg || !_setPage || !mTSettings)
+    {
         surface_mutex.unlock();
         return false;
         subPg->setFonts(mFonts);
         subPg->registerCallback(_setBackground);
         subPg->registerCallbackDB(_displayButton);
         subPg->regCallDropSubPage(_callDropSubPage);
         subPg->registerCallbackFT(_setText);
+        subPg->regCallPlayVideo(_callPlayVideo);
         if (_setSubPage)
+        {
             MSG_DEBUG("Drawing page " << subPg->getNumber() << ": " << subPg->getName() << "...");
             _setSubPage(((subPg->getNumber() << 16) & 0xffff0000), subPg->getLeft(), subPg->getTop(), subPg->getWidth(), subPg->getHeight());
         page->setPalette(mPalette);
         page->setFonts(mFonts);
         page->registerCallback(_setBackground);
         page->registerCallbackDB(_displayButton);
         page->registerCallbackFT(_setText);
+        page->regCallPlayVideo(_callPlayVideo);
         if (!addPage(page))
             return false;
+    }
         page->setFonts(mFonts);
         page->registerCallback(_setBackground);
         page->registerCallbackDB(_displayButton);
         page->regCallDropSubPage(_callDropSubPage);
         page->registerCallbackFT(_setText);
+        page->regCallPlayVideo(_callPlayVideo);
         page->setGroup(spgIter->group);
         if (!addSubPage(page))
             return false;
+    }
     pg->setPalette(mPalette);
     pg->setFonts(mFonts);
     pg->registerCallback(_setBackground);
     pg->registerCallbackDB(_displayButton);
     pg->registerCallbackFT(_setText);
+    pg->regCallPlayVideo(_callPlayVideo);
     if (!addPage(pg))
         return false;
     return true;
     pg->setPalette(mPalette);
     pg->setFonts(mFonts);
     pg->registerCallback(_setBackground);
     pg->registerCallbackDB(_displayButton);
     pg->registerCallbackFT(_setText);
+    pg->regCallPlayVideo(_callPlayVideo);
     if (!addPage(pg))
         return false;
     return true;
     pg->setFonts(mFonts);
     pg->registerCallback(_setBackground);
     pg->registerCallbackDB(_displayButton);
     pg->regCallDropSubPage(_callDropSubPage);
     pg->registerCallbackFT(_setText);
+    pg->regCallPlayVideo(_callPlayVideo);
     pg->setGroup(page.group);
     if (!addSubPage(pg))
+    {
         delete pg;
     pg->setFonts(mFonts);
     pg->registerCallback(_setBackground);
     pg->registerCallbackDB(_displayButton);
     pg->regCallDropSubPage(_callDropSubPage);
     pg->registerCallbackFT(_setText);
+    pg->regCallPlayVideo(_callPlayVideo);
     pg->setGroup(page.group);
     if (!addSubPage(pg))
         return false;
 void TPageManager::setButtonCallbacks(Button::TButton *bt)
+{
     bt->registerCallback(_displayButton);
     bt->registerCallbackFT(_setText);
+    bt->regCallPlayVideo(_callPlayVideo);
     bt->setFonts(mFonts);
     bt->setPalette(mPalette);
+}
 /**
+        }
         else
             bt->setText(text, btState - 1);
+    }
+}
+void TPageManager::doBBR(int port, vector<int>& channels, vector<string>& pars)
+{
+    DECL_TRACER("TPageManager::doBBR(int port, vector<int>& channels, vector<string>& pars)");
+    if (pars.size() < 2)
+    {
+        MSG_ERROR("Expecting 2 parameters but got none! Ignoring command.");
+        return;
+    }
+    TError::clear();
+    int btState = atoi(pars[0].c_str());
+    string resName = pars[1];
+    vector<MAP_T> map = findButtons(port, channels);
+    if (TError::isError() || map.empty())
+        return;
+    vector<Button::TButton *> buttons = collectButtons(map);
+    vector<Button::TButton *>::iterator mapIter;
+    for (mapIter = buttons.begin(); mapIter != buttons.end(); mapIter++)
+    {
+        Button::TButton *bt = *mapIter;
+        setButtonCallbacks(bt);
+        if (btState == 0)       // All instances?
+        {
+            int bst = bt->getNumberInstances();
+            MSG_DEBUG("Setting BBR on all " << bst << " instances...");
+            for (int i = 0; i < bst; i++)
+                bt->setResourceName(resName, i);
+        }
+        else
+            bt->setResourceName(resName, btState - 1);
+    }
+}
+void TPageManager::doRMF(int port, vector<int>& channels, vector<string>& pars)
+{
+    DECL_TRACER("TPageManager::doRMF(int port, vector<int>& channels, vector<string>& pars)");
+    if (pars.size() < 2)
+    {
+        MSG_ERROR("Expecting 2 parameters but got none! Ignoring command.");
+        return;
+    }
+    string name = pars[0];
+    string data = pars[1];
+    vector<string> parts = StrSplit(data, "%");
+    RESOURCE_T res;
+    vector<string>::iterator sIter;
+    for (sIter = parts.begin(); sIter != parts.end(); sIter++)
+    {
+        const char *s = sIter->c_str();
+        MSG_DEBUG("Parsing \"" << s << "\" with token << " << *s);
+        switch(*s)
+        {
+            case 'P':
+                if (*(s+1) == '0')
+                    res.protocol = "HTTP";
+                else
+                    res.protocol = "FTP";
+            break;
+            case 'U': res.user = sIter->substr(1); break;
+            case 'S': res.password = sIter->substr(1); break;
+            case 'H': res.host = sIter->substr(1); break;
+            case 'F': res.file = sIter->substr(1); break;
+            case 'A': res.path = sIter->substr(1); break;
+            case 'R': res.refresh = atoi(sIter->substr(1).c_str()); break;
+            default:
+                MSG_WARNING("Option " << sIter->at(0) << " is currently not implemented!");
+        }
+    }
+    if (gPrjResources)
+        gPrjResources->setResource(name, res.protocol, res.host, res.path, res.file, res.user, res.password, res.refresh);
+}

Subversion Repositories tpanel

(root)/trunk/tpagemanager.cpp @ 21 – Rev 19 → 21