/* -*- Mode: C; tab-width: 8; indent-tabs-mode: t; c-basic-offset: 8 -*- * vi:set noexpandtab tabstop=8 shiftwidth=8: * * Copyright (C) 2016 Joaquim Rocha * Copyright (C) 2016-2018 Richard Hughes * Copyright (C) 2017-2020 Kalev Lember * * SPDX-License-Identifier: GPL-2.0-or-later */ /* * SECTION: * Exposes flatpaks from the user and system repositories. * * All GsApp's created have management-plugin set to flatpak * Some GsApp's created have have flatpak::kind of app or runtime * The GsApp:origin is the remote name, e.g. test-repo * * The plugin has a worker thread which all operations are delegated to, as the * libflatpak API is entirely synchronous (and thread-safe). * Message passing * to the worker thread is by gs_worker_thread_queue(). * * FIXME: It may speed things up in future to have one worker thread *per* * `FlatpakInstallation`, all operating in parallel. */ #include #include #include #include #include "gs-appstream.h" #include "gs-flatpak-app.h" #include "gs-flatpak.h" #include "gs-flatpak-transaction.h" #include "gs-flatpak-utils.h" #include "gs-metered.h" #include "gs-profiler.h" #include "gs-worker-thread.h" #include "gs-plugin-flatpak.h" /* Timeout for pure of unused refs: * - A timer checks every 2h * - If the plugin is enabled, and unused refs have not yet been * removed (successfully or not) in the last 24h, then `flatpak-purge-timestamp` * is updated and a purge operation is started * - Timeout callbacks are ignored until another 24h has passed */ #define PURGE_TIMEOUT_SECONDS (60 * 60 * 2) struct _GsPluginFlatpak { GsPlugin parent; GsWorkerThread *worker; /* (owned) */ GPtrArray *installations; /* (element-type GsFlatpak) (owned); may be NULL before setup or after shutdown */ gboolean has_system_helper; const gchar *destdir_for_tests; GCancellable *purge_cancellable; guint purge_timeout_id; GPtrArray *cache_files_to_delete; /* (element-type GFile) (nullable) */ }; G_DEFINE_TYPE (GsPluginFlatpak, gs_plugin_flatpak, GS_TYPE_PLUGIN) #define assert_in_worker(self) \ g_assert (gs_worker_thread_is_in_worker_context (self->worker)) /* Work around flatpak_transaction_get_no_interaction() not existing before * flatpak 1.13.0. */ #if !FLATPAK_CHECK_VERSION(1,13,0) #define flatpak_transaction_get_no_interaction(transaction) \ GPOINTER_TO_INT (g_object_get_data (G_OBJECT (transaction), "flatpak-no-interaction")) #define flatpak_transaction_set_no_interaction(transaction, no_interaction) \ G_STMT_START { \ FlatpakTransaction *ftsni_transaction = (transaction); \ gboolean ftsni_no_interaction = (no_interaction); \ (flatpak_transaction_set_no_interaction) (ftsni_transaction, ftsni_no_interaction); \ g_object_set_data (G_OBJECT (ftsni_transaction), "flatpak-no-interaction", GINT_TO_POINTER (ftsni_no_interaction)); \ } G_STMT_END #endif /* flatpak < 1.13.0 */ static void gs_plugin_flatpak_dispose (GObject *object) { GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (object); g_assert (self->cache_files_to_delete == NULL || self->cache_files_to_delete->len == 0); g_clear_pointer (&self->cache_files_to_delete, g_ptr_array_unref); g_cancellable_cancel (self->purge_cancellable); g_assert (self->purge_timeout_id == 0); g_clear_pointer (&self->installations, g_ptr_array_unref); g_clear_object (&self->purge_cancellable); g_clear_object (&self->worker); G_OBJECT_CLASS (gs_plugin_flatpak_parent_class)->dispose (object); } static void gs_plugin_flatpak_init (GsPluginFlatpak *self) { GsPlugin *plugin = GS_PLUGIN (self); self->installations = g_ptr_array_new_with_free_func ((GDestroyNotify) g_object_unref); /* getting app properties from appstream is quicker */ gs_plugin_add_rule (plugin, GS_PLUGIN_RULE_RUN_AFTER, "appstream"); /* like appstream, we need the icon plugin to load cached icons into pixbufs */ gs_plugin_add_rule (plugin, GS_PLUGIN_RULE_RUN_BEFORE, "icons"); /* prioritize over packages */ gs_plugin_add_rule (plugin, GS_PLUGIN_RULE_BETTER_THAN, "packagekit"); gs_plugin_add_rule (plugin, GS_PLUGIN_RULE_BETTER_THAN, "rpm-ostree"); /* set name of MetaInfo file */ gs_plugin_set_appstream_id (plugin, "org.gnome.Software.Plugin.Flatpak"); /* used for self tests */ self->destdir_for_tests = g_getenv ("GS_SELF_TEST_FLATPAK_DATADIR"); } /* Run in @worker. */ static void gs_plugin_flatpak_purge_thread_cb (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable) { GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (source_object); GPtrArray *flatpaks = task_data; assert_in_worker (self); for (guint i = 0; i < flatpaks->len; i++) { g_autoptr(GError) local_error = NULL; GsFlatpak *flatpak = g_ptr_array_index (flatpaks, i); if (!gs_flatpak_purge_sync (flatpak, cancellable, &local_error)) { gs_flatpak_error_convert (&local_error); g_debug ("Failed to purge unused refs at '%s': %s", gs_flatpak_get_id (flatpak), local_error->message); } } g_task_return_boolean (task, TRUE); } static gboolean gs_plugin_flatpak_purge_timeout_cb (gpointer user_data) { GsPluginFlatpak *self = user_data; if (gs_plugin_get_enabled (GS_PLUGIN (self))) { g_autoptr(GSettings) settings = g_settings_new ("org.gnome.software"); gint64 current_time = g_get_real_time () / G_USEC_PER_SEC; if ((current_time / (60 * 60 * 24)) != (g_settings_get_int64 (settings, "flatpak-purge-timestamp") / (60 * 60 * 24))) { g_autoptr(GPtrArray) flatpaks = g_ptr_array_new_with_free_func (g_object_unref); g_settings_set_int64 (settings, "flatpak-purge-timestamp", current_time); g_cancellable_cancel (self->purge_cancellable); g_clear_object (&self->purge_cancellable); self->purge_cancellable = g_cancellable_new (); for (guint i = 0; i < self->installations->len; i++) { GsFlatpak *flatpak = g_ptr_array_index (self->installations, i); if (gs_flatpak_get_busy (flatpak)) { g_debug ("Skipping '%s' in this round, it's busy right now", gs_flatpak_get_id (flatpak)); continue; } g_ptr_array_add (flatpaks, g_object_ref (flatpak)); } if (flatpaks->len > 0) { g_autoptr(GTask) task = NULL; task = g_task_new (self, self->purge_cancellable, NULL, NULL); g_task_set_source_tag (task, gs_plugin_flatpak_purge_timeout_cb); g_task_set_task_data (task, g_steal_pointer (&flatpaks), (GDestroyNotify) g_ptr_array_unref); gs_worker_thread_queue (self->worker, G_PRIORITY_LOW, gs_plugin_flatpak_purge_thread_cb, g_steal_pointer (&task)); } } } else { self->purge_timeout_id = 0; return G_SOURCE_REMOVE; } return G_SOURCE_CONTINUE; } static gboolean _as_component_scope_is_compatible (AsComponentScope scope1, AsComponentScope scope2) { if (scope1 == AS_COMPONENT_SCOPE_UNKNOWN) return TRUE; if (scope2 == AS_COMPONENT_SCOPE_UNKNOWN) return TRUE; return scope1 == scope2; } void gs_plugin_adopt_app (GsPlugin *plugin, GsApp *app) { if (gs_app_get_bundle_kind (app) == AS_BUNDLE_KIND_FLATPAK) gs_app_set_management_plugin (app, plugin); } static gboolean gs_plugin_flatpak_add_installation (GsPluginFlatpak *self, FlatpakInstallation *installation, GCancellable *cancellable, GError **error) { g_autoptr(GsFlatpak) flatpak = NULL; /* create and set up */ flatpak = gs_flatpak_new (GS_PLUGIN (self), installation, GS_FLATPAK_FLAG_NONE); if (!gs_flatpak_setup (flatpak, cancellable, error)) return FALSE; g_debug ("successfully set up %s", gs_flatpak_get_id (flatpak)); /* add objects that set up correctly */ g_ptr_array_add (self->installations, g_steal_pointer (&flatpak)); return TRUE; } static void gs_plugin_flatpak_report_warning (GsPlugin *plugin, GError **error) { g_autoptr(GsPluginEvent) event = NULL; g_assert (error != NULL); if (*error != NULL && (*error)->domain != GS_PLUGIN_ERROR) gs_flatpak_error_convert (error); event = gs_plugin_event_new ("error", *error, NULL); gs_plugin_event_add_flag (event, GS_PLUGIN_EVENT_FLAG_WARNING); gs_plugin_report_event (plugin, event); } static gint get_priority_for_interactivity (gboolean interactive) { return interactive ? G_PRIORITY_DEFAULT : G_PRIORITY_LOW; } static void setup_thread_cb (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable); static void gs_plugin_flatpak_setup_async (GsPlugin *plugin, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (plugin); g_autoptr(GTask) task = NULL; g_debug ("Flatpak version: %d.%d.%d", FLATPAK_MAJOR_VERSION, FLATPAK_MINOR_VERSION, FLATPAK_MICRO_VERSION); task = g_task_new (plugin, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_flatpak_setup_async); /* Shouldn’t end up setting up twice */ g_assert (self->installations == NULL || self->installations->len == 0); /* Start up a worker thread to process all the plugin’s function calls. */ self->worker = gs_worker_thread_new ("gs-plugin-flatpak"); /* Queue a job to find and set up the installations. */ gs_worker_thread_queue (self->worker, G_PRIORITY_DEFAULT, setup_thread_cb, g_steal_pointer (&task)); if (!self->purge_timeout_id) self->purge_timeout_id = g_timeout_add_seconds (PURGE_TIMEOUT_SECONDS, gs_plugin_flatpak_purge_timeout_cb, self); } /* Run in @worker. */ static void setup_thread_cb (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable) { GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (source_object); GsPlugin *plugin = GS_PLUGIN (self); g_autoptr(GPtrArray) installations = NULL; const gchar *action_id = "org.freedesktop.Flatpak.appstream-update"; g_autoptr(GError) permission_error = NULL; g_autoptr(GPermission) permission = NULL; assert_in_worker (self); /* if we can't update the AppStream database system-wide don't even * pull the data as we can't do anything with it */ permission = gs_utils_get_permission (action_id, NULL, &permission_error); if (permission == NULL) { g_debug ("no permission for %s: %s", action_id, permission_error->message); g_clear_error (&permission_error); } else { self->has_system_helper = g_permission_get_allowed (permission) || g_permission_get_can_acquire (permission); } /* if we're not just running the tests */ if (self->destdir_for_tests == NULL) { g_autoptr(GError) error_local = NULL; g_autoptr(FlatpakInstallation) installation = NULL; /* include the system installations */ if (self->has_system_helper) { installations = flatpak_get_system_installations (cancellable, &error_local); if (installations == NULL) { gs_plugin_flatpak_report_warning (plugin, &error_local); g_clear_error (&error_local); } } /* include the user installation */ installation = flatpak_installation_new_user (cancellable, &error_local); if (installation == NULL) { /* if some error happened, report it as an event, but * do not return it, otherwise it will disable the whole * plugin (meaning that support for Flatpak will not be * possible even if a system installation is working) */ gs_plugin_flatpak_report_warning (plugin, &error_local); } else { if (installations == NULL) installations = g_ptr_array_new_with_free_func (g_object_unref); g_ptr_array_add (installations, g_steal_pointer (&installation)); } } else { g_autoptr(GError) error_local = NULL; /* use the test installation */ g_autofree gchar *full_path = g_build_filename (self->destdir_for_tests, "flatpak", NULL); g_autoptr(GFile) file = g_file_new_for_path (full_path); g_autoptr(FlatpakInstallation) installation = NULL; g_debug ("using custom flatpak path %s", full_path); installation = flatpak_installation_new_for_path (file, TRUE, cancellable, &error_local); if (installation == NULL) { gs_flatpak_error_convert (&error_local); g_task_return_error (task, g_steal_pointer (&error_local)); return; } installations = g_ptr_array_new_with_free_func (g_object_unref); g_ptr_array_add (installations, g_steal_pointer (&installation)); } /* add the installations */ for (guint i = 0; installations != NULL && i < installations->len; i++) { g_autoptr(GError) error_local = NULL; FlatpakInstallation *installation = g_ptr_array_index (installations, i); if (!gs_plugin_flatpak_add_installation (self, installation, cancellable, &error_local)) { gs_plugin_flatpak_report_warning (plugin, &error_local); continue; } } /* when no installation has been loaded, return the error so the * plugin gets disabled */ if (self->installations->len == 0) { g_task_return_new_error (task, GS_PLUGIN_ERROR, GS_PLUGIN_ERROR_FAILED, "Failed to load any Flatpak installations"); return; } g_task_return_boolean (task, TRUE); } static gboolean gs_plugin_flatpak_setup_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } static void shutdown_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void gs_plugin_flatpak_shutdown_async (GsPlugin *plugin, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (plugin); g_autoptr(GTask) task = NULL; g_clear_handle_id (&self->purge_timeout_id, g_source_remove); g_cancellable_cancel (self->purge_cancellable); task = g_task_new (self, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_flatpak_shutdown_async); /* Delete any cache files from this session. This should not really * block, as they’re all local. */ for (guint i = 0; self->cache_files_to_delete != NULL && i < self->cache_files_to_delete->len; i++) { GFile *cache_file = g_ptr_array_index (self->cache_files_to_delete, i); g_file_delete (cache_file, NULL, NULL); } g_clear_pointer (&self->cache_files_to_delete, g_ptr_array_unref); /* Stop the worker thread. */ gs_worker_thread_shutdown_async (self->worker, cancellable, shutdown_cb, g_steal_pointer (&task)); } static void shutdown_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { g_autoptr(GTask) task = G_TASK (user_data); GsPluginFlatpak *self = g_task_get_source_object (task); g_autoptr(GsWorkerThread) worker = NULL; g_autoptr(GError) local_error = NULL; worker = g_steal_pointer (&self->worker); if (!gs_worker_thread_shutdown_finish (worker, result, &local_error)) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } /* Clear the flatpak installations */ g_ptr_array_set_size (self->installations, 0); g_task_return_boolean (task, TRUE); } static gboolean gs_plugin_flatpak_shutdown_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } static void refresh_metadata_thread_cb (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable); static void gs_plugin_flatpak_refresh_metadata_async (GsPlugin *plugin, guint64 cache_age_secs, GsPluginRefreshMetadataFlags flags, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (plugin); g_autoptr(GTask) task = NULL; gboolean interactive = (flags & GS_PLUGIN_REFRESH_METADATA_FLAGS_INTERACTIVE); task = g_task_new (plugin, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_flatpak_refresh_metadata_async); g_task_set_task_data (task, gs_plugin_refresh_metadata_data_new (cache_age_secs, flags), (GDestroyNotify) gs_plugin_refresh_metadata_data_free); /* Queue a job to get the installed apps. */ gs_worker_thread_queue (self->worker, get_priority_for_interactivity (interactive), refresh_metadata_thread_cb, g_steal_pointer (&task)); } /* Run in @worker. */ static void refresh_metadata_thread_cb (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable) { GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (source_object); GsPluginRefreshMetadataData *data = task_data; gboolean interactive = (data->flags & GS_PLUGIN_REFRESH_METADATA_FLAGS_INTERACTIVE); assert_in_worker (self); for (guint i = 0; i < self->installations->len; i++) { g_autoptr(GError) local_error = NULL; GsFlatpak *flatpak = g_ptr_array_index (self->installations, i); if (!gs_flatpak_refresh (flatpak, data->cache_age_secs, interactive, cancellable, &local_error)) g_debug ("Failed to refresh metadata for '%s': %s", gs_flatpak_get_id (flatpak), local_error->message); } g_task_return_boolean (task, TRUE); } static gboolean gs_plugin_flatpak_refresh_metadata_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } static GsFlatpak * gs_plugin_flatpak_get_handler (GsPluginFlatpak *self, GsApp *app) { const gchar *object_id; /* only process this app if was created by this plugin */ if (!gs_app_has_management_plugin (app, GS_PLUGIN (self))) return NULL; /* specified an explicit name */ object_id = gs_flatpak_app_get_object_id (app); if (object_id != NULL) { for (guint i = 0; i < self->installations->len; i++) { GsFlatpak *flatpak = g_ptr_array_index (self->installations, i); if (g_strcmp0 (gs_flatpak_get_id (flatpak), object_id) == 0) return flatpak; } } /* find a scope that matches */ for (guint i = 0; i < self->installations->len; i++) { GsFlatpak *flatpak = g_ptr_array_index (self->installations, i); if (_as_component_scope_is_compatible (gs_flatpak_get_scope (flatpak), gs_app_get_scope (app))) return flatpak; } return NULL; } static gboolean gs_plugin_flatpak_refine_app (GsPluginFlatpak *self, GsApp *app, GsPluginRefineFlags flags, gboolean interactive, GCancellable *cancellable, GError **error) { GsFlatpak *flatpak = NULL; /* not us */ if (gs_app_get_bundle_kind (app) != AS_BUNDLE_KIND_FLATPAK) { g_debug ("%s not a package, ignoring", gs_app_get_unique_id (app)); return TRUE; } /* we have to look for the app in all GsFlatpak stores */ if (gs_app_get_scope (app) == AS_COMPONENT_SCOPE_UNKNOWN) { for (guint i = 0; i < self->installations->len; i++) { GsFlatpak *flatpak_tmp = g_ptr_array_index (self->installations, i); g_autoptr(GError) error_local = NULL; if (gs_flatpak_refine_app_state (flatpak_tmp, app, interactive, FALSE, cancellable, &error_local)) { flatpak = flatpak_tmp; break; } else { g_debug ("%s", error_local->message); } } } else { flatpak = gs_plugin_flatpak_get_handler (self, app); } if (flatpak == NULL) return TRUE; return gs_flatpak_refine_app (flatpak, app, flags, interactive, FALSE, cancellable, error); } static void unref_nonnull_hash_table (gpointer ptr) { GHashTable *hash_table = ptr; if (hash_table != NULL) g_hash_table_unref (hash_table); } static gboolean refine_app (GsPluginFlatpak *self, GsApp *app, GsPluginRefineFlags flags, gboolean interactive, GCancellable *cancellable, GError **error) { GS_PROFILER_BEGIN_SCOPED (FlatpakRefineApp, "Flatpak (refine app)", NULL); /* only process this app if was created by this plugin */ if (!gs_app_has_management_plugin (app, GS_PLUGIN (self))) return TRUE; /* get the runtime first */ if (!gs_plugin_flatpak_refine_app (self, app, flags, interactive, cancellable, error)) return FALSE; GS_PROFILER_END_SCOPED (FlatpakRefineApp); /* the runtime might be installed in a different scope */ if (flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_RUNTIME) { GsApp *runtime = gs_app_get_runtime (app); if (runtime != NULL) { GS_PROFILER_BEGIN_SCOPED (FlatpakRefineAppRuntime, "Flatpak (refine runtime)", NULL); if (!gs_plugin_flatpak_refine_app (self, runtime, flags, interactive, cancellable, error)) { return FALSE; } GS_PROFILER_END_SCOPED (FlatpakRefineAppRuntime); } } return TRUE; } static void refine_thread_cb (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable); static void gs_plugin_flatpak_refine_async (GsPlugin *plugin, GsAppList *list, GsPluginRefineFlags flags, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (plugin); g_autoptr(GTask) task = NULL; gboolean interactive = gs_plugin_has_flags (GS_PLUGIN (self), GS_PLUGIN_FLAGS_INTERACTIVE); task = gs_plugin_refine_data_new_task (plugin, list, flags, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_flatpak_refine_async); /* Queue a job to refine the apps. */ gs_worker_thread_queue (self->worker, get_priority_for_interactivity (interactive), refine_thread_cb, g_steal_pointer (&task)); } /* Run in @worker. */ static void refine_thread_cb (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable) { GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (source_object); GsPluginRefineData *data = task_data; GsAppList *list = data->list; GsPluginRefineFlags flags = data->flags; gboolean interactive = gs_plugin_has_flags (GS_PLUGIN (self), GS_PLUGIN_FLAGS_INTERACTIVE); g_autoptr(GPtrArray) array_components_by_id = NULL; /* (element-type GHashTable) */ g_autoptr(GPtrArray) array_components_by_bundle = NULL; /* (element-type GHashTable) */ g_autoptr(GsAppList) app_list = NULL; g_autoptr(GError) local_error = NULL; assert_in_worker (self); for (guint i = 0; i < gs_app_list_length (list); i++) { GsApp *app = gs_app_list_index (list, i); if (!refine_app (self, app, flags, interactive, cancellable, &local_error)) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } } /* Refine wildcards. * * Use a copy of the list for the loop because a function called * on the plugin may affect the list which can lead to problems * (e.g. inserting an app in the list on every call results in * an infinite loop) */ app_list = gs_app_list_copy (list); array_components_by_id = g_ptr_array_new_full (self->installations->len, unref_nonnull_hash_table); g_ptr_array_set_size (array_components_by_id, self->installations->len); array_components_by_bundle = g_ptr_array_new_full (self->installations->len, unref_nonnull_hash_table); g_ptr_array_set_size (array_components_by_bundle, self->installations->len); for (guint j = 0; j < gs_app_list_length (app_list); j++) { GsApp *app = gs_app_list_index (app_list, j); if (!gs_app_has_quirk (app, GS_APP_QUIRK_IS_WILDCARD)) continue; for (guint i = 0; i < self->installations->len; i++) { GsFlatpak *flatpak = g_ptr_array_index (self->installations, i); GHashTable *components_by_id = array_components_by_id->pdata[i]; GHashTable *components_by_bundle = array_components_by_bundle->pdata[i]; if (!gs_flatpak_refine_wildcard (flatpak, app, list, flags, interactive, &components_by_id, &components_by_bundle, cancellable, &local_error)) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } array_components_by_id->pdata[i] = components_by_id; array_components_by_bundle->pdata[i] = components_by_bundle; } } g_task_return_boolean (task, TRUE); } static gboolean gs_plugin_flatpak_refine_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } /* Run in @worker. */ static void launch_thread_cb (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable) { GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (source_object); GsPluginLaunchData *data = task_data; GsFlatpak *flatpak; g_autoptr(GError) local_error = NULL; gboolean interactive = (data->flags & GS_PLUGIN_LAUNCH_FLAGS_INTERACTIVE) != 0; assert_in_worker (self); flatpak = gs_plugin_flatpak_get_handler (self, data->app); if (flatpak == NULL) { g_task_return_boolean (task, TRUE); return; } if (gs_flatpak_launch (flatpak, data->app, interactive, cancellable, &local_error)) g_task_return_boolean (task, TRUE); else g_task_return_error (task, g_steal_pointer (&local_error)); } static void gs_plugin_flatpak_launch_async (GsPlugin *plugin, GsApp *app, GsPluginLaunchFlags flags, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (plugin); g_autoptr(GTask) task = NULL; gboolean interactive = (flags & GS_PLUGIN_LAUNCH_FLAGS_INTERACTIVE) != 0; task = gs_plugin_launch_data_new_task (plugin, app, flags, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_flatpak_launch_async); /* only process this app if was created by this plugin */ if (!gs_app_has_management_plugin (app, plugin)) { g_task_return_boolean (task, TRUE); return; } /* Queue a job to launch the app. */ gs_worker_thread_queue (self->worker, get_priority_for_interactivity (interactive), launch_thread_cb, g_steal_pointer (&task)); } static gboolean gs_plugin_flatpak_launch_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } /* ref full */ static GsApp * gs_plugin_flatpak_find_app_by_ref (GsPluginFlatpak *self, const gchar *ref, gboolean interactive, GsApp *alternate_of, GCancellable *cancellable, GError **error) { g_debug ("finding ref %s", ref); for (guint i = 0; i < self->installations->len; i++) { GsFlatpak *flatpak_tmp = g_ptr_array_index (self->installations, i); g_autoptr(GsApp) app = NULL; g_autoptr(GError) error_local = NULL; app = gs_flatpak_ref_to_app (flatpak_tmp, ref, interactive, cancellable, &error_local); if (app == NULL) { g_debug ("%s", error_local->message); continue; } if (alternate_of != NULL && alternate_of == app) { g_debug ("skipping ref=%s->%s, due to being alternate_of", ref, gs_app_get_unique_id (app)); continue; } g_debug ("found ref=%s->%s", ref, gs_app_get_unique_id (app)); return g_steal_pointer (&app); } return NULL; } /* ref full */ static GsApp * _ref_to_app (FlatpakTransaction *transaction, const gchar *ref, GsPluginFlatpak *self) { g_return_val_if_fail (GS_IS_FLATPAK_TRANSACTION (transaction), NULL); g_return_val_if_fail (ref != NULL, NULL); g_return_val_if_fail (GS_IS_PLUGIN_FLATPAK (self), NULL); /* search through each GsFlatpak */ return gs_plugin_flatpak_find_app_by_ref (self, ref, gs_plugin_has_flags (GS_PLUGIN (self), GS_PLUGIN_FLAGS_INTERACTIVE), NULL, NULL, NULL); } static void _group_apps_by_installation_recurse (GsPluginFlatpak *self, GsAppList *list, GHashTable *applist_by_flatpaks) { if (!list) return; for (guint i = 0; i < gs_app_list_length (list); i++) { GsApp *app = gs_app_list_index (list, i); GsFlatpak *flatpak = gs_plugin_flatpak_get_handler (self, app); if (flatpak != NULL) { GsAppList *list_tmp = g_hash_table_lookup (applist_by_flatpaks, flatpak); GsAppList *related_list; if (list_tmp == NULL) { list_tmp = gs_app_list_new (); g_hash_table_insert (applist_by_flatpaks, g_object_ref (flatpak), list_tmp); } gs_app_list_add (list_tmp, app); /* Add also related apps, which can be those recognized for update, while the 'app' is already up to date. */ related_list = gs_app_get_related (app); _group_apps_by_installation_recurse (self, related_list, applist_by_flatpaks); } } } /* * Returns: (transfer full) (element-type GsFlatpak GsAppList): * a map from GsFlatpak to non-empty lists of apps from @list associated * with that installation. */ static GHashTable * _group_apps_by_installation (GsPluginFlatpak *self, GsAppList *list) { g_autoptr(GHashTable) applist_by_flatpaks = NULL; /* list of apps to be handled by each flatpak installation */ applist_by_flatpaks = g_hash_table_new_full (g_direct_hash, g_direct_equal, (GDestroyNotify) g_object_unref, (GDestroyNotify) g_object_unref); /* put each app into the correct per-GsFlatpak list */ _group_apps_by_installation_recurse (self, list, applist_by_flatpaks); return g_steal_pointer (&applist_by_flatpaks); } typedef struct { FlatpakTransaction *transaction; guint id; } BasicAuthData; static void basic_auth_data_free (BasicAuthData *data) { g_object_unref (data->transaction); g_slice_free (BasicAuthData, data); } G_DEFINE_AUTOPTR_CLEANUP_FUNC(BasicAuthData, basic_auth_data_free) static void _basic_auth_cb (const gchar *user, const gchar *password, gpointer user_data) { g_autoptr(BasicAuthData) data = user_data; g_debug ("Submitting basic auth data"); /* NULL user aborts the basic auth request */ flatpak_transaction_complete_basic_auth (data->transaction, data->id, user, password, NULL /* options */); } static gboolean _basic_auth_start (FlatpakTransaction *transaction, const char *remote, const char *realm, GVariant *options, guint id, GsPlugin *plugin) { BasicAuthData *data; if (flatpak_transaction_get_no_interaction (transaction)) return FALSE; data = g_slice_new0 (BasicAuthData); data->transaction = g_object_ref (transaction); data->id = id; g_debug ("Login required remote %s (realm %s)\n", remote, realm); gs_plugin_basic_auth_start (plugin, remote, realm, G_CALLBACK (_basic_auth_cb), data); return TRUE; } static gboolean _webflow_start (FlatpakTransaction *transaction, const char *remote, const char *url, GVariant *options, guint id, GsPlugin *plugin) { const char *browser; g_autoptr(GError) error_local = NULL; if (flatpak_transaction_get_no_interaction (transaction)) return FALSE; g_debug ("Authentication required for remote '%s'", remote); /* Allow hard overrides with $BROWSER */ browser = g_getenv ("BROWSER"); if (browser != NULL) { const char *args[3] = { NULL, url, NULL }; args[0] = browser; if (!g_spawn_async (NULL, (char **)args, NULL, G_SPAWN_SEARCH_PATH, NULL, NULL, NULL, &error_local)) { g_autoptr(GsPluginEvent) event = NULL; g_warning ("Failed to start browser %s: %s", browser, error_local->message); gs_flatpak_error_convert (&error_local); event = gs_plugin_event_new ("error", error_local, NULL); gs_plugin_event_add_flag (event, GS_PLUGIN_EVENT_FLAG_WARNING); gs_plugin_report_event (plugin, event); return FALSE; } } else { if (!g_app_info_launch_default_for_uri (url, NULL, &error_local)) { g_autoptr(GsPluginEvent) event = NULL; g_warning ("Failed to show url: %s", error_local->message); gs_flatpak_error_convert (&error_local); event = gs_plugin_event_new ("error", error_local, NULL); gs_plugin_event_add_flag (event, GS_PLUGIN_EVENT_FLAG_WARNING); gs_plugin_report_event (plugin, event); return FALSE; } } g_debug ("Waiting for browser..."); return TRUE; } static void _webflow_done (FlatpakTransaction *transaction, GVariant *options, guint id, GsPlugin *plugin) { g_debug ("Browser done"); } /* This can only fail if flatpak_dir_ensure_repo() fails, for example if the * repo is configured but doesn’t exist and can’t be created on disk. */ static FlatpakTransaction * _build_transaction (GsPlugin *plugin, GsFlatpak *flatpak, gboolean stop_on_first_error, gboolean interactive, GCancellable *cancellable, GError **error) { FlatpakInstallation *installation; g_autoptr(FlatpakInstallation) installation_clone = NULL; g_autoptr(FlatpakTransaction) transaction = NULL; installation = gs_flatpak_get_installation (flatpak, interactive); installation_clone = g_object_ref (installation); /* create transaction */ transaction = gs_flatpak_transaction_new (installation_clone, stop_on_first_error, cancellable, error); if (transaction == NULL) { g_prefix_error (error, "failed to build transaction: "); gs_flatpak_error_convert (error); return NULL; } /* Let flatpak know if it is a background operation */ flatpak_transaction_set_no_interaction (transaction, !interactive); /* connect up signals */ g_signal_connect (transaction, "ref-to-app", G_CALLBACK (_ref_to_app), plugin); g_signal_connect (transaction, "basic-auth-start", G_CALLBACK (_basic_auth_start), plugin); g_signal_connect (transaction, "webflow-start", G_CALLBACK (_webflow_start), plugin); g_signal_connect (transaction, "webflow-done", G_CALLBACK (_webflow_done), plugin); /* use system installations as dependency sources for user installations */ flatpak_transaction_add_default_dependency_sources (transaction); return g_steal_pointer (&transaction); } static void remove_schedule_entry (gpointer schedule_entry_handle) { g_autoptr(GError) error_local = NULL; if (!gs_metered_remove_from_download_scheduler (schedule_entry_handle, NULL, &error_local)) g_warning ("Failed to remove schedule entry: %s", error_local->message); } static void update_apps_thread_cb (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable); static void gs_plugin_flatpak_update_apps_async (GsPlugin *plugin, GsAppList *apps, GsPluginUpdateAppsFlags flags, GsPluginProgressCallback progress_callback, gpointer progress_user_data, GsPluginAppNeedsUserActionCallback app_needs_user_action_callback, gpointer app_needs_user_action_data, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (plugin); g_autoptr(GTask) task = NULL; gboolean interactive = (flags & GS_PLUGIN_UPDATE_APPS_FLAGS_INTERACTIVE); task = gs_plugin_update_apps_data_new_task (plugin, apps, flags, progress_callback, progress_user_data, app_needs_user_action_callback, app_needs_user_action_data, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_flatpak_update_apps_async); /* Queue a job to get the apps. */ gs_worker_thread_queue (self->worker, get_priority_for_interactivity (interactive), update_apps_thread_cb, g_steal_pointer (&task)); } /* Run in @worker. */ static void update_apps_thread_cb (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable) { GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (source_object); GsPluginUpdateAppsData *data = task_data; gboolean interactive = (data->flags & GS_PLUGIN_UPDATE_APPS_FLAGS_INTERACTIVE); g_autoptr(GHashTable) applist_by_flatpaks = NULL; GHashTableIter iter; gpointer key, value; g_autoptr(GError) local_error = NULL; assert_in_worker (self); /* Mark all the apps as pending installation. While the op/progress * handling code in #GsFlatpakTransaction does this more accurately and * in more detail, we need to pre-emptively do it here, since multiple * transactions are run sequentially below. That means that all the apps * from the 2nd, 3rd, etc. transactions will not have their state * updated until that transaction is prepared. That’s a long time for * the apps to look like they’ve been left out of the update in the UI. */ applist_by_flatpaks = _group_apps_by_installation (self, data->apps); g_hash_table_iter_init (&iter, applist_by_flatpaks); while (g_hash_table_iter_next (&iter, NULL, &value)) { GsAppList *apps_for_installation = GS_APP_LIST (value); for (guint i = 0; i < gs_app_list_length (apps_for_installation); i++) { GsApp *app = gs_app_list_index (apps_for_installation, i); gs_app_set_state (app, GS_APP_STATE_INSTALLING); } } /* build and run transaction for each flatpak installation */ g_hash_table_iter_init (&iter, applist_by_flatpaks); while (g_hash_table_iter_next (&iter, &key, &value)) { GsFlatpak *flatpak = GS_FLATPAK (key); GsAppList *list_tmp = GS_APP_LIST (value); g_autoptr(FlatpakTransaction) transaction = NULL; gpointer schedule_entry_handle = NULL; g_assert (GS_IS_FLATPAK (flatpak)); g_assert (list_tmp != NULL); g_assert (gs_app_list_length (list_tmp) > 0); if (!interactive) { if (!gs_metered_block_app_list_on_download_scheduler (list_tmp, &schedule_entry_handle, cancellable, &local_error)) { g_warning ("Failed to block on download scheduler: %s", local_error->message); g_clear_error (&local_error); } } /* Now apply the updates. */ gs_flatpak_set_busy (flatpak, TRUE); /* Build and run transaction. Pass %FALSE to stop_on_first_error * so that the transaction continues past the first fatal error * in an attempt to try and update as many apps as possible. * * Internally, `FlatpakTransaction` uses `op->fail_if_op_fails` * and `op->non_fatal` to track the relationships between ops * (such as updating an app and its runtime, or add-ons and * their app). If, for example, updating a runtime fails, the * ops to update apps which use that runtime will automatically * be skipped and will fail with `FLATPAK_ERROR_SKIPPED`. * * %GS_FLATPAK_ERROR_MODE_IGNORE_ERRORS does not ignore * `FLATPAK_ERROR_SKIPPED` errors, so this will not cause * corruption of the transaction. * * This approach is the same as what the `flatpak` CLI uses in * `flatpak-builtins-update.c` in flatpak. */ transaction = _build_transaction (GS_PLUGIN (self), flatpak, GS_FLATPAK_ERROR_MODE_IGNORE_ERRORS, interactive, cancellable, &local_error); if (transaction == NULL) { g_autoptr(GsPluginEvent) event = NULL; /* Reset the state of all the apps in this transaction. */ for (guint i = 0; i < gs_app_list_length (list_tmp); i++) { GsApp *app = gs_app_list_index (list_tmp, i); gs_app_set_state_recover (app); } /* This can only fail if the repo doesn’t exist and can’t * be created, which is unlikely. */ gs_flatpak_error_convert (&local_error); event = gs_plugin_event_new ("error", local_error, NULL); if (interactive) gs_plugin_event_add_flag (event, GS_PLUGIN_EVENT_FLAG_INTERACTIVE); gs_plugin_event_add_flag (event, GS_PLUGIN_EVENT_FLAG_WARNING); gs_plugin_report_event (GS_PLUGIN (self), event); g_clear_error (&local_error); remove_schedule_entry (schedule_entry_handle); gs_flatpak_set_busy (flatpak, FALSE); continue; } for (guint i = 0; i < gs_app_list_length (list_tmp); i++) { GsApp *app = gs_app_list_index (list_tmp, i); g_autofree gchar *ref = NULL; ref = gs_flatpak_app_get_ref_display (app); if (flatpak_transaction_add_update (transaction, ref, NULL, NULL, &local_error)) { /* add to the transaction cache for quick look up -- other unrelated * refs will be matched using gs_plugin_flatpak_find_app_by_ref() */ gs_flatpak_transaction_add_app (transaction, app); continue; } /* Errors are not fatal, as otherwise a single app * failure will take down the whole update, blocking * updates for all other apps. * * The common two errors to see here are * - FLATPAK_ERROR_REMOTE_NOT_FOUND * - FLATPAK_ERROR_NOT_INSTALLED */ { g_autoptr(GsPluginEvent) event = NULL; g_warning ("Skipping update for ‘%s’: %s", ref, local_error->message); /* Reset the state of the app. */ gs_app_set_state_recover (app); gs_flatpak_error_convert (&local_error); event = gs_plugin_event_new ("error", local_error, "app", app, NULL); if (interactive) gs_plugin_event_add_flag (event, GS_PLUGIN_EVENT_FLAG_INTERACTIVE); gs_plugin_event_add_flag (event, GS_PLUGIN_EVENT_FLAG_WARNING); gs_plugin_report_event (GS_PLUGIN (self), event); g_clear_error (&local_error); continue; } } /* automatically clean up unused EOL runtimes when updating */ flatpak_transaction_set_include_unused_uninstall_ops (transaction, TRUE); /* FIXME: Link progress reporting from #FlatpakTransaction * up to `data->progress_callback`. */ if (!gs_flatpak_transaction_run (transaction, cancellable, &local_error)) { g_autoptr(GsPluginEvent) event = NULL; g_autoptr(GError) prune_error = NULL; /* Reset the state of all the apps in this transaction. */ for (guint i = 0; i < gs_app_list_length (list_tmp); i++) { GsApp *app = gs_app_list_index (list_tmp, i); gs_app_set_state_recover (app); } /* Try pruning the repo, just in case this is a failure * caused by running out of disk space. The transaction * typically won’t try this itself, and will only prune * on success (if it knows an update has potentially * left dangling objects). */ if (!flatpak_installation_prune_local_repo (gs_flatpak_get_installation (flatpak, interactive), NULL, &prune_error)) { gs_flatpak_error_convert (&prune_error); g_warning ("Error pruning flatpak repo for %s after failed update: %s", gs_flatpak_get_id (flatpak), prune_error->message); } gs_flatpak_error_convert (&local_error); event = gs_plugin_event_new ("error", local_error, NULL); if (interactive) gs_plugin_event_add_flag (event, GS_PLUGIN_EVENT_FLAG_INTERACTIVE); gs_plugin_event_add_flag (event, GS_PLUGIN_EVENT_FLAG_WARNING); gs_plugin_report_event (GS_PLUGIN (self), event); g_clear_error (&local_error); remove_schedule_entry (schedule_entry_handle); gs_flatpak_set_busy (flatpak, FALSE); continue; } remove_schedule_entry (schedule_entry_handle); gs_plugin_updates_changed (GS_PLUGIN (self)); /* Get any new state. Ignore failure and fall through to * refining the apps, since refreshing is not an entirely * necessary part of the update operation. */ if (!gs_flatpak_refresh (flatpak, G_MAXUINT, interactive, cancellable, &local_error)) { gs_flatpak_error_convert (&local_error); g_warning ("Error refreshing flatpak data for ‘%s’ after update: %s", gs_flatpak_get_id (flatpak), local_error->message); g_clear_error (&local_error); } /* Refine all the updated apps to make sure they’re up to date * in the UI. Ignore failure since it’s not an entirely * necessary part of the update operation. */ for (guint i = 0; i < gs_app_list_length (list_tmp); i++) { GsApp *app = gs_app_list_index (list_tmp, i); g_autofree gchar *ref = NULL; ref = gs_flatpak_app_get_ref_display (app); if (!gs_flatpak_refine_app (flatpak, app, GS_PLUGIN_REFINE_FLAGS_REQUIRE_RUNTIME, interactive, TRUE, cancellable, &local_error)) { gs_flatpak_error_convert (&local_error); g_warning ("Error refining app ‘%s’ after update: %s", ref, local_error->message); g_clear_error (&local_error); continue; } } gs_flatpak_set_busy (flatpak, FALSE); } g_task_return_boolean (task, TRUE); } static gboolean gs_plugin_flatpak_update_apps_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } static void gs_flatpak_cover_addons_in_transaction (GsPlugin *plugin, FlatpakTransaction *transaction, GsApp *parent_app, GsAppState state) { g_autoptr(GsAppList) addons = NULL; g_autoptr(GString) errors = NULL; guint ii, sz; g_return_if_fail (transaction != NULL); g_return_if_fail (GS_IS_APP (parent_app)); addons = gs_app_dup_addons (parent_app); sz = addons ? gs_app_list_length (addons) : 0; for (ii = 0; ii < sz; ii++) { GsApp *addon = gs_app_list_index (addons, ii); g_autoptr(GError) local_error = NULL; if (state == GS_APP_STATE_INSTALLING && gs_app_get_to_be_installed (addon)) { g_autofree gchar *ref = NULL; ref = gs_flatpak_app_get_ref_display (addon); if (flatpak_transaction_add_install (transaction, gs_app_get_origin (addon), ref, NULL, &local_error)) { gs_app_set_state (addon, state); } else { if (errors) g_string_append_c (errors, '\n'); else errors = g_string_new (NULL); g_string_append_printf (errors, _("Failed to add to install for addon ‘%s’: %s"), gs_app_get_name (addon), local_error->message); } } else if (state == GS_APP_STATE_REMOVING && gs_app_get_state (addon) == GS_APP_STATE_INSTALLED) { g_autofree gchar *ref = NULL; ref = gs_flatpak_app_get_ref_display (addon); if (flatpak_transaction_add_uninstall (transaction, ref, &local_error)) { gs_app_set_state (addon, state); } else { if (errors) g_string_append_c (errors, '\n'); else errors = g_string_new (NULL); g_string_append_printf (errors, _("Failed to add to uninstall for addon ‘%s’: %s"), gs_app_get_name (addon), local_error->message); } } } if (errors) { g_autoptr(GsPluginEvent) event = NULL; g_autoptr(GError) error_local = g_error_new_literal (GS_PLUGIN_ERROR, GS_PLUGIN_ERROR_FAILED, errors->str); event = gs_plugin_event_new ("error", error_local, NULL); gs_plugin_event_add_flag (event, GS_PLUGIN_EVENT_FLAG_WARNING); gs_plugin_report_event (plugin, event); } } static void uninstall_apps_thread_cb (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable); static void gs_plugin_flatpak_uninstall_apps_async (GsPlugin *plugin, GsAppList *apps, GsPluginUninstallAppsFlags flags, GsPluginProgressCallback progress_callback, gpointer progress_user_data, GsPluginAppNeedsUserActionCallback app_needs_user_action_callback, gpointer app_needs_user_action_data, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (plugin); g_autoptr(GTask) task = NULL; gboolean interactive = (flags & GS_PLUGIN_UNINSTALL_APPS_FLAGS_INTERACTIVE); task = gs_plugin_uninstall_apps_data_new_task (plugin, apps, flags, progress_callback, progress_user_data, app_needs_user_action_callback, app_needs_user_action_data, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_flatpak_uninstall_apps_async); /* Queue a job to uninstall the apps. */ gs_worker_thread_queue (self->worker, get_priority_for_interactivity (interactive), uninstall_apps_thread_cb, g_steal_pointer (&task)); } /* Run in @worker. */ static void uninstall_apps_thread_cb (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable) { GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (source_object); GsPlugin *plugin = GS_PLUGIN (self); GsPluginUninstallAppsData *data = task_data; gboolean interactive = (data->flags & GS_PLUGIN_UNINSTALL_APPS_FLAGS_INTERACTIVE); g_autoptr(GHashTable) applist_by_flatpaks = NULL; GHashTableIter iter; gpointer key, value; g_autoptr(GError) local_error = NULL; assert_in_worker (self); /* Mark all the apps as pending uninstallation. While the op/progress * handling code in #GsFlatpakTransaction does this more accurately and * in more detail, we need to pre-emptively do it here, since multiple * transactions are run sequentially below. That means that all the apps * from the 2nd, 3rd, etc. transactions will not have their state * updated until that transaction is prepared. That’s a long time for * the apps to look like they’ve been left out of the uninstall in the UI. */ applist_by_flatpaks = _group_apps_by_installation (self, data->apps); g_hash_table_iter_init (&iter, applist_by_flatpaks); while (g_hash_table_iter_next (&iter, NULL, &value)) { GsAppList *apps_for_installation = GS_APP_LIST (value); for (guint i = 0; i < gs_app_list_length (apps_for_installation); i++) { GsApp *app = gs_app_list_index (apps_for_installation, i); gs_app_set_state (app, GS_APP_STATE_REMOVING); } } /* build and run transaction for each flatpak installation */ g_hash_table_iter_init (&iter, applist_by_flatpaks); while (g_hash_table_iter_next (&iter, &key, &value)) { GsFlatpak *flatpak = GS_FLATPAK (key); GsAppList *list_tmp = GS_APP_LIST (value); g_autoptr(FlatpakTransaction) transaction = NULL; g_assert (GS_IS_FLATPAK (flatpak)); g_assert (list_tmp != NULL); g_assert (gs_app_list_length (list_tmp) > 0); gs_flatpak_set_busy (flatpak, TRUE); /* build */ transaction = _build_transaction (plugin, flatpak, GS_FLATPAK_ERROR_MODE_STOP_ON_FIRST_ERROR, interactive, cancellable, &local_error); if (transaction == NULL) { g_autoptr(GsPluginEvent) event = NULL; /* Reset the state of all the apps in this transaction. */ for (guint i = 0; i < gs_app_list_length (list_tmp); i++) { GsApp *app = gs_app_list_index (list_tmp, i); gs_app_set_state_recover (app); } /* This can only fail if the repo doesn’t exist and can’t * be created, which is unlikely. */ gs_flatpak_error_convert (&local_error); event = gs_plugin_event_new ("error", local_error, NULL); if (interactive) gs_plugin_event_add_flag (event, GS_PLUGIN_EVENT_FLAG_INTERACTIVE); gs_plugin_event_add_flag (event, GS_PLUGIN_EVENT_FLAG_WARNING); gs_plugin_report_event (GS_PLUGIN (self), event); g_clear_error (&local_error); gs_flatpak_set_busy (flatpak, FALSE); continue; } for (guint i = 0; i < gs_app_list_length (list_tmp); i++) { GsApp *app = gs_app_list_index (list_tmp, i); g_autofree char *ref = NULL; /* not supported */ if (gs_plugin_flatpak_get_handler (self, app) == NULL) continue; /* is a source, handled by dedicated function */ g_assert (gs_app_get_kind (app) != AS_COMPONENT_KIND_REPOSITORY); /* add to the transaction cache for quick look up -- other unrelated * refs will be matched using gs_plugin_flatpak_find_app_by_ref() */ gs_flatpak_transaction_add_app (transaction, app); /* add to the transaction */ ref = gs_flatpak_app_get_ref_display (app); if (!flatpak_transaction_add_uninstall (transaction, ref, &local_error)) { /* Somehow, the app might already be uninstalled. */ if (g_error_matches (local_error, FLATPAK_ERROR, FLATPAK_ERROR_NOT_INSTALLED)) { g_clear_error (&local_error); } } /* Reset state if adding the app to the transaction failed. */ if (local_error != NULL) { g_autoptr(GsPluginEvent) event = NULL; /* Reset the state of all the apps in this transaction. */ for (guint j = 0; j < gs_app_list_length (list_tmp); j++) { GsApp *recover_app = gs_app_list_index (list_tmp, j); gs_app_set_state_recover (recover_app); } gs_flatpak_error_convert (&local_error); event = gs_plugin_event_new ("error", local_error, NULL); if (interactive) gs_plugin_event_add_flag (event, GS_PLUGIN_EVENT_FLAG_INTERACTIVE); gs_plugin_event_add_flag (event, GS_PLUGIN_EVENT_FLAG_WARNING); gs_plugin_report_event (GS_PLUGIN (self), event); g_clear_error (&local_error); gs_flatpak_set_busy (flatpak, FALSE); continue; } gs_flatpak_cover_addons_in_transaction (plugin, transaction, app, GS_APP_STATE_REMOVING); } /* run transaction */ /* FIXME: Link progress reporting from #FlatpakTransaction * up to `data->progress_callback`. */ if (!gs_flatpak_transaction_run (transaction, cancellable, &local_error)) { GsApp *error_app = NULL; gs_flatpak_transaction_get_error_operation (GS_FLATPAK_TRANSACTION (transaction), &error_app); /* Reset the state of all the apps in this transaction. */ for (guint i = 0; i < gs_app_list_length (list_tmp); i++) { GsApp *app = gs_app_list_index (list_tmp, i); gs_app_set_state_recover (app); } /* Somehow, the app might already be uninstalled. */ if (g_error_matches (local_error, FLATPAK_ERROR, FLATPAK_ERROR_NOT_INSTALLED)) { g_clear_error (&local_error); /* Set the app back to UNKNOWN so that refining it gets all the right details. */ if (error_app != NULL) { g_debug ("App %s is already uninstalled", gs_app_get_unique_id (error_app)); gs_app_set_state (error_app, GS_APP_STATE_UNKNOWN); } } else { g_autoptr(GsPluginEvent) event = NULL; gs_flatpak_error_convert (&local_error); event = gs_plugin_event_new ("error", local_error, NULL); if (interactive) gs_plugin_event_add_flag (event, GS_PLUGIN_EVENT_FLAG_INTERACTIVE); gs_plugin_event_add_flag (event, GS_PLUGIN_EVENT_FLAG_WARNING); gs_plugin_report_event (GS_PLUGIN (self), event); g_clear_error (&local_error); gs_flatpak_set_busy (flatpak, FALSE); continue; } } /* Get any new state. Ignore failure and fall through to * refining the apps, since refreshing is not an entirely * necessary part of the uninstall operation. */ if (!gs_flatpak_refresh (flatpak, G_MAXUINT, interactive, cancellable, &local_error)) { gs_flatpak_error_convert (&local_error); g_debug ("Error refreshing flatpak data for ‘%s’ after uninstall: %s", gs_flatpak_get_id (flatpak), local_error->message); g_clear_error (&local_error); } /* Refine all the uninstalled apps to make sure they’re up to date * in the UI. Ignore failure since it’s not an entirely * necessary part of the uninstall operation. */ for (guint i = 0; i < gs_app_list_length (list_tmp); i++) { GsApp *app = gs_app_list_index (list_tmp, i); g_autofree gchar *ref = NULL; gs_app_set_size_download (app, GS_SIZE_TYPE_UNKNOWN, 0); gs_app_set_size_installed (app, GS_SIZE_TYPE_UNKNOWN, 0); ref = gs_flatpak_app_get_ref_display (app); if (!gs_flatpak_refine_app (flatpak, app, GS_PLUGIN_REFINE_FLAGS_REQUIRE_ID | GS_PLUGIN_REFINE_FLAGS_REQUIRE_ORIGIN | GS_PLUGIN_REFINE_FLAGS_REQUIRE_SETUP_ACTION, interactive, FALSE, cancellable, &local_error)) { gs_flatpak_error_convert (&local_error); g_debug ("Error refining app ‘%s’ after uninstall: %s", ref, local_error->message); g_clear_error (&local_error); continue; } gs_flatpak_refine_addons (flatpak, app, GS_PLUGIN_REFINE_FLAGS_REQUIRE_ID, GS_APP_STATE_REMOVING, interactive, cancellable); } gs_flatpak_set_busy (flatpak, FALSE); } g_task_return_boolean (task, TRUE); } static gboolean gs_plugin_flatpak_uninstall_apps_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } static gboolean app_has_local_source (GsApp *app) { const gchar *url = gs_app_get_origin_hostname (app); if (gs_flatpak_app_get_file_kind (app) == GS_FLATPAK_APP_FILE_KIND_BUNDLE) return TRUE; if (gs_flatpak_app_get_file_kind (app) == GS_FLATPAK_APP_FILE_KIND_REF && g_strcmp0 (url, "localhost") == 0) return TRUE; return FALSE; } static void gs_plugin_flatpak_ensure_scope (GsPlugin *plugin, GsApp *app) { GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (plugin); if (gs_app_get_scope (app) == AS_COMPONENT_SCOPE_UNKNOWN) { g_autoptr(GSettings) settings = g_settings_new ("org.gnome.software"); /* get the new GsFlatpak for handling of local files */ gs_app_set_scope (app, g_settings_get_boolean (settings, "install-bundles-system-wide") ? AS_COMPONENT_SCOPE_SYSTEM : AS_COMPONENT_SCOPE_USER); if (!self->has_system_helper) { g_info ("no flatpak system helper is available, using user"); gs_app_set_scope (app, AS_COMPONENT_SCOPE_USER); } if (self->destdir_for_tests != NULL) { g_debug ("in self tests, using user"); gs_app_set_scope (app, AS_COMPONENT_SCOPE_USER); } } } static void install_apps_thread_cb (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable); static void gs_plugin_flatpak_install_apps_async (GsPlugin *plugin, GsAppList *apps, GsPluginInstallAppsFlags flags, GsPluginProgressCallback progress_callback, gpointer progress_user_data, GsPluginAppNeedsUserActionCallback app_needs_user_action_callback, gpointer app_needs_user_action_data, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (plugin); g_autoptr(GTask) task = NULL; gboolean interactive = (flags & GS_PLUGIN_INSTALL_APPS_FLAGS_INTERACTIVE); task = gs_plugin_install_apps_data_new_task (plugin, apps, flags, progress_callback, progress_user_data, app_needs_user_action_callback, app_needs_user_action_data, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_flatpak_install_apps_async); /* Queue a job to install the apps. */ gs_worker_thread_queue (self->worker, get_priority_for_interactivity (interactive), install_apps_thread_cb, g_steal_pointer (&task)); } /* Run in @worker. */ static void install_apps_thread_cb (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable) { GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (source_object); GsPlugin *plugin = GS_PLUGIN (self); GsPluginInstallAppsData *data = task_data; gboolean interactive = (data->flags & GS_PLUGIN_INSTALL_APPS_FLAGS_INTERACTIVE); g_autoptr(GHashTable) applist_by_flatpaks = NULL; GHashTableIter iter; gpointer key, value; g_autoptr(GError) local_error = NULL; assert_in_worker (self); /* Mark all the apps as pending installation. While the op/progress * handling code in #GsFlatpakTransaction does this more accurately and * in more detail, we need to pre-emptively do it here, since multiple * transactions are run sequentially below. That means that all the apps * from the 2nd, 3rd, etc. transactions will not have their state * updated until that transaction is prepared. That’s a long time for * the apps to look like they’ve been left out of the install in the UI. */ applist_by_flatpaks = _group_apps_by_installation (self, data->apps); g_hash_table_iter_init (&iter, applist_by_flatpaks); while (g_hash_table_iter_next (&iter, NULL, &value)) { GsAppList *apps_for_installation = GS_APP_LIST (value); for (guint i = 0; i < gs_app_list_length (apps_for_installation); i++) { GsApp *app = gs_app_list_index (apps_for_installation, i); gs_app_set_state (app, GS_APP_STATE_INSTALLING); } } /* build and run transaction for each flatpak installation */ g_hash_table_iter_init (&iter, applist_by_flatpaks); while (g_hash_table_iter_next (&iter, &key, &value)) { GsFlatpak *flatpak = GS_FLATPAK (key); GsAppList *list_tmp = GS_APP_LIST (value); g_autoptr(FlatpakTransaction) transaction = NULL; gpointer schedule_entry_handle = NULL; g_assert (GS_IS_FLATPAK (flatpak)); g_assert (list_tmp != NULL); g_assert (gs_app_list_length (list_tmp) > 0); if (!interactive) { if (!(data->flags & GS_PLUGIN_INSTALL_APPS_FLAGS_NO_DOWNLOAD) && !gs_metered_block_app_list_on_download_scheduler (list_tmp, &schedule_entry_handle, cancellable, &local_error)) { g_warning ("Failed to block on download scheduler: %s", local_error->message); g_clear_error (&local_error); } } gs_flatpak_set_busy (flatpak, TRUE); /* build */ transaction = _build_transaction (plugin, flatpak, GS_FLATPAK_ERROR_MODE_STOP_ON_FIRST_ERROR, interactive, cancellable, &local_error); if (transaction == NULL) { g_autoptr(GsPluginEvent) event = NULL; /* Reset the state of all the apps in this transaction. */ for (guint i = 0; i < gs_app_list_length (list_tmp); i++) { GsApp *app = gs_app_list_index (list_tmp, i); gs_app_set_state_recover (app); } /* This can only fail if the repo doesn’t exist and can’t * be created, which is unlikely. */ gs_flatpak_error_convert (&local_error); event = gs_plugin_event_new ("error", local_error, NULL); if (interactive) gs_plugin_event_add_flag (event, GS_PLUGIN_EVENT_FLAG_INTERACTIVE); gs_plugin_event_add_flag (event, GS_PLUGIN_EVENT_FLAG_WARNING); gs_plugin_report_event (GS_PLUGIN (self), event); g_clear_error (&local_error); remove_schedule_entry (schedule_entry_handle); gs_flatpak_set_busy (flatpak, FALSE); continue; } /* Apply flags to the transaction. */ if (data->flags & GS_PLUGIN_INSTALL_APPS_FLAGS_NO_DOWNLOAD) flatpak_transaction_set_no_pull (transaction, TRUE); if (data->flags & GS_PLUGIN_INSTALL_APPS_FLAGS_NO_APPLY) flatpak_transaction_set_no_deploy (transaction, TRUE); for (guint i = 0; i < gs_app_list_length (list_tmp); i++) { GsApp *app = gs_app_list_index (list_tmp, i); /* queue for install if installation needs the network */ if (!app_has_local_source (app) && !gs_plugin_get_network_available (plugin)) { gs_app_set_state (app, GS_APP_STATE_QUEUED_FOR_INSTALL); continue; } /* set the app scope */ gs_plugin_flatpak_ensure_scope (plugin, app); /* not supported */ if (gs_plugin_flatpak_get_handler (self, app) == NULL) continue; /* is a source, handled by dedicated function */ g_assert (gs_app_get_kind (app) != AS_COMPONENT_KIND_REPOSITORY); /* add to the transaction cache for quick look up -- other unrelated * refs will be matched using gs_plugin_flatpak_find_app_by_ref() */ gs_flatpak_transaction_add_app (transaction, app); /* add flatpakref */ if (gs_flatpak_app_get_file_kind (app) == GS_FLATPAK_APP_FILE_KIND_REF) { GFile *file = gs_app_get_local_file (app); if (file == NULL) { g_set_error (&local_error, GS_PLUGIN_ERROR, GS_PLUGIN_ERROR_NOT_SUPPORTED, "no local file set for bundle %s", gs_app_get_unique_id (app)); } else { g_autoptr(GBytes) blob = g_file_load_bytes (file, cancellable, NULL, &local_error); if (blob != NULL) flatpak_transaction_add_install_flatpakref (transaction, blob, &local_error); } /* add bundle */ } else if (gs_flatpak_app_get_file_kind (app) == GS_FLATPAK_APP_FILE_KIND_BUNDLE) { GFile *file = gs_app_get_local_file (app); if (file == NULL) { g_set_error (&local_error, GS_PLUGIN_ERROR, GS_PLUGIN_ERROR_NOT_SUPPORTED, "no local file set for bundle %s", gs_app_get_unique_id (app)); } else { flatpak_transaction_add_install_bundle (transaction, file, NULL, &local_error); } /* add normal ref */ } else { g_autofree gchar *ref = gs_flatpak_app_get_ref_display (app); if (!flatpak_transaction_add_install (transaction, gs_app_get_origin (app), ref, NULL, &local_error)) { /* Somehow, the app might already be installed. */ if (g_error_matches (local_error, FLATPAK_ERROR, FLATPAK_ERROR_ALREADY_INSTALLED)) { g_clear_error (&local_error); } } } /* Reset state if adding the app to the transaction failed. */ if (local_error != NULL) { g_autoptr(GsPluginEvent) event = NULL; /* Reset the state of the failed app */ gs_app_set_state_recover (app); gs_flatpak_error_convert (&local_error); event = gs_plugin_event_new ("error", local_error, "app", app, NULL); if (interactive) gs_plugin_event_add_flag (event, GS_PLUGIN_EVENT_FLAG_INTERACTIVE); gs_plugin_event_add_flag (event, GS_PLUGIN_EVENT_FLAG_WARNING); gs_plugin_report_event (GS_PLUGIN (self), event); g_clear_error (&local_error); continue; } gs_flatpak_cover_addons_in_transaction (plugin, transaction, app, GS_APP_STATE_INSTALLING); } /* run transaction */ /* FIXME: Link progress reporting from #FlatpakTransaction * up to `data->progress_callback`. */ if (!gs_flatpak_transaction_run (transaction, cancellable, &local_error)) { GsApp *error_app = NULL; gs_flatpak_transaction_get_error_operation (GS_FLATPAK_TRANSACTION (transaction), &error_app); /* Reset the state of all the apps in this transaction. */ for (guint i = 0; i < gs_app_list_length (list_tmp); i++) { GsApp *app = gs_app_list_index (list_tmp, i); gs_app_set_state_recover (app); } /* Somehow, the app might already be installed. */ if (g_error_matches (local_error, FLATPAK_ERROR, FLATPAK_ERROR_ALREADY_INSTALLED)) { g_clear_error (&local_error); /* Set the app back to UNKNOWN so that refining it gets all the right details. */ if (error_app != NULL) { g_debug ("App %s is already installed", gs_app_get_unique_id (error_app)); gs_app_set_state (error_app, GS_APP_STATE_UNKNOWN); } } else { g_autoptr(GsPluginEvent) event = NULL; if (error_app != NULL && g_error_matches (local_error, FLATPAK_ERROR, FLATPAK_ERROR_REF_NOT_FOUND)) { const gchar *origin = gs_app_get_origin (error_app); if (origin != NULL) { g_autoptr(FlatpakRemote) remote = NULL; remote = flatpak_installation_get_remote_by_name (gs_flatpak_get_installation (flatpak, interactive), origin, cancellable, NULL); if (remote != NULL) { g_autofree gchar *filter = flatpak_remote_get_filter (remote); if (filter != NULL && *filter != '\0') { /* It's a filtered remote, create a user friendly error message for it */ g_autoptr(GError) error_tmp = NULL; g_set_error (&error_tmp, GS_PLUGIN_ERROR, GS_PLUGIN_ERROR_FAILED, _("Remote “%s” doesn't allow install of “%s”, possibly due to its filter. Remove the filter and repeat the install. Detailed error: %s"), flatpak_remote_get_title (remote), gs_app_get_name (error_app), local_error->message); g_clear_error (&local_error); local_error = g_steal_pointer (&error_tmp); } } } } gs_flatpak_error_convert (&local_error); event = gs_plugin_event_new ("error", local_error, "app", error_app, NULL); if (interactive) gs_plugin_event_add_flag (event, GS_PLUGIN_EVENT_FLAG_INTERACTIVE); gs_plugin_event_add_flag (event, GS_PLUGIN_EVENT_FLAG_WARNING); gs_plugin_report_event (GS_PLUGIN (self), event); g_clear_error (&local_error); remove_schedule_entry (schedule_entry_handle); gs_flatpak_set_busy (flatpak, FALSE); continue; } } remove_schedule_entry (schedule_entry_handle); /* Get any new state. Ignore failure and fall through to * refining the apps, since refreshing is not an entirely * necessary part of the install operation. */ if (!(data->flags & GS_PLUGIN_INSTALL_APPS_FLAGS_NO_DOWNLOAD) && !gs_flatpak_refresh (flatpak, G_MAXUINT, interactive, cancellable, &local_error)) { gs_flatpak_error_convert (&local_error); g_warning ("Error refreshing flatpak data for ‘%s’ after install: %s", gs_flatpak_get_id (flatpak), local_error->message); g_clear_error (&local_error); } /* Refine all the installed apps to make sure they’re up to date * in the UI. Ignore failure since it’s not an entirely * necessary part of the install operation. */ for (guint i = 0; i < gs_app_list_length (list_tmp); i++) { GsApp *app = gs_app_list_index (list_tmp, i); g_autofree gchar *ref = NULL; ref = gs_flatpak_app_get_ref_display (app); if (!gs_flatpak_refine_app (flatpak, app, GS_PLUGIN_REFINE_FLAGS_REQUIRE_ID | GS_PLUGIN_REFINE_FLAGS_REQUIRE_ORIGIN | GS_PLUGIN_REFINE_FLAGS_REQUIRE_SETUP_ACTION, interactive, FALSE, cancellable, &local_error)) { gs_flatpak_error_convert (&local_error); g_warning ("Error refining app ‘%s’ after install: %s", ref, local_error->message); g_clear_error (&local_error); continue; } gs_flatpak_refine_addons (flatpak, app, GS_PLUGIN_REFINE_FLAGS_REQUIRE_ID, GS_APP_STATE_INSTALLING, interactive, cancellable); } gs_flatpak_set_busy (flatpak, FALSE); } g_task_return_boolean (task, TRUE); } static gboolean gs_plugin_flatpak_install_apps_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } static GsApp * gs_plugin_flatpak_file_to_app_repo (GsPluginFlatpak *self, GFile *file, gboolean interactive, GCancellable *cancellable, GError **error) { g_autoptr(GsApp) app = NULL; /* parse the repo file */ app = gs_flatpak_app_new_from_repo_file (file, cancellable, error); if (app == NULL) return NULL; /* already exists */ for (guint i = 0; i < self->installations->len; i++) { GsFlatpak *flatpak = g_ptr_array_index (self->installations, i); g_autoptr(GError) error_local = NULL; g_autoptr(GsApp) app_tmp = NULL; app_tmp = gs_flatpak_find_source_by_url (flatpak, gs_flatpak_app_get_repo_url (app), interactive, cancellable, &error_local); if (app_tmp == NULL) { g_debug ("%s", error_local->message); continue; } if (g_strcmp0 (gs_flatpak_app_get_repo_filter (app), gs_flatpak_app_get_repo_filter (app_tmp)) != 0) continue; return g_steal_pointer (&app_tmp); } /* this is new */ gs_app_set_management_plugin (app, GS_PLUGIN (self)); return g_steal_pointer (&app); } static GsFlatpak * gs_plugin_flatpak_create_temporary (GsPluginFlatpak *self, GCancellable *cancellable, GError **error) { g_autofree gchar *installation_path = NULL; g_autoptr(FlatpakInstallation) installation = NULL; g_autoptr(GFile) installation_file = NULL; /* create new per-user installation in a cache dir */ installation_path = gs_utils_get_cache_filename ("flatpak", "installation-tmp", GS_UTILS_CACHE_FLAG_WRITEABLE | GS_UTILS_CACHE_FLAG_ENSURE_EMPTY | GS_UTILS_CACHE_FLAG_CREATE_DIRECTORY, error); if (installation_path == NULL) return NULL; installation_file = g_file_new_for_path (installation_path); installation = flatpak_installation_new_for_path (installation_file, TRUE, /* user */ cancellable, error); if (installation == NULL) { gs_flatpak_error_convert (error); return NULL; } return gs_flatpak_new (GS_PLUGIN (self), installation, GS_FLATPAK_FLAG_IS_TEMPORARY); } static GsApp * gs_plugin_flatpak_file_to_app_bundle (GsPluginFlatpak *self, GFile *file, gboolean interactive, GsApp *alternate_of, GCancellable *cancellable, GError **error) { g_autofree gchar *ref = NULL; g_autoptr(GsApp) app = NULL; g_autoptr(GsApp) app_tmp = NULL; g_autoptr(GsFlatpak) flatpak_tmp = NULL; GsApp *runtime; /* only use the temporary GsFlatpak to avoid the auth dialog */ flatpak_tmp = gs_plugin_flatpak_create_temporary (self, cancellable, error); if (flatpak_tmp == NULL) return NULL; /* First make a quick GsApp to get the ref */ app = gs_flatpak_file_to_app_bundle (flatpak_tmp, file, TRUE /* unrefined */, interactive, cancellable, error); if (app == NULL) return NULL; /* is this already installed or available in a configured remote */ ref = gs_flatpak_app_get_ref_display (app); app_tmp = gs_plugin_flatpak_find_app_by_ref (self, ref, interactive, alternate_of, cancellable, NULL); if (app_tmp != NULL) return g_steal_pointer (&app_tmp); /* If not installed/available, make a fully refined GsApp */ g_clear_object (&app); app = gs_flatpak_file_to_app_bundle (flatpak_tmp, file, FALSE /* unrefined */, interactive, cancellable, error); if (app == NULL) return NULL; /* force this to be 'any' scope for installation */ gs_app_set_scope (app, AS_COMPONENT_SCOPE_UNKNOWN); runtime = gs_app_get_runtime (app); if (runtime != NULL) gs_app_set_scope (runtime, AS_COMPONENT_SCOPE_UNKNOWN); /* this is new */ return g_steal_pointer (&app); } static GsApp * gs_plugin_flatpak_file_to_app_ref (GsPluginFlatpak *self, GFile *file, gboolean interactive, GsApp *alternate_of, GCancellable *cancellable, GError **error) { GsApp *runtime; g_autofree gchar *ref = NULL; g_autoptr(GsApp) app = NULL; g_autoptr(GsApp) app_tmp = NULL; g_autoptr(GsFlatpak) flatpak_tmp = NULL; /* only use the temporary GsFlatpak to avoid the auth dialog */ flatpak_tmp = gs_plugin_flatpak_create_temporary (self, cancellable, error); if (flatpak_tmp == NULL) return NULL; /* First make a quick GsApp to get the ref */ app = gs_flatpak_file_to_app_ref (flatpak_tmp, file, TRUE /* unrefined */, interactive, cancellable, error); if (app == NULL) return NULL; /* is this already installed or available in a configured remote */ ref = gs_flatpak_app_get_ref_display (app); app_tmp = gs_plugin_flatpak_find_app_by_ref (self, ref, interactive, alternate_of, cancellable, NULL); if (app_tmp != NULL) return g_steal_pointer (&app_tmp); /* If not installed/available, make a fully refined GsApp */ g_clear_object (&app); app = gs_flatpak_file_to_app_ref (flatpak_tmp, file, FALSE /* unrefined */, interactive, cancellable, error); if (app == NULL) return NULL; /* force this to be 'any' scope for installation */ gs_app_set_scope (app, AS_COMPONENT_SCOPE_UNKNOWN); /* do we have a system runtime available */ runtime = gs_app_get_runtime (app); if (runtime != NULL) { g_autoptr(GsApp) runtime_tmp = NULL; g_autofree gchar *runtime_ref = gs_flatpak_app_get_ref_display (runtime); runtime_tmp = gs_plugin_flatpak_find_app_by_ref (self, runtime_ref, interactive, alternate_of, cancellable, NULL); if (runtime_tmp != NULL) { gs_app_set_runtime (app, runtime_tmp); } else { /* the new runtime is available from the RuntimeRepo */ if (gs_flatpak_app_get_runtime_url (runtime) != NULL) gs_app_set_state (runtime, GS_APP_STATE_AVAILABLE); } } /* this is new */ return g_steal_pointer (&app); } static GsApp * /* (transfer full) */ gs_plugin_flatpak_file_to_app (GsPluginFlatpak *self, GFile *file, gboolean interactive, GsApp *alternate_of, GCancellable *cancellable, GError **error) { g_autofree gchar *content_type = NULL; GsApp *app = NULL; const gchar *mimetypes_bundle[] = { "application/vnd.flatpak", NULL }; const gchar *mimetypes_repo[] = { "application/vnd.flatpak.repo", NULL }; const gchar *mimetypes_ref[] = { "application/vnd.flatpak.ref", NULL }; /* does this match any of the mimetypes we support */ content_type = gs_utils_get_content_type (file, cancellable, error); if (content_type == NULL) return NULL; if (g_strv_contains (mimetypes_bundle, content_type)) app = gs_plugin_flatpak_file_to_app_bundle (self, file, interactive, alternate_of, cancellable, error); else if (g_strv_contains (mimetypes_repo, content_type)) app = gs_plugin_flatpak_file_to_app_repo (self, file, interactive, cancellable, error); else if (g_strv_contains (mimetypes_ref, content_type)) app = gs_plugin_flatpak_file_to_app_ref (self, file, interactive, alternate_of, cancellable, error); if (app != NULL) { GsApp *runtime = gs_app_get_runtime (app); /* Ensure the origin for the runtime is set */ if (runtime != NULL && gs_app_get_origin (runtime) == NULL) { g_autoptr(GError) error_local = NULL; if (!gs_plugin_flatpak_refine_app (self, runtime, GS_PLUGIN_REFINE_FLAGS_REQUIRE_ORIGIN, interactive, cancellable, &error_local)) g_debug ("Failed to refine runtime: %s", error_local->message); } gs_plugin_flatpak_ensure_scope (GS_PLUGIN (self), app); /* It can return a cached app when the app is available in one of the remotes. Cached apps cannot have set the local file property. */ if (gs_plugin_cache_lookup (GS_PLUGIN (self), gs_app_get_unique_id (app)) != app) gs_app_set_local_file (app, file); } return app; } static void file_to_app_thread_cb (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable) { g_autoptr(GsApp) app = NULL; g_autoptr(GError) local_error = NULL; GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (source_object); GsPluginFileToAppData *data = task_data; gboolean interactive = (data->flags & GS_PLUGIN_FILE_TO_APP_FLAGS_INTERACTIVE) != 0; app = gs_plugin_flatpak_file_to_app (self, data->file, interactive, NULL, cancellable, &local_error); if (app != NULL) { g_autoptr(GsAppList) list = gs_app_list_new (); gs_app_list_add (list, app); g_task_return_pointer (task, g_steal_pointer (&list), g_object_unref); } else if (local_error != NULL) { g_task_return_error (task, g_steal_pointer (&local_error)); } else { g_task_return_pointer (task, gs_app_list_new (), g_object_unref); } } static void gs_plugin_flatpak_file_to_app_async (GsPlugin *plugin, GFile *file, GsPluginFileToAppFlags flags, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { g_autoptr(GTask) task = NULL; GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (plugin); gboolean interactive = (flags & GS_PLUGIN_FILE_TO_APP_FLAGS_INTERACTIVE) != 0; task = gs_plugin_file_to_app_data_new_task (plugin, file, flags, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_flatpak_file_to_app_async); /* Queue a job to get the apps. */ gs_worker_thread_queue (self->worker, get_priority_for_interactivity (interactive), file_to_app_thread_cb, g_steal_pointer (&task)); } static GsAppList * gs_plugin_flatpak_file_to_app_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_pointer (G_TASK (result), error); } static void refine_categories_thread_cb (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable); static void gs_plugin_flatpak_refine_categories_async (GsPlugin *plugin, GPtrArray *list, GsPluginRefineCategoriesFlags flags, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (plugin); g_autoptr(GTask) task = NULL; gboolean interactive = (flags & GS_PLUGIN_REFINE_CATEGORIES_FLAGS_INTERACTIVE); task = gs_plugin_refine_categories_data_new_task (plugin, list, flags, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_flatpak_refine_categories_async); /* All we actually do is add the sizes of each category. If that’s * not been requested, avoid queueing a worker job. */ if (!(flags & GS_PLUGIN_REFINE_CATEGORIES_FLAGS_SIZE)) { g_task_return_boolean (task, TRUE); return; } /* Queue a job to get the apps. */ gs_worker_thread_queue (self->worker, get_priority_for_interactivity (interactive), refine_categories_thread_cb, g_steal_pointer (&task)); } /* Run in @worker. */ static void refine_categories_thread_cb (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable) { GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (source_object); GsPluginRefineCategoriesData *data = task_data; gboolean interactive = (data->flags & GS_PLUGIN_REFINE_CATEGORIES_FLAGS_INTERACTIVE); g_autoptr(GError) local_error = NULL; assert_in_worker (self); for (guint i = 0; i < self->installations->len; i++) { GsFlatpak *flatpak = g_ptr_array_index (self->installations, i); if (!gs_flatpak_refine_category_sizes (flatpak, data->list, interactive, cancellable, &local_error)) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } } g_task_return_boolean (task, TRUE); } static gboolean gs_plugin_flatpak_refine_categories_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } static void list_apps_thread_cb (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable); static void gs_plugin_flatpak_list_apps_async (GsPlugin *plugin, GsAppQuery *query, GsPluginListAppsFlags flags, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (plugin); g_autoptr(GTask) task = NULL; gboolean interactive = (flags & GS_PLUGIN_LIST_APPS_FLAGS_INTERACTIVE); task = gs_plugin_list_apps_data_new_task (plugin, query, flags, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_flatpak_list_apps_async); /* Queue a job to get the apps. */ gs_worker_thread_queue (self->worker, get_priority_for_interactivity (interactive), list_apps_thread_cb, g_steal_pointer (&task)); } /* Run in @worker. */ static void list_apps_thread_cb (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable) { GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (source_object); g_autoptr(GsAppList) list = gs_app_list_new (); GsPluginListAppsData *data = task_data; gboolean interactive = (data->flags & GS_PLUGIN_LIST_APPS_FLAGS_INTERACTIVE); GDateTime *released_since = NULL; GsAppQueryTristate is_curated = GS_APP_QUERY_TRISTATE_UNSET; GsAppQueryTristate is_featured = GS_APP_QUERY_TRISTATE_UNSET; GsCategory *category = NULL; GsAppQueryTristate is_installed = GS_APP_QUERY_TRISTATE_UNSET; GsAppQueryTristate is_for_update = GS_APP_QUERY_TRISTATE_UNSET; GsAppQueryTristate is_source = GS_APP_QUERY_TRISTATE_UNSET; guint64 age_secs = 0; const gchar * const *deployment_featured = NULL; const gchar *const *developers = NULL; const gchar * const *keywords = NULL; GsApp *alternate_of = NULL; const gchar *provides_tag = NULL; GsAppQueryProvidesType provides_type = GS_APP_QUERY_PROVIDES_UNKNOWN; g_autoptr(GError) local_error = NULL; assert_in_worker (self); if (data->query != NULL) { released_since = gs_app_query_get_released_since (data->query); is_curated = gs_app_query_get_is_curated (data->query); is_featured = gs_app_query_get_is_featured (data->query); category = gs_app_query_get_category (data->query); is_installed = gs_app_query_get_is_installed (data->query); deployment_featured = gs_app_query_get_deployment_featured (data->query); developers = gs_app_query_get_developers (data->query); keywords = gs_app_query_get_keywords (data->query); alternate_of = gs_app_query_get_alternate_of (data->query); provides_type = gs_app_query_get_provides (data->query, &provides_tag); is_for_update = gs_app_query_get_is_for_update (data->query); is_source = gs_app_query_get_is_source (data->query); } if (released_since != NULL) { g_autoptr(GDateTime) now = g_date_time_new_now_local (); age_secs = g_date_time_difference (now, released_since) / G_TIME_SPAN_SECOND; } /* Currently only support a subset of query properties, and only one set at once. * Also don’t currently support GS_APP_QUERY_TRISTATE_FALSE. */ if ((released_since == NULL && is_curated == GS_APP_QUERY_TRISTATE_UNSET && is_featured == GS_APP_QUERY_TRISTATE_UNSET && category == NULL && is_installed == GS_APP_QUERY_TRISTATE_UNSET && deployment_featured == NULL && developers == NULL && keywords == NULL && alternate_of == NULL && provides_tag == NULL && is_for_update == GS_APP_QUERY_TRISTATE_UNSET && is_source == GS_APP_QUERY_TRISTATE_UNSET) || is_curated == GS_APP_QUERY_TRISTATE_FALSE || is_featured == GS_APP_QUERY_TRISTATE_FALSE || is_installed == GS_APP_QUERY_TRISTATE_FALSE || is_for_update == GS_APP_QUERY_TRISTATE_FALSE || is_source == GS_APP_QUERY_TRISTATE_FALSE || gs_app_query_get_n_properties_set (data->query) != 1) { g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_NOT_SUPPORTED, "Unsupported query"); return; } if (alternate_of != NULL && gs_app_get_bundle_kind (alternate_of) == AS_BUNDLE_KIND_FLATPAK && gs_app_get_scope (alternate_of) != AS_COMPONENT_SCOPE_UNKNOWN && gs_app_get_local_file (alternate_of) != NULL) { g_autoptr(GsApp) app = NULL; GFile *file = gs_app_get_local_file (alternate_of); app = gs_plugin_flatpak_file_to_app (self, file, interactive, alternate_of, cancellable, NULL); if (app != NULL && app != alternate_of) { gs_app_set_local_file (app, file); if (gs_app_get_scope (alternate_of) == AS_COMPONENT_SCOPE_SYSTEM) gs_app_set_scope (app, AS_COMPONENT_SCOPE_USER); else gs_app_set_scope (app, AS_COMPONENT_SCOPE_SYSTEM); /* ensure both are considered */ gs_app_list_add (list, alternate_of); gs_app_list_add (list, app); } } for (guint i = 0; i < self->installations->len; i++) { GsFlatpak *flatpak = g_ptr_array_index (self->installations, i); const gchar * const provides_tag_strv[2] = { provides_tag, NULL }; if (released_since != NULL && !gs_flatpak_add_recent (flatpak, list, age_secs, interactive, cancellable, &local_error)) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } if (is_curated != GS_APP_QUERY_TRISTATE_UNSET && !gs_flatpak_add_popular (flatpak, list, interactive, cancellable, &local_error)) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } if (is_featured != GS_APP_QUERY_TRISTATE_UNSET && !gs_flatpak_add_featured (flatpak, list, interactive, cancellable, &local_error)) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } if (category != NULL && !gs_flatpak_add_category_apps (flatpak, category, list, interactive, cancellable, &local_error)) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } if (is_installed != GS_APP_QUERY_TRISTATE_UNSET && !gs_flatpak_add_installed (flatpak, list, interactive, cancellable, &local_error)) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } if (deployment_featured != NULL && !gs_flatpak_add_deployment_featured (flatpak, list, interactive, deployment_featured, cancellable, &local_error)) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } if (developers != NULL && !gs_flatpak_search_developer_apps (flatpak, developers, list, interactive, cancellable, &local_error)) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } if (keywords != NULL && !gs_flatpak_search (flatpak, keywords, list, interactive, cancellable, &local_error)) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } if (alternate_of != NULL && !gs_flatpak_add_alternates (flatpak, alternate_of, list, interactive, cancellable, &local_error)) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } /* The @provides_type is deliberately ignored here, as flatpak * wants to try and match anything. This could be changed in * future. */ if (provides_tag != NULL && provides_type != GS_APP_QUERY_PROVIDES_UNKNOWN && !gs_flatpak_search (flatpak, provides_tag_strv, list, interactive, cancellable, &local_error)) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } if (is_for_update == GS_APP_QUERY_TRISTATE_TRUE) { g_autoptr(GError) local_error2 = NULL; if (!gs_flatpak_add_updates (flatpak, list, interactive, cancellable, &local_error2)) g_debug ("Failed to get updates for '%s': %s", gs_flatpak_get_id (flatpak), local_error2->message); } if (is_source == GS_APP_QUERY_TRISTATE_TRUE && !gs_flatpak_add_sources (flatpak, list, interactive, cancellable, &local_error)) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } } if (is_for_update == GS_APP_QUERY_TRISTATE_TRUE) gs_plugin_cache_lookup_by_state (GS_PLUGIN (self), list, GS_APP_STATE_INSTALLING); g_task_return_pointer (task, g_steal_pointer (&list), g_object_unref); } static GsAppList * gs_plugin_flatpak_list_apps_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_pointer (G_TASK (result), error); } typedef struct { gboolean interactive; GFile *cache_file; /* (owned) (not nullable) */ } UrlToAppDownloadData; static void url_to_app_download_data_free (UrlToAppDownloadData *data) { g_clear_object (&data->cache_file); g_free (data); } G_DEFINE_AUTOPTR_CLEANUP_FUNC (UrlToAppDownloadData, url_to_app_download_data_free) static void url_to_app_download_cb (GObject *object, GAsyncResult *result, gpointer user_data); static void url_to_app_file_cb (GObject *object, GAsyncResult *result, gpointer user_data); static void url_to_app_thread_cb (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable) { g_autoptr(GsAppList) list = gs_app_list_new (); g_autoptr(GError) local_error = NULL; GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (source_object); GsPluginUrlToAppData *data = task_data; gboolean interactive = (data->flags & GS_PLUGIN_URL_TO_APP_FLAGS_INTERACTIVE) != 0; for (guint i = 0; i < self->installations->len; i++) { GsFlatpak *flatpak = g_ptr_array_index (self->installations, i); if (!gs_flatpak_url_to_app (flatpak, list, data->url, interactive, cancellable, &local_error)) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } } g_task_return_pointer (task, g_steal_pointer (&list), g_object_unref); } static void gs_plugin_flatpak_url_to_app_async (GsPlugin *plugin, const gchar *url, GsPluginUrlToAppFlags flags, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { g_autoptr(GTask) task = NULL; GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (plugin); gboolean interactive = (flags & GS_PLUGIN_URL_TO_APP_FLAGS_INTERACTIVE) != 0; g_autofree char *scheme = NULL; task = gs_plugin_url_to_app_data_new_task (plugin, url, flags, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_flatpak_url_to_app_async); /* Firstly, try and support `flatpak+https` URIs. This needs to be done * at the #GsPluginFlatpak level rather than the #GsFlatpak level, * because we need to hand off to the plugin’s file-to-app code. * * The flatpak+https URI scheme points towards a .flatpakref file which * we can download and then treat like a normal local file. This code * actually also supports the URI pointing at a bundle or a repo file, * since that also seems sensible to support. * * https://gitlab.gnome.org/GNOME/gnome-software/-/issues/2240#note_1787991 */ scheme = gs_utils_get_url_scheme (url); if (g_strcmp0 (scheme, "flatpak+https") == 0) { g_autofree gchar *cache_filename = NULL; g_autoptr(GFile) cache_file = NULL; g_autoptr(SoupSession) soup_session = NULL; g_autoptr(GError) local_error = NULL; g_autoptr(UrlToAppDownloadData) data = NULL; /* Download and cache the file. */ cache_filename = gs_utils_get_cache_filename ("flatpak-downloaded-refs", url, GS_UTILS_CACHE_FLAG_WRITEABLE | GS_UTILS_CACHE_FLAG_CREATE_DIRECTORY, &local_error); if (cache_filename == NULL) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } cache_file = g_file_new_for_path (cache_filename); soup_session = gs_build_soup_session (); if (self->cache_files_to_delete == NULL) self->cache_files_to_delete = g_ptr_array_new_with_free_func ((GDestroyNotify) g_object_unref); g_ptr_array_add (self->cache_files_to_delete, g_object_ref (cache_file)); data = g_new0 (UrlToAppDownloadData, 1); data->interactive = interactive; data->cache_file = g_object_ref (cache_file); g_task_set_task_data (task, g_steal_pointer (&data), (GDestroyNotify) url_to_app_download_data_free); gs_download_file_async (soup_session, url + strlen ("flatpak+"), cache_file, G_PRIORITY_DEFAULT, NULL, NULL, /* progress */ cancellable, url_to_app_download_cb, g_steal_pointer (&task)); } else { /* If it’s not a file we need to download, queue a job to get the apps. */ gs_worker_thread_queue (self->worker, get_priority_for_interactivity (interactive), url_to_app_thread_cb, g_steal_pointer (&task)); } } static void url_to_app_download_cb (GObject *object, GAsyncResult *result, gpointer user_data) { SoupSession *soup_session = SOUP_SESSION (object); g_autoptr(GTask) task = g_steal_pointer (&user_data); GsPluginFlatpak *self = g_task_get_source_object (task); UrlToAppDownloadData *data = g_task_get_task_data (task); GCancellable *cancellable = g_task_get_cancellable (task); g_autoptr(GError) local_error = NULL; if (!gs_download_file_finish (soup_session, result, &local_error) && !g_error_matches (local_error, GS_DOWNLOAD_ERROR, GS_DOWNLOAD_ERROR_NOT_MODIFIED)) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } g_clear_error (&local_error); /* Now load and display the downloaded flatpakref file. */ gs_plugin_flatpak_file_to_app_async (GS_PLUGIN (self), data->cache_file, data->interactive ? GS_PLUGIN_FILE_TO_APP_FLAGS_INTERACTIVE : GS_PLUGIN_FILE_TO_APP_FLAGS_NONE, cancellable, url_to_app_file_cb, g_steal_pointer (&task)); } static void url_to_app_file_cb (GObject *object, GAsyncResult *result, gpointer user_data) { g_autoptr(GTask) task = g_steal_pointer (&user_data); GsPluginFlatpak *self = g_task_get_source_object (task); g_autoptr(GsAppList) list = NULL; g_autoptr(GError) local_error = NULL; list = gs_plugin_flatpak_file_to_app_finish (GS_PLUGIN (self), result, &local_error); if (list != NULL) g_task_return_pointer (task, g_steal_pointer (&list), g_object_unref); else g_task_return_error (task, g_steal_pointer (&local_error)); } static GsAppList * gs_plugin_flatpak_url_to_app_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_pointer (G_TASK (result), error); } static void install_repository_thread_cb (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable); static void gs_plugin_flatpak_install_repository_async (GsPlugin *plugin, GsApp *repository, GsPluginManageRepositoryFlags flags, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (plugin); g_autoptr(GTask) task = NULL; gboolean interactive = (flags & GS_PLUGIN_MANAGE_REPOSITORY_FLAGS_INTERACTIVE); task = gs_plugin_manage_repository_data_new_task (plugin, repository, flags, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_flatpak_install_repository_async); /* only process this app if was created by this plugin */ if (!gs_app_has_management_plugin (repository, plugin)) { g_task_return_boolean (task, TRUE); return; } /* is a source */ g_assert (gs_app_get_kind (repository) == AS_COMPONENT_KIND_REPOSITORY); gs_worker_thread_queue (self->worker, get_priority_for_interactivity (interactive), install_repository_thread_cb, g_steal_pointer (&task)); } /* Run in @worker. */ static void install_repository_thread_cb (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable) { GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (source_object); GsFlatpak *flatpak; GsPluginManageRepositoryData *data = task_data; gboolean interactive = (data->flags & GS_PLUGIN_MANAGE_REPOSITORY_FLAGS_INTERACTIVE); g_autoptr(GError) local_error = NULL; assert_in_worker (self); /* queue for install if installation needs the network */ if (!app_has_local_source (data->repository) && !gs_plugin_get_network_available (GS_PLUGIN (self))) { gs_app_set_state (data->repository, GS_APP_STATE_QUEUED_FOR_INSTALL); g_task_return_boolean (task, TRUE); return; } gs_plugin_flatpak_ensure_scope (GS_PLUGIN (self), data->repository); flatpak = gs_plugin_flatpak_get_handler (self, data->repository); if (flatpak == NULL) { g_task_return_boolean (task, TRUE); return; } if (gs_flatpak_app_install_source (flatpak, data->repository, TRUE, interactive, cancellable, &local_error)) g_task_return_boolean (task, TRUE); else g_task_return_error (task, g_steal_pointer (&local_error)); } static gboolean gs_plugin_flatpak_install_repository_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } static void remove_repository_thread_cb (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable); static void gs_plugin_flatpak_remove_repository_async (GsPlugin *plugin, GsApp *repository, GsPluginManageRepositoryFlags flags, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (plugin); g_autoptr(GTask) task = NULL; gboolean interactive = (flags & GS_PLUGIN_MANAGE_REPOSITORY_FLAGS_INTERACTIVE); task = gs_plugin_manage_repository_data_new_task (plugin, repository, flags, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_flatpak_remove_repository_async); /* only process this app if was created by this plugin */ if (!gs_app_has_management_plugin (repository, plugin)) { g_task_return_boolean (task, TRUE); return; } /* is a source */ g_assert (gs_app_get_kind (repository) == AS_COMPONENT_KIND_REPOSITORY); gs_worker_thread_queue (self->worker, get_priority_for_interactivity (interactive), remove_repository_thread_cb, g_steal_pointer (&task)); } /* Run in @worker. */ static void remove_repository_thread_cb (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable) { GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (source_object); GsFlatpak *flatpak; GsPluginManageRepositoryData *data = task_data; gboolean interactive = (data->flags & GS_PLUGIN_MANAGE_REPOSITORY_FLAGS_INTERACTIVE); g_autoptr(GError) local_error = NULL; assert_in_worker (self); flatpak = gs_plugin_flatpak_get_handler (self, data->repository); if (flatpak == NULL) { g_task_return_boolean (task, TRUE); return; } if (gs_flatpak_app_remove_source (flatpak, data->repository, TRUE, interactive, cancellable, &local_error)) g_task_return_boolean (task, TRUE); else g_task_return_error (task, g_steal_pointer (&local_error)); } static gboolean gs_plugin_flatpak_remove_repository_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } static void enable_repository_thread_cb (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable); static void gs_plugin_flatpak_enable_repository_async (GsPlugin *plugin, GsApp *repository, GsPluginManageRepositoryFlags flags, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (plugin); g_autoptr(GTask) task = NULL; gboolean interactive = (flags & GS_PLUGIN_MANAGE_REPOSITORY_FLAGS_INTERACTIVE); task = gs_plugin_manage_repository_data_new_task (plugin, repository, flags, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_flatpak_enable_repository_async); /* only process this app if was created by this plugin */ if (!gs_app_has_management_plugin (repository, plugin)) { g_task_return_boolean (task, TRUE); return; } /* is a source */ g_assert (gs_app_get_kind (repository) == AS_COMPONENT_KIND_REPOSITORY); gs_worker_thread_queue (self->worker, get_priority_for_interactivity (interactive), enable_repository_thread_cb, g_steal_pointer (&task)); } /* Run in @worker. */ static void enable_repository_thread_cb (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable) { GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (source_object); GsFlatpak *flatpak; GsPluginManageRepositoryData *data = task_data; gboolean interactive = (data->flags & GS_PLUGIN_MANAGE_REPOSITORY_FLAGS_INTERACTIVE); g_autoptr(GError) local_error = NULL; assert_in_worker (self); flatpak = gs_plugin_flatpak_get_handler (self, data->repository); if (flatpak == NULL) { g_task_return_boolean (task, TRUE); return; } if (gs_flatpak_app_install_source (flatpak, data->repository, FALSE, interactive, cancellable, &local_error)) g_task_return_boolean (task, TRUE); else g_task_return_error (task, g_steal_pointer (&local_error)); } static gboolean gs_plugin_flatpak_enable_repository_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } static void disable_repository_thread_cb (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable); static void gs_plugin_flatpak_disable_repository_async (GsPlugin *plugin, GsApp *repository, GsPluginManageRepositoryFlags flags, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (plugin); g_autoptr(GTask) task = NULL; gboolean interactive = (flags & GS_PLUGIN_MANAGE_REPOSITORY_FLAGS_INTERACTIVE); task = gs_plugin_manage_repository_data_new_task (plugin, repository, flags, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_flatpak_disable_repository_async); /* only process this app if was created by this plugin */ if (!gs_app_has_management_plugin (repository, plugin)) { g_task_return_boolean (task, TRUE); return; } /* is a source */ g_assert (gs_app_get_kind (repository) == AS_COMPONENT_KIND_REPOSITORY); gs_worker_thread_queue (self->worker, get_priority_for_interactivity (interactive), disable_repository_thread_cb, g_steal_pointer (&task)); } /* Run in @worker. */ static void disable_repository_thread_cb (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable) { GsPluginFlatpak *self = GS_PLUGIN_FLATPAK (source_object); GsFlatpak *flatpak; GsPluginManageRepositoryData *data = task_data; gboolean interactive = (data->flags & GS_PLUGIN_MANAGE_REPOSITORY_FLAGS_INTERACTIVE); g_autoptr(GError) local_error = NULL; assert_in_worker (self); flatpak = gs_plugin_flatpak_get_handler (self, data->repository); if (flatpak == NULL) { g_task_return_boolean (task, TRUE); return; } if (gs_flatpak_app_remove_source (flatpak, data->repository, FALSE, interactive, cancellable, &local_error)) g_task_return_boolean (task, TRUE); else g_task_return_error (task, g_steal_pointer (&local_error)); } static gboolean gs_plugin_flatpak_disable_repository_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } static void gs_plugin_flatpak_class_init (GsPluginFlatpakClass *klass) { GObjectClass *object_class = G_OBJECT_CLASS (klass); GsPluginClass *plugin_class = GS_PLUGIN_CLASS (klass); object_class->dispose = gs_plugin_flatpak_dispose; plugin_class->setup_async = gs_plugin_flatpak_setup_async; plugin_class->setup_finish = gs_plugin_flatpak_setup_finish; plugin_class->shutdown_async = gs_plugin_flatpak_shutdown_async; plugin_class->shutdown_finish = gs_plugin_flatpak_shutdown_finish; plugin_class->refine_async = gs_plugin_flatpak_refine_async; plugin_class->refine_finish = gs_plugin_flatpak_refine_finish; plugin_class->list_apps_async = gs_plugin_flatpak_list_apps_async; plugin_class->list_apps_finish = gs_plugin_flatpak_list_apps_finish; plugin_class->refresh_metadata_async = gs_plugin_flatpak_refresh_metadata_async; plugin_class->refresh_metadata_finish = gs_plugin_flatpak_refresh_metadata_finish; plugin_class->install_repository_async = gs_plugin_flatpak_install_repository_async; plugin_class->install_repository_finish = gs_plugin_flatpak_install_repository_finish; plugin_class->remove_repository_async = gs_plugin_flatpak_remove_repository_async; plugin_class->remove_repository_finish = gs_plugin_flatpak_remove_repository_finish; plugin_class->enable_repository_async = gs_plugin_flatpak_enable_repository_async; plugin_class->enable_repository_finish = gs_plugin_flatpak_enable_repository_finish; plugin_class->disable_repository_async = gs_plugin_flatpak_disable_repository_async; plugin_class->disable_repository_finish = gs_plugin_flatpak_disable_repository_finish; plugin_class->refine_categories_async = gs_plugin_flatpak_refine_categories_async; plugin_class->refine_categories_finish = gs_plugin_flatpak_refine_categories_finish; plugin_class->install_apps_async = gs_plugin_flatpak_install_apps_async; plugin_class->install_apps_finish = gs_plugin_flatpak_install_apps_finish; plugin_class->uninstall_apps_async = gs_plugin_flatpak_uninstall_apps_async; plugin_class->uninstall_apps_finish = gs_plugin_flatpak_uninstall_apps_finish; plugin_class->update_apps_async = gs_plugin_flatpak_update_apps_async; plugin_class->update_apps_finish = gs_plugin_flatpak_update_apps_finish; plugin_class->launch_async = gs_plugin_flatpak_launch_async; plugin_class->launch_finish = gs_plugin_flatpak_launch_finish; plugin_class->file_to_app_async = gs_plugin_flatpak_file_to_app_async; plugin_class->file_to_app_finish = gs_plugin_flatpak_file_to_app_finish; plugin_class->url_to_app_async = gs_plugin_flatpak_url_to_app_async; plugin_class->url_to_app_finish = gs_plugin_flatpak_url_to_app_finish; } GType gs_plugin_query_type (void) { return GS_TYPE_PLUGIN_FLATPAK; }