Greatly improve frontend/backend communication hygiene + logging

CMakeLists.txt

@@ -77,7 +77,7 @@ endif()
 
 include(OB/FetchQx)
 ob_fetch_qx(
-    REF "b29e03cf42dfed65a5ecaf18ce192f3051f0e25f"
+    REF "9043d76da8214c8bbe3f3343c72c5382b85dc36a"
     COMPONENTS
         ${CLIFP_QX_COMPONENTS}
 )
@@ -99,7 +99,7 @@ ob_fetch_quazip(
 
 # Fetch Neargye's Magic Enum
 include(OB/FetchMagicEnum)
-ob_fetch_magicenum("v0.9.3")
+ob_fetch_magicenum("v0.9.6")
 
 # Process Targets
 set(APP_TARGET_NAME ${PROJECT_NAMESPACE_LC}_${PROJECT_NAMESPACE_LC})

app/CMakeLists.txt

@@ -5,6 +5,11 @@ set(CLIFP_SOURCE
     kernel/buildinfo.h
     kernel/core.h
     kernel/core.cpp
+    kernel/directive.h
+    kernel/director.h
+    kernel/director.cpp
+    kernel/directorate.h
+    kernel/directorate.cpp
     kernel/driver.h
     kernel/driver.cpp
     kernel/errorstatus.h
@@ -57,7 +62,6 @@ set(CLIFP_SOURCE
     tools/mounter_qmp.cpp
     tools/mounter_router.h
     tools/mounter_router.cpp
-    frontend/message.h
     frontend/statusrelay.h
     frontend/statusrelay.cpp
     controller.h

app/src/command/c-download.cpp

@@ -2,6 +2,7 @@
 #include "c-download.h"
 
 // Project Includes
+#include "kernel/core.h"
 #include "task/t-download.h"
 #include "task/t-generic.h"
 
@@ -61,13 +62,13 @@ Qx::Error CDownload::perform()
     if(pItr == playlists.cend())
     {
         CDownloadError err(CDownloadError::InvalidPlaylist, playlistName);
-        postError(err);
+        postDirective<DError>(err);
         return err;
     }
     logEvent(LOG_EVENT_PLAYLIST_MATCH.arg(pItr->id().toString(QUuid::WithoutBraces)));
 
     // Queue downloads for each game
-    TDownload* downloadTask = new TDownload(&mCore);
+    TDownload* downloadTask = new TDownload(mCore);
     downloadTask->setStage(Task::Stage::Primary);
     downloadTask->setDescription(u"playlist data packs"_s);
     QList<int> dataIds;
@@ -83,7 +84,7 @@ Qx::Error CDownload::perform()
         Fp::GameData gameData;
         if(Fp::DbError gdErr = db->getGameData(gameData, pg.gameId()); gdErr.isValid())
         {
-            postError(gdErr);
+            postDirective<DError>(gdErr);
             return gdErr;
         }
 
@@ -100,7 +101,7 @@ Qx::Error CDownload::perform()
         TDownloadError packError = downloadTask->addDatapack(tk, &gameData);
         if(packError.isValid())
         {
-            postError(packError);
+            postDirective<DError>(packError);
             return packError;
         }
 
@@ -119,7 +120,7 @@ Qx::Error CDownload::perform()
 
     // Enqueue onDiskState update task
     Core* corePtr = &mCore; // Safe, will outlive task
-    TGeneric* onDiskUpdateTask = new TGeneric(corePtr);
+    TGeneric* onDiskUpdateTask = new TGeneric(mCore);
     onDiskUpdateTask->setStage(Task::Stage::Primary);
     onDiskUpdateTask->setDescription(u"Update GameData onDisk state."_s);
     onDiskUpdateTask->setAction([dataIds, corePtr]{

app/src/command/c-link.cpp

@@ -1,6 +1,9 @@
 // Unit Include
 #include "c-link.h"
 
+// Project Includes
+#include "kernel/core.h"
+
 //===============================================================================================================
 // CLinkError
 //===============================================================================================================
@@ -59,7 +62,7 @@ Qx::Error CLink::perform()
     Fp::DbError dbError = database->getEntry(entry_v, shortcutId);
     if(dbError.isValid())
     {
-        postError(dbError);
+        postDirective<DError>(dbError);
         return dbError;
     }
 
@@ -76,7 +79,7 @@ Qx::Error CLink::perform()
         Fp::DbError dbError = database->getEntry(entry_v, addApp.parentId());
         if(dbError.isValid())
         {
-            postError(dbError);
+            postDirective<DError>(dbError);
             return dbError;
         }
         Q_ASSERT(std::holds_alternative<Fp::Game>(entry_v));
@@ -99,11 +102,12 @@ Qx::Error CLink::perform()
         logEvent(LOG_EVENT_NO_PATH);
 
         // Prompt user for path
-        Core::ExistingDirRequest edr{
+        QString selectedPath; // Default is empty dir
+        postDirective(DExistingDir{
             .caption = DIAG_CAPTION,
-            .dir = QStandardPaths::writableLocation(QStandardPaths::DesktopLocation)
-        };
-        QString selectedPath = mCore.requestExistingDirPath(edr);
+            .startingDir = QStandardPaths::writableLocation(QStandardPaths::DesktopLocation),
+            .response = &selectedPath
+        });
 
         if(selectedPath.isEmpty())
         {
@@ -123,7 +127,7 @@ Qx::Error CLink::perform()
         if(!shortcutDir.mkpath(shortcutDir.absolutePath()))
         {
             CLinkError err(CLinkError::InvalidPath);
-            postError(err);
+            postDirective<DError>(err);
             return err;
         }
         logEvent(LOG_EVENT_CREATED_DIR_PATH.arg(QDir::toNativeSeparators(shortcutDir.absolutePath())));

app/src/command/c-link_win.cpp

@@ -31,7 +31,7 @@ Qx::Error CLink::createShortcut(const QString& name, const QDir& dir, QUuid id)
     // Check for creation failure
     if(shortcutError.isValid())
     {
-        postError(shortcutError);
+        postDirective<DError>(shortcutError);
         return shortcutError;
     }
     else

app/src/command/c-play.cpp

@@ -8,9 +8,10 @@
 #include <qx/core/qx-regularexpression.h>
 
 // Project Includes
-#include "../task/t-exec.h"
-#include "../task/t-message.h"
-#include "../task/t-extra.h"
+#include "kernel/core.h"
+#include "task/t-exec.h"
+#include "task/t-message.h"
+#include "task/t-extra.h"
 
 //===============================================================================================================
 // CPlayError
@@ -100,7 +101,7 @@ Qx::Error CPlay::handleEntry(const Fp::Game& game)
     Fp::GameData gameData;
     if(Fp::DbError gdErr = db->getGameData(gameData, game.id()); gdErr.isValid())
     {
-        postError(gdErr);
+        postDirective<DError>(gdErr);
         return gdErr;
     }
     bool hasDatapack = !gameData.isNull();
@@ -130,7 +131,7 @@ Qx::Error CPlay::handleEntry(const Fp::Game& game)
     addAppSearchError = db->queryEntrys(addAppSearchResult, addAppFilter);
     if(addAppSearchError.isValid())
     {
-        postError(addAppSearchError);
+        postDirective<DError>(addAppSearchError);
         return addAppSearchError;
     }
 
@@ -176,7 +177,7 @@ Qx::Error CPlay::handleEntry(const Fp::AddApp& addApp)
     Fp::GameData parentGameData;
     if(Fp::DbError gdErr = db->getGameData(parentGameData, parentId); gdErr.isValid())
     {
-        postError(gdErr);
+        postDirective<DError>(gdErr);
         return gdErr;
     }
     bool hasDatapack = !parentGameData.isNull();
@@ -205,7 +206,7 @@ Qx::Error CPlay::handleEntry(const Fp::AddApp& addApp)
 
     if(Fp::DbError pge = db->queryEntrys(parentResult, parentFilter); pge.isValid())
     {
-        postError(pge);
+        postDirective<DError>(pge);
         return pge;
     }
 
@@ -232,7 +233,7 @@ Qx::Error CPlay::enqueueAdditionalApp(const Fp::AddApp& addApp, const QString& p
 {
     if(addApp.appPath() == Fp::Db::Table_Add_App::ENTRY_MESSAGE)
     {
-        TMessage* messageTask = new TMessage(&mCore);
+        TMessage* messageTask = new TMessage(mCore);
         messageTask->setStage(taskStage);
         messageTask->setText(addApp.launchCommand());
         messageTask->setBlocking(addApp.isWaitExit());
@@ -241,7 +242,7 @@ Qx::Error CPlay::enqueueAdditionalApp(const Fp::AddApp& addApp, const QString& p
     }
     else if(addApp.appPath() == Fp::Db::Table_Add_App::ENTRY_EXTRAS)
     {
-        TExtra* extraTask = new TExtra(&mCore);
+        TExtra* extraTask = new TExtra(mCore);
         extraTask->setStage(taskStage);
         extraTask->setDirectory(QDir(mCore.fpInstall().extrasDirectory().absolutePath() + '/' + addApp.launchCommand()));
 
@@ -254,7 +255,7 @@ Qx::Error CPlay::enqueueAdditionalApp(const Fp::AddApp& addApp, const QString& p
         QString param = addApp.launchCommand();
         addPassthroughParameters(param);
 
-        TExec* addAppTask = new TExec(&mCore);
+        TExec* addAppTask = new TExec(mCore);
         addAppTask->setIdentifier(addApp.name());
         addAppTask->setStage(taskStage);
         addAppTask->setExecutable(QDir::cleanPath(addAppPathInfo.absoluteFilePath())); // Like canonical but doesn't care if path DNE
@@ -284,7 +285,7 @@ Qx::Error CPlay::enqueueGame(const Fp::Game& game, const Fp::GameData& gameData,
     QString param = !gameData.isNull() ? gameData.launchCommand() : game.launchCommand();
     addPassthroughParameters(param);
 
-    TExec* gameTask = new TExec(&mCore);
+    TExec* gameTask = new TExec(mCore);
     gameTask->setIdentifier(game.title());
     gameTask->setStage(taskStage);
     gameTask->setExecutable(QDir::cleanPath(gamePathInfo.absoluteFilePath())); // Like canonical but doesn't care if path DNE
@@ -320,7 +321,7 @@ Qx::Error CPlay::perform()
         if(!urlMatch.hasMatch())
         {
             CPlayError err(CPlayError::InvalidUrl);
-            postError(err);
+            postDirective<DError>(err);
             return err;
         }
 
@@ -341,7 +342,7 @@ Qx::Error CPlay::perform()
     Fp::Entry entry;
     if(Fp::DbError eErr = db->getEntry(entry, titleId); eErr.isValid())
     {
-        postError(eErr);
+        postDirective<DError>(eErr);
         return eErr;
     }
 

app/src/command/c-play.h

@@ -6,6 +6,7 @@
 
 // Project Includes
 #include "command/title-command.h"
+#include "task/task.h"
 
 class QX_ERROR_TYPE(CPlayError, "CPlayError", 1212)
 {

app/src/command/c-prepare.cpp

@@ -4,6 +4,9 @@
 // Qx Includes
 #include <qx/core/qx-genericerror.h>
 
+// Project Includes
+#include "kernel/core.h"
+
 //===============================================================================================================
 // CPREPARE
 //===============================================================================================================
@@ -28,7 +31,7 @@ Qx::Error CPrepare::perform()
     Fp::GameData titleGameData;
     if(Fp::DbError gdErr = mCore.fpInstall().database()->getGameData(titleGameData, id); gdErr.isValid())
     {
-        postError(gdErr);
+        postDirective<DError>(gdErr);
         return gdErr;
     }
 

app/src/command/c-run.cpp

@@ -2,6 +2,7 @@
 #include "c-run.h"
 
 // Project Includes
+#include "kernel/core.h"
 #include "task/t-exec.h"
 
 //===============================================================================================================
@@ -50,7 +51,7 @@ Qx::Error CRun::perform()
     QString inputPath = mCore.resolveFullAppPath(mParser.value(CL_OPTION_APP), u""_s); // No way of knowing platform
     QFileInfo inputInfo = QFileInfo(inputPath);
 
-    TExec* runTask = new TExec(&mCore);
+    TExec* runTask = new TExec(mCore);
     runTask->setIdentifier(NAME + u" program"_s);
     runTask->setStage(Task::Stage::Primary);
     runTask->setExecutable(QDir::cleanPath(inputInfo.absoluteFilePath())); // Like canonical but doesn't care if path DNE

app/src/command/c-share.cpp

@@ -5,6 +5,7 @@
 #include <qx/core/qx-system.h>
 
 // Project Includes
+#include "kernel/core.h"
 #include "task/t-message.h"
 #include "utility.h"
 
@@ -54,12 +55,12 @@ Qx::Error CShare::perform()
         if(!Qx::setDefaultProtocolHandler(SCHEME, SCHEME_NAME))
         {
             CShareError err(CShareError::RegistrationFailed);
-            postError(err);
+            postDirective<DError>(err);
             return err;
         }
 
         // Enqueue success message task
-        TMessage* successMsg = new TMessage(&mCore);
+        TMessage* successMsg = new TMessage(mCore);
         successMsg->setStage(Task::Stage::Primary);
         successMsg->setText(MSG_REGISTRATION_COMPLETE);
         mCore.enqueueSingleTask(successMsg);
@@ -77,12 +78,12 @@ Qx::Error CShare::perform()
 #endif
         {
             CShareError err(CShareError::UnregistrationFailed);
-            postError(err);
+            postDirective<DError>(err);
             return err;
         }
 
         // Enqueue success message task
-        TMessage* successMsg = new TMessage(&mCore);
+        TMessage* successMsg = new TMessage(mCore);
         successMsg->setStage(Task::Stage::Primary);
         successMsg->setText(MSG_UNREGISTRATION_COMPLETE);
         mCore.enqueueSingleTask(successMsg);
@@ -103,10 +104,10 @@ Qx::Error CShare::perform()
     logEvent(LOG_EVENT_URL.arg(shareUrl));
 
     // Add URL to clipboard
-    mCore.requestClipboardUpdate(shareUrl);
+    postDirective<DClipboardUpdate>(shareUrl);
 
     // Enqueue message task
-    TMessage* urlMsg = new TMessage(&mCore);
+    TMessage* urlMsg = new TMessage(mCore);
     urlMsg->setStage(Task::Stage::Primary);
     urlMsg->setText(MSG_GENERATED_URL.arg(shareUrl));
     urlMsg->setSelectable(true);

app/src/command/c-show.cpp

@@ -2,6 +2,7 @@
 #include "c-show.h"
 
 // Project Includes
+#include "kernel/core.h"
 #include "task/t-message.h"
 #include "task/t-extra.h"
 
@@ -46,7 +47,7 @@ Qx::Error CShow::perform()
     // Enqueue show task
     if(mParser.isSet(CL_OPTION_MSG))
     {
-        TMessage* messageTask = new TMessage(&mCore);
+        TMessage* messageTask = new TMessage(mCore);
         messageTask->setStage(Task::Stage::Primary);
         messageTask->setText(mParser.value(CL_OPTION_MSG));
 
@@ -55,7 +56,7 @@ Qx::Error CShow::perform()
     }
     else if(mParser.isSet(CL_OPTION_EXTRA))
     {
-        TExtra* extraTask = new TExtra(&mCore);
+        TExtra* extraTask = new TExtra(mCore);
         extraTask->setStage(Task::Stage::Primary);
         extraTask->setDirectory(QDir(mCore.fpInstall().extrasDirectory().absolutePath() + '/' + mParser.value(CL_OPTION_EXTRA)));
 
@@ -65,7 +66,7 @@ Qx::Error CShow::perform()
     else
     {
         CShowError err(CShowError::MissingThing);
-        postError(err);
+        postDirective<DError>(err);
         return err;
     }