fix: solve discovered bugs and improve ui operations

1 files changed, 28 insertions, 0 deletions

diff --git a/src/core/utils/AsyncUtils.cpp b/src/core/utils/AsyncUtils.cpp
index 40c2ece1..9ce94247 100644
--- a/src/core/utils/AsyncUtils.cpp
+++ b/src/core/utils/AsyncUtils.cpp
@@ -123,4 +123,32 @@ auto RunIOOperaAsync(const OperaRunnable& runnable,
   handler.Start();
   return handler;
 }
+
+auto RunOperaAsync(const OperaRunnable& runnable,
+                   const OperationCallback& callback, const QString& operation)
+    -> Thread::Task::TaskHandler {
+  auto handler =
+      Thread::TaskRunnerGetter::GetInstance()
+          .GetTaskRunner(Thread::TaskRunnerGetter::kTaskRunnerType_Default)
+          ->RegisterTask(
+              operation,
+              [=](const DataObjectPtr& data_object) -> int {
+                auto custom_data_object = TransferParams();
+                GpgError err = runnable(custom_data_object);
+
+                data_object->Swap({err, custom_data_object});
+                return 0;
+              },
+              [=](int rtn, const DataObjectPtr& data_object) {
+                if (rtn < 0) {
+                  callback(-1, ExtractParams<DataObjectPtr>(data_object, 1));
+                } else {
+                  callback(ExtractParams<GFError>(data_object, 0),
+                           ExtractParams<DataObjectPtr>(data_object, 1));
+                }
+              },
+              TransferParams());
+  handler.Start();
+  return handler;
+}
 }  // namespace GpgFrontend
\ No newline at end of file