[gnome-software/wip/async-plugin-repo-funcs: 15/37] gs-plugin-loader: Replace GS_PLUGIN_ACTION_INSTALL_REPO job with manage repository job

[Milan Crha <mcrha src gnome org>]

commit 44279712b4d74460dbd553d4560a79a78d648af8
Author: Milan Crha <mcrha redhat com>
Date:   Tue Jun 14 12:19:23 2022 +0200

    gs-plugin-loader: Replace GS_PLUGIN_ACTION_INSTALL_REPO job with manage repository job

 lib/gs-plugin-loader.c | 21 ++++++++++++++++-----
 1 file changed, 16 insertions(+), 5 deletions(-)
---
diff --git a/lib/gs-plugin-loader.c b/lib/gs-plugin-loader.c
index 9b361ce9c..e843ce955 100644
--- a/lib/gs-plugin-loader.c
+++ b/lib/gs-plugin-loader.c
@@ -3217,12 +3217,18 @@ gs_plugin_loader_maybe_flush_pending_install_queue (GsPluginLoader *plugin_loade
        }
        for (guint i = 0; i < gs_app_list_length (queue); i++) {
                GsApp *app = gs_app_list_index (queue, i);
-               GsPluginAction action = gs_app_get_kind (app) == AS_COMPONENT_KIND_REPOSITORY ? 
GS_PLUGIN_ACTION_INSTALL_REPO : GS_PLUGIN_ACTION_INSTALL;
                g_autoptr(GsPluginJob) plugin_job = NULL;
-               plugin_job = gs_plugin_job_newv (action,
-                                                "app", app,
-                                                "interactive", TRUE, /* needed for credentials prompt, 
otherwise it just fails */
-                                                NULL);
+               /* The 'interactive' is needed for credentials prompt, otherwise it just fails */
+               if (gs_app_get_kind (app) == AS_COMPONENT_KIND_REPOSITORY) {
+                       plugin_job = gs_plugin_job_manage_repository_new (app,
+                                                                         
GS_PLUGIN_MANAGE_REPOSITORY_FLAGS_INTERACTIVE |
+                                                                         
GS_PLUGIN_MANAGE_REPOSITORY_FLAGS_INSTALL);
+               } else {
+                       plugin_job = gs_plugin_job_newv (GS_PLUGIN_ACTION_INSTALL,
+                                                        "app", app,
+                                                        "interactive", TRUE,
+                                                        NULL);
+               }
                gs_plugin_loader_job_process_async (plugin_loader, plugin_job,
                                                    NULL,
                                                    gs_plugin_loader_app_installed_cb,
@@ -3890,6 +3896,11 @@ run_job_cb (GObject      *source_object,
                 * job_process_async() does. */
                g_task_return_pointer (task, gs_app_list_new (), g_object_unref);
                return;
+       } else if (GS_IS_PLUGIN_JOB_MANAGE_REPOSITORY (plugin_job)) {
+               /* FIXME: The gs_plugin_loader_job_action_finish() expects a #GsAppList
+                * pointer on success, thus return it. */
+               g_task_return_pointer (task, gs_app_list_new (), g_object_unref);
+               return;
        }
 
        g_assert_not_reached ();