[gnome-software/wip/async-plugin-repo-funcs: 2/29] lib: Add GsPluginJobManageRepository

[Milan Crha <mcrha src gnome org>]

commit 8a64f9fe7772055e9c2156e771686ab7d78e39dd
Author: Milan Crha <mcrha redhat com>
Date:   Mon Jun 13 18:42:25 2022 +0200

    lib: Add GsPluginJobManageRepository
    
    This will be used to install, remove, enable or disable given repository.

 lib/gnome-software.h                  |   1 +
 lib/gs-plugin-job-manage-repository.c | 391 ++++++++++++++++++++++++++++++++++
 lib/gs-plugin-job-manage-repository.h |  27 +++
 lib/meson.build                       |   2 +
 4 files changed, 421 insertions(+)
---
diff --git a/lib/gnome-software.h b/lib/gnome-software.h
index 1594bfc14..12d8af5de 100644
--- a/lib/gnome-software.h
+++ b/lib/gnome-software.h
@@ -31,6 +31,7 @@
 #include <gs-plugin-job.h>
 #include <gs-plugin-job-list-apps.h>
 #include <gs-plugin-job-list-distro-upgrades.h>
+#include <gs-plugin-job-manage-repository.h>
 #include <gs-plugin-job-refine.h>
 #include <gs-plugin-job-refresh-metadata.h>
 #include <gs-plugin-vfuncs.h>
diff --git a/lib/gs-plugin-job-manage-repository.c b/lib/gs-plugin-job-manage-repository.c
new file mode 100644
index 000000000..d60ab362d
--- /dev/null
+++ b/lib/gs-plugin-job-manage-repository.c
@@ -0,0 +1,391 @@
+/* -*- Mode: C; tab-width: 8; indent-tabs-mode: t; c-basic-offset: 8 -*-
+ * vi:set noexpandtab tabstop=8 shiftwidth=8:
+ *
+ * Copyright (C) 2022 Red Hat <www.redhat.com>
+ *
+ * SPDX-License-Identifier: GPL-2.0+
+ */
+
+/**
+ * SECTION:gs-plugin-job-manage-repository
+ * @short_description: A plugin job on a repository
+ *
+ * #GsPluginJobManageRepository is a #GsPluginJob representing an operation on
+ * a repository, like install, remove, enable and disable it.
+ *
+ * This class is a wrapper around #GsPluginClass.install_repository_async,
+ * #GsPluginClass.remove_repository_async, #GsPluginClass.enable_repository_async
+ * and #GsPluginClass.disable_repository_async calling it for all loaded plugins.
+ *
+ * Since: 43
+ */
+
+#include "config.h"
+
+#include <glib.h>
+#include <glib-object.h>
+
+#include "gs-app.h"
+#include "gs-app-collation.h"
+#include "gs-enums.h"
+#include "gs-plugin-job.h"
+#include "gs-plugin-job-manage-repository.h"
+#include "gs-plugin-job-private.h"
+#include "gs-plugin-types.h"
+
+struct _GsPluginJobManageRepository
+{
+       GsPluginJob parent;
+
+       /* Input arguments. */
+       GsApp *repository;  /* (owned) (not nullable) */
+       GsPluginManageRepositoryOperation operation;
+       GsPluginManageRepositoryFlags flags;
+
+       /* In-progress data. */
+       GError *saved_error;  /* (owned) (nullable) */
+       guint n_pending_ops;
+};
+
+G_DEFINE_TYPE (GsPluginJobManageRepository, gs_plugin_job_manage_repository, GS_TYPE_PLUGIN_JOB)
+
+typedef enum {
+       PROP_FLAGS = 1,
+       PROP_OPERATION,
+       PROP_REPOSITORY,
+} GsPluginJobManageRepositoryProperty;
+
+static GParamSpec *props[PROP_REPOSITORY + 1] = { NULL, };
+
+static void
+gs_plugin_job_manage_repository_dispose (GObject *object)
+{
+       GsPluginJobManageRepository *self = GS_PLUGIN_JOB_MANAGE_REPOSITORY (object);
+
+       g_assert (self->saved_error == NULL);
+       g_assert (self->n_pending_ops == 0);
+
+       G_OBJECT_CLASS (gs_plugin_job_manage_repository_parent_class)->dispose (object);
+}
+
+static void
+gs_plugin_job_manage_repository_get_property (GObject    *object,
+                                             guint       prop_id,
+                                             GValue     *value,
+                                             GParamSpec *pspec)
+{
+       GsPluginJobManageRepository *self = GS_PLUGIN_JOB_MANAGE_REPOSITORY (object);
+
+       switch ((GsPluginJobManageRepositoryProperty) prop_id) {
+       case PROP_FLAGS:
+               g_value_set_flags (value, self->flags);
+               break;
+       case PROP_OPERATION:
+               g_value_set_enum (value, self->operation);
+               break;
+       case PROP_REPOSITORY:
+               g_value_set_object (value, self->repository);
+               break;
+       default:
+               G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+               break;
+       }
+}
+
+static void
+gs_plugin_job_manage_repository_set_property (GObject      *object,
+                                             guint         prop_id,
+                                             const GValue *value,
+                                             GParamSpec   *pspec)
+{
+       GsPluginJobManageRepository *self = GS_PLUGIN_JOB_MANAGE_REPOSITORY (object);
+
+       switch ((GsPluginJobManageRepositoryProperty) prop_id) {
+       case PROP_FLAGS:
+               /* Construct only. */
+               g_assert (self->flags == 0);
+               self->flags = g_value_get_flags (value);
+               g_object_notify_by_pspec (object, props[prop_id]);
+               break;
+       case PROP_OPERATION:
+               /* Construct only. */
+               g_assert (self->operation == GS_PLUGIN_MANAGE_REPOSITORY_OPERATION_UNKNOWN);
+               self->operation = g_value_get_enum (value);
+               g_assert (self->operation != GS_PLUGIN_MANAGE_REPOSITORY_OPERATION_UNKNOWN);
+               g_object_notify_by_pspec (object, props[prop_id]);
+               break;
+       case PROP_REPOSITORY:
+               /* Construct only. */
+               g_assert (self->repository == NULL);
+               self->repository = g_value_dup_object (value);
+               g_assert (self->repository != NULL);
+               g_object_notify_by_pspec (object, props[prop_id]);
+               break;
+       default:
+               G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+               break;
+       }
+}
+
+static void plugin_repository_func_cb (GObject      *source_object,
+                                      GAsyncResult *result,
+                                      gpointer      user_data);
+static void finish_op (GTask  *task,
+                       GError *error);
+
+static void
+gs_plugin_job_manage_repository_run_async (GsPluginJob         *job,
+                                          GsPluginLoader      *plugin_loader,
+                                          GCancellable        *cancellable,
+                                          GAsyncReadyCallback  callback,
+                                          gpointer             user_data)
+{
+       GsPluginJobManageRepository *self = GS_PLUGIN_JOB_MANAGE_REPOSITORY (job);
+       g_autoptr(GTask) task = NULL;
+       GPtrArray *plugins;  /* (element-type GsPlugin) */
+       gboolean anything_ran = FALSE;
+
+       task = g_task_new (job, cancellable, callback, user_data);
+       g_task_set_source_tag (task, gs_plugin_job_manage_repository_run_async);
+       g_task_set_task_data (task, g_object_ref (plugin_loader), (GDestroyNotify) g_object_unref);
+
+       /* run each plugin, keeping a counter of pending operations which is
+        * initialised to 1 until all the operations are started */
+       self->n_pending_ops = 1;
+       plugins = gs_plugin_loader_get_plugins (plugin_loader);
+
+       for (guint i = 0; i < plugins->len; i++) {
+               GsPlugin *plugin = g_ptr_array_index (plugins, i);
+               GsPluginClass *plugin_class = GS_PLUGIN_GET_CLASS (plugin);
+               void (* repository_func_async) (GsPlugin *plugin,
+                                               GsApp *repository,
+                                               GsPluginManageRepositoryFlags flags,
+                                               GCancellable *cancellable,
+                                               GAsyncReadyCallback callback,
+                                               gpointer user_data) = NULL;
+
+               if (!gs_plugin_get_enabled (plugin))
+                       continue;
+               switch (self->operation) {
+               case GS_PLUGIN_MANAGE_REPOSITORY_OPERATION_INSTALL:
+                       repository_func_async = plugin_class->install_repository_async;
+                       break;
+               case GS_PLUGIN_MANAGE_REPOSITORY_OPERATION_REMOVE:
+                       repository_func_async = plugin_class->remove_repository_async;
+                       break;
+               case GS_PLUGIN_MANAGE_REPOSITORY_OPERATION_ENABLE:
+                       repository_func_async = plugin_class->enable_repository_async;
+                       break;
+               case GS_PLUGIN_MANAGE_REPOSITORY_OPERATION_DISABLE:
+                       repository_func_async = plugin_class->disable_repository_async;
+                       break;
+               default:
+                       g_assert_not_reached ();
+                       break;
+               }
+               if (repository_func_async == NULL)
+                       continue;
+
+               /* at least one plugin supports this vfunc */
+               anything_ran = TRUE;
+
+               /* run the plugin */
+               self->n_pending_ops++;
+               repository_func_async (plugin, self->repository, self->flags, cancellable, 
plugin_repository_func_cb, g_object_ref (task));
+       }
+
+       if (!anything_ran)
+               g_debug ("no plugin could handle repository operation");
+
+       finish_op (task, NULL);
+}
+
+static void
+plugin_repository_func_cb (GObject      *source_object,
+                          GAsyncResult *result,
+                          gpointer      user_data)
+{
+       GsPlugin *plugin = GS_PLUGIN (source_object);
+       GsPluginClass *plugin_class = GS_PLUGIN_GET_CLASS (plugin);
+       g_autoptr(GTask) task = G_TASK (user_data);
+       GsPluginJobManageRepository *self = g_task_get_source_object (task);
+       gboolean success;
+       g_autoptr(GError) local_error = NULL;
+       gboolean (* repository_func_finish) (GsPlugin *plugin,
+                                            GAsyncResult *result,
+                                            GError **error) = NULL;
+
+       switch (self->operation) {
+       case GS_PLUGIN_MANAGE_REPOSITORY_OPERATION_INSTALL:
+               repository_func_finish = plugin_class->install_repository_finish;
+               break;
+       case GS_PLUGIN_MANAGE_REPOSITORY_OPERATION_REMOVE:
+               repository_func_finish = plugin_class->remove_repository_finish;
+               break;
+       case GS_PLUGIN_MANAGE_REPOSITORY_OPERATION_ENABLE:
+               repository_func_finish = plugin_class->enable_repository_finish;
+               break;
+       case GS_PLUGIN_MANAGE_REPOSITORY_OPERATION_DISABLE:
+               repository_func_finish = plugin_class->disable_repository_finish;
+               break;
+       default:
+               g_assert_not_reached ();
+               break;
+       }
+
+       g_assert (repository_func_finish != NULL);
+
+       success = repository_func_finish (plugin, result, &local_error);
+       gs_plugin_status_update (plugin, NULL, GS_PLUGIN_STATUS_FINISHED);
+
+       g_assert (success || local_error != NULL);
+
+       finish_op (task, g_steal_pointer (&local_error));
+}
+
+static void
+reset_app_progress (GsApp *app)
+{
+       g_autoptr(GsAppList) addons = gs_app_dup_addons (app);
+       GsAppList *related = gs_app_get_related (app);
+
+       gs_app_set_progress (app, GS_APP_PROGRESS_UNKNOWN);
+
+       for (guint i = 0; addons != NULL && i < gs_app_list_length (addons); i++) {
+               GsApp *app_addons = gs_app_list_index (addons, i);
+               gs_app_set_progress (app_addons, GS_APP_PROGRESS_UNKNOWN);
+       }
+       for (guint i = 0; i < gs_app_list_length (related); i++) {
+               GsApp *app_related = gs_app_list_index (related, i);
+               gs_app_set_progress (app_related, GS_APP_PROGRESS_UNKNOWN);
+       }
+}
+
+/* @error is (transfer full) if non-%NULL */
+static void
+finish_op (GTask  *task,
+           GError *error)
+{
+       GsPluginJobManageRepository *self = g_task_get_source_object (task);
+       g_autoptr(GError) error_owned = g_steal_pointer (&error);
+       g_autofree gchar *job_debug = NULL;
+
+       if (error_owned != NULL && self->saved_error == NULL)
+               self->saved_error = g_steal_pointer (&error_owned);
+       else if (error_owned != NULL)
+               g_debug ("Additional error while managing repository: %s", error_owned->message);
+
+       g_assert (self->n_pending_ops > 0);
+       self->n_pending_ops--;
+
+       if (self->n_pending_ops > 0)
+               return;
+
+       /* show elapsed time */
+       job_debug = gs_plugin_job_to_string (GS_PLUGIN_JOB (self));
+       g_debug ("%s", job_debug);
+
+       reset_app_progress (self->repository);
+
+       if (self->saved_error != NULL)
+               g_task_return_error (task, g_steal_pointer (&self->saved_error));
+       else
+               g_task_return_boolean (task, TRUE);
+}
+
+static gboolean
+gs_plugin_job_manage_repository_run_finish (GsPluginJob   *self,
+                                           GAsyncResult  *result,
+                                           GError       **error)
+{
+       return g_task_propagate_boolean (G_TASK (result), error);
+}
+
+static void
+gs_plugin_job_manage_repository_class_init (GsPluginJobManageRepositoryClass *klass)
+{
+       GObjectClass *object_class = G_OBJECT_CLASS (klass);
+       GsPluginJobClass *job_class = GS_PLUGIN_JOB_CLASS (klass);
+
+       object_class->dispose = gs_plugin_job_manage_repository_dispose;
+       object_class->get_property = gs_plugin_job_manage_repository_get_property;
+       object_class->set_property = gs_plugin_job_manage_repository_set_property;
+
+       job_class->run_async = gs_plugin_job_manage_repository_run_async;
+       job_class->run_finish = gs_plugin_job_manage_repository_run_finish;
+
+       /**
+        * GsPluginJobManageRepository:repository: (not nullable)
+        *
+        * A #GsApp describing the repository to run the operation on.
+        *
+        * Since: 43
+        */
+       props[PROP_REPOSITORY] =
+               g_param_spec_object ("repository", "Repository",
+                                    "A #GsApp describing the repository to run the operation on.",
+                                    GS_TYPE_APP,
+                                    G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY |
+                                    G_PARAM_STATIC_STRINGS | G_PARAM_EXPLICIT_NOTIFY);
+
+       /**
+        * GsPluginJobManageRepository:operation:
+        *
+        * The operation to run.
+        *
+        * Since: 43
+        */
+       props[PROP_OPERATION] =
+               g_param_spec_enum ("operation", "Operation",
+                                  "The operation to run.",
+                                  GS_TYPE_PLUGIN_MANAGE_REPOSITORY_OPERATION,
+                                  GS_PLUGIN_MANAGE_REPOSITORY_OPERATION_UNKNOWN,
+                                  G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY |
+                                  G_PARAM_STATIC_STRINGS | G_PARAM_EXPLICIT_NOTIFY);
+
+       /**
+        * GsPluginJobManageRepository:flags:
+        *
+        * Flags to specify how the operation should run.
+        *
+        * Since: 43
+        */
+       props[PROP_FLAGS] =
+               g_param_spec_flags ("flags", "Flags",
+                                   "Flags to specify how and which the operation should run.",
+                                   GS_TYPE_PLUGIN_MANAGE_REPOSITORY_FLAGS,
+                                   GS_PLUGIN_MANAGE_REPOSITORY_FLAGS_NONE,
+                                   G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY |
+                                   G_PARAM_STATIC_STRINGS | G_PARAM_EXPLICIT_NOTIFY);
+
+       g_object_class_install_properties (object_class, G_N_ELEMENTS (props), props);
+}
+
+static void
+gs_plugin_job_manage_repository_init (GsPluginJobManageRepository *self)
+{
+}
+
+/**
+ * gs_plugin_job_manage_repository_new:
+ * @repository: (not nullable) (transfer none): a repository to run the operation on
+ * @flags: flags affecting how the operation runs
+ *
+ * Create a new #GsPluginJobManageRepository to manage the given @repository.
+ *
+ * Returns: (transfer full): a new #GsPluginJobManageRepository
+ * Since: 43
+ */
+GsPluginJob *
+gs_plugin_job_manage_repository_new (GsApp                             *repository,
+                                    GsPluginManageRepositoryOperation  operation,
+                                    GsPluginManageRepositoryFlags      flags)
+{
+       g_return_val_if_fail (GS_IS_APP (repository), NULL);
+
+       return g_object_new (GS_TYPE_PLUGIN_JOB_MANAGE_REPOSITORY,
+                            "repository", repository,
+                            "operation", operation,
+                            "flags", flags,
+                            NULL);
+}
diff --git a/lib/gs-plugin-job-manage-repository.h b/lib/gs-plugin-job-manage-repository.h
new file mode 100644
index 000000000..3ca9a48e3
--- /dev/null
+++ b/lib/gs-plugin-job-manage-repository.h
@@ -0,0 +1,27 @@
+/* -*- Mode: C; tab-width: 8; indent-tabs-mode: t; c-basic-offset: 8 -*-
+ * vi:set noexpandtab tabstop=8 shiftwidth=8:
+ *
+ * Copyright (C) 2022 Red Hat <www.redhat.com>
+ *
+ * SPDX-License-Identifier: GPL-2.0+
+ */
+
+#pragma once
+
+#include <glib.h>
+#include <glib-object.h>
+#include <gio/gio.h>
+
+#include "gs-plugin-job.h"
+
+G_BEGIN_DECLS
+
+#define GS_TYPE_PLUGIN_JOB_MANAGE_REPOSITORY (gs_plugin_job_manage_repository_get_type ())
+
+G_DECLARE_FINAL_TYPE (GsPluginJobManageRepository, gs_plugin_job_manage_repository, GS, 
PLUGIN_JOB_MANAGE_REPOSITORY, GsPluginJob)
+
+GsPluginJob    *gs_plugin_job_manage_repository_new    (GsApp                             *repository,
+                                                        GsPluginManageRepositoryOperation  operation,
+                                                        GsPluginManageRepositoryFlags      flags);
+
+G_END_DECLS
diff --git a/lib/meson.build b/lib/meson.build
index a99a80abb..779c09a1d 100644
--- a/lib/meson.build
+++ b/lib/meson.build
@@ -26,6 +26,7 @@ libgnomesoftware_public_headers = [
   'gs-plugin-job.h',
   'gs-plugin-job-list-apps.h',
   'gs-plugin-job-list-distro-upgrades.h',
+  'gs-plugin-job-manage-repository.h',
   'gs-plugin-job-refine.h',
   'gs-plugin-job-refresh-metadata.h',
   'gs-plugin-loader.h',
@@ -107,6 +108,7 @@ libgnomesoftware = library(
     'gs-plugin-job.c',
     'gs-plugin-job-list-apps.c',
     'gs-plugin-job-list-distro-upgrades.c',
+    'gs-plugin-job-manage-repository.c',
     'gs-plugin-job-refine.c',
     'gs-plugin-job-refresh-metadata.c',
     'gs-plugin-loader.c',