make edit resources asynchronously

source/Gui/EditSimulationDialog.cpp

@@ -12,6 +12,7 @@
 #include "HelpStrings.h"
 #include "StyleRepository.h"
 #include "GenericMessageDialog.h"
+#include "NetworkTransferController.h"
 #include "OverlayController.h"
 
 void EditSimulationDialog::openForLeaf(NetworkResourceTreeTO const& treeTO)
@@ -72,13 +73,8 @@ void EditSimulationDialog::processForLeaf()
     ImGui::BeginDisabled(_newName.empty());
     if (AlienImGui::Button("OK")) {
         if (ValidationService::isStringValidForDatabase(_newName) && ValidationService::isStringValidForDatabase(_newDescription)) {
-            delayedExecution([rawTO = rawTO, resourceTypeString = resourceTypeString, this] {
-                if (!NetworkService::get().editResource(rawTO->id, _newName, _newDescription)) {
-                    showMessage("Error", "Failed to edit " + resourceTypeString + ".");
-                }
-                BrowserWindow::get().onRefresh();
-            });
-            printOverlayMessage("Applying changes ...");
+            NetworkTransferController::get().onEdit(
+                EditNetworkResourceRequestData{.resourceId = rawTO->id, .newName = _newName, .newDescription = _newDescription});
             close();
         } else {
             showMessage("Error", Const::NotAllowedCharacters);
@@ -105,18 +101,12 @@ void EditSimulationDialog::processForFolder()
     ImGui::BeginDisabled(_newName.empty());
     if (AlienImGui::Button("OK")) {
         if (ValidationService::isStringValidForDatabase(_newName)) {
-            delayedExecution([this] {
-                for (auto const& rawTO : _rawTOs) {
-                    auto nameWithoutOldFolder = rawTO->resourceName.substr(_origFolderName.size() + 1);
-                    auto newName = NetworkResourceService::get().concatenateFolderName({_newName, nameWithoutOldFolder}, false);
-                    if (!NetworkService::get().editResource(rawTO->id, newName, rawTO->description)) {
-                        showMessage("Error", "Failed to change folder name.");
-                        break;
-                    }
-                }
-                BrowserWindow::get().onRefresh();
-            });
-            printOverlayMessage("Applying changes ...");
+            for (auto const& rawTO : _rawTOs) {
+                auto nameWithoutOldFolder = rawTO->resourceName.substr(_origFolderName.size() + 1);
+                auto newName = NetworkResourceService::get().concatenateFolderName({_newName, nameWithoutOldFolder}, false);
+                NetworkTransferController::get().onEdit(
+                    EditNetworkResourceRequestData{.resourceId = rawTO->id, .newName = newName, .newDescription = rawTO->description});
+            }
             close();
         } else {
             showMessage("Error", Const::NotAllowedCharacters);

source/Gui/MainLoopController.cpp

@@ -1,5 +1,7 @@
 #include "MainLoopController.h"
 
+#include <thread>
+
 #include <glad/glad.h>
 #include <GLFW/glfw3.h>
 

source/Gui/NetworkTransferController.cpp

@@ -20,6 +20,7 @@ void NetworkTransferController::init(SimulationFacade simulationFacade, Persiste
     _uploadProcessor = _TaskProcessor::createTaskProcessor(_persisterFacade);
     _replaceProcessor = _TaskProcessor::createTaskProcessor(_persisterFacade);
     _deleteProcessor = _TaskProcessor::createTaskProcessor(_persisterFacade);
+    _editProcessor = _TaskProcessor::createTaskProcessor(_persisterFacade);
 }
 
 void NetworkTransferController::onDownload(DownloadNetworkResourceRequestData const& requestData)
@@ -134,10 +135,27 @@ void NetworkTransferController::onDelete(DeleteNetworkResourceRequestData const&
         [](auto const& errors) { GenericMessageDialog::get().information("Error", errors); });
 }
 
+void NetworkTransferController::onEdit(EditNetworkResourceRequestData const& requestData)
+{
+    printOverlayMessage("Applying changes ...");
+
+    _editProcessor->executeTask(
+        [&](auto const& senderId) {
+            return _persisterFacade->scheduleEditNetworkResource(
+                SenderInfo{.senderId = senderId, .wishResultData = true, .wishErrorInfo = true}, requestData);
+        },
+        [&](auto const& requestId) {
+            _persisterFacade->fetchEditNetworkResourcesData(requestId);
+            BrowserWindow::get().onRefresh();
+        },
+        [](auto const& errors) { GenericMessageDialog::get().information("Error", errors); });
+}
+
 void NetworkTransferController::process()
 {
     _downloadProcessor->process();
     _uploadProcessor->process();
     _replaceProcessor->process();
     _deleteProcessor->process();
+    _editProcessor->process();
 }

source/Gui/NetworkTransferController.h

@@ -24,6 +24,7 @@ class NetworkTransferController : public MainLoopEntity<SimulationFacade, Persis
     void onUpload(UploadNetworkResourceRequestData const& requestData);
     void onReplace(ReplaceNetworkResourceRequestData const& requestData);
     void onDelete(DeleteNetworkResourceRequestData const& requestData);
+    void onEdit(EditNetworkResourceRequestData const& requestData);
 
 private:
     void init(SimulationFacade simulationFacade, PersisterFacade persisterFacade) override;
@@ -37,4 +38,5 @@ class NetworkTransferController : public MainLoopEntity<SimulationFacade, Persis
     TaskProcessor _uploadProcessor;
     TaskProcessor _replaceProcessor;
     TaskProcessor _deleteProcessor;
+    TaskProcessor _editProcessor;
 };

source/PersisterImpl/PersisterWorker.cpp

@@ -157,6 +157,9 @@ void _PersisterWorker::processRequests(std::unique_lock<std::mutex>& lock)
         if (auto const& concreteRequest = std::dynamic_pointer_cast<_DeleteNetworkResourceRequest>(request)) {
             processingResult = processRequest(lock, concreteRequest);
         }
+        if (auto const& concreteRequest = std::dynamic_pointer_cast<_EditNetworkResourceRequest>(request)) {
+            processingResult = processRequest(lock, concreteRequest);
+        }
         auto inProgressJobsIter = std::ranges::find_if(
             _inProgressRequests, [&](PersisterRequest const& otherRequest) { return otherRequest->getRequestId() == request->getRequestId(); });
         _inProgressRequests.erase(inProgressJobsIter);
@@ -554,3 +557,17 @@ _PersisterWorker::PersisterRequestResultOrError _PersisterWorker::processRequest
 
     return std::make_shared<_DeleteNetworkResourceRequestResult>(request->getRequestId(), DeleteNetworkResourceResultData{});
 }
+
+_PersisterWorker::PersisterRequestResultOrError _PersisterWorker::processRequest(std::unique_lock<std::mutex>& lock, EditNetworkResourceRequest const& request)
+{
+    UnlockGuard unlockGuard(lock);
+
+    auto const& requestData = request->getData();
+
+    if (!NetworkService::get().editResource(requestData.resourceId, requestData.newName, requestData.newDescription)) {
+        return std::make_shared<_PersisterRequestError>(
+            request->getRequestId(), request->getSenderInfo().senderId, PersisterErrorInfo{"Failed to edit item. Please try again later."});
+    }
+
+    return std::make_shared<_EditNetworkResourceRequestResult>(request->getRequestId(), EditNetworkResourceResultData{});
+}

source/PersisterImpl/PersisterWorker.h

@@ -43,6 +43,7 @@ class _PersisterWorker
     PersisterRequestResultOrError processRequest(std::unique_lock<std::mutex>& lock, ReplaceNetworkResourceRequest const& request);
     PersisterRequestResultOrError processRequest(std::unique_lock<std::mutex>& lock, GetUserNamesForEmojiRequest const& request);
     PersisterRequestResultOrError processRequest(std::unique_lock<std::mutex>& lock, DeleteNetworkResourceRequest const& request);
+    PersisterRequestResultOrError processRequest(std::unique_lock<std::mutex>& lock, EditNetworkResourceRequest const& request);
 
     SimulationFacade _simulationFacade;
 

source/PersisterInterface/EditNetworkResourceRequestData.h

@@ -1,4 +1,9 @@
 #pragma once
+#include <string>
 
 struct EditNetworkResourceRequestData
-{};
+{
+    std::string resourceId;
+    std::string newName;
+    std::string newDescription;
+};