[gnome-software: 11/72] rpm-ostree: Make refine asynchronous

[Philip Withnall <pwithnall src gnome org>]

commit 20889d0eaf991255ee0bddaf2bdbc4a605c5bce6
Author: Philip Withnall <pwithnall endlessos org>
Date:   Fri Oct 22 14:53:11 2021 +0100

    rpm-ostree: Make refine asynchronous
    
    Signed-off-by: Philip Withnall <pwithnall endlessos org>
    
    Helps: #1472

 plugins/rpm-ostree/gs-plugin-rpm-ostree.c | 58 +++++++++++++++++++++++++++----
 1 file changed, 51 insertions(+), 7 deletions(-)
---
diff --git a/plugins/rpm-ostree/gs-plugin-rpm-ostree.c b/plugins/rpm-ostree/gs-plugin-rpm-ostree.c
index 4bd9fb659..01c2741e0 100644
--- a/plugins/rpm-ostree/gs-plugin-rpm-ostree.c
+++ b/plugins/rpm-ostree/gs-plugin-rpm-ostree.c
@@ -1983,14 +1983,56 @@ gs_rpm_ostree_refine_apps (GsPlugin *plugin,
        return TRUE;
 }
 
-gboolean
-gs_plugin_refine (GsPlugin *plugin,
-                  GsAppList *list,
-                  GsPluginRefineFlags flags,
-                  GCancellable *cancellable,
-                  GError **error)
+static void refine_thread_cb (GTask        *task,
+                              gpointer      source_object,
+                              gpointer      task_data,
+                              GCancellable *cancellable);
+
+static void
+gs_plugin_rpm_ostree_refine_async (GsPlugin            *plugin,
+                                   GsAppList           *list,
+                                   GsPluginRefineFlags  flags,
+                                   GCancellable        *cancellable,
+                                   GAsyncReadyCallback  callback,
+                                   gpointer             user_data)
+{
+       GsPluginRpmOstree *self = GS_PLUGIN_RPM_OSTREE (plugin);
+       g_autoptr(GTask) task = NULL;
+
+       task = gs_plugin_refine_data_new_task (plugin, list, flags, cancellable, callback, user_data);
+       g_task_set_source_tag (task, gs_plugin_rpm_ostree_refine_async);
+
+       gs_worker_thread_queue (self->worker, G_PRIORITY_DEFAULT,
+                               refine_thread_cb, g_steal_pointer (&task));
+}
+
+static void
+refine_thread_cb (GTask        *task,
+                  gpointer      source_object,
+                  gpointer      task_data,
+                  GCancellable *cancellable)
 {
-       return gs_rpm_ostree_refine_apps (plugin, list, flags, cancellable, error);
+       GsPlugin *plugin = GS_PLUGIN (source_object);
+       GsPluginRpmOstree *self = GS_PLUGIN_RPM_OSTREE (plugin);
+       GsPluginRefineData *data = task_data;
+       GsAppList *list = data->list;
+       GsPluginRefineFlags flags = data->flags;
+       g_autoptr(GError) local_error = NULL;
+
+       assert_in_worker (self);
+
+       if (!gs_rpm_ostree_refine_apps (plugin, list, flags, cancellable, &local_error))
+               g_task_return_error (task, g_steal_pointer (&local_error));
+       else
+               g_task_return_boolean (task, TRUE);
+}
+
+static gboolean
+gs_plugin_rpm_ostree_refine_finish (GsPlugin      *plugin,
+                                    GAsyncResult  *result,
+                                    GError       **error)
+{
+       return g_task_propagate_boolean (G_TASK (result), error);
 }
 
 gboolean
@@ -2420,6 +2462,8 @@ gs_plugin_rpm_ostree_class_init (GsPluginRpmOstreeClass *klass)
        plugin_class->setup_finish = gs_plugin_rpm_ostree_setup_finish;
        plugin_class->shutdown_async = gs_plugin_rpm_ostree_shutdown_async;
        plugin_class->shutdown_finish = gs_plugin_rpm_ostree_shutdown_finish;
+       plugin_class->refine_async = gs_plugin_rpm_ostree_refine_async;
+       plugin_class->refine_finish = gs_plugin_rpm_ostree_refine_finish;
 }
 
 GType