/* -*- Mode: C; tab-width: 8; indent-tabs-mode: t; c-basic-offset: 8 -*- * vi:set noexpandtab tabstop=8 shiftwidth=8: * * Copyright (C) 2013-2016 Richard Hughes * Copyright (C) 2014-2018 Kalev Lember * Copyright (C) 2017 Canonical Ltd * Copyright (C) 2013 Matthias Clasen * Copyright (C) 2024 GNOME Foundation, Inc. * * SPDX-License-Identifier: GPL-2.0-or-later */ #include #include #include #include #include #include #include "packagekit-common.h" #include "gs-markdown.h" #include "gs-packagekit-helper.h" #include "gs-packagekit-task.h" #include "gs-plugin-private.h" #include "gs-plugin-packagekit.h" /* * SECTION: * Uses the system PackageKit instance to return installed packages, * sources and the ability to add and remove packages. Supports package history * and converting URIs to apps. * * Supports setting the session proxy on the system PackageKit instance. * * Also supports doing a PackageKit UpdatePackages(ONLY_DOWNLOAD) method on * refresh and also converts any package files to applications the best we can. * * Also supports converting repo filenames to package-ids. * * Also supports marking previously downloaded packages as zero size, and allows * scheduling an offline update. An offline update is when packages are * downloaded in advance, but are then deployed on reboot, when the system is in * a minimally started-up state. This reduces the risk of things crashing as * files are updated. * * See https://github.com/PackageKit/PackageKit/blob/main/docs/offline-updates.txt * and https://www.freedesktop.org/software/systemd/man/latest/systemd.offline-updates.html * for details of how offline updates work. * * Requires: | [source-id], [repos::repo-filename] * Refines: | [source-id], [source], [update-details], [management-plugin] */ #define GS_PLUGIN_PACKAGEKIT_HISTORY_TIMEOUT 5000 /* ms */ /* Timeout to trigger auto-prepare update after the prepared update had been invalidated */ #define PREPARE_UPDATE_TIMEOUT_SECS 30 struct _GsPluginPackagekit { GsPlugin parent; PkControl *control_refine; PkControl *control_proxy; GSettings *settings_proxy; GSettings *settings_http; GSettings *settings_https; GSettings *settings_ftp; GSettings *settings_socks; GFileMonitor *monitor; GFileMonitor *monitor_trigger; GPermission *permission; gboolean is_triggered; GHashTable *prepared_updates; /* (element-type utf8); set of package IDs for updates which are already prepared */ GMutex prepared_updates_mutex; guint prepare_update_timeout_id; GCancellable *proxy_settings_cancellable; /* (nullable) (owned) */ GHashTable *cached_sources; /* (nullable) (owned) (element-type utf8 GsApp); sources by id, each value is weak reffed */ GMutex cached_sources_mutex; }; G_DEFINE_TYPE (GsPluginPackagekit, gs_plugin_packagekit, GS_TYPE_PLUGIN) static void gs_plugin_packagekit_installed_changed_cb (PkControl *control, GsPlugin *plugin); static void gs_plugin_packagekit_updates_changed_cb (PkControl *control, GsPlugin *plugin); static void gs_plugin_packagekit_repo_list_changed_cb (PkControl *control, GsPlugin *plugin); static void gs_plugin_packagekit_refine_history_async (GsPluginPackagekit *self, GsAppList *list, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data); static gboolean gs_plugin_packagekit_refine_history_finish (GsPluginPackagekit *self, GAsyncResult *result, GError **error); static void gs_plugin_packagekit_enable_repository_async (GsPlugin *plugin, GsApp *repository, GsPluginManageRepositoryFlags flags, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data); static gboolean gs_plugin_packagekit_enable_repository_finish (GsPlugin *plugin, GAsyncResult *result, GError **error); static void gs_plugin_packagekit_proxy_changed_cb (GSettings *settings, const gchar *key, gpointer user_data); static void reload_proxy_settings_async (GsPluginPackagekit *self, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data); static gboolean reload_proxy_settings_finish (GsPluginPackagekit *self, GAsyncResult *result, GError **error); static void gs_plugin_packagekit_refine_async (GsPlugin *plugin, GsAppList *list, GsPluginRefineFlags flags, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data); static gboolean gs_plugin_packagekit_refine_finish (GsPlugin *plugin, GAsyncResult *result, GError **error); static void cached_sources_weak_ref_cb (gpointer user_data, GObject *object) { GsPluginPackagekit *self = user_data; GHashTableIter iter; gpointer key, value; g_autoptr(GMutexLocker) locker = NULL; locker = g_mutex_locker_new (&self->cached_sources_mutex); g_assert (self->cached_sources != NULL); g_hash_table_iter_init (&iter, self->cached_sources); while (g_hash_table_iter_next (&iter, &key, &value)) { GObject *repo_object = value; if (repo_object == object) { g_hash_table_iter_remove (&iter); if (!g_hash_table_size (self->cached_sources)) g_clear_pointer (&self->cached_sources, g_hash_table_unref); break; } } } static void gs_plugin_packagekit_init (GsPluginPackagekit *self) { GsPlugin *plugin = GS_PLUGIN (self); /* refine */ self->control_refine = pk_control_new (); g_signal_connect (self->control_refine, "updates-changed", G_CALLBACK (gs_plugin_packagekit_updates_changed_cb), plugin); g_signal_connect (self->control_refine, "repo-list-changed", G_CALLBACK (gs_plugin_packagekit_repo_list_changed_cb), plugin); if (g_signal_lookup ("installed-changed", PK_TYPE_CONTROL) != 0) { g_debug ("Connecting to PkControl::installed-changed signal"); g_signal_connect_object (self->control_refine, "installed-changed", G_CALLBACK (gs_plugin_packagekit_installed_changed_cb), plugin, 0); } /* proxy */ self->control_proxy = pk_control_new (); self->settings_proxy = g_settings_new ("org.gnome.system.proxy"); g_signal_connect (self->settings_proxy, "changed", G_CALLBACK (gs_plugin_packagekit_proxy_changed_cb), self); self->settings_http = g_settings_new ("org.gnome.system.proxy.http"); self->settings_https = g_settings_new ("org.gnome.system.proxy.https"); self->settings_ftp = g_settings_new ("org.gnome.system.proxy.ftp"); self->settings_socks = g_settings_new ("org.gnome.system.proxy.socks"); g_signal_connect (self->settings_http, "changed", G_CALLBACK (gs_plugin_packagekit_proxy_changed_cb), self); g_signal_connect (self->settings_https, "changed", G_CALLBACK (gs_plugin_packagekit_proxy_changed_cb), self); g_signal_connect (self->settings_ftp, "changed", G_CALLBACK (gs_plugin_packagekit_proxy_changed_cb), self); g_signal_connect (self->settings_socks, "changed", G_CALLBACK (gs_plugin_packagekit_proxy_changed_cb), self); /* offline updates */ g_mutex_init (&self->prepared_updates_mutex); self->prepared_updates = g_hash_table_new_full (g_str_hash, g_str_equal, g_free, NULL); g_mutex_init (&self->cached_sources_mutex); /* need pkgname and ID */ gs_plugin_add_rule (plugin, GS_PLUGIN_RULE_RUN_AFTER, "appstream"); /* we can return better results than dpkg directly */ gs_plugin_add_rule (plugin, GS_PLUGIN_RULE_CONFLICTS, "dpkg"); /* need repos::repo-filename */ gs_plugin_add_rule (plugin, GS_PLUGIN_RULE_RUN_AFTER, "repos"); /* generic updates happen after PackageKit offline updates */ gs_plugin_add_rule (plugin, GS_PLUGIN_RULE_RUN_BEFORE, "generic-updates"); } static void gs_plugin_packagekit_dispose (GObject *object) { GsPluginPackagekit *self = GS_PLUGIN_PACKAGEKIT (object); if (self->prepare_update_timeout_id) { g_source_remove (self->prepare_update_timeout_id); self->prepare_update_timeout_id = 0; } g_cancellable_cancel (self->proxy_settings_cancellable); g_clear_object (&self->proxy_settings_cancellable); /* refine */ g_clear_object (&self->control_refine); /* proxy */ g_clear_object (&self->control_proxy); g_clear_object (&self->settings_proxy); g_clear_object (&self->settings_http); g_clear_object (&self->settings_https); g_clear_object (&self->settings_ftp); g_clear_object (&self->settings_socks); /* offline updates */ g_clear_pointer (&self->prepared_updates, g_hash_table_unref); g_clear_object (&self->monitor); g_clear_object (&self->monitor_trigger); if (self->cached_sources != NULL) { GHashTableIter iter; gpointer value; g_hash_table_iter_init (&iter, self->cached_sources); while (g_hash_table_iter_next (&iter, NULL, &value)) { GObject *app_repo = value; g_object_weak_unref (app_repo, cached_sources_weak_ref_cb, self); } g_clear_pointer (&self->cached_sources, g_hash_table_unref); } G_OBJECT_CLASS (gs_plugin_packagekit_parent_class)->dispose (object); } static void gs_plugin_packagekit_finalize (GObject *object) { GsPluginPackagekit *self = GS_PLUGIN_PACKAGEKIT (object); g_mutex_clear (&self->prepared_updates_mutex); g_mutex_clear (&self->cached_sources_mutex); G_OBJECT_CLASS (gs_plugin_packagekit_parent_class)->finalize (object); } static gboolean gs_plugin_packagekit_convert_error (GError **error, PkErrorEnum error_enum, const gchar *details, const gchar *prefix) { switch (error_enum) { case PK_ERROR_ENUM_PACKAGE_DOWNLOAD_FAILED: case PK_ERROR_ENUM_NO_CACHE: case PK_ERROR_ENUM_NO_NETWORK: case PK_ERROR_ENUM_NO_MORE_MIRRORS_TO_TRY: case PK_ERROR_ENUM_CANNOT_FETCH_SOURCES: case PK_ERROR_ENUM_UNFINISHED_TRANSACTION: g_set_error_literal (error, GS_PLUGIN_ERROR, GS_PLUGIN_ERROR_NO_NETWORK, details); break; case PK_ERROR_ENUM_BAD_GPG_SIGNATURE: case PK_ERROR_ENUM_CANNOT_UPDATE_REPO_UNSIGNED: case PK_ERROR_ENUM_GPG_FAILURE: case PK_ERROR_ENUM_MISSING_GPG_SIGNATURE: case PK_ERROR_ENUM_PACKAGE_CORRUPT: g_set_error_literal (error, GS_PLUGIN_ERROR, GS_PLUGIN_ERROR_NO_SECURITY, details); break; case PK_ERROR_ENUM_TRANSACTION_CANCELLED: g_set_error_literal (error, GS_PLUGIN_ERROR, GS_PLUGIN_ERROR_CANCELLED, details); break; case PK_ERROR_ENUM_NO_PACKAGES_TO_UPDATE: case PK_ERROR_ENUM_UPDATE_NOT_FOUND: g_set_error_literal (error, GS_PLUGIN_ERROR, GS_PLUGIN_ERROR_NOT_SUPPORTED, details); break; case PK_ERROR_ENUM_NO_SPACE_ON_DEVICE: g_set_error_literal (error, GS_PLUGIN_ERROR, GS_PLUGIN_ERROR_NO_SPACE, details); break; default: g_set_error_literal (error, GS_PLUGIN_ERROR, GS_PLUGIN_ERROR_FAILED, details); break; } if (prefix != NULL) g_prefix_error_literal (error, prefix); return FALSE; } typedef gboolean (*GsAppFilterFunc) (GsApp *app); static gboolean package_is_installed (const gchar *package_id) { g_auto(GStrv) split = NULL; const gchar *data; split = pk_package_id_split (package_id); if (split == NULL) { return FALSE; } data = split[PK_PACKAGE_ID_DATA]; if (g_str_has_prefix (data, "installed") || g_str_has_prefix (data, "manual:") || g_str_has_prefix (data, "auto:")) { return TRUE; } return FALSE; } /* The elements in the returned #GPtrArray reference memory from within the * @apps list, so the array is only valid as long as @apps is not modified or * freed. The array is not NULL-terminated. * * If @apps is %NULL, that’s considered equivalent to an empty list. */ static GPtrArray * app_list_get_package_ids (GsAppList *apps, GsAppFilterFunc app_filter, gboolean ignore_installed) { g_autoptr(GPtrArray) list_package_ids = g_ptr_array_new_with_free_func (NULL); for (guint i = 0; apps != NULL && i < gs_app_list_length (apps); i++) { GsApp *app = gs_app_list_index (apps, i); GPtrArray *app_source_ids; if (app_filter != NULL && !app_filter (app)) continue; app_source_ids = gs_app_get_source_ids (app); for (guint j = 0; j < app_source_ids->len; j++) { const gchar *package_id = g_ptr_array_index (app_source_ids, j); if (ignore_installed && package_is_installed (package_id)) continue; g_ptr_array_add (list_package_ids, (gchar *) package_id); } } return g_steal_pointer (&list_package_ids); } static GsApp * gs_plugin_packagekit_dup_app_origin_repo (GsPluginPackagekit *self, GsApp *app, GError **error) { GsPlugin *plugin = GS_PLUGIN (self); g_autoptr(GMutexLocker) locker = NULL; g_autoptr(GTask) task = NULL; g_autoptr(GsApp) repo_app = NULL; const gchar *repo_id; repo_id = gs_app_get_origin (app); if (repo_id == NULL) { g_set_error_literal (error, GS_PLUGIN_ERROR, GS_PLUGIN_ERROR_NOT_SUPPORTED, "origin not set"); return NULL; } locker = g_mutex_locker_new (&self->cached_sources_mutex); repo_app = g_hash_table_lookup (self->cached_sources, repo_id); if (repo_app != NULL) { g_object_ref (repo_app); } else { repo_app = gs_app_new (repo_id); gs_app_set_management_plugin (repo_app, plugin); gs_app_set_kind (repo_app, AS_COMPONENT_KIND_REPOSITORY); gs_app_set_bundle_kind (repo_app, AS_BUNDLE_KIND_PACKAGE); gs_app_set_scope (repo_app, AS_COMPONENT_SCOPE_SYSTEM); gs_app_add_quirk (repo_app, GS_APP_QUIRK_NOT_LAUNCHABLE); gs_plugin_packagekit_set_packaging_format (plugin, repo_app); } g_clear_pointer (&locker, g_mutex_locker_free); return g_steal_pointer (&repo_app); } typedef struct { /* Input data. */ GsAppList *apps; /* (owned) (not nullable) */ GsPluginInstallAppsFlags flags; GsPluginProgressCallback progress_callback; gpointer progress_user_data; /* In-progress data. */ guint n_pending_enable_repo_ops; guint n_pending_install_ops; GError *saved_enable_repo_error; /* (owned) (nullable) */ GError *saved_install_error; /* (owned) (nullable) */ GsAppList *remote_apps_to_install; /* (owned) (nullable) */ GsAppList *local_apps_to_install; /* (owned) (nullable) */ GsPackagekitHelper *progress_data; /* (owned) (nullable) */ } InstallAppsData; static void install_apps_data_free (InstallAppsData *data) { g_clear_object (&data->apps); g_clear_object (&data->remote_apps_to_install); g_clear_object (&data->local_apps_to_install); g_clear_object (&data->progress_data); /* Error should have been propagated by now, and all pending ops completed. */ g_assert (data->saved_enable_repo_error == NULL); g_assert (data->saved_install_error == NULL); g_assert (data->n_pending_enable_repo_ops == 0); g_assert (data->n_pending_install_ops == 0); g_free (data); } G_DEFINE_AUTOPTR_CLEANUP_FUNC (InstallAppsData, install_apps_data_free) static void finish_install_apps_enable_repo_op (GTask *task, GError *error); static void install_apps_enable_repo_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void install_apps_remote_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void install_apps_local_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void finish_install_apps_install_op (GTask *task, GError *error); static void gs_plugin_packagekit_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) { GsPluginPackagekit *self = GS_PLUGIN_PACKAGEKIT (plugin); g_autoptr(GTask) task = NULL; InstallAppsData *data; g_autoptr(InstallAppsData) data_owned = NULL; gboolean interactive = (flags & GS_PLUGIN_INSTALL_APPS_FLAGS_INTERACTIVE); g_autoptr(GHashTable) repos = NULL; GHashTableIter iter; gpointer value; g_autoptr(GError) local_error = NULL; task = g_task_new (self, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_packagekit_install_apps_async); data = data_owned = g_new0 (InstallAppsData, 1); data->flags = flags; data->progress_callback = progress_callback; data->progress_user_data = progress_user_data; data->apps = g_object_ref (apps); g_task_set_task_data (task, g_steal_pointer (&data_owned), (GDestroyNotify) install_apps_data_free); /* Start a load of operations in parallel to install the apps, in the * following structure: * * gs_plugin_packagekit_install_apps_async * | * /--------+------------------------------------+--------------------------\ * v v v * gs_plugin_packagekit_enable_repository_async gs_plugin_packagekit_enable_repository_async … * | | | * \--------+------------------------------------+--------------------------/ * | * /--------------+----------------\ * | | * v v * pk_task_install_packages_async pk_task_install_files_async * | | * \--------------+----------------/ * | * v * finish_install_apps_install_op * * When all installs are finished for all apps, * finish_install_apps_install_op() will return success/error for the * overall #GTask. * * FIXME: Tie @progress_callback to number of completed operations. */ data->n_pending_enable_repo_ops = 1; /* Firstly, find all the apps which need their origin repo to be enabled * first, deduplicate the repos and enable them. */ repos = g_hash_table_new_full (g_str_hash, g_str_equal, NULL, g_object_unref); for (guint i = 0; i < gs_app_list_length (apps); i++) { GsApp *app = gs_app_list_index (apps, i); /* only process this app if was created by this plugin */ if (!gs_app_has_management_plugin (app, GS_PLUGIN (self))) continue; /* enable repo, handled by dedicated function */ g_assert (gs_app_get_kind (app) != AS_COMPONENT_KIND_REPOSITORY); if (gs_app_get_state (app) == GS_APP_STATE_UNAVAILABLE) { g_autoptr(GsApp) repo_app = NULL; const gchar *repo_app_id; repo_app = gs_plugin_packagekit_dup_app_origin_repo (self, app, &local_error); if (repo_app == NULL) { finish_install_apps_enable_repo_op (task, g_steal_pointer (&local_error)); return; } gs_plugin_status_update (plugin, app, GS_PLUGIN_STATUS_WAITING); repo_app_id = gs_app_get_id (repo_app); g_hash_table_replace (repos, (gpointer) repo_app_id, g_steal_pointer (&repo_app)); } } /* Enable the repos. */ g_hash_table_iter_init (&iter, repos); while (g_hash_table_iter_next (&iter, NULL, &value)) { GsApp *repo_app = value; data->n_pending_enable_repo_ops++; gs_plugin_packagekit_enable_repository_async (plugin, repo_app, interactive ? GS_PLUGIN_MANAGE_REPOSITORY_FLAGS_INTERACTIVE : GS_PLUGIN_MANAGE_REPOSITORY_FLAGS_NONE, cancellable, install_apps_enable_repo_cb, g_object_ref (task)); } finish_install_apps_enable_repo_op (task, NULL); } static void install_apps_enable_repo_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { GsPluginPackagekit *self = GS_PLUGIN_PACKAGEKIT (source_object); g_autoptr(GTask) task = g_steal_pointer (&user_data); g_autoptr(GError) local_error = NULL; gs_plugin_packagekit_enable_repository_finish (GS_PLUGIN (self), result, &local_error); finish_install_apps_enable_repo_op (task, g_steal_pointer (&local_error)); } /* @error is (transfer full) if non-%NULL */ static void finish_install_apps_enable_repo_op (GTask *task, GError *error) { GsPluginPackagekit *self = g_task_get_source_object (task); GCancellable *cancellable = g_task_get_cancellable (task); InstallAppsData *data = g_task_get_task_data (task); gboolean interactive = (data->flags & GS_PLUGIN_INSTALL_APPS_FLAGS_INTERACTIVE); g_autoptr(GError) error_owned = g_steal_pointer (&error); g_autoptr(GPtrArray) overall_remote_package_ids = NULL; g_autoptr(GPtrArray) overall_local_package_ids = NULL; g_autoptr(PkTask) task_install = NULL; g_autoptr(GError) local_error = NULL; if (error_owned != NULL && data->saved_enable_repo_error == NULL) data->saved_enable_repo_error = g_steal_pointer (&error_owned); else if (error_owned != NULL) g_debug ("Additional error while enabling repos to install apps: %s", error_owned->message); g_assert (data->n_pending_enable_repo_ops > 0); data->n_pending_enable_repo_ops--; if (data->n_pending_enable_repo_ops > 0) return; /* If enabling any repos failed, abandon the entire operation. * Otherwise, carry on to installing apps. */ if (data->saved_enable_repo_error != NULL) { g_autoptr(GsPluginEvent) event = NULL; event = gs_plugin_event_new ("error", data->saved_enable_repo_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_task_return_boolean (task, TRUE); return; } overall_remote_package_ids = g_ptr_array_new_with_free_func (NULL); overall_local_package_ids = g_ptr_array_new_with_free_func (g_free); data->remote_apps_to_install = gs_app_list_new (); data->local_apps_to_install = gs_app_list_new (); /* Mark all the unavailable apps as available, now that their repos * are enabled. */ for (guint i = 0; i < gs_app_list_length (data->apps); i++) { GsApp *app = gs_app_list_index (data->apps, i); /* only process this app if was created by this plugin */ if (!gs_app_has_management_plugin (app, GS_PLUGIN (self))) continue; if (gs_app_get_state (app) == GS_APP_STATE_UNAVAILABLE) gs_app_set_state (app, GS_APP_STATE_AVAILABLE); } /* Next, group the apps into those which need internet to install, * and those which can be installed locally, and grab their package * IDs ready to pass to PackageKit. */ for (guint i = 0; i < gs_app_list_length (data->apps); i++) { GsApp *app = gs_app_list_index (data->apps, i); /* only process this app if was created by this plugin */ if (!gs_app_has_management_plugin (app, GS_PLUGIN (self))) continue; /* queue for install if installation needs the network */ if (!gs_plugin_get_network_available (GS_PLUGIN (self)) && gs_app_get_state (app) != GS_APP_STATE_AVAILABLE_LOCAL) { gs_app_set_state (app, GS_APP_STATE_QUEUED_FOR_INSTALL); continue; } switch (gs_app_get_state (app)) { case GS_APP_STATE_AVAILABLE: case GS_APP_STATE_UPDATABLE: case GS_APP_STATE_QUEUED_FOR_INSTALL: { GPtrArray *source_ids; g_autoptr(GsAppList) addons = NULL; g_autoptr(GPtrArray) array_package_ids = NULL; source_ids = gs_app_get_source_ids (app); if (source_ids->len == 0) { g_autoptr(GsPluginEvent) event = NULL; g_set_error_literal (&local_error, GS_PLUGIN_ERROR, GS_PLUGIN_ERROR_NOT_SUPPORTED, "installing not available"); 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; } addons = gs_app_dup_addons (app); array_package_ids = app_list_get_package_ids (addons, gs_app_get_to_be_installed, TRUE); for (guint j = 0; j < source_ids->len; j++) { const gchar *package_id = g_ptr_array_index (source_ids, j); if (package_is_installed (package_id)) continue; g_ptr_array_add (array_package_ids, (gpointer) package_id); } if (array_package_ids->len == 0) { g_autoptr(GsPluginEvent) event = NULL; g_set_error_literal (&local_error, GS_PLUGIN_ERROR, GS_PLUGIN_ERROR_NOT_SUPPORTED, "no packages to install"); 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); continue; } /* Add to the big array. */ g_ptr_array_extend_and_steal (overall_remote_package_ids, g_steal_pointer (&array_package_ids)); for (guint j = 0; addons != NULL && j < gs_app_list_length (addons); j++) { GsApp *addon = gs_app_list_index (addons, j); if (gs_app_get_to_be_installed (addon)) gs_app_list_add (data->remote_apps_to_install, addon); } gs_app_list_add (data->remote_apps_to_install, app); break; } case GS_APP_STATE_AVAILABLE_LOCAL: { g_autofree gchar *local_filename = NULL; g_auto(GStrv) package_ids = NULL; if (gs_app_get_local_file (app) == NULL) { g_autoptr(GsPluginEvent) event = NULL; g_set_error_literal (&local_error, GS_PLUGIN_ERROR, GS_PLUGIN_ERROR_NOT_SUPPORTED, "local package, but no filename"); 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; } local_filename = g_file_get_path (gs_app_get_local_file (app)); package_ids = g_strsplit (local_filename, "\t", -1); /* Add to the big array. */ for (gsize j = 0; package_ids[j] != NULL; j++) g_ptr_array_add (overall_local_package_ids, g_steal_pointer (&package_ids[j])); gs_app_list_add (data->local_apps_to_install, app); break; } default: { g_autoptr(GsPluginEvent) event = NULL; g_set_error (&local_error, GS_PLUGIN_ERROR, GS_PLUGIN_ERROR_NOT_SUPPORTED, "do not know how to install app in state %s", gs_app_state_to_string (gs_app_get_state (app))); 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; } } } /* Set up a #PkTask to handle the D-Bus calls to packagekitd. */ data->progress_data = gs_packagekit_helper_new (GS_PLUGIN (self)); task_install = gs_packagekit_task_new (GS_PLUGIN (self)); gs_packagekit_task_setup (GS_PACKAGEKIT_TASK (task_install), GS_PACKAGEKIT_TASK_QUESTION_TYPE_INSTALL, interactive); data->n_pending_install_ops = 1; /* to track setup */ /* Install the remote packages. */ if (overall_remote_package_ids->len > 0 && !(data->flags & GS_PLUGIN_INSTALL_APPS_FLAGS_NO_DOWNLOAD) && !(data->flags & GS_PLUGIN_INSTALL_APPS_FLAGS_NO_APPLY)) { /* NULL-terminate the array. */ g_ptr_array_add (overall_remote_package_ids, NULL); /* Update the app’s and its addons‘ states. */ for (guint i = 0; i < gs_app_list_length (data->remote_apps_to_install); i++) { GsApp *app = gs_app_list_index (data->remote_apps_to_install, i); gs_app_set_state (app, GS_APP_STATE_INSTALLING); gs_packagekit_helper_add_app (data->progress_data, app); } data->n_pending_install_ops++; pk_task_install_packages_async (task_install, (gchar **) overall_remote_package_ids->pdata, cancellable, gs_packagekit_helper_cb, data->progress_data, install_apps_remote_cb, g_object_ref (task)); } /* And, in parallel, install the local packages. */ if (overall_local_package_ids->len > 0 && !(data->flags & GS_PLUGIN_INSTALL_APPS_FLAGS_NO_APPLY)) { /* NULL-terminate the array. */ g_ptr_array_add (overall_local_package_ids, NULL); /* Update the apps’ states. */ for (guint i = 0; i < gs_app_list_length (data->local_apps_to_install); i++) { GsApp *app = gs_app_list_index (data->local_apps_to_install, i); gs_app_set_state (app, GS_APP_STATE_INSTALLING); gs_packagekit_helper_add_app (data->progress_data, app); } data->n_pending_install_ops++; pk_task_install_files_async (task_install, (gchar **) overall_local_package_ids->pdata, cancellable, gs_packagekit_helper_cb, data->progress_data, install_apps_local_cb, g_object_ref (task)); } finish_install_apps_install_op (task, NULL); } static void install_apps_remote_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { PkTask *task_install = PK_TASK (source_object); g_autoptr(GTask) task = g_steal_pointer (&user_data); GsPluginPackagekit *self = g_task_get_source_object (task); GCancellable *cancellable = g_task_get_cancellable (task); InstallAppsData *data = g_task_get_task_data (task); gboolean interactive = (data->flags & GS_PLUGIN_INSTALL_APPS_FLAGS_INTERACTIVE); g_autoptr(PkResults) results = NULL; g_autoptr(GError) local_error = NULL; results = pk_task_generic_finish (task_install, result, &local_error); if (!gs_plugin_packagekit_results_valid (results, cancellable, &local_error)) { g_autoptr(GsPluginEvent) event = NULL; for (guint i = 0; i < gs_app_list_length (data->remote_apps_to_install); i++) { GsApp *app = gs_app_list_index (data->remote_apps_to_install, i); gs_app_set_state_recover (app); } gs_plugin_packagekit_error_convert (&local_error, cancellable); 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); finish_install_apps_install_op (task, g_steal_pointer (&local_error)); return; } for (guint i = 0; i < gs_app_list_length (data->remote_apps_to_install); i++) { GsApp *app = gs_app_list_index (data->remote_apps_to_install, i); gs_app_set_state (app, GS_APP_STATE_INSTALLED); /* no longer valid */ gs_app_clear_source_ids (app); } finish_install_apps_install_op (task, NULL); } static void install_apps_local_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { PkTask *task_install = PK_TASK (source_object); g_autoptr(GTask) task = g_steal_pointer (&user_data); GsPluginPackagekit *self = g_task_get_source_object (task); GCancellable *cancellable = g_task_get_cancellable (task); InstallAppsData *data = g_task_get_task_data (task); gboolean interactive = (data->flags & GS_PLUGIN_INSTALL_APPS_FLAGS_INTERACTIVE); g_autoptr(PkResults) results = NULL; g_autoptr(GError) local_error = NULL; results = pk_task_generic_finish (task_install, result, &local_error); if (!gs_plugin_packagekit_results_valid (results, cancellable, &local_error)) { g_autoptr(GsPluginEvent) event = NULL; for (guint i = 0; i < gs_app_list_length (data->local_apps_to_install); i++) { GsApp *app = gs_app_list_index (data->local_apps_to_install, i); gs_app_set_state_recover (app); } gs_plugin_packagekit_error_convert (&local_error, cancellable); 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); finish_install_apps_install_op (task, g_steal_pointer (&local_error)); return; } for (guint i = 0; i < gs_app_list_length (data->local_apps_to_install); i++) { GsApp *app = gs_app_list_index (data->local_apps_to_install, i); /* state is known */ gs_app_set_state (app, GS_APP_STATE_INSTALLED); /* get the new icon from the package */ gs_app_set_local_file (app, NULL); gs_app_remove_all_icons (app); /* no longer valid */ gs_app_clear_source_ids (app); } finish_install_apps_install_op (task, NULL); } /* @error is (transfer full) if non-%NULL */ static void finish_install_apps_install_op (GTask *task, GError *error) { InstallAppsData *data = g_task_get_task_data (task); g_autoptr(GError) error_owned = g_steal_pointer (&error); if (error_owned != NULL && data->saved_install_error == NULL) data->saved_install_error = g_steal_pointer (&error_owned); else if (error_owned != NULL) g_debug ("Additional error while installing apps: %s", error_owned->message); g_assert (data->n_pending_install_ops > 0); data->n_pending_install_ops--; if (data->n_pending_install_ops > 0) return; /* Get the results of the parallel ops. */ if (data->saved_install_error != NULL) g_task_return_error (task, g_steal_pointer (&data->saved_install_error)); else g_task_return_boolean (task, TRUE); } static gboolean gs_plugin_packagekit_install_apps_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } typedef struct { /* Input data. */ GsAppList *apps; /* (owned) (not nullable) */ GsPluginUninstallAppsFlags flags; GsPluginProgressCallback progress_callback; gpointer progress_user_data; /* In-progress data. */ GsAppList *apps_to_uninstall; /* (owned) (nullable) */ GsPackagekitHelper *progress_data; /* (owned) (nullable) */ } UninstallAppsData; static void uninstall_apps_data_free (UninstallAppsData *data) { g_clear_object (&data->apps); g_clear_object (&data->apps_to_uninstall); g_clear_object (&data->progress_data); g_free (data); } G_DEFINE_AUTOPTR_CLEANUP_FUNC (UninstallAppsData, uninstall_apps_data_free) static void uninstall_apps_remove_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void uninstall_apps_refine_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void gs_plugin_packagekit_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) { GsPluginPackagekit *self = GS_PLUGIN_PACKAGEKIT (plugin); g_autoptr(GTask) task = NULL; UninstallAppsData *data; g_autoptr(UninstallAppsData) data_owned = NULL; gboolean interactive = (flags & GS_PLUGIN_UNINSTALL_APPS_FLAGS_INTERACTIVE); g_autoptr(GPtrArray) overall_package_ids = NULL; g_autoptr(PkTask) task_uninstall = NULL; g_autoptr(GError) local_error = NULL; task = g_task_new (self, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_packagekit_uninstall_apps_async); data = data_owned = g_new0 (UninstallAppsData, 1); data->flags = flags; data->progress_callback = progress_callback; data->progress_user_data = progress_user_data; data->apps = g_object_ref (apps); g_task_set_task_data (task, g_steal_pointer (&data_owned), (GDestroyNotify) uninstall_apps_data_free); overall_package_ids = g_ptr_array_new_with_free_func (NULL); data->apps_to_uninstall = gs_app_list_new (); /* Grab the package IDs from the apps ready to pass to PackageKit. */ for (guint i = 0; i < gs_app_list_length (data->apps); i++) { GsApp *app = gs_app_list_index (data->apps, i); GPtrArray *source_ids; g_autoptr(GPtrArray) array_package_ids = NULL; /* only process this app if was created by this plugin */ if (!gs_app_has_management_plugin (app, GS_PLUGIN (self))) continue; /* disable repo, handled by dedicated function */ g_assert (gs_app_get_kind (app) != AS_COMPONENT_KIND_REPOSITORY); source_ids = gs_app_get_source_ids (app); if (source_ids->len == 0) { g_autoptr(GsPluginEvent) event = NULL; g_set_error_literal (&local_error, GS_PLUGIN_ERROR, GS_PLUGIN_ERROR_NOT_SUPPORTED, "uninstalling not available"); 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; } array_package_ids = g_ptr_array_new_with_free_func (NULL); for (guint j = 0; j < source_ids->len; j++) { const gchar *package_id = g_ptr_array_index (source_ids, j); if (!package_is_installed (package_id)) continue; g_ptr_array_add (array_package_ids, (gpointer) package_id); } if (array_package_ids->len == 0) { g_autoptr(GsPluginEvent) event = NULL; g_set_error_literal (&local_error, GS_PLUGIN_ERROR, GS_PLUGIN_ERROR_NOT_SUPPORTED, "no packages to uninstall"); 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; } /* Add to the big array. */ g_ptr_array_extend_and_steal (overall_package_ids, g_steal_pointer (&array_package_ids)); gs_app_list_add (data->apps_to_uninstall, app); } if (overall_package_ids->len == 0) { g_task_return_boolean (task, TRUE); return; } /* NULL-terminate the array. */ g_ptr_array_add (overall_package_ids, NULL); /* Set up a #PkTask to handle the D-Bus calls to packagekitd. * FIXME: Tie @progress_callback to number of completed operations. */ data->progress_data = gs_packagekit_helper_new (GS_PLUGIN (self)); task_uninstall = gs_packagekit_task_new (GS_PLUGIN (self)); gs_packagekit_task_setup (GS_PACKAGEKIT_TASK (task_uninstall), GS_PACKAGEKIT_TASK_QUESTION_TYPE_NONE, interactive); /* Update the app’s and its addons‘ states. */ for (guint i = 0; i < gs_app_list_length (data->apps_to_uninstall); i++) { GsApp *app = gs_app_list_index (data->apps_to_uninstall, i); gs_app_set_state (app, GS_APP_STATE_REMOVING); gs_packagekit_helper_add_app (data->progress_data, app); } /* Uninstall the packages. */ pk_task_remove_packages_async (task_uninstall, (gchar **) overall_package_ids->pdata, TRUE /* allow_deps */, GS_PACKAGEKIT_AUTOREMOVE, cancellable, gs_packagekit_helper_cb, data->progress_data, uninstall_apps_remove_cb, g_steal_pointer (&task)); } static void uninstall_apps_remove_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { PkTask *task_uninstall = PK_TASK (source_object); g_autoptr(GTask) task = g_steal_pointer (&user_data); GsPluginPackagekit *self = g_task_get_source_object (task); GCancellable *cancellable = g_task_get_cancellable (task); UninstallAppsData *data = g_task_get_task_data (task); gboolean interactive = (data->flags & GS_PLUGIN_UNINSTALL_APPS_FLAGS_INTERACTIVE); g_autoptr(PkResults) results = NULL; g_autoptr(GError) local_error = NULL; results = pk_task_generic_finish (task_uninstall, result, &local_error); if (!gs_plugin_packagekit_results_valid (results, cancellable, &local_error)) { g_autoptr(GsPluginEvent) event = NULL; for (guint i = 0; i < gs_app_list_length (data->apps_to_uninstall); i++) { GsApp *app = gs_app_list_index (data->apps_to_uninstall, i); gs_app_set_state_recover (app); } gs_plugin_packagekit_error_convert (&local_error, cancellable); 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); g_task_return_boolean (task, TRUE); return; } for (guint i = 0; i < gs_app_list_length (data->apps_to_uninstall); i++) { GsApp *app = gs_app_list_index (data->apps_to_uninstall, i); g_autoptr(GsAppList) addons = NULL; /* Make sure addons' state is updated as well */ addons = gs_app_dup_addons (app); for (guint j = 0; addons != NULL && j < gs_app_list_length (addons); j++) { GsApp *addon = gs_app_list_index (addons, j); if (gs_app_get_state (addon) == GS_APP_STATE_INSTALLED) { gs_app_set_state (addon, GS_APP_STATE_UNKNOWN); gs_app_clear_source_ids (addon); } } /* state is not known: we don't know if we can re-install this app */ gs_app_set_state (app, GS_APP_STATE_UNKNOWN); /* no longer valid */ gs_app_clear_source_ids (app); } /* Refine the apps so their state is up to date again. */ gs_plugin_packagekit_refine_async (GS_PLUGIN (self), data->apps_to_uninstall, GS_PLUGIN_REFINE_FLAGS_REQUIRE_ORIGIN | GS_PLUGIN_REFINE_FLAGS_REQUIRE_SETUP_ACTION, cancellable, uninstall_apps_refine_cb, g_steal_pointer (&task)); } static void uninstall_apps_refine_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { g_autoptr(GTask) task = g_steal_pointer (&user_data); GsPluginPackagekit *self = g_task_get_source_object (task); GCancellable *cancellable = g_task_get_cancellable (task); g_autoptr(GError) local_error = NULL; if (!gs_plugin_packagekit_refine_finish (GS_PLUGIN (self), result, &local_error)) { gs_plugin_packagekit_error_convert (&local_error, cancellable); g_debug ("Error refining apps after uninstall: %s", local_error->message); g_clear_error (&local_error); } g_task_return_boolean (task, TRUE); } static gboolean gs_plugin_packagekit_uninstall_apps_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } static void gs_plugin_packagekit_set_update_app_state (GsApp *app, PkPackage *package) { #if PK_CHECK_VERSION(1, 3, 0) if (pk_package_get_info (package) == PK_INFO_ENUM_REMOVE || pk_package_get_info (package) == PK_INFO_ENUM_REMOVING || pk_package_get_info (package) == PK_INFO_ENUM_OBSOLETE || pk_package_get_info (package) == PK_INFO_ENUM_OBSOLETING) { gs_app_set_state (app, GS_APP_STATE_INSTALLED); } else if (pk_package_get_info (package) == PK_INFO_ENUM_INSTALL || pk_package_get_info (package) == PK_INFO_ENUM_INSTALLING) { gs_app_set_state (app, GS_APP_STATE_AVAILABLE); } else { gs_app_set_state (app, GS_APP_STATE_UPDATABLE); } #else if (pk_package_get_info (package) == PK_INFO_ENUM_REMOVING || pk_package_get_info (package) == PK_INFO_ENUM_OBSOLETING) { gs_app_set_state (app, GS_APP_STATE_INSTALLED); } else if (pk_package_get_info (package) == PK_INFO_ENUM_INSTALLING) { gs_app_set_state (app, GS_APP_STATE_AVAILABLE); } else { gs_app_set_state (app, GS_APP_STATE_UPDATABLE); } #endif } static GsApp * gs_plugin_packagekit_build_update_app (GsPlugin *plugin, PkPackage *package) { GsApp *app = gs_plugin_cache_lookup (plugin, pk_package_get_id (package)); if (app != NULL) { if (gs_app_get_state (app) == GS_APP_STATE_UNKNOWN) gs_plugin_packagekit_set_update_app_state (app, package); return app; } app = gs_app_new (NULL); gs_plugin_packagekit_set_packaging_format (plugin, app); gs_app_add_source (app, pk_package_get_name (package)); gs_app_add_source_id (app, pk_package_get_id (package)); gs_plugin_packagekit_set_package_name (app, package); gs_app_set_name (app, GS_APP_QUALITY_LOWEST, pk_package_get_name (package)); gs_app_set_summary (app, GS_APP_QUALITY_LOWEST, pk_package_get_summary (package)); gs_app_set_metadata (app, "GnomeSoftware::Creator", gs_plugin_get_name (plugin)); gs_app_set_management_plugin (app, plugin); gs_app_set_update_version (app, pk_package_get_version (package)); gs_app_set_kind (app, AS_COMPONENT_KIND_GENERIC); gs_app_set_scope (app, AS_COMPONENT_SCOPE_SYSTEM); gs_app_set_bundle_kind (app, AS_BUNDLE_KIND_PACKAGE); gs_plugin_packagekit_set_update_app_state (app, package); gs_plugin_cache_add (plugin, pk_package_get_id (package), app); return app; } static gboolean gs_plugin_package_list_updates_process_results (GsPlugin *plugin, PkResults *results, GsAppList *list, GCancellable *cancellable, GError **error) { g_autoptr(GPtrArray) array = NULL; g_autoptr(GsApp) first_app = NULL; gboolean all_downloaded = TRUE; if (!gs_plugin_packagekit_results_valid (results, cancellable, error)) return FALSE; /* add results */ array = pk_results_get_package_array (results); for (guint i = 0; i < array->len; i++) { PkPackage *package = g_ptr_array_index (array, i); g_autoptr(GsApp) app = NULL; guint64 size_download_bytes; if (pk_package_get_info (package) == PK_INFO_ENUM_BLOCKED) { g_debug ("Skipping blocked '%s' in list of packages to update", pk_package_get_id (package)); continue; } app = gs_plugin_packagekit_build_update_app (plugin, package); all_downloaded = (all_downloaded && gs_app_get_size_download (app, &size_download_bytes) == GS_SIZE_TYPE_VALID && size_download_bytes == 0); if (all_downloaded && first_app == NULL) first_app = g_object_ref (app); gs_app_list_add (list, app); } /* Having all packages downloaded doesn't mean the update is also prepared, because the 'prepared-update' file can be missing, thus verify it and if not found, then set one application as needed download, to have the update properly prepared. */ if (all_downloaded && first_app != NULL) { g_auto(GStrv) prepared_ids = NULL; /* It's an overhead to get all the package IDs, but there's no easier way to verify the prepared-update file exists. */ prepared_ids = pk_offline_get_prepared_ids (NULL); if (prepared_ids == NULL || prepared_ids[0] == NULL) gs_app_set_size_download (first_app, GS_SIZE_TYPE_VALID, 1); } return TRUE; } static gboolean gs_plugin_packagekit_add_updates (GsPlugin *plugin, GsAppList *list, GCancellable *cancellable, GError **error) { g_autoptr(GsPackagekitHelper) helper = gs_packagekit_helper_new (plugin); g_autoptr(PkTask) task_updates = NULL; g_autoptr(PkResults) results = NULL; /* do sync call */ gs_plugin_status_update (plugin, NULL, GS_PLUGIN_STATUS_WAITING); task_updates = gs_packagekit_task_new (plugin); gs_packagekit_task_setup (GS_PACKAGEKIT_TASK (task_updates), GS_PACKAGEKIT_TASK_QUESTION_TYPE_NONE, gs_plugin_has_flags (plugin, GS_PLUGIN_FLAGS_INTERACTIVE)); gs_packagekit_helper_set_allow_emit_updates_changed (helper, FALSE); results = pk_client_get_updates (PK_CLIENT (task_updates), pk_bitfield_value (PK_FILTER_ENUM_NONE), cancellable, gs_packagekit_helper_cb, helper, error); return gs_plugin_package_list_updates_process_results (plugin, results, list, cancellable, error); } static void gs_packagekit_list_updates_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { g_autoptr(GTask) task = user_data; g_autoptr(GsAppList) list = gs_app_list_new (); g_autoptr(PkResults) results = NULL; g_autoptr(GError) local_error = NULL; results = pk_client_generic_finish (PK_CLIENT (source_object), result, &local_error); if (!gs_plugin_package_list_updates_process_results (GS_PLUGIN (g_task_get_source_object (task)), results, list, g_task_get_cancellable (task), &local_error)) { g_debug ("Failed to get updates: %s", local_error->message); } /* only log about the errors, do not propagate them to the caller */ g_task_return_pointer (task, g_steal_pointer (&list), g_object_unref); } static gboolean gs_packagekit_add_historical_updates_sync (GsPlugin *plugin, GsAppList *list, GCancellable *cancellable, GError **error) { guint64 mtime; guint i; g_autoptr(GPtrArray) package_array = NULL; g_autoptr(GError) error_local = NULL; g_autoptr(GSettings) settings = NULL; g_autoptr(PkResults) results = NULL; gboolean is_new_result; PkExitEnum exit_code; /* get the results */ results = pk_offline_get_results (&error_local); if (results == NULL) { /* was any offline update attempted */ if (g_error_matches (error_local, PK_OFFLINE_ERROR, PK_OFFLINE_ERROR_NO_DATA)) { return TRUE; } gs_plugin_packagekit_error_convert (&error_local, cancellable); g_set_error (error, GS_PLUGIN_ERROR, GS_PLUGIN_ERROR_INVALID_FORMAT, "Failed to get offline update results: %s", error_local->message); return FALSE; } /* get the mtime of the results */ mtime = pk_offline_get_results_mtime (error); if (mtime == 0) { gs_plugin_packagekit_error_convert (error, cancellable); return FALSE; } settings = g_settings_new ("org.gnome.software"); /* Two seconds precision */ is_new_result = mtime > g_settings_get_uint64 (settings, "packagekit-historical-updates-timestamp") + 2; if (is_new_result) g_settings_set_uint64 (settings, "packagekit-historical-updates-timestamp", mtime); /* only return results if successful */ exit_code = pk_results_get_exit_code (results); if (exit_code != PK_EXIT_ENUM_SUCCESS) { g_autoptr(PkError) error_code = NULL; error_code = pk_results_get_error_code (results); if (error_code == NULL) { g_set_error (error, GS_PLUGIN_ERROR, GS_PLUGIN_ERROR_FAILED, "Offline update failed without error_code set"); return FALSE; } /* Ignore previously shown errors */ if (!is_new_result) return TRUE; return gs_plugin_packagekit_convert_error (error, pk_error_get_code (error_code), pk_error_get_details (error_code), _("Failed to install updates: ")); } /* distro upgrade? */ if (pk_results_get_role (results) == PK_ROLE_ENUM_UPGRADE_SYSTEM) { g_autoptr(GsApp) app = NULL; app = gs_app_new (NULL); gs_app_set_from_unique_id (app, "*/*/*/system/*", AS_COMPONENT_KIND_GENERIC); gs_app_set_management_plugin (app, plugin); gs_app_add_quirk (app, GS_APP_QUIRK_IS_WILDCARD); gs_app_set_state (app, GS_APP_STATE_UNKNOWN); gs_app_set_kind (app, AS_COMPONENT_KIND_OPERATING_SYSTEM); gs_app_set_bundle_kind (app, AS_BUNDLE_KIND_PACKAGE); gs_app_set_install_date (app, mtime); gs_app_set_metadata (app, "GnomeSoftware::Creator", gs_plugin_get_name (plugin)); gs_app_list_add (list, app); return TRUE; } /* get list of package-ids */ package_array = pk_results_get_package_array (results); for (i = 0; i < package_array->len; i++) { PkPackage *pkg = g_ptr_array_index (package_array, i); const gchar *package_id; g_autoptr(GsApp) app = NULL; g_auto(GStrv) split = NULL; app = gs_app_new (NULL); package_id = pk_package_get_id (pkg); split = g_strsplit (package_id, ";", 4); gs_plugin_packagekit_set_packaging_format (plugin, app); gs_plugin_packagekit_set_package_name (app, pkg); gs_app_add_source (app, split[0]); gs_app_set_update_version (app, split[1]); gs_app_set_management_plugin (app, plugin); gs_app_add_source_id (app, package_id); gs_app_set_state (app, GS_APP_STATE_UPDATABLE); gs_app_set_kind (app, AS_COMPONENT_KIND_GENERIC); gs_app_set_bundle_kind (app, AS_BUNDLE_KIND_PACKAGE); gs_app_set_install_date (app, mtime); gs_app_set_metadata (app, "GnomeSoftware::Creator", gs_plugin_get_name (plugin)); gs_app_list_add (list, app); } return TRUE; } static void gs_packagekit_list_sources_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { g_autoptr(GTask) task = g_steal_pointer (&user_data); g_autoptr(GsAppList) list = gs_app_list_new (); g_autoptr(GMutexLocker) locker = NULL; g_autoptr(PkResults) results = NULL; g_autoptr(GPtrArray) array = NULL; g_autoptr(GError) local_error = NULL; GsPluginPackagekit *self = GS_PLUGIN_PACKAGEKIT (g_task_get_source_object (task)); GsPlugin *plugin = GS_PLUGIN (self); results = pk_client_generic_finish (PK_CLIENT (source_object), result, &local_error); if (local_error != NULL || !gs_plugin_packagekit_results_valid (results, g_task_get_cancellable (task), &local_error)) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } locker = g_mutex_locker_new (&self->cached_sources_mutex); if (self->cached_sources == NULL) self->cached_sources = g_hash_table_new_full (g_str_hash, g_str_equal, g_free, NULL); array = pk_results_get_repo_detail_array (results); for (guint i = 0; i < array->len; i++) { g_autoptr(GsApp) app = NULL; PkRepoDetail *rd = g_ptr_array_index (array, i); const gchar *id = pk_repo_detail_get_id (rd); app = g_hash_table_lookup (self->cached_sources, id); if (app == NULL) { app = gs_app_new (id); gs_app_set_management_plugin (app, plugin); gs_app_set_kind (app, AS_COMPONENT_KIND_REPOSITORY); gs_app_set_bundle_kind (app, AS_BUNDLE_KIND_PACKAGE); gs_app_set_scope (app, AS_COMPONENT_SCOPE_SYSTEM); gs_app_add_quirk (app, GS_APP_QUIRK_NOT_LAUNCHABLE); gs_app_set_state (app, pk_repo_detail_get_enabled (rd) ? GS_APP_STATE_INSTALLED : GS_APP_STATE_AVAILABLE); gs_app_set_name (app, GS_APP_QUALITY_HIGHEST, pk_repo_detail_get_description (rd)); gs_app_set_summary (app, GS_APP_QUALITY_HIGHEST, pk_repo_detail_get_description (rd)); gs_plugin_packagekit_set_packaging_format (plugin, app); gs_app_set_metadata (app, "GnomeSoftware::SortKey", "300"); gs_app_set_origin_ui (app, _("Packages")); g_hash_table_insert (self->cached_sources, g_strdup (id), app); g_object_weak_ref (G_OBJECT (app), cached_sources_weak_ref_cb, self); } else { g_object_ref (app); /* The repo-related apps are those installed; due to re-using cached app, make sure the list is populated from fresh data. */ gs_app_list_remove_all (gs_app_get_related (app)); } gs_app_list_add (list, app); } g_task_return_pointer (task, g_steal_pointer (&list), g_object_unref); } static void list_apps_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void gs_plugin_packagekit_list_apps_async (GsPlugin *plugin, GsAppQuery *query, GsPluginListAppsFlags flags, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { PkBitfield filter; g_autoptr(GsPackagekitHelper) helper = gs_packagekit_helper_new (plugin); g_autoptr(PkTask) task_list_apps = NULL; g_autoptr(GsApp) app_dl = gs_app_new (gs_plugin_get_name (plugin)); const gchar *const *provides_files = NULL; const gchar *provides_tag = NULL; GsAppQueryProvidesType provides_type = GS_APP_QUERY_PROVIDES_UNKNOWN; GsAppQueryTristate is_for_update = GS_APP_QUERY_TRISTATE_UNSET; GsAppQueryTristate is_historical_update = GS_APP_QUERY_TRISTATE_UNSET; GsAppQueryTristate is_source = GS_APP_QUERY_TRISTATE_UNSET; gboolean interactive = (flags & GS_PLUGIN_LIST_APPS_FLAGS_INTERACTIVE); g_autoptr(GTask) task = NULL; task = g_task_new (plugin, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_packagekit_list_apps_async); g_task_set_task_data (task, g_object_ref (helper), g_object_unref); if (query != NULL) { provides_files = gs_app_query_get_provides_files (query); provides_type = gs_app_query_get_provides (query, &provides_tag); is_for_update = gs_app_query_get_is_for_update (query); is_historical_update = gs_app_query_get_is_historical_update (query); is_source = gs_app_query_get_is_source (query); } /* Currently only support a subset of query properties, and only one set at once. */ if ((provides_files == NULL && provides_tag == NULL && is_for_update == GS_APP_QUERY_TRISTATE_UNSET && is_historical_update == GS_APP_QUERY_TRISTATE_UNSET && is_source == GS_APP_QUERY_TRISTATE_UNSET) || is_for_update == GS_APP_QUERY_TRISTATE_FALSE || is_historical_update == GS_APP_QUERY_TRISTATE_FALSE || is_source == GS_APP_QUERY_TRISTATE_FALSE || gs_app_query_get_n_properties_set (query) != 1) { g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_NOT_SUPPORTED, "Unsupported query"); return; } gs_plugin_status_update (plugin, NULL, GS_PLUGIN_STATUS_WAITING); gs_packagekit_helper_set_progress_app (helper, app_dl); task_list_apps = gs_packagekit_task_new (plugin); gs_packagekit_task_setup (GS_PACKAGEKIT_TASK (task_list_apps), GS_PACKAGEKIT_TASK_QUESTION_TYPE_NONE, interactive); if (provides_files != NULL) { filter = pk_bitfield_from_enums (PK_FILTER_ENUM_NEWEST, PK_FILTER_ENUM_ARCH, -1); pk_client_search_files_async (PK_CLIENT (task_list_apps), filter, (gchar **) provides_files, cancellable, gs_packagekit_helper_cb, helper, list_apps_cb, g_steal_pointer (&task)); } else if (provides_type != GS_APP_QUERY_PROVIDES_UNKNOWN) { const gchar * const provides_tag_strv[2] = { provides_tag, NULL }; filter = pk_bitfield_from_enums (PK_FILTER_ENUM_NEWEST, PK_FILTER_ENUM_ARCH, -1); pk_client_what_provides_async (PK_CLIENT (task_list_apps), filter, (gchar **) provides_tag_strv, cancellable, gs_packagekit_helper_cb, helper, list_apps_cb, g_steal_pointer (&task)); } else if (is_for_update == GS_APP_QUERY_TRISTATE_TRUE) { gs_packagekit_helper_set_allow_emit_updates_changed (helper, FALSE); pk_client_get_updates_async (PK_CLIENT (task_list_apps), pk_bitfield_value (PK_FILTER_ENUM_NONE), cancellable, gs_packagekit_helper_cb, helper, gs_packagekit_list_updates_cb, g_steal_pointer (&task)); } else if (is_historical_update == GS_APP_QUERY_TRISTATE_TRUE) { g_autoptr(GsAppList) list = gs_app_list_new (); g_autoptr(GError) local_error = NULL; if (gs_packagekit_add_historical_updates_sync (plugin, list, cancellable, &local_error)) g_task_return_pointer (task, g_steal_pointer (&list), g_object_unref); else g_task_return_error (task, g_steal_pointer (&local_error)); } else if (is_source == GS_APP_QUERY_TRISTATE_TRUE) { /* ask PK for the repo details */ filter = pk_bitfield_from_enums (PK_FILTER_ENUM_NOT_SOURCE, PK_FILTER_ENUM_NOT_DEVELOPMENT, -1); pk_client_get_repo_list_async (PK_CLIENT (task_list_apps), filter, cancellable, gs_packagekit_helper_cb, helper, gs_packagekit_list_sources_cb, g_steal_pointer (&task)); } else { g_assert_not_reached (); } } static void list_apps_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { PkClient *client = PK_CLIENT (source_object); g_autoptr(GTask) task = g_steal_pointer (&user_data); GsPlugin *plugin = g_task_get_source_object (task); g_autoptr(PkResults) results = NULL; g_autoptr(GsAppList) list = gs_app_list_new (); g_autoptr(GError) local_error = NULL; results = pk_client_generic_finish (client, result, &local_error); if (!gs_plugin_packagekit_results_valid (results, g_task_get_cancellable (task), &local_error) || !gs_plugin_packagekit_add_results (plugin, list, results, &local_error)) { g_task_return_error (task, g_steal_pointer (&local_error)); } else { g_task_return_pointer (task, g_steal_pointer (&list), g_object_unref); } } static GsAppList * gs_plugin_packagekit_list_apps_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_pointer (G_TASK (result), error); } static gboolean plugin_packagekit_pick_rpm_desktop_file_cb (GsPlugin *plugin, GsApp *app, const gchar *filename, GKeyFile *key_file, gpointer user_data) { return strstr (filename, "/snapd/") == NULL && strstr (filename, "/snap/") == NULL && strstr (filename, "/flatpak/") == NULL && g_key_file_has_group (key_file, "Desktop Entry") && !g_key_file_has_key (key_file, "Desktop Entry", "X-Flatpak", NULL) && !g_key_file_has_key (key_file, "Desktop Entry", "X-SnapInstanceName", NULL); } static void gs_plugin_packagekit_launch_async (GsPlugin *plugin, GsApp *app, GsPluginLaunchFlags flags, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { gs_plugin_app_launch_filtered_async (plugin, app, flags, plugin_packagekit_pick_rpm_desktop_file_cb, NULL, cancellable, callback, user_data); } static gboolean gs_plugin_packagekit_launch_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return gs_plugin_app_launch_filtered_finish (plugin, result, error); } static void gs_plugin_packagekit_invoke_reload (GsPlugin *plugin) { g_autoptr(GsAppList) list = gs_plugin_list_cached (plugin); guint sz = gs_app_list_length (list); for (guint i = 0; i < sz; i++) { GsApp *app = gs_app_list_index (list, i); /* to ensure the app states are refined */ gs_app_set_state (app, GS_APP_STATE_UNKNOWN); } gs_plugin_reload (plugin); } static void gs_plugin_packagekit_installed_changed_cb (PkControl *control, GsPlugin *plugin) { gs_plugin_packagekit_invoke_reload (plugin); } static void gs_plugin_packagekit_updates_changed_cb (PkControl *control, GsPlugin *plugin) { gs_plugin_updates_changed (plugin); } static void gs_plugin_packagekit_repo_list_changed_cb (PkControl *control, GsPlugin *plugin) { gs_plugin_packagekit_invoke_reload (plugin); } void gs_plugin_adopt_app (GsPlugin *plugin, GsApp *app) { if (gs_app_get_bundle_kind (app) == AS_BUNDLE_KIND_PACKAGE && gs_app_get_scope (app) == AS_COMPONENT_SCOPE_SYSTEM) { gs_app_set_management_plugin (app, plugin); gs_plugin_packagekit_set_packaging_format (plugin, app); return; } else if (gs_app_get_kind (app) == AS_COMPONENT_KIND_OPERATING_SYSTEM) { gs_app_set_management_plugin (app, plugin); } } typedef struct { GsAppList *list; /* (owned) (not nullable) */ GsPackagekitHelper *progress_data; /* (owned) (not nullable) */ } ResolvePackagesWithFilterData; static void resolve_packages_with_filter_data_free (ResolvePackagesWithFilterData *data) { g_clear_object (&data->list); g_clear_object (&data->progress_data); g_free (data); } G_DEFINE_AUTOPTR_CLEANUP_FUNC (ResolvePackagesWithFilterData, resolve_packages_with_filter_data_free) static void resolve_packages_with_filter_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void gs_plugin_packagekit_resolve_packages_with_filter_async (GsPluginPackagekit *self, PkClient *client_refine, GsAppList *list, PkBitfield filter, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { GsPlugin *plugin = GS_PLUGIN (self); GPtrArray *sources; GsApp *app; const gchar *pkgname; guint i; guint j; g_autoptr(GPtrArray) package_ids = NULL; g_autoptr(GTask) task = NULL; g_autoptr(ResolvePackagesWithFilterData) data = NULL; ResolvePackagesWithFilterData *data_unowned; task = g_task_new (self, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_packagekit_resolve_packages_with_filter_async); data_unowned = data = g_new0 (ResolvePackagesWithFilterData, 1); data->list = g_object_ref (list); data->progress_data = gs_packagekit_helper_new (plugin); g_task_set_task_data (task, g_steal_pointer (&data), (GDestroyNotify) resolve_packages_with_filter_data_free); package_ids = g_ptr_array_new_with_free_func (g_free); for (i = 0; i < gs_app_list_length (list); i++) { app = gs_app_list_index (list, i); sources = gs_app_get_sources (app); for (j = 0; j < sources->len; j++) { pkgname = g_ptr_array_index (sources, j); if (pkgname == NULL || pkgname[0] == '\0') { g_warning ("invalid pkgname '%s' for %s", pkgname, gs_app_get_unique_id (app)); continue; } g_ptr_array_add (package_ids, g_strdup (pkgname)); } } if (package_ids->len == 0) { g_task_return_boolean (task, TRUE); return; } g_ptr_array_add (package_ids, NULL); /* resolve them all at once */ pk_client_resolve_async (client_refine, filter, (gchar **) package_ids->pdata, cancellable, gs_packagekit_helper_cb, data_unowned->progress_data, resolve_packages_with_filter_cb, g_steal_pointer (&task)); } static void resolve_packages_with_filter_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { PkClient *client = PK_CLIENT (source_object); g_autoptr(GTask) task = g_steal_pointer (&user_data); GsPluginPackagekit *self = g_task_get_source_object (task); GCancellable *cancellable = g_task_get_cancellable (task); ResolvePackagesWithFilterData *data = g_task_get_task_data (task); GsAppList *list = data->list; g_autoptr(PkResults) results = NULL; g_autoptr(GPtrArray) packages = NULL; g_autoptr(GError) local_error = NULL; results = pk_client_generic_finish (client, result, &local_error); if (!gs_plugin_packagekit_results_valid (results, cancellable, &local_error)) { g_prefix_error (&local_error, "failed to resolve package_ids: "); g_task_return_error (task, g_steal_pointer (&local_error)); return; } /* get results */ packages = pk_results_get_package_array (results); /* if the user types more characters we'll get cancelled - don't go on * to mark apps as unavailable because packages->len = 0 */ if (g_cancellable_set_error_if_cancelled (cancellable, &local_error)) { gs_utils_error_convert_gio (&local_error); g_task_return_error (task, g_steal_pointer (&local_error)); return; } for (guint i = 0; i < gs_app_list_length (list); i++) { GsApp *app = gs_app_list_index (list, i); if (gs_app_get_local_file (app) != NULL) continue; gs_plugin_packagekit_resolve_packages_app (GS_PLUGIN (self), packages, app); } g_task_return_boolean (task, TRUE); } static gboolean gs_plugin_packagekit_resolve_packages_with_filter_finish (GsPluginPackagekit *self, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } /* * markdown_to_pango: * * Converts markdown text to pango markup which can be used in a * GtkLabel etc. This function assumes @text is valid markdown. * * Returns: pango markup, or %NULL on failure * */ static gchar * markdown_to_pango (const gchar *text) { g_autoptr(GsMarkdown) markdown = NULL; g_return_val_if_fail (text != NULL, NULL); /* try to parse */ markdown = gs_markdown_new (GS_MARKDOWN_OUTPUT_PANGO); gs_markdown_set_smart_quoting (markdown, FALSE); gs_markdown_set_autocode (markdown, FALSE); gs_markdown_set_autolinkify (markdown, FALSE); return gs_markdown_parse (markdown, text); } static gboolean gs_plugin_refine_app_needs_details (GsPluginRefineFlags flags, GsApp *app) { if ((flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_LICENSE) > 0 && gs_app_get_license (app) == NULL) return TRUE; if ((flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_URL) > 0 && gs_app_get_url (app, AS_URL_KIND_HOMEPAGE) == NULL) return TRUE; if ((flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_SIZE) > 0 && gs_app_get_size_installed (app, NULL) != GS_SIZE_TYPE_VALID) return TRUE; if ((flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_SIZE) > 0 && gs_app_get_size_download (app, NULL) != GS_SIZE_TYPE_VALID) return TRUE; return FALSE; } static gboolean gs_plugin_refine_requires_version (GsApp *app, GsPluginRefineFlags flags) { const gchar *tmp; tmp = gs_app_get_version (app); if (tmp != NULL) return FALSE; return (flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_VERSION) > 0; } static gboolean gs_plugin_refine_requires_update_details (GsApp *app, GsPluginRefineFlags flags) { const gchar *tmp; tmp = gs_app_get_update_details_markup (app); if (tmp != NULL) return FALSE; return (flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_UPDATE_DETAILS) > 0; } static gboolean gs_plugin_refine_requires_origin (GsApp *app, GsPluginRefineFlags flags) { const gchar *tmp; tmp = gs_app_get_origin (app); if (tmp != NULL) return FALSE; if ((flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_ORIGIN) > 0) return TRUE; return FALSE; } static gboolean gs_plugin_refine_requires_package_id (GsApp *app, GsPluginRefineFlags flags) { const gchar *tmp; tmp = gs_app_get_source_id_default (app); if (tmp != NULL) return FALSE; if ((flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_VERSION) > 0) return TRUE; if ((flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_LICENSE) > 0) return TRUE; if ((flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_URL) > 0) return TRUE; if ((flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_SIZE) > 0) return TRUE; if ((flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_DESCRIPTION) > 0) return TRUE; if ((flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_VERSION) > 0) return TRUE; if ((flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_UPDATE_DETAILS) > 0) return TRUE; if ((flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_UPDATE_SEVERITY) > 0) return TRUE; if ((flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_PROVENANCE) > 0) return TRUE; if ((flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_SETUP_ACTION) > 0) return TRUE; return FALSE; } static gboolean gs_plugin_packagekit_refine_valid_package_name (const gchar *source) { if (g_strstr_len (source, -1, "/") != NULL) return FALSE; return TRUE; } static gboolean gs_plugin_systemd_update_cache (GsPluginPackagekit *self, GCancellable *cancellable, GError **error) { g_autoptr(GError) error_local = NULL; g_auto(GStrv) package_ids = NULL; g_autoptr(GHashTable) new_prepared_updates = NULL; g_autoptr(GMutexLocker) locker = NULL; /* get new list of package-ids. This loads a local file, so should be * just about fast enough to be sync. */ new_prepared_updates = g_hash_table_new_full (g_str_hash, g_str_equal, g_free, NULL); package_ids = pk_offline_get_prepared_ids (&error_local); if (package_ids == NULL) { if (g_error_matches (error_local, PK_OFFLINE_ERROR, PK_OFFLINE_ERROR_NO_DATA)) { return TRUE; } g_debug ("Failed to get prepared IDs: %s", error_local->message); /* Ignore errors returned here, they are not crucial, the plugin can work without it too */ return TRUE; } /* Build the new table, stealing all the elements from @package_ids. */ for (guint i = 0; package_ids[i] != NULL; i++) { g_hash_table_add (new_prepared_updates, g_steal_pointer (&package_ids[i])); } g_clear_pointer (&package_ids, g_free); /* Update the shared state. */ locker = g_mutex_locker_new (&self->prepared_updates_mutex); g_clear_pointer (&self->prepared_updates, g_hash_table_unref); self->prepared_updates = g_steal_pointer (&new_prepared_updates); return TRUE; } typedef struct { /* Track pending operations. */ guint n_pending_operations; gboolean completed; GError *error; /* (nullable) (owned) */ GPtrArray *progress_datas; /* (element-type GsPackagekitHelper) (owned) (not nullable) */ PkClient *client_refine; /* (owned) */ /* Input data for operations. */ GsAppList *full_list; /* (nullable) (owned) */ GsAppList *resolve_list; /* (nullable) (owned) */ GsApp *app_operating_system; /* (nullable) (owned) */ GsAppList *update_details_list; /* (nullable) (owned) */ GsAppList *details_list; /* (nullable) (owned) */ } RefineData; static void refine_data_free (RefineData *data) { g_assert (data->n_pending_operations == 0); g_assert (data->completed); g_clear_error (&data->error); g_clear_pointer (&data->progress_datas, g_ptr_array_unref); g_clear_object (&data->client_refine); g_clear_object (&data->full_list); g_clear_object (&data->resolve_list); g_clear_object (&data->app_operating_system); g_clear_object (&data->update_details_list); g_clear_object (&data->details_list); g_free (data); } G_DEFINE_AUTOPTR_CLEANUP_FUNC (RefineData, refine_data_free) /* Add @helper to the list of progress data closures to free when the * #RefineData is freed. This means it can be reliably used, 0 or more times, * by the async operation up until the operation is finished. */ static GsPackagekitHelper * refine_task_add_progress_data (GTask *refine_task, GsPackagekitHelper *helper) { RefineData *data = g_task_get_task_data (refine_task); g_ptr_array_add (data->progress_datas, g_object_ref (helper)); return helper; } static GTask * refine_task_add_operation (GTask *refine_task) { RefineData *data = g_task_get_task_data (refine_task); g_assert (!data->completed); data->n_pending_operations++; return g_object_ref (refine_task); } static void refine_task_complete_operation (GTask *refine_task) { RefineData *data = g_task_get_task_data (refine_task); g_assert (data->n_pending_operations > 0); data->n_pending_operations--; /* Have all operations completed? */ if (data->n_pending_operations == 0) { g_assert (!data->completed); data->completed = TRUE; if (data->error != NULL) g_task_return_error (refine_task, g_steal_pointer (&data->error)); else g_task_return_boolean (refine_task, TRUE); } } static void refine_task_complete_operation_with_error (GTask *refine_task, GError *error /* (transfer full) */) { RefineData *data = g_task_get_task_data (refine_task); g_autoptr(GError) owned_error = g_steal_pointer (&error); /* Multiple operations might fail. Just take the first error. */ if (data->error == NULL) data->error = g_steal_pointer (&owned_error); refine_task_complete_operation (refine_task); } typedef struct { GTask *refine_task; /* (owned) (not nullable) */ GsApp *app; /* (owned) (nullable) for single file query */ GHashTable *source_to_app; /* (owned) (nullable) for multifile query */ guint n_expected_results; } SearchFilesData; static void search_files_data_free (SearchFilesData *data) { g_clear_object (&data->app); g_clear_object (&data->refine_task); g_clear_pointer (&data->source_to_app, g_hash_table_unref); g_free (data); } G_DEFINE_AUTOPTR_CLEANUP_FUNC (SearchFilesData, search_files_data_free) static SearchFilesData * search_files_data_new_operation (GTask *refine_task, GsApp *app, GHashTable *source_to_app, guint n_expected_results) { g_autoptr(SearchFilesData) data = g_new0 (SearchFilesData, 1); g_assert ((app != NULL && source_to_app == NULL) || (app == NULL && source_to_app != NULL)); data->refine_task = refine_task_add_operation (refine_task); if (app) { data->app = g_object_ref (app); } else { data->source_to_app = g_hash_table_ref (source_to_app); data->n_expected_results = n_expected_results; } return g_steal_pointer (&data); } typedef struct { GTask *refine_task; /* (owned) (not nullable) */ GsAppList *sources; /* (owned) (not nullable) */ } SourcesRelatedData; static void sources_related_data_free (SourcesRelatedData *data) { g_clear_object (&data->sources); g_clear_object (&data->refine_task); g_free (data); } G_DEFINE_AUTOPTR_CLEANUP_FUNC (SourcesRelatedData, sources_related_data_free) static SourcesRelatedData * sources_related_data_new_operation (GTask *refine_task, GsAppList *sources) { g_autoptr(SourcesRelatedData) data = g_new0 (SourcesRelatedData, 1); data->refine_task = refine_task_add_operation (refine_task); data->sources = g_object_ref (sources); return g_steal_pointer (&data); } static void upgrade_system_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void resolve_all_packages_with_filter_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void search_files_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void get_update_detail_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void get_details_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void get_updates_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void refine_all_history_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void sources_related_got_installed_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void gs_plugin_packagekit_refine_async (GsPlugin *plugin, GsAppList *list, GsPluginRefineFlags flags, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { GsPluginPackagekit *self = GS_PLUGIN_PACKAGEKIT (plugin); g_autoptr(GHashTable) resolve_list_apps = g_hash_table_new (NULL, NULL); g_autoptr(GsAppList) resolve_list = gs_app_list_new (); g_autoptr(GsAppList) update_details_list = gs_app_list_new (); g_autoptr(GsAppList) details_list = gs_app_list_new (); g_autoptr(GsAppList) history_list = gs_app_list_new (); g_autoptr(GsAppList) repos_list = gs_app_list_new (); g_autoptr(GTask) task = NULL; g_autoptr(RefineData) data = NULL; RefineData *data_unowned = NULL; g_autoptr(GError) local_error = NULL; guint n_considered = 0; /* Searches for multiple files are broken for PackageKit’s apt backend * in 1.2.6 and earlier. * See https://github.com/PackageKit/PackageKit/pull/649 */ #if PK_CHECK_VERSION(1, 2, 7) gboolean is_pk_apt_backend_broken = FALSE; #else gboolean is_pk_apt_backend_broken = TRUE; #endif task = g_task_new (plugin, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_packagekit_refine_async); data_unowned = data = g_new0 (RefineData, 1); data->full_list = g_object_ref (list); data->n_pending_operations = 1; /* to prevent the task being completed before all operations have been started */ data->progress_datas = g_ptr_array_new_with_free_func ((GDestroyNotify) g_object_unref); data->client_refine = pk_client_new (); pk_client_set_interactive (data->client_refine, gs_plugin_has_flags (plugin, GS_PLUGIN_FLAGS_INTERACTIVE)); g_task_set_task_data (task, g_steal_pointer (&data), (GDestroyNotify) refine_data_free); /* Process the @list and work out what information is needed for each * app. */ for (guint i = 0; i < gs_app_list_length (list); i++) { GsApp *app = gs_app_list_index (list, i); GPtrArray *sources; const gchar *filename; if (gs_app_has_quirk (app, GS_APP_QUIRK_IS_WILDCARD)) continue; if (!gs_app_has_management_plugin (app, NULL) && !gs_app_has_management_plugin (app, GS_PLUGIN (self))) continue; n_considered++; /* Repositories */ filename = gs_app_get_metadata_item (app, "repos::repo-filename"); if (gs_app_get_kind (app) == AS_COMPONENT_KIND_REPOSITORY && filename != NULL) { gs_app_list_add (repos_list, app); } /* Apps */ sources = gs_app_get_sources (app); if (sources->len > 0 && gs_plugin_packagekit_refine_valid_package_name (g_ptr_array_index (sources, 0)) && (gs_app_get_state (app) == GS_APP_STATE_UNKNOWN || gs_plugin_refine_requires_package_id (app, flags) || gs_plugin_refine_requires_origin (app, flags) || gs_plugin_refine_requires_version (app, flags))) { g_hash_table_add (resolve_list_apps, app); gs_app_list_add (resolve_list, app); } if ((gs_app_get_state (app) == GS_APP_STATE_UPDATABLE || gs_app_get_state (app) == GS_APP_STATE_UNKNOWN) && gs_app_get_source_id_default (app) != NULL && gs_plugin_refine_requires_update_details (app, flags)) { gs_app_list_add (update_details_list, app); } if (gs_app_get_source_id_default (app) != NULL && gs_plugin_refine_app_needs_details (flags, app)) { gs_app_list_add (details_list, app); } if ((flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_HISTORY) != 0 && sources->len > 0 && gs_app_get_install_date (app) == 0) { gs_app_list_add (history_list, app); } } /* Add sources' related apps only when refining sources and nothing else */ if ((flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_RELATED) != 0 && n_considered > 0 && gs_app_list_length (repos_list) == n_considered) { PkBitfield filter; g_autoptr(GsPackagekitHelper) helper = gs_packagekit_helper_new (plugin); filter = pk_bitfield_from_enums (PK_FILTER_ENUM_INSTALLED, PK_FILTER_ENUM_NEWEST, PK_FILTER_ENUM_ARCH, PK_FILTER_ENUM_NOT_COLLECTIONS, -1); pk_client_get_packages_async (data_unowned->client_refine, filter, cancellable, gs_packagekit_helper_cb, refine_task_add_progress_data (task, helper), sources_related_got_installed_cb, sources_related_data_new_operation (task, repos_list)); } /* re-read /var/lib/PackageKit/prepared-update so we know what packages * to mark as already downloaded and prepared for offline updates */ if ((flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_SIZE) && !gs_plugin_systemd_update_cache (self, cancellable, &local_error)) { refine_task_complete_operation_with_error (task, g_steal_pointer (&local_error)); return; } /* when we need the cannot-be-upgraded applications, we implement this * by doing a UpgradeSystem(SIMULATE) which adds the removed packages * to the related-apps list with a state of %GS_APP_STATE_UNAVAILABLE */ if (flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_UPGRADE_REMOVED) { for (guint i = 0; i < gs_app_list_length (list); i++) { GsApp *app = gs_app_list_index (list, i); g_autoptr(GsPackagekitHelper) helper = gs_packagekit_helper_new (plugin); guint cache_age_save; if (gs_app_get_kind (app) != AS_COMPONENT_KIND_OPERATING_SYSTEM) continue; gs_packagekit_helper_add_app (helper, app); /* Expose the @app to the callback functions so that * upgrade packages can be added as related. This only * supports one OS. */ g_assert (data_unowned->app_operating_system == NULL); data_unowned->app_operating_system = g_object_ref (app); /* ask PK to simulate upgrading the system */ cache_age_save = pk_client_get_cache_age (data_unowned->client_refine); pk_client_set_cache_age (data_unowned->client_refine, 60 * 60 * 24 * 7); /* once per week */ pk_client_set_interactive (data_unowned->client_refine, gs_plugin_has_flags (plugin, GS_PLUGIN_FLAGS_INTERACTIVE)); pk_client_upgrade_system_async (data_unowned->client_refine, pk_bitfield_from_enums (PK_TRANSACTION_FLAG_ENUM_SIMULATE, -1), gs_app_get_version (app), PK_UPGRADE_KIND_ENUM_COMPLETE, cancellable, gs_packagekit_helper_cb, refine_task_add_progress_data (task, helper), upgrade_system_cb, refine_task_add_operation (task)); pk_client_set_cache_age (data_unowned->client_refine, cache_age_save); /* Only support one operating system. */ break; } } /* can we resolve in one go? */ if (gs_app_list_length (resolve_list) > 0) { PkBitfield filter; /* Expose the @resolve_list to the callback functions in case a * second attempt is needed. */ g_assert (data_unowned->resolve_list == NULL); data_unowned->resolve_list = g_object_ref (resolve_list); /* first, try to resolve packages with ARCH filter */ filter = pk_bitfield_from_enums (PK_FILTER_ENUM_NEWEST, PK_FILTER_ENUM_ARCH, -1); gs_plugin_packagekit_resolve_packages_with_filter_async (self, data_unowned->client_refine, resolve_list, filter, cancellable, resolve_all_packages_with_filter_cb, refine_task_add_operation (task)); } /* set the package-id for an installed desktop file */ if ((flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_SETUP_ACTION) != 0) { g_autoptr(GPtrArray) to_array = g_ptr_array_new_with_free_func (g_free); g_autoptr(GHashTable) source_to_app = g_hash_table_new_full (g_str_hash, g_str_equal, g_free, g_object_unref); g_autoptr(GsPackagekitHelper) helper = NULL; for (guint i = 0; i < gs_app_list_length (list); i++) { g_autofree gchar *fn = NULL; GsApp *app = gs_app_list_index (list, i); GPtrArray *sources; const gchar *tmp; if (gs_app_has_quirk (app, GS_APP_QUIRK_IS_WILDCARD)) continue; if (gs_app_get_source_id_default (app) != NULL) continue; if (!gs_app_has_management_plugin (app, NULL) && !gs_app_has_management_plugin (app, GS_PLUGIN (self))) continue; tmp = gs_app_get_id (app); if (tmp == NULL) continue; /* The information will be added within the resolve_list operation */ if (g_hash_table_contains (resolve_list_apps, app)) continue; switch (gs_app_get_kind (app)) { case AS_COMPONENT_KIND_DESKTOP_APP: fn = g_strdup_printf ("/usr/share/applications/%s", tmp); break; case AS_COMPONENT_KIND_ADDON: fn = g_strdup_printf ("/usr/share/metainfo/%s.metainfo.xml", tmp); if (!g_file_test (fn, G_FILE_TEST_EXISTS)) { g_free (fn); fn = g_strdup_printf ("/usr/share/appdata/%s.metainfo.xml", tmp); } break; default: break; } if (fn == NULL) continue; if (!g_file_test (fn, G_FILE_TEST_EXISTS)) { g_debug ("ignoring %s as does not exist", fn); continue; } sources = gs_app_get_sources (app); if (!is_pk_apt_backend_broken && sources->len > 0) { /* do a batch query and match by the source (aka package name), if available */ g_ptr_array_add (to_array, g_strdup (fn)); if (helper == NULL) helper = gs_packagekit_helper_new (plugin); gs_packagekit_helper_add_app (helper, app); for (guint jj = 0; jj < sources->len; jj++) { const gchar *source = g_ptr_array_index (sources, jj); g_hash_table_insert (source_to_app, g_strdup (source), g_object_ref (app)); } } else { /* otherwise do a query with a single file only */ const gchar *single_array[] = { NULL, NULL }; g_autoptr(GsPackagekitHelper) single_helper = NULL; single_array[0] = fn; single_helper = gs_packagekit_helper_new (plugin); gs_packagekit_helper_add_app (single_helper, app); pk_client_search_files_async (data_unowned->client_refine, pk_bitfield_from_enums (PK_FILTER_ENUM_INSTALLED, -1), (gchar **) single_array, cancellable, gs_packagekit_helper_cb, refine_task_add_progress_data (task, single_helper), search_files_cb, search_files_data_new_operation (task, app, NULL, 0)); } } if (to_array->len > 0) { g_ptr_array_add (to_array, NULL); pk_client_search_files_async (data_unowned->client_refine, pk_bitfield_from_enums (PK_FILTER_ENUM_INSTALLED, -1), (gchar **) to_array->pdata, cancellable, gs_packagekit_helper_cb, refine_task_add_progress_data (task, helper), search_files_cb, search_files_data_new_operation (task, NULL, source_to_app, to_array->len - 1)); } } /* Refine repo package names */ if (gs_app_list_length (repos_list) > 0) { g_autoptr(GPtrArray) to_array = g_ptr_array_new_full (gs_app_list_length (repos_list) + 1, g_free); g_autoptr(GHashTable) source_to_app = g_hash_table_new_full (g_str_hash, g_str_equal, g_free, g_object_unref); g_autoptr(GsPackagekitHelper) helper = gs_packagekit_helper_new (plugin); for (guint i = 0; i < gs_app_list_length (repos_list); i++) { GsApp *app = gs_app_list_index (repos_list, i); GPtrArray *sources; const gchar *filename; /* The information will be added within the resolve_list operation */ if (g_hash_table_contains (resolve_list_apps, app)) continue; filename = gs_app_get_metadata_item (app, "repos::repo-filename"); sources = gs_app_get_sources (app); if (!is_pk_apt_backend_broken && sources->len > 0) { /* do a batch query and match by the source (aka package name), if available */ g_ptr_array_add (to_array, g_strdup (filename)); gs_packagekit_helper_add_app (helper, app); for (guint jj = 0; jj < sources->len; jj++) { const gchar *source = g_ptr_array_index (sources, jj); g_hash_table_insert (source_to_app, g_strdup (source), g_object_ref (app)); } } else { /* otherwise do a query with a single file only */ const gchar *single_array[] = { NULL, NULL }; g_autoptr(GsPackagekitHelper) single_helper = NULL; single_array[0] = filename; single_helper = gs_packagekit_helper_new (plugin); gs_packagekit_helper_add_app (single_helper, app); pk_client_search_files_async (data_unowned->client_refine, pk_bitfield_from_enums (PK_FILTER_ENUM_INSTALLED, -1), (gchar **) single_array, cancellable, gs_packagekit_helper_cb, refine_task_add_progress_data (task, single_helper), search_files_cb, search_files_data_new_operation (task, app, NULL, 0)); } } if (to_array->len > 0) { g_ptr_array_add (to_array, NULL); pk_client_search_files_async (data_unowned->client_refine, pk_bitfield_from_enums (PK_FILTER_ENUM_INSTALLED, -1), (gchar **) to_array->pdata, cancellable, gs_packagekit_helper_cb, refine_task_add_progress_data (task, helper), search_files_cb, search_files_data_new_operation (task, NULL, source_to_app, to_array->len - 1)); } } /* any update details missing? */ if (gs_app_list_length (update_details_list) > 0) { GsApp *app; g_autoptr(GsPackagekitHelper) helper = gs_packagekit_helper_new (plugin); g_autofree const gchar **package_ids = NULL; /* Expose the @update_details_list to the callback functions so * its apps can be updated. */ g_assert (data_unowned->update_details_list == NULL); data_unowned->update_details_list = g_object_ref (update_details_list); package_ids = g_new0 (const gchar *, gs_app_list_length (update_details_list) + 1); for (guint i = 0; i < gs_app_list_length (update_details_list); i++) { app = gs_app_list_index (update_details_list, i); package_ids[i] = gs_app_get_source_id_default (app); g_assert (package_ids[i] != NULL); /* checked when update_details_list is built */ } /* get any update details */ pk_client_get_update_detail_async (data_unowned->client_refine, (gchar **) package_ids, cancellable, gs_packagekit_helper_cb, refine_task_add_progress_data (task, helper), get_update_detail_cb, refine_task_add_operation (task)); } /* any package details missing? */ if (gs_app_list_length (details_list) > 0) { g_autoptr(GsPackagekitHelper) helper = gs_packagekit_helper_new (plugin); g_autoptr(GPtrArray) package_ids = NULL; /* Expose the @details_list to the callback functions so * its apps can be updated. */ g_assert (data_unowned->details_list == NULL); data_unowned->details_list = g_object_ref (details_list); package_ids = app_list_get_package_ids (details_list, NULL, FALSE); if (package_ids->len > 0) { /* NULL-terminate the array */ g_ptr_array_add (package_ids, NULL); #if PK_CHECK_VERSION (1, 2, 7) if ((flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_SIZE) != 0) pk_client_set_details_with_deps_size (data_unowned->client_refine, TRUE); #endif /* get any details */ pk_client_get_details_async (data_unowned->client_refine, (gchar **) package_ids->pdata, cancellable, gs_packagekit_helper_cb, refine_task_add_progress_data (task, helper), get_details_cb, refine_task_add_operation (task)); } } /* get the update severity */ if ((flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_UPDATE_SEVERITY) != 0) { PkBitfield filter; g_autoptr(GsPackagekitHelper) helper = gs_packagekit_helper_new (plugin); gs_packagekit_helper_set_allow_emit_updates_changed (helper, FALSE); /* get the list of updates */ filter = pk_bitfield_value (PK_FILTER_ENUM_NONE); pk_client_get_updates_async (data_unowned->client_refine, filter, cancellable, gs_packagekit_helper_cb, refine_task_add_progress_data (task, helper), get_updates_cb, refine_task_add_operation (task)); } for (guint i = 0; i < gs_app_list_length (list); i++) { GsApp *app = gs_app_list_index (list, i); /* only process this app if was created by this plugin */ if (!gs_app_has_management_plugin (app, plugin)) continue; /* the scope is always system-wide */ if (gs_app_get_scope (app) == AS_COMPONENT_SCOPE_UNKNOWN) gs_app_set_scope (app, AS_COMPONENT_SCOPE_SYSTEM); if (gs_app_get_bundle_kind (app) == AS_BUNDLE_KIND_UNKNOWN) gs_app_set_bundle_kind (app, AS_BUNDLE_KIND_PACKAGE); } /* add any missing history data */ if (gs_app_list_length (history_list) > 0) { gs_plugin_packagekit_refine_history_async (self, history_list, cancellable, refine_all_history_cb, refine_task_add_operation (task)); } /* Mark the operation to set up all the other operations as completed. * The @refine_task will now be completed once all the async operations * have completed, and the task callback invoked. */ refine_task_complete_operation (task); } static void upgrade_system_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { PkClient *client = PK_CLIENT (source_object); g_autoptr(GTask) refine_task = g_steal_pointer (&user_data); GsPluginPackagekit *self = GS_PLUGIN_PACKAGEKIT (g_task_get_source_object (refine_task)); RefineData *data = g_task_get_task_data (refine_task); g_autoptr(PkResults) results = NULL; g_autoptr(GsAppList) results_list = NULL; g_autoptr(GError) local_error = NULL; results = pk_client_generic_finish (client, result, &local_error); if (!gs_plugin_packagekit_results_valid (results, g_task_get_cancellable (refine_task), &local_error)) { g_prefix_error (&local_error, "failed to refine distro upgrade: "); refine_task_complete_operation_with_error (refine_task, g_steal_pointer (&local_error)); return; } results_list = gs_app_list_new (); if (!gs_plugin_packagekit_add_results (GS_PLUGIN (self), results_list, results, &local_error)) { refine_task_complete_operation_with_error (refine_task, g_steal_pointer (&local_error)); return; } /* add each of these as related applications */ for (guint j = 0; j < gs_app_list_length (results_list); j++) { GsApp *app2 = gs_app_list_index (results_list, j); if (gs_app_get_state (app2) != GS_APP_STATE_UNAVAILABLE) continue; gs_app_add_related (data->app_operating_system, app2); } refine_task_complete_operation (refine_task); } static void sources_related_got_installed_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { PkClient *client = PK_CLIENT (source_object); g_autoptr(SourcesRelatedData) sources_related_data = g_steal_pointer (&user_data); GTask *refine_task = sources_related_data->refine_task; GsPluginPackagekit *self = GS_PLUGIN_PACKAGEKIT (g_task_get_source_object (refine_task)); g_autoptr(GHashTable) sources_hash = g_hash_table_new_full (g_str_hash, g_str_equal, g_free, NULL); g_autoptr(PkResults) results = NULL; g_autoptr(GsAppList) installed = gs_app_list_new (); g_autoptr(GError) local_error = NULL; results = pk_client_generic_finish (client, result, &local_error); if (!gs_plugin_packagekit_results_valid (results, g_task_get_cancellable (refine_task), &local_error)) { g_prefix_error (&local_error, "failed to get sources related: "); refine_task_complete_operation_with_error (refine_task, g_steal_pointer (&local_error)); return; } if (!gs_plugin_packagekit_add_results (GS_PLUGIN (self), installed, results, &local_error)) { g_prefix_error (&local_error, "failed to read results for sources related: "); refine_task_complete_operation_with_error (refine_task, g_steal_pointer (&local_error)); return; } for (guint i = 0; i < gs_app_list_length (sources_related_data->sources); i++) { GsApp *app = gs_app_list_index (sources_related_data->sources, i); if (gs_app_has_quirk (app, GS_APP_QUIRK_IS_WILDCARD) || gs_app_get_kind (app) != AS_COMPONENT_KIND_REPOSITORY || gs_app_get_id (app) == NULL) continue; if (!gs_app_has_management_plugin (app, NULL) && !gs_app_has_management_plugin (app, GS_PLUGIN (self))) continue; g_hash_table_insert (sources_hash, g_strdup (gs_app_get_id (app)), app); } for (guint i = 0; i < gs_app_list_length (installed); i++) { g_auto(GStrv) split = NULL; GsApp *app = gs_app_list_index (installed, i); split = pk_package_id_split (gs_app_get_source_id_default (app)); if (split == NULL) { g_set_error (&local_error, GS_PLUGIN_ERROR, GS_PLUGIN_ERROR_INVALID_FORMAT, "invalid package-id: %s", gs_app_get_source_id_default (app)); refine_task_complete_operation_with_error (refine_task, g_steal_pointer (&local_error)); return; } if (g_str_has_prefix (split[PK_PACKAGE_ID_DATA], "installed:")) { const gchar *id = split[PK_PACKAGE_ID_DATA] + 10; GsApp *app_tmp = g_hash_table_lookup (sources_hash, id); if (app_tmp != NULL) { g_debug ("found package %s from %s", gs_app_get_source_default (app), id); gs_app_add_related (app_tmp, app); } } } refine_task_complete_operation (refine_task); } static gboolean gs_plugin_packagekit_refine_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } static void resolve_all_packages_with_filter_cb2 (GObject *source_object, GAsyncResult *result, gpointer user_data); static void resolve_all_packages_with_filter_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { GsPluginPackagekit *self = GS_PLUGIN_PACKAGEKIT (source_object); g_autoptr(GTask) refine_task = g_steal_pointer (&user_data); RefineData *data = g_task_get_task_data (refine_task); GCancellable *cancellable = g_task_get_cancellable (refine_task); GsAppList *resolve_list = data->resolve_list; g_autoptr(GsAppList) resolve2_list = NULL; PkBitfield filter; g_autoptr(GError) local_error = NULL; if (!gs_plugin_packagekit_resolve_packages_with_filter_finish (self, result, &local_error)) { refine_task_complete_operation_with_error (refine_task, g_steal_pointer (&local_error)); return; } /* if any packages remaining in UNKNOWN state, try to resolve them again, * but this time without ARCH filter */ resolve2_list = gs_app_list_new (); for (guint i = 0; i < gs_app_list_length (resolve_list); i++) { GsApp *app = gs_app_list_index (resolve_list, i); if (gs_app_get_state (app) == GS_APP_STATE_UNKNOWN) gs_app_list_add (resolve2_list, app); } filter = pk_bitfield_from_enums (PK_FILTER_ENUM_NEWEST, PK_FILTER_ENUM_NOT_ARCH, PK_FILTER_ENUM_NOT_SOURCE, -1); gs_plugin_packagekit_resolve_packages_with_filter_async (self, data->client_refine, resolve2_list, filter, cancellable, resolve_all_packages_with_filter_cb2, g_steal_pointer (&refine_task)); } static void resolve_all_packages_with_filter_cb2 (GObject *source_object, GAsyncResult *result, gpointer user_data) { GsPluginPackagekit *self = GS_PLUGIN_PACKAGEKIT (source_object); g_autoptr(GTask) refine_task = g_steal_pointer (&user_data); g_autoptr(GError) local_error = NULL; if (!gs_plugin_packagekit_resolve_packages_with_filter_finish (self, result, &local_error)) { refine_task_complete_operation_with_error (refine_task, g_steal_pointer (&local_error)); return; } refine_task_complete_operation (refine_task); } static void search_files_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { PkClient *client = PK_CLIENT (source_object); g_autoptr(SearchFilesData) search_files_data = g_steal_pointer (&user_data); GTask *refine_task = search_files_data->refine_task; GsPluginPackagekit *self = GS_PLUGIN_PACKAGEKIT (g_task_get_source_object (refine_task)); g_autoptr(PkResults) results = NULL; g_autoptr(GPtrArray) packages = NULL; g_autoptr(GError) local_error = NULL; results = pk_client_generic_finish (client, result, &local_error); if (!gs_plugin_packagekit_results_valid (results, g_task_get_cancellable (refine_task), &local_error)) { g_prefix_error_literal (&local_error, "failed to search files: "); refine_task_complete_operation_with_error (refine_task, g_steal_pointer (&local_error)); return; } /* get results */ packages = pk_results_get_package_array (results); if (search_files_data->app != NULL) { if (packages->len == 1) { PkPackage *package; package = g_ptr_array_index (packages, 0); gs_plugin_packagekit_set_metadata_from_package (GS_PLUGIN (self), search_files_data->app, package); } else { g_debug ("%s: Failed to find one package for %s, [%u]", G_STRFUNC, gs_app_get_id (search_files_data->app), packages->len); } } else { for (guint ii = 0; ii < packages->len; ii++) { PkPackage *package = g_ptr_array_index (packages, ii); GsApp *app; if (pk_package_get_name (package) == NULL) continue; app = g_hash_table_lookup (search_files_data->source_to_app, pk_package_get_name (package)); if (app != NULL) gs_plugin_packagekit_set_metadata_from_package (GS_PLUGIN (self), app, package); else g_debug ("%s: Failed to find app for package id '%s'", G_STRFUNC, pk_package_get_id (package)); } if (packages->len != search_files_data->n_expected_results) { g_debug ("%s: Failed to find package data for each of %u apps, received %u packages instead", G_STRFUNC, search_files_data->n_expected_results, packages->len); } else { g_debug ("%s: Received package data for all %u apps", G_STRFUNC, packages->len); } } refine_task_complete_operation (refine_task); } static void get_update_detail_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { PkClient *client = PK_CLIENT (source_object); g_autoptr(GTask) refine_task = g_steal_pointer (&user_data); GsPlugin *plugin = GS_PLUGIN (g_task_get_source_object (refine_task)); RefineData *data = g_task_get_task_data (refine_task); g_autoptr(PkResults) results = NULL; g_autoptr(GPtrArray) array = NULL; g_autoptr(GError) local_error = NULL; gboolean is_markdown_desc; results = pk_client_generic_finish (client, result, &local_error); if (!gs_plugin_packagekit_results_valid (results, g_task_get_cancellable (refine_task), &local_error)) { g_prefix_error (&local_error, "failed to get update details: "); refine_task_complete_operation_with_error (refine_task, g_steal_pointer (&local_error)); return; } /* * Only Fedora and RHEL (PackageKit DNF backend) are known to * provide update descriptions in markdown format. Other * distros if any should be added below in future. For more * details, refer: * * - https://gitlab.gnome.org/GNOME/gnome-software/-/issues/2621 * - https://github.com/PackageKit/PackageKit/issues/828 * */ is_markdown_desc = (gs_plugin_check_distro_id (plugin, "fedora") || gs_plugin_check_distro_id (plugin, "rhel")); /* set the update details for the update */ array = pk_results_get_update_detail_array (results); for (guint j = 0; j < gs_app_list_length (data->update_details_list); j++) { GsApp *app = gs_app_list_index (data->update_details_list, j); const gchar *package_id = gs_app_get_source_id_default (app); for (guint i = 0; i < array->len; i++) { const gchar *tmp; PkUpdateDetail *update_detail; g_autofree gchar *pango_desc = NULL; /* right package? */ update_detail = g_ptr_array_index (array, i); if (g_strcmp0 (package_id, pk_update_detail_get_package_id (update_detail)) != 0) continue; tmp = pk_update_detail_get_update_text (update_detail); if (tmp == NULL || *tmp == '\0') break; if (is_markdown_desc) pango_desc = markdown_to_pango (tmp); if (pango_desc != NULL && *pango_desc != '\0') gs_app_set_update_details_markup (app, pango_desc); else gs_app_set_update_details_text (app, tmp); } } refine_task_complete_operation (refine_task); } static void get_details_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { PkClient *client = PK_CLIENT (source_object); g_autoptr(GTask) refine_task = g_steal_pointer (&user_data); GsPluginPackagekit *self = GS_PLUGIN_PACKAGEKIT (g_task_get_source_object (refine_task)); RefineData *data = g_task_get_task_data (refine_task); g_autoptr(GPtrArray) array = NULL; g_autoptr(PkResults) results = NULL; g_autoptr(GHashTable) details_collection = NULL; g_autoptr(GHashTable) prepared_updates = NULL; g_autoptr(GError) local_error = NULL; results = pk_client_generic_finish (client, result, &local_error); if (!gs_plugin_packagekit_results_valid (results, g_task_get_cancellable (refine_task), &local_error)) { g_autoptr(GPtrArray) package_ids = app_list_get_package_ids (data->details_list, NULL, FALSE); g_autofree gchar *package_ids_str = NULL; /* NULL-terminate the array */ g_ptr_array_add (package_ids, NULL); package_ids_str = g_strjoinv (",", (gchar **) package_ids->pdata); g_prefix_error (&local_error, "failed to get details for %s: ", package_ids_str); refine_task_complete_operation_with_error (refine_task, g_steal_pointer (&local_error)); return; } /* get the results and copy them into a hash table for fast lookups: * there are typically 400 to 700 elements in @array, and 100 to 200 * elements in @list, each with 1 or 2 source IDs to look up (but * sometimes 200) */ array = pk_results_get_details_array (results); details_collection = gs_plugin_packagekit_details_array_to_hash (array); /* set the update details for the update */ g_mutex_lock (&self->prepared_updates_mutex); prepared_updates = g_hash_table_ref (self->prepared_updates); g_mutex_unlock (&self->prepared_updates_mutex); for (guint i = 0; i < gs_app_list_length (data->details_list); i++) { GsApp *app = gs_app_list_index (data->details_list, i); gs_plugin_packagekit_refine_details_app (GS_PLUGIN (self), details_collection, prepared_updates, app); } refine_task_complete_operation (refine_task); } static void get_updates_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { PkClient *client = PK_CLIENT (source_object); g_autoptr(GTask) refine_task = g_steal_pointer (&user_data); RefineData *data = g_task_get_task_data (refine_task); g_autoptr(PkPackageSack) sack = NULL; g_autoptr(PkResults) results = NULL; g_autoptr(GError) local_error = NULL; results = pk_client_generic_finish (client, result, &local_error); if (!gs_plugin_packagekit_results_valid (results, g_task_get_cancellable (refine_task), &local_error)) { g_prefix_error (&local_error, "failed to get updates for urgency: "); refine_task_complete_operation_with_error (refine_task, g_steal_pointer (&local_error)); return; } /* set the update severity for the app */ sack = pk_results_get_package_sack (results); for (guint i = 0; i < gs_app_list_length (data->full_list); i++) { g_autoptr(PkPackage) pkg = NULL; const gchar *package_id; GsApp *app = gs_app_list_index (data->full_list, i); if (gs_app_has_quirk (app, GS_APP_QUIRK_IS_WILDCARD)) continue; package_id = gs_app_get_source_id_default (app); if (package_id == NULL) continue; pkg = pk_package_sack_find_by_id (sack, package_id); if (pkg == NULL) continue; switch (pk_package_get_update_severity (pkg)) { case PK_INFO_ENUM_LOW: gs_app_set_update_urgency (app, AS_URGENCY_KIND_LOW); break; case PK_INFO_ENUM_NORMAL: gs_app_set_update_urgency (app, AS_URGENCY_KIND_MEDIUM); break; case PK_INFO_ENUM_IMPORTANT: gs_app_set_update_urgency (app, AS_URGENCY_KIND_HIGH); break; case PK_INFO_ENUM_CRITICAL: gs_app_set_update_urgency (app, AS_URGENCY_KIND_CRITICAL); break; default: gs_app_set_update_urgency (app, AS_URGENCY_KIND_UNKNOWN); break; } } refine_task_complete_operation (refine_task); } static void refine_all_history_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { GsPluginPackagekit *self = GS_PLUGIN_PACKAGEKIT (source_object); g_autoptr(GTask) refine_task = g_steal_pointer (&user_data); g_autoptr(GError) local_error = NULL; if (!gs_plugin_packagekit_refine_history_finish (self, result, &local_error)) { refine_task_complete_operation_with_error (refine_task, g_steal_pointer (&local_error)); return; } refine_task_complete_operation (refine_task); } static void gs_plugin_packagekit_refine_add_history (GsApp *app, GVariant *dict) { const gchar *version; gboolean ret; guint64 timestamp; PkInfoEnum info_enum; g_autoptr(GsApp) history = NULL; /* create new history item with same ID as parent */ history = gs_app_new (gs_app_get_id (app)); gs_app_set_kind (history, AS_COMPONENT_KIND_GENERIC); gs_app_set_bundle_kind (app, AS_BUNDLE_KIND_PACKAGE); gs_app_set_name (history, GS_APP_QUALITY_NORMAL, gs_app_get_name (app)); /* get the installed state */ ret = g_variant_lookup (dict, "info", "u", &info_enum); g_assert (ret); switch (info_enum) { case PK_INFO_ENUM_INSTALLING: gs_app_set_state (history, GS_APP_STATE_INSTALLED); break; case PK_INFO_ENUM_REMOVING: gs_app_set_state (history, GS_APP_STATE_AVAILABLE); break; case PK_INFO_ENUM_UPDATING: gs_app_set_state (history, GS_APP_STATE_UPDATABLE); break; default: g_debug ("ignoring history kind: %s", pk_info_enum_to_string (info_enum)); return; } /* set the history time and date */ ret = g_variant_lookup (dict, "timestamp", "t", ×tamp); g_assert (ret); gs_app_set_install_date (history, timestamp); /* set the history version number */ ret = g_variant_lookup (dict, "version", "&s", &version); g_assert (ret); gs_app_set_version (history, version); /* add the package to the main application */ gs_app_add_history (app, history); /* use the last event as approximation of the package timestamp */ gs_app_set_install_date (app, timestamp); } /* Run in the main thread. */ static void gs_plugin_packagekit_permission_cb (GPermission *permission, GParamSpec *pspec, gpointer data) { GsPlugin *plugin = GS_PLUGIN (data); gboolean ret = g_permission_get_allowed (permission) || g_permission_get_can_acquire (permission); gs_plugin_set_allow_updates (plugin, ret); } static void gs_plugin_packagekit_download_async (GsPluginPackagekit *self, GsAppList *list, gboolean interactive, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data); static gboolean gs_plugin_packagekit_download_finish (GsPluginPackagekit *self, GAsyncResult *result, GError **error); static void async_result_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { GAsyncResult **result_out = user_data; g_assert (result_out != NULL && *result_out == NULL); *result_out = g_object_ref (result); g_main_context_wakeup (g_main_context_get_thread_default ()); } static void gs_plugin_packagekit_auto_prepare_update_thread (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable) { GsPluginPackagekit *self = GS_PLUGIN_PACKAGEKIT (source_object); g_autoptr(GsAppList) list = NULL; g_autoptr(GError) local_error = NULL; gboolean interactive = gs_plugin_has_flags (GS_PLUGIN (self), GS_PLUGIN_FLAGS_INTERACTIVE); list = gs_app_list_new (); if (!gs_plugin_packagekit_add_updates (GS_PLUGIN (self), list, cancellable, &local_error)) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } if (gs_app_list_length (list) > 0) { g_autoptr(GMainContext) context = g_main_context_new (); g_autoptr(GMainContextPusher) pusher = g_main_context_pusher_new (context); g_autoptr(GAsyncResult) result = NULL; gs_plugin_packagekit_download_async (self, list, interactive, cancellable, async_result_cb, &result); while (result == NULL) g_main_context_iteration (context, TRUE); if (!gs_plugin_packagekit_download_finish (self, result, &local_error)) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } } /* Ignore errors here */ gs_plugin_systemd_update_cache (self, cancellable, NULL); g_task_return_boolean (task, TRUE); } static void gs_plugin_packagekit_auto_prepare_update_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { g_autoptr(GError) local_error = NULL; if (g_task_propagate_boolean (G_TASK (result), &local_error)) { g_debug ("Successfully auto-prepared update"); gs_plugin_updates_changed (GS_PLUGIN (source_object)); } else { g_debug ("Failed to auto-prepare update: %s", local_error->message); } } static gboolean gs_plugin_packagekit_run_prepare_update_cb (gpointer user_data) { GsPluginPackagekit *self = user_data; g_autoptr(GTask) task = NULL; self->prepare_update_timeout_id = 0; g_debug ("Going to auto-prepare update"); task = g_task_new (self, self->proxy_settings_cancellable, gs_plugin_packagekit_auto_prepare_update_cb, NULL); g_task_set_source_tag (task, gs_plugin_packagekit_run_prepare_update_cb); g_task_run_in_thread (task, gs_plugin_packagekit_auto_prepare_update_thread); return G_SOURCE_REMOVE; } /* Run in the main thread. */ static void gs_plugin_packagekit_prepared_update_changed_cb (GFileMonitor *monitor, GFile *file, GFile *other_file, GFileMonitorEvent event_type, gpointer user_data) { GsPluginPackagekit *self = GS_PLUGIN_PACKAGEKIT (user_data); /* Interested only in these events. */ if (event_type != G_FILE_MONITOR_EVENT_CHANGED && event_type != G_FILE_MONITOR_EVENT_DELETED && event_type != G_FILE_MONITOR_EVENT_CREATED) return; /* This is going to break, if PackageKit renames the file, but it's unlikely to happen; there is no API to get the file name from, sadly. */ if (g_file_peek_path (file) == NULL || !g_str_has_suffix (g_file_peek_path (file), "prepared-update")) return; if (event_type == G_FILE_MONITOR_EVENT_DELETED) { g_autoptr(GSettings) settings = g_settings_new ("org.gnome.software"); if (g_settings_get_boolean (settings, "download-updates")) { /* The prepared-update file had been removed, but the user has set to have the updates downloaded, thus prepared, thus prepare the update again. */ if (self->prepare_update_timeout_id) g_source_remove (self->prepare_update_timeout_id); g_debug ("Scheduled to auto-prepare update in %d s", PREPARE_UPDATE_TIMEOUT_SECS); self->prepare_update_timeout_id = g_timeout_add_seconds (PREPARE_UPDATE_TIMEOUT_SECS, gs_plugin_packagekit_run_prepare_update_cb, self); } else { if (self->prepare_update_timeout_id) { g_source_remove (self->prepare_update_timeout_id); self->prepare_update_timeout_id = 0; g_debug ("Cancelled auto-prepare update"); } } } else if (self->prepare_update_timeout_id) { g_source_remove (self->prepare_update_timeout_id); self->prepare_update_timeout_id = 0; g_debug ("Cancelled auto-prepare update"); } /* update UI */ gs_plugin_systemd_update_cache (self, NULL, NULL); gs_plugin_updates_changed (GS_PLUGIN (self)); } static void gs_plugin_packagekit_refresh_is_triggered (GsPluginPackagekit *self, GCancellable *cancellable) { g_autoptr(GFile) file_trigger = NULL; file_trigger = g_file_new_for_path ("/system-update"); self->is_triggered = g_file_query_exists (file_trigger, NULL); g_debug ("offline trigger is now %s", self->is_triggered ? "enabled" : "disabled"); } /* Run in the main thread. */ static void gs_plugin_systemd_trigger_changed_cb (GFileMonitor *monitor, GFile *file, GFile *other_file, GFileMonitorEvent event_type, gpointer user_data) { GsPluginPackagekit *self = GS_PLUGIN_PACKAGEKIT (user_data); gs_plugin_packagekit_refresh_is_triggered (self, NULL); } static void setup_proxy_settings_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void get_offline_update_permission_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void gs_plugin_packagekit_get_properties_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { PkControl *control = PK_CONTROL (source_object); g_autoptr(GError) error = NULL; if (pk_control_get_properties_finish (control, result, &error)) { guint32 major, minor, micro; g_autoptr(GString) string = g_string_new (NULL); g_object_get (control, "version_major", &major, "version_minor", &minor, "version_micro", µ, NULL); g_string_append_printf (string, "PackageKit version: %u.%u.%u", major, minor, micro); if (major != PK_MAJOR_VERSION || minor != PK_MINOR_VERSION || micro != PK_MICRO_VERSION) { g_string_append_printf (string, " (build version: %d.%d.%d)", PK_MAJOR_VERSION, PK_MINOR_VERSION, PK_MICRO_VERSION); } g_debug ("%s", string->str); } else { g_debug ("Failed to get PackageKit properties: %s (build version: %d.%d.%d)", (error ? error->message : "Unknown error"), PK_MAJOR_VERSION, PK_MINOR_VERSION, PK_MICRO_VERSION); } } static void gs_plugin_packagekit_setup_async (GsPlugin *plugin, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { GsPluginPackagekit *self = GS_PLUGIN_PACKAGEKIT (plugin); g_autoptr(GTask) task = NULL; /* print real packagekit version, no need to wait for it */ pk_control_get_properties_async (self->control_proxy, cancellable, gs_plugin_packagekit_get_properties_cb, NULL); task = g_task_new (plugin, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_packagekit_setup_async); reload_proxy_settings_async (self, cancellable, setup_proxy_settings_cb, g_steal_pointer (&task)); } static void setup_proxy_settings_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { g_autoptr(GTask) task = g_steal_pointer (&user_data); GsPluginPackagekit *self = g_task_get_source_object (task); GCancellable *cancellable = g_task_get_cancellable (task); g_autoptr(GFile) file_trigger = NULL; g_autoptr(GError) local_error = NULL; if (!reload_proxy_settings_finish (self, result, &local_error)) g_warning ("Failed to load proxy settings: %s", local_error->message); g_clear_error (&local_error); /* watch the prepared file */ self->monitor = pk_offline_get_prepared_monitor (cancellable, &local_error); if (self->monitor == NULL) { g_debug ("Failed to get prepared update file monitor: %s", local_error->message); gs_utils_error_convert_gio (&local_error); g_task_return_error (task, g_steal_pointer (&local_error)); return; } g_signal_connect (self->monitor, "changed", G_CALLBACK (gs_plugin_packagekit_prepared_update_changed_cb), self); /* watch the trigger file */ file_trigger = g_file_new_for_path ("/system-update"); self->monitor_trigger = g_file_monitor_file (file_trigger, G_FILE_MONITOR_NONE, NULL, &local_error); if (self->monitor_trigger == NULL) { gs_utils_error_convert_gio (&local_error); g_task_return_error (task, g_steal_pointer (&local_error)); return; } g_signal_connect (self->monitor_trigger, "changed", G_CALLBACK (gs_plugin_systemd_trigger_changed_cb), self); /* check if we have permission to trigger offline updates */ gs_utils_get_permission_async ("org.freedesktop.packagekit.trigger-offline-update", cancellable, get_offline_update_permission_cb, g_steal_pointer (&task)); } static void get_offline_update_permission_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { g_autoptr(GTask) task = g_steal_pointer (&user_data); GsPluginPackagekit *self = g_task_get_source_object (task); g_autoptr(GError) local_error = NULL; self->permission = gs_utils_get_permission_finish (result, &local_error); if (self->permission != NULL) { g_signal_connect (self->permission, "notify", G_CALLBACK (gs_plugin_packagekit_permission_cb), self); } /* get the list of currently downloaded packages */ if (!gs_plugin_systemd_update_cache (self, g_task_get_cancellable (task), &local_error)) g_task_return_error (task, g_steal_pointer (&local_error)); else g_task_return_boolean (task, TRUE); } static gboolean gs_plugin_packagekit_setup_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } static void gs_plugin_packagekit_shutdown_async (GsPlugin *plugin, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { GsPluginPackagekit *self = GS_PLUGIN_PACKAGEKIT (plugin); g_autoptr(GTask) task = NULL; task = g_task_new (plugin, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_packagekit_shutdown_async); /* Cancel any ongoing proxy settings loading operation. */ g_cancellable_cancel (self->proxy_settings_cancellable); g_task_return_boolean (task, TRUE); } static gboolean gs_plugin_packagekit_shutdown_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } static void refine_history_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void gs_plugin_packagekit_refine_history_async (GsPluginPackagekit *self, GsAppList *list, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { GsApp *app; g_autofree const gchar **package_names = NULL; g_autoptr(GTask) task = NULL; task = g_task_new (self, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_packagekit_refine_history_async); g_task_set_task_data (task, g_object_ref (list), (GDestroyNotify) g_object_unref); /* get an array of package names */ package_names = g_new0 (const gchar *, gs_app_list_length (list) + 1); for (guint i = 0; i < gs_app_list_length (list); i++) { app = gs_app_list_index (list, i); package_names[i] = gs_app_get_source_default (app); } g_debug ("getting history for %u packages", gs_app_list_length (list)); g_dbus_connection_call (gs_plugin_get_system_bus_connection (GS_PLUGIN (self)), "org.freedesktop.PackageKit", "/org/freedesktop/PackageKit", "org.freedesktop.PackageKit", "GetPackageHistory", g_variant_new ("(^asu)", package_names, 0), NULL, G_DBUS_CALL_FLAGS_NONE, GS_PLUGIN_PACKAGEKIT_HISTORY_TIMEOUT, cancellable, refine_history_cb, g_steal_pointer (&task)); } static void refine_history_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { GDBusConnection *connection = G_DBUS_CONNECTION (source_object); g_autoptr(GTask) task = g_steal_pointer (&user_data); GsPluginPackagekit *self = g_task_get_source_object (task); GsPlugin *plugin = GS_PLUGIN (self); GsAppList *list = g_task_get_task_data (task); gboolean ret; guint i = 0; GVariantIter iter; GVariant *value; g_autoptr(GVariant) result_variant = NULL; g_autoptr(GVariant) tuple = NULL; g_autoptr(GError) error_local = NULL; result_variant = g_dbus_connection_call_finish (connection, result, &error_local); if (result_variant == NULL) { g_dbus_error_strip_remote_error (error_local); if (g_error_matches (error_local, G_DBUS_ERROR, G_DBUS_ERROR_UNKNOWN_METHOD)) { g_debug ("No history available as PackageKit is too old: %s", error_local->message); /* just set this to something non-zero so we don't keep * trying to call GetPackageHistory */ for (i = 0; i < gs_app_list_length (list); i++) { GsApp *app = gs_app_list_index (list, i); gs_app_set_install_date (app, GS_APP_INSTALL_DATE_UNKNOWN); } } else if (g_error_matches (error_local, G_IO_ERROR, G_IO_ERROR_CANCELLED)) { g_task_return_new_error (task, GS_PLUGIN_ERROR, GS_PLUGIN_ERROR_CANCELLED, "Failed to get history: %s", error_local->message); return; } else if (g_error_matches (error_local, G_IO_ERROR, G_IO_ERROR_TIMED_OUT)) { g_debug ("No history as PackageKit took too long: %s", error_local->message); for (i = 0; i < gs_app_list_length (list); i++) { GsApp *app = gs_app_list_index (list, i); gs_app_set_install_date (app, GS_APP_INSTALL_DATE_UNKNOWN); } } g_task_return_new_error (task, GS_PLUGIN_ERROR, GS_PLUGIN_ERROR_NOT_SUPPORTED, "Failed to get history: %s", error_local->message); return; } /* get any results */ tuple = g_variant_get_child_value (result_variant, 0); for (i = 0; i < gs_app_list_length (list); i++) { g_autoptr(GVariant) entries = NULL; GsApp *app = gs_app_list_index (list, i); ret = g_variant_lookup (tuple, gs_app_get_source_default (app), "@aa{sv}", &entries); if (!ret) { /* make up a fake entry as we know this package was at * least installed at some point in time */ if (gs_app_get_state (app) == GS_APP_STATE_INSTALLED) { g_autoptr(GsApp) app_dummy = NULL; app_dummy = gs_app_new (gs_app_get_id (app)); gs_plugin_packagekit_set_packaging_format (plugin, app); gs_app_set_metadata (app_dummy, "GnomeSoftware::Creator", gs_plugin_get_name (plugin)); gs_app_set_install_date (app_dummy, GS_APP_INSTALL_DATE_UNKNOWN); gs_app_set_kind (app_dummy, AS_COMPONENT_KIND_GENERIC); gs_app_set_state (app_dummy, GS_APP_STATE_INSTALLED); gs_app_set_version (app_dummy, gs_app_get_version (app)); gs_app_add_history (app, app_dummy); } gs_app_set_install_date (app, GS_APP_INSTALL_DATE_UNKNOWN); continue; } /* add history for application */ g_variant_iter_init (&iter, entries); while ((value = g_variant_iter_next_value (&iter))) { gs_plugin_packagekit_refine_add_history (app, value); g_variant_unref (value); } } g_task_return_boolean (task, TRUE); } static gboolean gs_plugin_packagekit_refine_history_finish (GsPluginPackagekit *self, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } static void add_quirks_from_package_name (GsApp *app, const gchar *package_name) { /* these packages don't have a .repo file in their file lists, but * instead install one through rpm scripts / cron job */ const gchar *packages_with_repos[] = { "google-chrome-stable", "google-earth-pro-stable", "google-talkplugin", NULL }; if (g_strv_contains (packages_with_repos, package_name)) gs_app_add_quirk (app, GS_APP_QUIRK_HAS_SOURCE); } typedef struct { GFile *file; /* (not nullable) (owned) */ GsPluginFileToAppFlags flags; GsApp *app; /* (nullable) (owned) */ } FileToAppData; static void file_to_app_data_free (FileToAppData *data) { g_clear_object (&data->file); g_clear_object (&data->app); g_free (data); } G_DEFINE_AUTOPTR_CLEANUP_FUNC (FileToAppData, file_to_app_data_free) static void file_to_app_get_content_type_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void file_to_app_get_details_local_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void file_to_app_resolve_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void file_to_app_get_files_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void gs_plugin_packagekit_file_to_app_async (GsPlugin *plugin, GFile *file, GsPluginFileToAppFlags flags, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { g_autoptr(GTask) task = NULL; g_autoptr(FileToAppData) data = NULL; task = g_task_new (plugin, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_packagekit_file_to_app_async); data = g_new0 (FileToAppData, 1); data->file = g_object_ref (file); data->flags = flags; g_task_set_task_data (task, g_steal_pointer (&data), (GDestroyNotify) file_to_app_data_free); /* does this match any of the mimetypes we support */ gs_utils_get_content_type_async (file, cancellable, file_to_app_get_content_type_cb, g_steal_pointer (&task)); } static void file_to_app_get_content_type_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { GFile *file = G_FILE (source_object); g_autoptr(GTask) task = G_TASK (g_steal_pointer (&user_data)); g_autoptr(GError) local_error = NULL; GsPlugin *plugin = g_task_get_source_object (task); FileToAppData *data = g_task_get_task_data (task); GCancellable *cancellable = g_task_get_cancellable (task); gboolean interactive = (data->flags & GS_PLUGIN_FILE_TO_APP_FLAGS_INTERACTIVE); g_autoptr(GsPackagekitHelper) helper = NULL; g_autoptr(PkTask) task_local = NULL; g_autofree char *content_type = NULL; g_autofree char *filename = NULL; g_auto(GStrv) files = NULL; const gchar *mimetypes[] = { "application/x-app-package", "application/x-deb", "application/vnd.debian.binary-package", "application/x-redhat-package-manager", "application/x-rpm", NULL }; /* does this match any of the mimetypes we support */ content_type = gs_utils_get_content_type_finish (file, result, &local_error); if (content_type == NULL) { gs_utils_error_convert_gio (&local_error); g_task_return_error (task, g_steal_pointer (&local_error)); return; } else if (!g_strv_contains (mimetypes, content_type)) { g_task_return_pointer (task, gs_app_list_new (), g_object_unref); return; } /* get details */ filename = g_file_get_path (file); files = g_strsplit (filename, "\t", -1); task_local = gs_packagekit_task_new (plugin); helper = gs_packagekit_helper_new (plugin); pk_client_set_cache_age (PK_CLIENT (task_local), G_MAXUINT); gs_packagekit_task_setup (GS_PACKAGEKIT_TASK (task_local), GS_PACKAGEKIT_TASK_QUESTION_TYPE_NONE, interactive); gs_packagekit_task_take_helper (GS_PACKAGEKIT_TASK (task_local), helper); pk_client_get_details_local_async (PK_CLIENT (task_local), files, cancellable, gs_packagekit_helper_cb, g_steal_pointer (&helper), file_to_app_get_details_local_cb, g_steal_pointer (&task)); } static void file_to_app_get_details_local_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { PkTask *task_local = PK_TASK (source_object); g_autoptr(GTask) task = G_TASK (g_steal_pointer (&user_data)); g_autoptr(GError) local_error = NULL; GsPlugin *plugin = g_task_get_source_object (task); FileToAppData *data = g_task_get_task_data (task); GCancellable *cancellable = g_task_get_cancellable (task); const gchar *package_id; PkDetails *item; g_autoptr(PkResults) results = NULL; g_autofree gchar *filename = NULL; g_autofree gchar *packagename = NULL; g_auto(GStrv) split = NULL; g_autoptr(GPtrArray) array = NULL; g_autoptr(GsApp) app = NULL; PkBitfield filter; const gchar *names[2] = { NULL, }; results = pk_client_generic_finish (PK_CLIENT (source_object), result, &local_error); if (local_error != NULL || !gs_plugin_packagekit_results_valid (results, cancellable, &local_error)) { g_prefix_error (&local_error, "Failed to resolve package_ids: "); gs_plugin_packagekit_error_convert (&local_error, cancellable); g_task_return_error (task, g_steal_pointer (&local_error)); return; } /* get results */ filename = g_file_get_path (data->file); array = pk_results_get_details_array (results); if (array->len == 0) { g_task_return_new_error (task, GS_PLUGIN_ERROR, GS_PLUGIN_ERROR_INVALID_FORMAT, "No details for %s", filename); return; } else if (array->len > 1) { g_task_return_new_error (task, GS_PLUGIN_ERROR, GS_PLUGIN_ERROR_INVALID_FORMAT, "Too many details [%u] for %s", array->len, filename); return; } /* create application */ item = g_ptr_array_index (array, 0); app = gs_app_new (NULL); gs_plugin_packagekit_set_packaging_format (plugin, app); gs_app_set_metadata (app, "GnomeSoftware::Creator", gs_plugin_get_name (plugin)); package_id = pk_details_get_package_id (item); split = pk_package_id_split (package_id); if (split == NULL) { g_task_return_new_error (task, GS_PLUGIN_ERROR, GS_PLUGIN_ERROR_INVALID_FORMAT, "Invalid package-id: %s", package_id); return; } gs_app_set_management_plugin (app, plugin); gs_app_set_kind (app, AS_COMPONENT_KIND_GENERIC); gs_app_set_bundle_kind (app, AS_BUNDLE_KIND_PACKAGE); gs_app_set_state (app, GS_APP_STATE_AVAILABLE_LOCAL); gs_app_set_local_file (app, data->file); gs_app_set_name (app, GS_APP_QUALITY_LOWEST, split[PK_PACKAGE_ID_NAME]); gs_app_set_summary (app, GS_APP_QUALITY_LOWEST, pk_details_get_summary (item)); gs_app_set_version (app, split[PK_PACKAGE_ID_VERSION]); gs_app_add_source (app, split[PK_PACKAGE_ID_NAME]); gs_app_add_source_id (app, package_id); gs_app_set_description (app, GS_APP_QUALITY_LOWEST, pk_details_get_description (item)); gs_app_set_url (app, AS_URL_KIND_HOMEPAGE, pk_details_get_url (item)); gs_app_set_size_installed (app, GS_SIZE_TYPE_VALID, pk_details_get_size (item)); gs_app_set_size_download (app, GS_SIZE_TYPE_VALID, 0); if (pk_details_get_license (item) != NULL && g_ascii_strcasecmp (pk_details_get_license (item), "unknown") != 0) { g_autofree gchar *license_spdx = NULL; license_spdx = as_license_to_spdx_id (pk_details_get_license (item)); if (license_spdx != NULL && g_ascii_strcasecmp (license_spdx, "unknown") == 0) { g_clear_pointer (&license_spdx, g_free); license_spdx = g_strdup (pk_details_get_license (item)); if (license_spdx != NULL) g_strstrip (license_spdx); } gs_app_set_license (app, GS_APP_QUALITY_LOWEST, license_spdx); } add_quirks_from_package_name (app, split[PK_PACKAGE_ID_NAME]); packagename = g_strdup_printf ("%s-%s.%s", split[PK_PACKAGE_ID_NAME], split[PK_PACKAGE_ID_VERSION], split[PK_PACKAGE_ID_ARCH]); gs_app_set_metadata (app, "GnomeSoftware::packagename-value", packagename); data->app = g_steal_pointer (&app); /* is already installed? */ names[0] = gs_app_get_source_default (data->app); filter = pk_bitfield_from_enums (PK_FILTER_ENUM_NEWEST, PK_FILTER_ENUM_ARCH, PK_FILTER_ENUM_INSTALLED, -1); pk_client_resolve_async (PK_CLIENT (task_local), filter, (gchar **) names, cancellable, NULL, NULL, file_to_app_resolve_cb, g_steal_pointer (&task)); } static void file_to_app_resolve_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { PkTask *task_local = PK_TASK (source_object); g_autoptr(GTask) task = G_TASK (g_steal_pointer (&user_data)); g_autoptr(GError) local_error = NULL; FileToAppData *data = g_task_get_task_data (task); GCancellable *cancellable = g_task_get_cancellable (task); GsPackagekitHelper *helper; g_autoptr(PkResults) results = NULL; g_autofree gchar *filename = NULL; g_auto(GStrv) files = NULL; g_autoptr(GPtrArray) packages = NULL; results = pk_client_generic_finish (PK_CLIENT (source_object), result, &local_error); if (local_error != NULL || !gs_plugin_packagekit_results_valid (results, cancellable, &local_error)) { g_prefix_error (&local_error, "Failed to resolve whether package is installed: "); gs_plugin_packagekit_error_convert (&local_error, cancellable); g_task_return_error (task, g_steal_pointer (&local_error)); return; } packages = pk_results_get_package_array (results); if (packages->len > 0) { gboolean is_higher_version = FALSE; const gchar *app_version = gs_app_get_version (data->app); for (guint i = 0; i < packages->len; i++){ PkPackage *pkg = g_ptr_array_index (packages, i); gs_app_add_source_id (data->app, pk_package_get_id (pkg)); gs_plugin_packagekit_set_package_name (data->app, pkg); if (!is_higher_version && gs_utils_compare_versions (pk_package_get_version (pkg), app_version) < 0) is_higher_version = TRUE; } if (!is_higher_version) { gs_app_set_state (data->app, GS_APP_STATE_UNKNOWN); gs_app_set_state (data->app, GS_APP_STATE_INSTALLED); } } /* look for a desktop file so we can use a valid application id */ filename = g_file_get_path (data->file); /* get file list so we can work out ID */ files = g_strsplit (filename, "\t", -1); helper = gs_packagekit_task_get_helper (GS_PACKAGEKIT_TASK (task_local)); gs_packagekit_helper_add_app (helper, data->app); pk_client_get_files_local_async (PK_CLIENT (task_local), files, cancellable, gs_packagekit_helper_cb, helper, file_to_app_get_files_cb, g_steal_pointer (&task)); } static void file_to_app_get_files_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { g_autoptr(GTask) task = G_TASK (g_steal_pointer (&user_data)); g_autoptr(GsAppList) list = gs_app_list_new (); g_autoptr(GError) local_error = NULL; FileToAppData *data = g_task_get_task_data (task); GCancellable *cancellable = g_task_get_cancellable (task); g_autoptr(PkResults) results = NULL; g_autofree char *filename = NULL; g_autoptr(GPtrArray) array = NULL; g_autoptr(GString) basename_best = g_string_new (NULL); results = pk_client_generic_finish (PK_CLIENT (source_object), result, &local_error); if (local_error != NULL || !gs_plugin_packagekit_results_valid (results, cancellable, &local_error)) { gs_utils_error_add_origin_id (&local_error, data->app); g_prefix_error (&local_error, "Failed to resolve files in local package: "); gs_plugin_packagekit_error_convert (&local_error, cancellable); g_task_return_error (task, g_steal_pointer (&local_error)); return; } filename = g_file_get_path (data->file); array = pk_results_get_files_array (results); if (array->len == 0) { g_task_return_new_error (task, GS_PLUGIN_ERROR, GS_PLUGIN_ERROR_INVALID_FORMAT, "No files for %s", filename); return; } /* find the smallest length desktop file, on the logic that * ${app}.desktop is going to be better than ${app}-${action}.desktop */ for (guint i = 0; i < array->len; i++) { PkFiles *item = g_ptr_array_index (array, i); const char * const *fns = (const char * const *) pk_files_get_files (item); for (guint j = 0; fns[j] != NULL; j++) { if (g_str_has_prefix (fns[j], "/etc/yum.repos.d/") && g_str_has_suffix (fns[j], ".repo")) { gs_app_add_quirk (data->app, GS_APP_QUIRK_HAS_SOURCE); } if (g_str_has_prefix (fns[j], "/usr/share/applications/") && g_str_has_suffix (fns[j], ".desktop")) { g_autofree gchar *basename = g_path_get_basename (fns[j]); if (basename_best->len == 0 || strlen (basename) < basename_best->len) g_string_assign (basename_best, basename); } } } if (basename_best->len > 0) { gs_app_set_kind (data->app, AS_COMPONENT_KIND_DESKTOP_APP); gs_app_set_id (data->app, basename_best->str); } /* Success */ gs_app_list_add (list, data->app); g_task_return_pointer (task, g_steal_pointer (&list), g_object_unref); } static GsAppList * gs_plugin_packagekit_file_to_app_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_pointer (G_TASK (result), error); } static void gs_plugin_packagekit_url_to_app_resolved_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void gs_plugin_packagekit_url_to_app_async (GsPlugin *plugin, const gchar *url, GsPluginUrlToAppFlags flags, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { g_auto(GStrv) package_ids = NULL; g_autoptr(GsOsRelease) os_release = NULL; g_autoptr(GsPackagekitHelper) helper = NULL; g_autoptr(PkTask) task_resolve = NULL; g_autoptr(GTask) task = NULL; g_autoptr(GError) local_error = 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_packagekit_url_to_app_async); /* only do this for apt:// on debian or debian-like distros */ os_release = gs_os_release_new (&local_error); if (os_release == NULL) { g_prefix_error_literal (&local_error, "Failed to determine OS information: "); g_task_return_error (task, g_steal_pointer (&local_error)); return; } else { const gchar *id = NULL; const gchar * const *id_like = NULL; g_autofree gchar *scheme = NULL; id = gs_os_release_get_id (os_release); id_like = gs_os_release_get_id_like (os_release); scheme = gs_utils_get_url_scheme (url); if (!(g_strcmp0 (scheme, "apt") == 0 && (g_strcmp0 (id, "debian") == 0 || (id_like != NULL && g_strv_contains (id_like, "debian"))))) { g_task_return_pointer (task, gs_app_list_new (), g_object_unref); return; } } package_ids = g_new0 (gchar *, 2); package_ids[0] = gs_utils_get_url_path (url); task_resolve = gs_packagekit_task_new (plugin); helper = gs_packagekit_helper_new (plugin); gs_packagekit_task_setup (GS_PACKAGEKIT_TASK (task_resolve), GS_PACKAGEKIT_TASK_QUESTION_TYPE_NONE, flags & GS_PLUGIN_URL_TO_APP_FLAGS_INTERACTIVE); gs_packagekit_task_take_helper (GS_PACKAGEKIT_TASK (task_resolve), helper); pk_client_resolve_async (PK_CLIENT (task_resolve), pk_bitfield_from_enums (PK_FILTER_ENUM_NEWEST, PK_FILTER_ENUM_ARCH, -1), package_ids, cancellable, gs_packagekit_helper_cb, g_steal_pointer (&helper), gs_plugin_packagekit_url_to_app_resolved_cb, g_steal_pointer (&task)); } static void gs_plugin_packagekit_url_to_app_resolved_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { g_autoptr(GTask) task = G_TASK (g_steal_pointer (&user_data)); GsPluginPackagekit *self = GS_PLUGIN_PACKAGEKIT (g_task_get_source_object (task)); GsPluginUrlToAppData *data = g_task_get_task_data (task); GCancellable *cancellable = g_task_get_cancellable (task); GsPlugin *plugin = GS_PLUGIN (self); g_autofree gchar *path = NULL; g_autoptr(PkResults) results = NULL; g_autoptr(GsApp) app = NULL; g_autoptr(GsAppList) list = NULL; g_autoptr(GPtrArray) packages = NULL; g_autoptr(GPtrArray) details = NULL; g_autoptr(GError) local_error = NULL; results = pk_client_generic_finish (PK_CLIENT (source_object), result, &local_error); if (local_error != NULL || !gs_plugin_packagekit_results_valid (results, cancellable, &local_error)) { g_prefix_error (&local_error, "Failed to resolve package_ids: "); gs_plugin_packagekit_error_convert (&local_error, cancellable); g_task_return_error (task, g_steal_pointer (&local_error)); return; } path = gs_utils_get_url_path (data->url); list = gs_app_list_new (); app = gs_app_new (NULL); gs_plugin_packagekit_set_packaging_format (plugin, app); gs_app_add_source (app, path); gs_app_set_kind (app, AS_COMPONENT_KIND_GENERIC); gs_app_set_bundle_kind (app, AS_BUNDLE_KIND_PACKAGE); /* get results */ packages = pk_results_get_package_array (results); details = pk_results_get_details_array (results); if (packages->len >= 1) { g_autoptr(GHashTable) details_collection = NULL; g_autoptr(GHashTable) prepared_updates = NULL; if (gs_app_get_local_file (app) == NULL) { details_collection = gs_plugin_packagekit_details_array_to_hash (details); g_mutex_lock (&self->prepared_updates_mutex); prepared_updates = g_hash_table_ref (self->prepared_updates); g_mutex_unlock (&self->prepared_updates_mutex); gs_plugin_packagekit_resolve_packages_app (plugin, packages, app); gs_plugin_packagekit_refine_details_app (plugin, details_collection, prepared_updates, app); } gs_app_list_add (list, app); } else { g_task_return_new_error (task, GS_PLUGIN_ERROR, GS_PLUGIN_ERROR_INVALID_FORMAT, "No files for %s", data->url); return; } g_task_return_pointer (task, g_steal_pointer (&list), g_object_unref); } static GsAppList * gs_plugin_packagekit_url_to_app_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_pointer (G_TASK (result), error); } static gchar * get_proxy_http (GsPluginPackagekit *self) { gboolean ret; GString *string = NULL; gint port; GDesktopProxyMode proxy_mode; g_autofree gchar *host = NULL; g_autofree gchar *password = NULL; g_autofree gchar *username = NULL; proxy_mode = g_settings_get_enum (self->settings_proxy, "mode"); if (proxy_mode != G_DESKTOP_PROXY_MODE_MANUAL) return NULL; host = g_settings_get_string (self->settings_http, "host"); if (host == NULL || host[0] == '\0') return NULL; port = g_settings_get_int (self->settings_http, "port"); ret = g_settings_get_boolean (self->settings_http, "use-authentication"); if (ret) { username = g_settings_get_string (self->settings_http, "authentication-user"); password = g_settings_get_string (self->settings_http, "authentication-password"); } /* make PackageKit proxy string */ string = g_string_new (""); if (username != NULL || password != NULL) { if (username != NULL) g_string_append_printf (string, "%s", username); if (password != NULL) g_string_append_printf (string, ":%s", password); g_string_append (string, "@"); } g_string_append (string, host); if (port > 0) g_string_append_printf (string, ":%i", port); return g_string_free (string, FALSE); } static gchar * get_proxy_https (GsPluginPackagekit *self) { GString *string = NULL; gint port; GDesktopProxyMode proxy_mode; g_autofree gchar *host = NULL; proxy_mode = g_settings_get_enum (self->settings_proxy, "mode"); if (proxy_mode != G_DESKTOP_PROXY_MODE_MANUAL) return NULL; host = g_settings_get_string (self->settings_https, "host"); if (host == NULL || host[0] == '\0') return NULL; port = g_settings_get_int (self->settings_https, "port"); if (port == 0) return NULL; /* make PackageKit proxy string */ string = g_string_new (host); if (port > 0) g_string_append_printf (string, ":%i", port); return g_string_free (string, FALSE); } static gchar * get_proxy_ftp (GsPluginPackagekit *self) { GString *string = NULL; gint port; GDesktopProxyMode proxy_mode; g_autofree gchar *host = NULL; proxy_mode = g_settings_get_enum (self->settings_proxy, "mode"); if (proxy_mode != G_DESKTOP_PROXY_MODE_MANUAL) return NULL; host = g_settings_get_string (self->settings_ftp, "host"); if (host == NULL || host[0] == '\0') return NULL; port = g_settings_get_int (self->settings_ftp, "port"); if (port == 0) return NULL; /* make PackageKit proxy string */ string = g_string_new (host); if (port > 0) g_string_append_printf (string, ":%i", port); return g_string_free (string, FALSE); } static gchar * get_proxy_socks (GsPluginPackagekit *self) { GString *string = NULL; gint port; GDesktopProxyMode proxy_mode; g_autofree gchar *host = NULL; proxy_mode = g_settings_get_enum (self->settings_proxy, "mode"); if (proxy_mode != G_DESKTOP_PROXY_MODE_MANUAL) return NULL; host = g_settings_get_string (self->settings_socks, "host"); if (host == NULL || host[0] == '\0') return NULL; port = g_settings_get_int (self->settings_socks, "port"); if (port == 0) return NULL; /* make PackageKit proxy string */ string = g_string_new (host); if (port > 0) g_string_append_printf (string, ":%i", port); return g_string_free (string, FALSE); } static gchar * get_no_proxy (GsPluginPackagekit *self) { GString *string = NULL; GDesktopProxyMode proxy_mode; g_autofree gchar **hosts = NULL; guint i; proxy_mode = g_settings_get_enum (self->settings_proxy, "mode"); if (proxy_mode != G_DESKTOP_PROXY_MODE_MANUAL) return NULL; hosts = g_settings_get_strv (self->settings_proxy, "ignore-hosts"); if (hosts == NULL) return NULL; /* make PackageKit proxy string */ string = g_string_new (""); for (i = 0; hosts[i] != NULL; i++) { if (i == 0) g_string_assign (string, hosts[i]); else g_string_append_printf (string, ",%s", hosts[i]); g_free (hosts[i]); } return g_string_free (string, FALSE); } static gchar * get_pac (GsPluginPackagekit *self) { GDesktopProxyMode proxy_mode; gchar *url = NULL; proxy_mode = g_settings_get_enum (self->settings_proxy, "mode"); if (proxy_mode != G_DESKTOP_PROXY_MODE_AUTO) return NULL; url = g_settings_get_string (self->settings_proxy, "autoconfig-url"); if (url == NULL) return NULL; return url; } static void get_permission_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void set_proxy_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void reload_proxy_settings_async (GsPluginPackagekit *self, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { g_autoptr(GTask) task = NULL; task = g_task_new (self, cancellable, callback, user_data); g_task_set_source_tag (task, reload_proxy_settings_async); /* only if we can achieve the action *without* an auth dialog */ gs_utils_get_permission_async ("org.freedesktop.packagekit." "system-network-proxy-configure", cancellable, get_permission_cb, g_steal_pointer (&task)); } static void get_permission_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { g_autoptr(GTask) task = g_steal_pointer (&user_data); GsPluginPackagekit *self = g_task_get_source_object (task); GCancellable *cancellable = g_task_get_cancellable (task); g_autofree gchar *proxy_http = NULL; g_autofree gchar *proxy_https = NULL; g_autofree gchar *proxy_ftp = NULL; g_autofree gchar *proxy_socks = NULL; g_autofree gchar *no_proxy = NULL; g_autofree gchar *pac = NULL; g_autoptr(GPermission) permission = NULL; g_autoptr(GError) local_error = NULL; permission = gs_utils_get_permission_finish (result, &local_error); if (permission == NULL) { g_debug ("not setting proxy as no permission: %s", local_error->message); g_task_return_boolean (task, TRUE); return; } if (!g_permission_get_allowed (permission)) { g_debug ("not setting proxy as no auth requested"); g_task_return_boolean (task, TRUE); return; } proxy_http = get_proxy_http (self); proxy_https = get_proxy_https (self); proxy_ftp = get_proxy_ftp (self); proxy_socks = get_proxy_socks (self); no_proxy = get_no_proxy (self); pac = get_pac (self); g_debug ("Setting proxies (http: %s, https: %s, ftp: %s, socks: %s, " "no_proxy: %s, pac: %s)", proxy_http, proxy_https, proxy_ftp, proxy_socks, no_proxy, pac); pk_control_set_proxy2_async (self->control_proxy, proxy_http, proxy_https, proxy_ftp, proxy_socks, no_proxy, pac, cancellable, set_proxy_cb, g_steal_pointer (&task)); } static void set_proxy_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { PkControl *control = PK_CONTROL (source_object); g_autoptr(GTask) task = g_steal_pointer (&user_data); g_autoptr(GError) local_error = NULL; if (!pk_control_set_proxy_finish (control, result, &local_error)) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } g_task_return_boolean (task, TRUE); } static gboolean reload_proxy_settings_finish (GsPluginPackagekit *self, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } static void proxy_changed_reload_proxy_settings_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void gs_plugin_packagekit_proxy_changed_cb (GSettings *settings, const gchar *key, gpointer user_data) { GsPluginPackagekit *self = GS_PLUGIN_PACKAGEKIT (user_data); if (!gs_plugin_get_enabled (GS_PLUGIN (self))) return; g_cancellable_cancel (self->proxy_settings_cancellable); g_clear_object (&self->proxy_settings_cancellable); self->proxy_settings_cancellable = g_cancellable_new (); reload_proxy_settings_async (self, self->proxy_settings_cancellable, proxy_changed_reload_proxy_settings_cb, self); } static void proxy_changed_reload_proxy_settings_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { GsPluginPackagekit *self = GS_PLUGIN_PACKAGEKIT (user_data); g_autoptr(GError) local_error = NULL; if (!reload_proxy_settings_finish (self, result, &local_error) && !g_error_matches (local_error, G_IO_ERROR, G_IO_ERROR_CANCELLED)) g_warning ("Failed to set proxies: %s", local_error->message); } static void gs_packagekit_upgrade_system_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { g_autoptr(GTask) task = user_data; g_autoptr(PkResults) results = NULL; g_autoptr(GError) local_error = NULL; GsPluginDownloadUpgradeData *data = g_task_get_task_data (task); results = pk_task_generic_finish (PK_TASK (source_object), result, &local_error); if (local_error != NULL || !gs_plugin_packagekit_results_valid (results, g_task_get_cancellable (task), &local_error)) { gs_app_set_state_recover (data->app); gs_plugin_packagekit_error_convert (&local_error, g_task_get_cancellable (task)); g_task_return_error (task, g_steal_pointer (&local_error)); return; } /* state is known */ gs_app_set_state (data->app, GS_APP_STATE_UPDATABLE); g_task_return_boolean (task, TRUE); } static void gs_plugin_packagekit_download_upgrade_async (GsPlugin *plugin, GsApp *app, GsPluginDownloadUpgradeFlags flags, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { g_autoptr(GsPackagekitHelper) helper = NULL; g_autoptr(PkTask) task_upgrade = NULL; g_autoptr(GTask) task = NULL; gboolean interactive = (flags & GS_PLUGIN_DOWNLOAD_UPGRADE_FLAGS_INTERACTIVE) != 0; task = gs_plugin_download_upgrade_data_new_task (plugin, app, flags, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_packagekit_download_upgrade_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; } /* check is distro-upgrade */ if (gs_app_get_kind (app) != AS_COMPONENT_KIND_OPERATING_SYSTEM) { g_task_return_boolean (task, TRUE); return; } helper = gs_packagekit_helper_new (plugin); /* ask PK to download enough packages to upgrade the system */ gs_app_set_state (app, GS_APP_STATE_DOWNLOADING); gs_packagekit_helper_set_progress_app (helper, app); task_upgrade = gs_packagekit_task_new (plugin); pk_task_set_only_download (task_upgrade, TRUE); pk_client_set_cache_age (PK_CLIENT (task_upgrade), 60 * 60 * 24); gs_packagekit_task_setup (GS_PACKAGEKIT_TASK (task_upgrade), GS_PACKAGEKIT_TASK_QUESTION_TYPE_DOWNLOAD, interactive); gs_packagekit_task_take_helper (GS_PACKAGEKIT_TASK (task_upgrade), helper); pk_task_upgrade_system_async (task_upgrade, gs_app_get_version (app), PK_UPGRADE_KIND_ENUM_COMPLETE, cancellable, gs_packagekit_helper_cb, g_steal_pointer (&helper), gs_packagekit_upgrade_system_cb, g_steal_pointer (&task)); } static gboolean gs_plugin_packagekit_download_upgrade_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } static void gs_plugin_packagekit_refresh_metadata_async (GsPlugin *plugin, guint64 cache_age_secs, GsPluginRefreshMetadataFlags flags, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data); static void gs_plugin_packagekit_enable_repository_refresh_ready_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { g_autoptr(GTask) task = user_data; GsPluginPackagekit *self = GS_PLUGIN_PACKAGEKIT (g_task_get_source_object (task)); GsPluginManageRepositoryData *data = g_task_get_task_data (task); gs_plugin_repository_changed (GS_PLUGIN (self), data->repository); /* Ignore refresh errors */ g_task_return_boolean (task, TRUE); } static void gs_plugin_packagekit_enable_repository_ready_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { g_autoptr(GTask) task = user_data; g_autoptr(PkResults) results = NULL; g_autoptr(PkError) error_code = NULL; g_autoptr(GError) local_error = NULL; GsPluginPackagekit *self = GS_PLUGIN_PACKAGEKIT (g_task_get_source_object (task)); GsPluginManageRepositoryData *data = g_task_get_task_data (task); GsPluginRefreshMetadataFlags metadata_flags; GCancellable *cancellable = g_task_get_cancellable (task); results = pk_client_generic_finish (PK_CLIENT (source_object), result, &local_error); /* pk_client_repo_enable() returns an error if the repo is already enabled. */ if (results != NULL && (error_code = pk_results_get_error_code (results)) != NULL && pk_error_get_code (error_code) == PK_ERROR_ENUM_REPO_ALREADY_SET) { g_clear_error (&local_error); } else if (local_error != NULL || !gs_plugin_packagekit_results_valid (results, cancellable, &local_error)) { gs_app_set_state_recover (data->repository); gs_utils_error_add_origin_id (&local_error, data->repository); g_task_return_error (task, g_steal_pointer (&local_error)); return; } /* state is known */ gs_app_set_state (data->repository, GS_APP_STATE_INSTALLED); metadata_flags = (data->flags & GS_PLUGIN_MANAGE_REPOSITORY_FLAGS_INTERACTIVE) != 0 ? GS_PLUGIN_REFRESH_METADATA_FLAGS_INTERACTIVE : GS_PLUGIN_REFRESH_METADATA_FLAGS_NONE; gs_plugin_packagekit_refresh_metadata_async (GS_PLUGIN (self), 1, /* cache age */ metadata_flags, cancellable, gs_plugin_packagekit_enable_repository_refresh_ready_cb, g_steal_pointer (&task)); } static void gs_plugin_packagekit_enable_repository_async (GsPlugin *plugin, GsApp *repository, GsPluginManageRepositoryFlags flags, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { g_autoptr(GsPackagekitHelper) helper = NULL; g_autoptr(PkTask) task_enable_repo = NULL; g_autoptr(GTask) task = NULL; task = gs_plugin_manage_repository_data_new_task (plugin, repository, flags, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_packagekit_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 repo */ g_assert (gs_app_get_kind (repository) == AS_COMPONENT_KIND_REPOSITORY); /* do the call */ gs_plugin_status_update (plugin, repository, GS_PLUGIN_STATUS_WAITING); gs_app_set_state (repository, GS_APP_STATE_INSTALLING); helper = gs_packagekit_helper_new (plugin); gs_packagekit_helper_add_app (helper, repository); task_enable_repo = gs_packagekit_task_new (plugin); gs_packagekit_task_setup (GS_PACKAGEKIT_TASK (task_enable_repo), GS_PACKAGEKIT_TASK_QUESTION_TYPE_NONE, (flags & GS_PLUGIN_MANAGE_REPOSITORY_FLAGS_INTERACTIVE) != 0); gs_packagekit_task_take_helper (GS_PACKAGEKIT_TASK (task_enable_repo), helper); pk_client_repo_enable_async (PK_CLIENT (task_enable_repo), gs_app_get_id (repository), TRUE, cancellable, gs_packagekit_helper_cb, g_steal_pointer (&helper), gs_plugin_packagekit_enable_repository_ready_cb, g_steal_pointer (&task)); } static gboolean gs_plugin_packagekit_enable_repository_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } static void gs_plugin_packagekit_disable_repository_ready_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { g_autoptr(GTask) task = user_data; g_autoptr(PkResults) results = NULL; g_autoptr(PkError) error_code = NULL; g_autoptr(GError) local_error = NULL; GsPluginPackagekit *self = GS_PLUGIN_PACKAGEKIT (g_task_get_source_object (task)); GsPluginManageRepositoryData *data = g_task_get_task_data (task); results = pk_client_generic_finish (PK_CLIENT (source_object), result, &local_error); /* pk_client_repo_enable() returns an error if the repo is already disabled. */ if (results != NULL && (error_code = pk_results_get_error_code (results)) != NULL && pk_error_get_code (error_code) == PK_ERROR_ENUM_REPO_ALREADY_SET) { g_clear_error (&local_error); } else if (local_error != NULL || !gs_plugin_packagekit_results_valid (results, g_task_get_cancellable (task), &local_error)) { gs_app_set_state_recover (data->repository); gs_utils_error_add_origin_id (&local_error, data->repository); g_task_return_error (task, g_steal_pointer (&local_error)); return; } /* state is known */ gs_app_set_state (data->repository, GS_APP_STATE_AVAILABLE); gs_plugin_repository_changed (GS_PLUGIN (self), data->repository); g_task_return_boolean (task, TRUE); } static void gs_plugin_packagekit_disable_repository_async (GsPlugin *plugin, GsApp *repository, GsPluginManageRepositoryFlags flags, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { g_autoptr(GsPackagekitHelper) helper = NULL; g_autoptr(PkTask) task_disable_repo = NULL; g_autoptr(GTask) task = NULL; task = gs_plugin_manage_repository_data_new_task (plugin, repository, flags, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_packagekit_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 repo */ g_assert (gs_app_get_kind (repository) == AS_COMPONENT_KIND_REPOSITORY); /* do the call */ gs_plugin_status_update (plugin, repository, GS_PLUGIN_STATUS_WAITING); gs_app_set_state (repository, GS_APP_STATE_REMOVING); helper = gs_packagekit_helper_new (plugin); gs_packagekit_helper_add_app (helper, repository); task_disable_repo = gs_packagekit_task_new (plugin); gs_packagekit_task_setup (GS_PACKAGEKIT_TASK (task_disable_repo), GS_PACKAGEKIT_TASK_QUESTION_TYPE_NONE, (flags & GS_PLUGIN_MANAGE_REPOSITORY_FLAGS_INTERACTIVE) != 0); gs_packagekit_task_take_helper (GS_PACKAGEKIT_TASK (task_disable_repo), helper); pk_client_repo_enable_async (PK_CLIENT (task_disable_repo), gs_app_get_id (repository), FALSE, cancellable, gs_packagekit_helper_cb, g_steal_pointer (&helper), gs_plugin_packagekit_disable_repository_ready_cb, g_steal_pointer (&task)); } static gboolean gs_plugin_packagekit_disable_repository_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } typedef struct { gpointer schedule_entry_handle; /* (nullable) (owned) */ /* List of apps to download, and list of apps to notify of download * progress on. @download_list is a superset of @progress_list, and * may include extra dependencies. */ GsAppList *download_list; /* (owned) */ GsAppList *progress_list; /* (owned) */ gboolean interactive; GsPackagekitHelper *helper; /* (owned) */ } DownloadData; static void download_data_free (DownloadData *data) { /* Should have been explicitly removed from the scheduler by now. */ g_assert (data->schedule_entry_handle == NULL); g_clear_object (&data->download_list); g_clear_object (&data->progress_list); g_clear_object (&data->helper); g_free (data); } G_DEFINE_AUTOPTR_CLEANUP_FUNC (DownloadData, download_data_free) static void download_schedule_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void download_get_updates_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void download_update_packages_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void finish_download (GTask *task, GError *error); static void gs_plugin_packagekit_download_async (GsPluginPackagekit *self, GsAppList *list, gboolean interactive, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { GsPlugin *plugin = GS_PLUGIN (self); g_autoptr(GTask) task = NULL; g_autoptr(DownloadData) data_owned = NULL; DownloadData *data; task = g_task_new (self, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_packagekit_download_async); data = data_owned = g_new0 (DownloadData, 1); data->download_list = gs_app_list_new (); data->progress_list = g_object_ref (list); data->interactive = interactive; data->helper = gs_packagekit_helper_new (plugin); gs_packagekit_helper_set_allow_emit_updates_changed (data->helper, FALSE); g_task_set_task_data (task, g_steal_pointer (&data_owned), (GDestroyNotify) download_data_free); /* add any packages */ for (guint i = 0; i < gs_app_list_length (list); i++) { GsApp *app = gs_app_list_index (list, i); GsAppList *related = gs_app_get_related (app); /* add this app */ if (!gs_app_has_quirk (app, GS_APP_QUIRK_IS_PROXY)) { if (gs_app_has_management_plugin (app, plugin)) gs_app_list_add (data->download_list, app); continue; } /* add each related app */ for (guint j = 0; j < gs_app_list_length (related); j++) { GsApp *app_tmp = gs_app_list_index (related, j); if (gs_app_has_management_plugin (app_tmp, plugin)) gs_app_list_add (data->download_list, app_tmp); } } if (gs_app_list_length (data->download_list) == 0) { finish_download (task, NULL); return; } /* Wait for permission to download, if needed. */ if (!data->interactive) { g_auto(GVariantDict) parameters_dict = G_VARIANT_DICT_INIT (NULL); g_variant_dict_insert (¶meters_dict, "resumable", "b", FALSE); gs_metered_block_on_download_scheduler_async (g_variant_dict_end (¶meters_dict), cancellable, download_schedule_cb, g_steal_pointer (&task)); } else { download_schedule_cb (NULL, NULL, g_steal_pointer (&task)); } } static void download_schedule_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { g_autoptr(GTask) task = g_steal_pointer (&user_data); GsPluginPackagekit *self = g_task_get_source_object (task); DownloadData *data = g_task_get_task_data (task); GCancellable *cancellable = g_task_get_cancellable (task); g_autoptr(PkTask) task_update = NULL; g_autoptr(GError) local_error = NULL; if (result != NULL && !gs_metered_block_on_download_scheduler_finish (result, &data->schedule_entry_handle, &local_error)) { g_warning ("Failed to block on download scheduler: %s", local_error->message); g_clear_error (&local_error); } /* get the list of packages to update */ gs_plugin_status_update (GS_PLUGIN (self), NULL, GS_PLUGIN_STATUS_WAITING); /* never refresh the metadata here as this can surprise the frontend if * we end up downloading a different set of packages than what was * shown to the user */ task_update = gs_packagekit_task_new (GS_PLUGIN (self)); pk_task_set_only_download (task_update, TRUE); gs_packagekit_task_setup (GS_PACKAGEKIT_TASK (task_update), GS_PACKAGEKIT_TASK_QUESTION_TYPE_DOWNLOAD, data->interactive); pk_client_get_updates_async (PK_CLIENT (task_update), pk_bitfield_value (PK_FILTER_ENUM_NONE), cancellable, gs_packagekit_helper_cb, data->helper, download_get_updates_cb, g_steal_pointer (&task)); } static gboolean update_system_filter_cb (PkPackage *package, gpointer user_data) { PkInfoEnum info = pk_package_get_info (package); #if PK_CHECK_VERSION(1, 3, 0) return info != PK_INFO_ENUM_OBSOLETE && info != PK_INFO_ENUM_OBSOLETING && info != PK_INFO_ENUM_REMOVE && info != PK_INFO_ENUM_REMOVING && info != PK_INFO_ENUM_BLOCKED; #else return info != PK_INFO_ENUM_OBSOLETING && info != PK_INFO_ENUM_REMOVING && info != PK_INFO_ENUM_BLOCKED; #endif } static void download_get_updates_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { PkTask *task_update = PK_TASK (source_object); g_autoptr(GTask) task = g_steal_pointer (&user_data); DownloadData *data = g_task_get_task_data (task); GCancellable *cancellable = g_task_get_cancellable (task); g_autoptr(PkResults) results = NULL; g_autoptr(PkPackageSack) sack = NULL; g_auto(GStrv) package_ids = NULL; g_autoptr(GError) local_error = NULL; results = pk_client_generic_finish (PK_CLIENT (task_update), result, &local_error); if (!gs_plugin_packagekit_results_valid (results, cancellable, &local_error)) { if (local_error->domain == PK_CLIENT_ERROR) { g_autoptr(GsPluginEvent) event = NULL; event = gs_plugin_event_new ("error", local_error, NULL); gs_plugin_event_add_flag (event, GS_PLUGIN_EVENT_FLAG_WARNING); if (data->interactive) gs_plugin_event_add_flag (event, GS_PLUGIN_EVENT_FLAG_INTERACTIVE); gs_plugin_report_event (g_task_get_source_object (task), event); } finish_download (task, g_steal_pointer (&local_error)); return; } /* download all the packages */ sack = pk_results_get_package_sack (results); if (pk_package_sack_get_size (sack) == 0) { finish_download (task, NULL); return; } /* Include only packages which are not to be obsoleted nor removed, because these can cause failure due to unmet dependencies. */ pk_package_sack_remove_by_filter (sack, update_system_filter_cb, NULL); package_ids = pk_package_sack_get_ids (sack); for (guint i = 0; i < gs_app_list_length (data->download_list); i++) { GsApp *app = gs_app_list_index (data->download_list, i); gs_packagekit_helper_add_app (data->helper, app); } gs_packagekit_helper_set_progress_list (data->helper, data->progress_list); /* never refresh the metadata here as this can surprise the frontend if * we end up downloading a different set of packages than what was * shown to the user */ pk_task_update_packages_async (task_update, package_ids, cancellable, gs_packagekit_helper_cb, data->helper, download_update_packages_cb, g_steal_pointer (&task)); } static void download_update_packages_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { PkTask *task_update = PK_TASK (source_object); g_autoptr(GTask) task = g_steal_pointer (&user_data); DownloadData *data = g_task_get_task_data (task); GCancellable *cancellable = g_task_get_cancellable (task); g_autoptr(PkResults) results = NULL; g_autoptr(GError) local_error = NULL; results = pk_task_generic_finish (task_update, result, &local_error); gs_app_list_override_progress (data->progress_list, GS_APP_PROGRESS_UNKNOWN); if (results == NULL) { if (local_error->domain == PK_CLIENT_ERROR) { g_autoptr(GsPluginEvent) event = NULL; event = gs_plugin_event_new ("error", local_error, NULL); gs_plugin_event_add_flag (event, GS_PLUGIN_EVENT_FLAG_WARNING); if (data->interactive) gs_plugin_event_add_flag (event, GS_PLUGIN_EVENT_FLAG_INTERACTIVE); gs_plugin_report_event (g_task_get_source_object (task), event); } gs_plugin_packagekit_error_convert (&local_error, cancellable); finish_download (task, g_steal_pointer (&local_error)); return; } if (g_cancellable_set_error_if_cancelled (cancellable, &local_error)) { finish_download (task, g_steal_pointer (&local_error)); return; } for (guint i = 0; i < gs_app_list_length (data->download_list); i++) { GsApp *app = gs_app_list_index (data->download_list, i); /* To indicate the app is already downloaded */ gs_app_set_size_download (app, GS_SIZE_TYPE_VALID, 0); } /* Success! */ finish_download (task, NULL); } /* If non-%NULL, @error is (transfer full). */ static void finish_download (GTask *task, GError *error) { GsPluginPackagekit *self = g_task_get_source_object (task); DownloadData *data = g_task_get_task_data (task); g_autoptr(GError) error_owned = g_steal_pointer (&error); /* Fire this call off into the void, it’s not worth tracking it. * Don’t pass a cancellable in, as the download may have been cancelled. */ if (data->schedule_entry_handle != NULL) gs_metered_remove_from_download_scheduler_async (data->schedule_entry_handle, NULL, NULL, NULL); if (error_owned == NULL) gs_plugin_updates_changed (GS_PLUGIN (self)); if (error_owned != NULL) g_task_return_error (task, g_steal_pointer (&error_owned)); else g_task_return_boolean (task, TRUE); } static gboolean gs_plugin_packagekit_download_finish (GsPluginPackagekit *self, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } static void update_apps_download_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void update_apps_trigger_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void gs_plugin_packagekit_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) { GsPluginPackagekit *self = GS_PLUGIN_PACKAGEKIT (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_packagekit_update_apps_async); if (!(flags & GS_PLUGIN_UPDATE_APPS_FLAGS_NO_DOWNLOAD)) { /* FIXME: Add progress reporting */ gs_plugin_packagekit_download_async (self, apps, interactive, cancellable, update_apps_download_cb, g_steal_pointer (&task)); } else { update_apps_download_cb (G_OBJECT (self), NULL, g_steal_pointer (&task)); } } static void update_apps_download_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { GsPluginPackagekit *self = GS_PLUGIN_PACKAGEKIT (source_object); g_autoptr(GTask) task = g_steal_pointer (&user_data); GsPluginUpdateAppsData *data = g_task_get_task_data (task); GCancellable *cancellable = g_task_get_cancellable (task); gboolean interactive = (data->flags & GS_PLUGIN_UPDATE_APPS_FLAGS_INTERACTIVE); g_autoptr(GError) local_error = NULL; if (result != NULL && !gs_plugin_packagekit_download_finish (self, result, &local_error)) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } if (!(data->flags & GS_PLUGIN_UPDATE_APPS_FLAGS_NO_APPLY)) { gboolean trigger_update = FALSE; /* Are any of these apps from PackageKit, and suitable for offline * updates? If any of them can be processed offline, trigger an offline * update. If all of them are updatable online, don’t. */ for (guint i = 0; i < gs_app_list_length (data->apps); i++) { GsApp *app = gs_app_list_index (data->apps, i); GsAppList *related = gs_app_get_related (app); /* try to trigger this app */ if (!gs_app_has_quirk (app, GS_APP_QUIRK_IS_PROXY) && gs_app_get_state (app) == GS_APP_STATE_UPDATABLE && gs_app_has_management_plugin (app, GS_PLUGIN (self))) { trigger_update = TRUE; break; } /* try to trigger each related app */ for (guint j = 0; j < gs_app_list_length (related); j++) { GsApp *app_tmp = gs_app_list_index (related, j); if (gs_app_get_state (app_tmp) == GS_APP_STATE_UPDATABLE && gs_app_has_management_plugin (app_tmp, GS_PLUGIN (self))) { trigger_update = TRUE; break; } } } if (trigger_update && !self->is_triggered) { GDBusConnection *connection; /* trigger offline update if it’s not already been triggered */ /* Assume we can use the singleton system bus connection * due to prior PackageKit calls having created it. This * avoids an async callback. */ connection = g_bus_get_sync (G_BUS_TYPE_SYSTEM, cancellable, &local_error); if (connection == NULL) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } /* FIXME: This can be simplified down to a call to * pk_offline_trigger_with_flags_async() when it exists. * See https://github.com/PackageKit/PackageKit/issues/605 */ g_dbus_connection_call (connection, "org.freedesktop.PackageKit", "/org/freedesktop/PackageKit", "org.freedesktop.PackageKit.Offline", "Trigger", g_variant_new ("(s)", pk_offline_action_to_string (PK_OFFLINE_ACTION_REBOOT)), NULL, interactive ? G_DBUS_CALL_FLAGS_ALLOW_INTERACTIVE_AUTHORIZATION : G_DBUS_CALL_FLAGS_NONE, -1, cancellable, update_apps_trigger_cb, g_steal_pointer (&task)); return; } } g_task_return_boolean (task, TRUE); } static void update_apps_trigger_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { GDBusConnection *connection = G_DBUS_CONNECTION (source_object); g_autoptr(GTask) task = g_steal_pointer (&user_data); GsPluginPackagekit *self = g_task_get_source_object (task); GCancellable *cancellable = g_task_get_cancellable (task); g_autoptr(GError) local_error = NULL; if (!g_dbus_connection_call_finish (connection, result, &local_error)) { gs_plugin_packagekit_error_convert (&local_error, cancellable); g_task_return_error (task, g_steal_pointer (&local_error)); return; } /* don't rely on the file monitor */ gs_plugin_packagekit_refresh_is_triggered (self, cancellable); g_task_return_boolean (task, TRUE); } static gboolean gs_plugin_packagekit_update_apps_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } static void refresh_metadata_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void gs_plugin_packagekit_refresh_metadata_async (GsPlugin *plugin, guint64 cache_age_secs, GsPluginRefreshMetadataFlags flags, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { g_autoptr(GsPackagekitHelper) helper = gs_packagekit_helper_new (plugin); g_autoptr(GsApp) app_dl = gs_app_new (gs_plugin_get_name (plugin)); gboolean interactive = (flags & GS_PLUGIN_REFRESH_METADATA_FLAGS_INTERACTIVE); g_autoptr(GTask) task = NULL; g_autoptr(PkTask) task_refresh = NULL; task = g_task_new (plugin, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_packagekit_refresh_metadata_async); g_task_set_task_data (task, g_object_ref (helper), g_object_unref); gs_plugin_status_update (plugin, NULL, GS_PLUGIN_STATUS_WAITING); gs_packagekit_helper_set_progress_app (helper, app_dl); task_refresh = gs_packagekit_task_new (plugin); pk_task_set_only_download (task_refresh, TRUE); gs_packagekit_task_setup (GS_PACKAGEKIT_TASK (task_refresh), GS_PACKAGEKIT_TASK_QUESTION_TYPE_NONE, interactive); pk_client_set_cache_age (PK_CLIENT (task_refresh), cache_age_secs); /* refresh the metadata */ pk_client_refresh_cache_async (PK_CLIENT (task_refresh), FALSE /* force */, cancellable, gs_packagekit_helper_cb, helper, refresh_metadata_cb, g_steal_pointer (&task)); } static void refresh_metadata_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { PkClient *client = PK_CLIENT (source_object); g_autoptr(GTask) task = g_steal_pointer (&user_data); GsPlugin *plugin = g_task_get_source_object (task); g_autoptr(PkResults) results = NULL; g_autoptr(GError) local_error = NULL; results = pk_client_generic_finish (client, result, &local_error); if (!gs_plugin_packagekit_results_valid (results, g_task_get_cancellable (task), &local_error)) { g_task_return_error (task, g_steal_pointer (&local_error)); } else { gs_plugin_updates_changed (plugin); g_task_return_boolean (task, TRUE); } } static gboolean gs_plugin_packagekit_refresh_metadata_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } static void gs_packagekit_cancel_offline_update_thread (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable); static void gs_plugin_packagekit_cancel_offline_update_async (GsPlugin *plugin, GsPluginCancelOfflineUpdateFlags flags, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { GsPluginPackagekit *self = GS_PLUGIN_PACKAGEKIT (plugin); g_autoptr(GTask) task = NULL; task = gs_plugin_cancel_offline_update_data_new_task (plugin, flags, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_packagekit_cancel_offline_update_async); /* already in correct state */ if (!self->is_triggered) { g_task_return_boolean (task, TRUE); return; } /* There is no async API in the pk-offline, thus run in a thread */ g_task_run_in_thread (task, gs_packagekit_cancel_offline_update_thread); } static void gs_packagekit_cancel_offline_update_thread (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable) { GsPluginPackagekit *self = GS_PLUGIN_PACKAGEKIT (source_object); GsPluginCancelOfflineUpdateData *data = task_data; gboolean interactive = (data->flags & GS_PLUGIN_CANCEL_OFFLINE_UPDATE_FLAGS_INTERACTIVE) != 0; g_autoptr(GError) local_error = NULL; /* cancel offline update */ if (!pk_offline_cancel_with_flags (interactive ? PK_OFFLINE_FLAGS_INTERACTIVE : PK_OFFLINE_FLAGS_NONE, cancellable, &local_error)) { gs_plugin_packagekit_error_convert (&local_error, cancellable); g_task_return_error (task, g_steal_pointer (&local_error)); return; } /* don't rely on the file monitor */ gs_plugin_packagekit_refresh_is_triggered (self, cancellable); g_task_return_boolean (task, TRUE); } static gboolean gs_plugin_packagekit_cancel_offline_update_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } static void gs_packagekit_trigger_upgrade_thread (GTask *task, gpointer source_object, gpointer task_data, GCancellable *cancellable) { GsPluginTriggerUpgradeData *data = task_data; gboolean interactive = (data->flags & GS_PLUGIN_TRIGGER_UPGRADE_FLAGS_INTERACTIVE) != 0; g_autoptr(GError) local_error = NULL; if (!pk_offline_trigger_upgrade_with_flags (PK_OFFLINE_ACTION_REBOOT, interactive ? PK_OFFLINE_FLAGS_INTERACTIVE : PK_OFFLINE_FLAGS_NONE, cancellable, &local_error)) { gs_app_set_state (data->app, GS_APP_STATE_UPDATABLE); gs_plugin_packagekit_error_convert (&local_error, cancellable); g_task_return_error (task, g_steal_pointer (&local_error)); return; } gs_app_set_state (data->app, GS_APP_STATE_UPDATABLE); g_task_return_boolean (task, TRUE); } static void gs_plugin_packagekit_trigger_upgrade_async (GsPlugin *plugin, GsApp *app, GsPluginTriggerUpgradeFlags flags, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { g_autoptr(GTask) task = NULL; task = gs_plugin_trigger_upgrade_data_new_task (plugin, app, flags, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_packagekit_trigger_upgrade_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; } gs_app_set_state (app, GS_APP_STATE_PENDING_INSTALL); /* There is no async API in the pk-offline, thus run in a thread */ g_task_run_in_thread (task, gs_packagekit_trigger_upgrade_thread); } static gboolean gs_plugin_packagekit_trigger_upgrade_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } static void gs_plugin_packagekit_class_init (GsPluginPackagekitClass *klass) { GObjectClass *object_class = G_OBJECT_CLASS (klass); GsPluginClass *plugin_class = GS_PLUGIN_CLASS (klass); object_class->dispose = gs_plugin_packagekit_dispose; object_class->finalize = gs_plugin_packagekit_finalize; plugin_class->setup_async = gs_plugin_packagekit_setup_async; plugin_class->setup_finish = gs_plugin_packagekit_setup_finish; plugin_class->shutdown_async = gs_plugin_packagekit_shutdown_async; plugin_class->shutdown_finish = gs_plugin_packagekit_shutdown_finish; plugin_class->refine_async = gs_plugin_packagekit_refine_async; plugin_class->refine_finish = gs_plugin_packagekit_refine_finish; plugin_class->refresh_metadata_async = gs_plugin_packagekit_refresh_metadata_async; plugin_class->refresh_metadata_finish = gs_plugin_packagekit_refresh_metadata_finish; plugin_class->list_apps_async = gs_plugin_packagekit_list_apps_async; plugin_class->list_apps_finish = gs_plugin_packagekit_list_apps_finish; plugin_class->enable_repository_async = gs_plugin_packagekit_enable_repository_async; plugin_class->enable_repository_finish = gs_plugin_packagekit_enable_repository_finish; plugin_class->disable_repository_async = gs_plugin_packagekit_disable_repository_async; plugin_class->disable_repository_finish = gs_plugin_packagekit_disable_repository_finish; plugin_class->install_apps_async = gs_plugin_packagekit_install_apps_async; plugin_class->install_apps_finish = gs_plugin_packagekit_install_apps_finish; plugin_class->uninstall_apps_async = gs_plugin_packagekit_uninstall_apps_async; plugin_class->uninstall_apps_finish = gs_plugin_packagekit_uninstall_apps_finish; plugin_class->update_apps_async = gs_plugin_packagekit_update_apps_async; plugin_class->update_apps_finish = gs_plugin_packagekit_update_apps_finish; plugin_class->cancel_offline_update_async = gs_plugin_packagekit_cancel_offline_update_async; plugin_class->cancel_offline_update_finish = gs_plugin_packagekit_cancel_offline_update_finish; plugin_class->download_upgrade_async = gs_plugin_packagekit_download_upgrade_async; plugin_class->download_upgrade_finish = gs_plugin_packagekit_download_upgrade_finish; plugin_class->trigger_upgrade_async = gs_plugin_packagekit_trigger_upgrade_async; plugin_class->trigger_upgrade_finish = gs_plugin_packagekit_trigger_upgrade_finish; plugin_class->launch_async = gs_plugin_packagekit_launch_async; plugin_class->launch_finish = gs_plugin_packagekit_launch_finish; plugin_class->file_to_app_async = gs_plugin_packagekit_file_to_app_async; plugin_class->file_to_app_finish = gs_plugin_packagekit_file_to_app_finish; plugin_class->url_to_app_async = gs_plugin_packagekit_url_to_app_async; plugin_class->url_to_app_finish = gs_plugin_packagekit_url_to_app_finish; } GType gs_plugin_query_type (void) { return GS_TYPE_PLUGIN_PACKAGEKIT; }