/* -*- Mode: C; tab-width: 8; indent-tabs-mode: t; c-basic-offset: 8 -*- * vi:set noexpandtab tabstop=8 shiftwidth=8: * * Copyright (C) 2015-2018 Canonical Ltd * * SPDX-License-Identifier: GPL-2.0-or-later */ #include #include #include #include #include #include #include "gs-plugin-snap.h" /* * SECTION: * Lists and allows installation/uninstallation of snaps from the snap store. * * Since snapd is a daemon accessible via HTTP calls on a Unix socket, this * plugin basically translates every job into one or more HTTP request, and all * the real work is done in the snapd daemon. FIXME: This means the plugin can * therefore execute entirely in the main thread, making asynchronous calls, * once all the vfuncs have been ported. */ struct _GsPluginSnap { GsPlugin parent; gchar *store_name; gchar *store_hostname; SnapdSystemConfinement system_confinement; GMutex store_snaps_lock; GHashTable *store_snaps; }; G_DEFINE_TYPE (GsPluginSnap, gs_plugin_snap, GS_TYPE_PLUGIN) typedef struct { SnapdSnap *snap; gboolean full_details; } CacheEntry; static CacheEntry * cache_entry_new (SnapdSnap *snap, gboolean full_details) { CacheEntry *entry = g_slice_new (CacheEntry); entry->snap = g_object_ref (snap); entry->full_details = full_details; return entry; } static void cache_entry_free (CacheEntry *entry) { g_object_unref (entry->snap); g_slice_free (CacheEntry, entry); } static SnapdAuthData * get_auth_data (GsPluginSnap *self) { g_autofree gchar *path = NULL; g_autoptr(JsonParser) parser = NULL; JsonNode *root; JsonObject *object; const gchar *macaroon; g_autoptr(GPtrArray) discharges = NULL; g_autoptr(GError) error = NULL; path = g_build_filename (g_get_home_dir (), ".snap", "auth.json", NULL); parser = json_parser_new (); if (!json_parser_load_from_file (parser, path, &error)) { if (!g_error_matches (error, G_FILE_ERROR, G_FILE_ERROR_NOENT)) g_warning ("Failed to load snap auth data: %s", error->message); return NULL; } root = json_parser_get_root (parser); if (root == NULL) return NULL; if (json_node_get_node_type (root) != JSON_NODE_OBJECT) { g_warning ("Ignoring invalid snap auth data in %s", path); return NULL; } object = json_node_get_object (root); if (!json_object_has_member (object, "macaroon")) { g_warning ("Ignoring invalid snap auth data in %s", path); return NULL; } macaroon = json_object_get_string_member (object, "macaroon"); discharges = g_ptr_array_new (); if (json_object_has_member (object, "discharges")) { JsonArray *discharge_array; discharge_array = json_object_get_array_member (object, "discharges"); for (guint i = 0; i < json_array_get_length (discharge_array); i++) g_ptr_array_add (discharges, (gpointer) json_array_get_string_element (discharge_array, i)); } g_ptr_array_add (discharges, NULL); return snapd_auth_data_new (macaroon, (GStrv) discharges->pdata); } static SnapdClient * get_client (GsPluginSnap *self, gboolean interactive, GError **error) { g_autoptr(SnapdClient) client = NULL; const gchar *old_user_agent; g_autofree gchar *user_agent = NULL; g_autoptr(SnapdAuthData) auth_data = NULL; client = snapd_client_new (); snapd_client_set_allow_interaction (client, interactive); old_user_agent = snapd_client_get_user_agent (client); user_agent = g_strdup_printf ("%s %s", gs_user_agent (), old_user_agent); snapd_client_set_user_agent (client, user_agent); auth_data = get_auth_data (self); snapd_client_set_auth_data (client, auth_data); return g_steal_pointer (&client); } static void gs_plugin_snap_init (GsPluginSnap *self) { g_autoptr(SnapdClient) client = NULL; g_autoptr (GError) error = NULL; g_mutex_init (&self->store_snaps_lock); client = get_client (self, FALSE, &error); if (client == NULL) { gs_plugin_set_enabled (GS_PLUGIN (self), FALSE); return; } self->store_snaps = g_hash_table_new_full (g_str_hash, g_str_equal, g_free, (GDestroyNotify) cache_entry_free); gs_plugin_add_rule (GS_PLUGIN (self), GS_PLUGIN_RULE_BETTER_THAN, "packagekit"); gs_plugin_add_rule (GS_PLUGIN (self), GS_PLUGIN_RULE_RUN_BEFORE, "icons"); /* set name of MetaInfo file */ gs_plugin_set_appstream_id (GS_PLUGIN (self), "org.gnome.Software.Plugin.Snap"); } void gs_plugin_adopt_app (GsPlugin *plugin, GsApp *app) { if (gs_app_get_bundle_kind (app) == AS_BUNDLE_KIND_SNAP) gs_app_set_management_plugin (app, plugin); if (gs_app_get_id (app) != NULL && g_str_has_prefix (gs_app_get_id (app), "io.snapcraft.")) { g_autofree gchar *name_and_id = NULL; gchar *divider, *snap_name;/*, *id;*/ name_and_id = g_strdup (gs_app_get_id (app) + strlen ("io.snapcraft.")); divider = strrchr (name_and_id, '-'); if (divider != NULL) { *divider = '\0'; snap_name = name_and_id; /*id = divider + 1;*/ /* NOTE: Should probably validate ID */ gs_app_set_management_plugin (app, plugin); gs_app_set_metadata (app, "snap::name", snap_name); gs_app_set_bundle_kind (app, AS_BUNDLE_KIND_SNAP); } } } static void snapd_error_convert (GError **perror) { GError *error = perror != NULL ? *perror : NULL; /* not set */ if (error == NULL) return; /* this are allowed for low-level errors */ if (gs_utils_error_convert_gio (perror)) return; /* custom to this plugin */ if (error->domain == SNAPD_ERROR) { switch (error->code) { case SNAPD_ERROR_AUTH_DATA_REQUIRED: error->code = GS_PLUGIN_ERROR_AUTH_REQUIRED; g_free (error->message); error->message = g_strdup ("Requires authentication with @snapd"); break; case SNAPD_ERROR_AUTH_DATA_INVALID: case SNAPD_ERROR_TWO_FACTOR_INVALID: error->code = GS_PLUGIN_ERROR_AUTH_INVALID; break; case SNAPD_ERROR_AUTH_CANCELLED: error->code = GS_PLUGIN_ERROR_CANCELLED; break; case SNAPD_ERROR_CONNECTION_FAILED: case SNAPD_ERROR_WRITE_FAILED: case SNAPD_ERROR_READ_FAILED: case SNAPD_ERROR_BAD_REQUEST: case SNAPD_ERROR_BAD_RESPONSE: case SNAPD_ERROR_PERMISSION_DENIED: case SNAPD_ERROR_FAILED: case SNAPD_ERROR_TERMS_NOT_ACCEPTED: case SNAPD_ERROR_PAYMENT_NOT_SETUP: case SNAPD_ERROR_PAYMENT_DECLINED: case SNAPD_ERROR_ALREADY_INSTALLED: case SNAPD_ERROR_NOT_INSTALLED: case SNAPD_ERROR_NO_UPDATE_AVAILABLE: case SNAPD_ERROR_PASSWORD_POLICY_ERROR: case SNAPD_ERROR_NEEDS_DEVMODE: case SNAPD_ERROR_NEEDS_CLASSIC: case SNAPD_ERROR_NEEDS_CLASSIC_SYSTEM: default: error->code = GS_PLUGIN_ERROR_FAILED; break; } } else { g_warning ("can't reliably fixup error from domain %s", g_quark_to_string (error->domain)); error->code = GS_PLUGIN_ERROR_FAILED; } error->domain = GS_PLUGIN_ERROR; } static void get_system_information_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void get_store_snap_async (GsPluginSnap *self, SnapdClient *client, const gchar *name, gboolean need_details, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data); static SnapdSnap *get_store_snap_finish (GsPluginSnap *self, GAsyncResult *result, GError **error); static void add_channels (GsPluginSnap *self, SnapdSnap *snap, GsAppList *list); static void gs_plugin_snap_setup_async (GsPlugin *plugin, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { GsPluginSnap *self = GS_PLUGIN_SNAP (plugin); g_autoptr(SnapdClient) client = NULL; g_autoptr(GTask) task = NULL; gboolean interactive = gs_plugin_has_flags (plugin, GS_PLUGIN_FLAGS_INTERACTIVE); g_autoptr(GError) local_error = NULL; task = g_task_new (plugin, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_snap_setup_async); client = get_client (self, interactive, &local_error); if (client == NULL) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } snapd_client_get_system_information_async (client, cancellable, get_system_information_cb, g_steal_pointer (&task)); } static void get_system_information_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { SnapdClient *client = SNAPD_CLIENT (source_object); g_autoptr(GTask) task = g_steal_pointer (&user_data); GsPluginSnap *self = g_task_get_source_object (task); g_autoptr(SnapdSystemInformation) system_information = NULL; g_autoptr(GError) local_error = NULL; system_information = snapd_client_get_system_information_finish (client, result, &local_error); if (system_information == NULL) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } self->store_name = g_strdup (snapd_system_information_get_store (system_information)); if (self->store_name == NULL) { self->store_name = g_strdup (/* TRANSLATORS: default snap store name */ _("Snap Store")); self->store_hostname = g_strdup ("snapcraft.io"); } self->system_confinement = snapd_system_information_get_confinement (system_information); g_debug ("Version '%s' on OS %s %s", snapd_system_information_get_version (system_information), snapd_system_information_get_os_id (system_information), snapd_system_information_get_os_version (system_information)); /* success */ g_task_return_boolean (task, TRUE); } static gboolean gs_plugin_snap_setup_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } static SnapdSnap * store_snap_cache_lookup (GsPluginSnap *self, const gchar *name, gboolean need_details) { CacheEntry *entry; g_autoptr(GMutexLocker) locker = g_mutex_locker_new (&self->store_snaps_lock); entry = g_hash_table_lookup (self->store_snaps, name); if (entry == NULL) return NULL; if (need_details && !entry->full_details) return NULL; return g_object_ref (entry->snap); } static void store_snap_cache_update (GsPluginSnap *self, GPtrArray *snaps, gboolean full_details) { g_autoptr(GMutexLocker) locker = g_mutex_locker_new (&self->store_snaps_lock); guint i; for (i = 0; i < snaps->len; i++) { SnapdSnap *snap = snaps->pdata[i]; g_debug ("Caching '%s' by '%s' version %s revision %s", snapd_snap_get_title (snap), snapd_snap_get_publisher_display_name (snap), snapd_snap_get_version (snap), snapd_snap_get_revision (snap)); g_hash_table_insert (self->store_snaps, g_strdup (snapd_snap_get_name (snap)), cache_entry_new (snap, full_details)); } } static GPtrArray * find_snaps (GsPluginSnap *self, SnapdClient *client, SnapdFindFlags flags, const gchar *category, const gchar *query, GCancellable *cancellable, GError **error) { g_autoptr(GPtrArray) snaps = NULL; snaps = snapd_client_find_category_sync (client, flags, category, query, NULL, cancellable, error); if (snaps == NULL) { snapd_error_convert (error); return NULL; } store_snap_cache_update (self, snaps, flags & SNAPD_FIND_FLAGS_MATCH_NAME); return g_steal_pointer (&snaps); } static gchar * get_appstream_id (SnapdSnap *snap) { GStrv common_ids; /* Get the AppStream ID from the snap, or generate a fallback one */ common_ids = snapd_snap_get_common_ids (snap); if (g_strv_length (common_ids) == 1) return g_strdup (common_ids[0]); else return g_strdup_printf ("io.snapcraft.%s-%s", snapd_snap_get_name (snap), snapd_snap_get_id (snap)); } static AsComponentKind snap_guess_component_kind (SnapdSnap *snap) { switch (snapd_snap_get_snap_type (snap)) { case SNAPD_SNAP_TYPE_APP: return AS_COMPONENT_KIND_DESKTOP_APP; case SNAPD_SNAP_TYPE_KERNEL: case SNAPD_SNAP_TYPE_GADGET: case SNAPD_SNAP_TYPE_OS: return AS_COMPONENT_KIND_RUNTIME; default: case SNAPD_SNAP_TYPE_UNKNOWN: return AS_COMPONENT_KIND_UNKNOWN; } } static GsApp * snap_to_app (GsPluginSnap *self, SnapdSnap *snap, const gchar *branch) { g_autofree gchar *cache_id = NULL; g_autoptr(GsApp) app = NULL; cache_id = g_strdup_printf ("%s:%s", snapd_snap_get_name (snap), branch != NULL ? branch : ""); app = gs_plugin_cache_lookup (GS_PLUGIN (self), cache_id); if (app == NULL) { g_autofree gchar *appstream_id = NULL; appstream_id = get_appstream_id (snap); app = gs_app_new (appstream_id); gs_app_set_kind (app, snap_guess_component_kind (snap)); gs_app_set_bundle_kind (app, AS_BUNDLE_KIND_SNAP); gs_app_set_branch (app, branch); gs_app_set_metadata (app, "snap::name", snapd_snap_get_name (snap)); gs_app_set_metadata (app, "GnomeSoftware::PackagingIcon", "package-snap-symbolic"); gs_plugin_cache_add (GS_PLUGIN (self), cache_id, app); } gs_app_set_management_plugin (app, GS_PLUGIN (self)); gs_app_add_quirk (app, GS_APP_QUIRK_DO_NOT_AUTO_UPDATE); if (gs_app_get_kind (app) != AS_COMPONENT_KIND_DESKTOP_APP) gs_app_add_quirk (app, GS_APP_QUIRK_NOT_LAUNCHABLE); if (gs_plugin_check_distro_id (GS_PLUGIN (self), "ubuntu")) gs_app_add_quirk (app, GS_APP_QUIRK_PROVENANCE); if (branch != NULL && (g_str_has_suffix (branch, "/beta") || g_str_has_suffix (branch, "/edge"))) gs_app_add_quirk (app, GS_APP_QUIRK_DEVELOPMENT_SOURCE); return g_steal_pointer (&app); } typedef struct { char *url; /* (owned) (not nullable) */ GsPluginUrlToAppFlags flags; gboolean tried_match_common_id; } UrlToAppData; static void url_to_app_data_free (UrlToAppData *data) { g_free (data->url); g_free (data); } G_DEFINE_AUTOPTR_CLEANUP_FUNC (UrlToAppData, url_to_app_data_free) static void url_to_app_find_category_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void gs_plugin_snap_url_to_app_async (GsPlugin *plugin, const gchar *url, GsPluginUrlToAppFlags flags, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { GsPluginSnap *self = GS_PLUGIN_SNAP (plugin); g_autoptr(GTask) task = NULL; g_autoptr(UrlToAppData) data = NULL; gboolean interactive = (flags & GS_PLUGIN_URL_TO_APP_FLAGS_INTERACTIVE) != 0; g_autoptr(SnapdClient) client = NULL; g_autofree gchar *scheme = NULL; g_autofree gchar *path = NULL; g_autoptr(GError) local_error = NULL; task = g_task_new (plugin, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_snap_url_to_app_async); data = g_new0 (UrlToAppData, 1); data->url = g_strdup (url); data->flags = flags; g_task_set_task_data (task, g_steal_pointer (&data), (GDestroyNotify) url_to_app_data_free); /* not us */ scheme = gs_utils_get_url_scheme (url); if (g_strcmp0 (scheme, "snap") != 0 && g_strcmp0 (scheme, "appstream") != 0) { g_task_return_pointer (task, gs_app_list_new (), g_object_unref); return; } /* Create client. */ client = get_client (self, interactive, &local_error); if (client == NULL) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } /* create app */ path = gs_utils_get_url_path (url); snapd_client_find_category_async (client, SNAPD_FIND_FLAGS_SCOPE_WIDE | SNAPD_FIND_FLAGS_MATCH_NAME, NULL, path, cancellable, url_to_app_find_category_cb, g_steal_pointer (&task)); } static void url_to_app_find_category_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { SnapdClient *client = SNAPD_CLIENT (source_object); g_autoptr(GTask) task = G_TASK (g_steal_pointer (&user_data)); GsPluginSnap *self = g_task_get_source_object (task); GCancellable *cancellable = g_task_get_cancellable (task); UrlToAppData *data = g_task_get_task_data (task); g_autoptr(GPtrArray) snaps = NULL; g_autoptr(GsAppList) list = gs_app_list_new (); g_autoptr(GsApp) app = NULL; g_autoptr(GError) local_error = NULL; snaps = snapd_client_find_category_finish (client, result, NULL, &local_error); if ((snaps == NULL || snaps->len < 1) && !data->tried_match_common_id) { g_autofree char *path = NULL; /* This works for the appstream:// URL-s */ data->tried_match_common_id = TRUE; path = gs_utils_get_url_path (data->url); snapd_client_find_category_async (client, SNAPD_FIND_FLAGS_SCOPE_WIDE | SNAPD_FIND_FLAGS_MATCH_COMMON_ID, NULL, path, cancellable, url_to_app_find_category_cb, g_steal_pointer (&task)); return; } if (snaps != NULL) store_snap_cache_update (self, snaps, FALSE); if (snaps == NULL || snaps->len < 1) { g_task_return_pointer (task, g_steal_pointer (&list), g_object_unref); return; } app = snap_to_app (self, g_ptr_array_index (snaps, 0), NULL); gs_app_list_add (list, app); g_task_return_pointer (task, g_steal_pointer (&list), g_object_unref); } static GsAppList * gs_plugin_snap_url_to_app_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_pointer (G_TASK (result), error); } static void gs_plugin_snap_dispose (GObject *object) { GsPluginSnap *self = GS_PLUGIN_SNAP (object); g_clear_pointer (&self->store_name, g_free); g_clear_pointer (&self->store_hostname, g_free); g_clear_pointer (&self->store_snaps, g_hash_table_unref); G_OBJECT_CLASS (gs_plugin_snap_parent_class)->dispose (object); } static void gs_plugin_snap_finalize (GObject *object) { GsPluginSnap *self = GS_PLUGIN_SNAP (object); g_mutex_clear (&self->store_snaps_lock); G_OBJECT_CLASS (gs_plugin_snap_parent_class)->finalize (object); } static gboolean is_banner_image (const gchar *filename) { /* Check if this screenshot was uploaded as "banner.png" or "banner.jpg". * The server optionally adds a 7 character suffix onto it if it would collide with * an existing name, e.g. "banner_MgEy4MI.png" * See https://forum.snapcraft.io/t/improve-method-for-setting-featured-snap-banner-image-in-store/ */ return g_regex_match_simple ("^banner(?:_[a-zA-Z0-9]{7})?\\.(?:png|jpg)$", filename, 0, 0); } static gboolean is_banner_icon_image (const gchar *filename) { /* Check if this screenshot was uploaded as "banner-icon.png" or "banner-icon.jpg". * The server optionally adds a 7 character suffix onto it if it would collide with * an existing name, e.g. "banner-icon_Ugn6pmj.png" * See https://forum.snapcraft.io/t/improve-method-for-setting-featured-snap-banner-image-in-store/ */ return g_regex_match_simple ("^banner-icon(?:_[a-zA-Z0-9]{7})?\\.(?:png|jpg)$", filename, 0, 0); } /* Build a string representation of the IDs of a category and its parents. * For example, `develop/featured`. */ static gchar * category_build_full_path (GsCategory *category) { g_autoptr(GString) id = g_string_new (""); GsCategory *c; for (c = category; c != NULL; c = gs_category_get_parent (c)) { if (c != category) g_string_prepend (id, "/"); g_string_prepend (id, gs_category_get_id (c)); } return g_string_free (g_steal_pointer (&id), FALSE); } typedef struct { /* In-progress data. */ guint n_pending_ops; GError *saved_error; /* (owned) (nullable) */ GsAppList *results_list; /* (owned) (nullable) */ } ListAppsData; static void list_apps_data_free (ListAppsData *data) { /* Error should have been propagated by now, and all pending ops completed. */ g_assert (data->saved_error == NULL); g_assert (data->n_pending_ops == 0); g_assert (data->results_list == NULL); g_free (data); } G_DEFINE_AUTOPTR_CLEANUP_FUNC (ListAppsData, list_apps_data_free) static void list_installed_apps_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void list_alternate_apps_snap_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void list_alternate_apps_nonsnap_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void list_alternative_apps_nonsnap_get_store_snap_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void list_apps_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void list_apps_for_update_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void finish_list_apps_op (GTask *task, GError *error); static void gs_plugin_snap_list_apps_async (GsPlugin *plugin, GsAppQuery *query, GsPluginListAppsFlags flags, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { GsPluginSnap *self = GS_PLUGIN_SNAP (plugin); g_autoptr(GTask) task = NULL; g_autoptr(ListAppsData) owned_data = NULL; ListAppsData *data; g_autoptr(SnapdClient) client = NULL; gboolean interactive = (flags & GS_PLUGIN_LIST_APPS_FLAGS_INTERACTIVE); GsAppQueryTristate is_curated = GS_APP_QUERY_TRISTATE_UNSET; GsCategory *category = NULL; GsAppQueryTristate is_installed = GS_APP_QUERY_TRISTATE_UNSET; GsAppQueryTristate is_for_update = GS_APP_QUERY_TRISTATE_UNSET; const gchar * const *keywords = NULL; GsApp *alternate_of = NULL; const gchar * const *sections = NULL; const gchar * const curated_sections[] = { "featured", NULL }; g_autoptr(GError) local_error = NULL; task = g_task_new (plugin, cancellable, callback, user_data); data = owned_data = g_new0 (ListAppsData, 1); g_task_set_task_data (task, g_steal_pointer (&owned_data), (GDestroyNotify) list_apps_data_free); g_task_set_source_tag (task, gs_plugin_snap_list_apps_async); client = get_client (self, interactive, &local_error); if (client == NULL) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } if (query != NULL) { is_curated = gs_app_query_get_is_curated (query); category = gs_app_query_get_category (query); is_installed = gs_app_query_get_is_installed (query); keywords = gs_app_query_get_keywords (query); alternate_of = gs_app_query_get_alternate_of (query); is_for_update = gs_app_query_get_is_for_update (query); } /* Currently only support a subset of query properties, and only one set at once. * Also don’t currently support GS_APP_QUERY_TRISTATE_FALSE. */ if ((is_curated == GS_APP_QUERY_TRISTATE_UNSET && category == NULL && is_installed == GS_APP_QUERY_TRISTATE_UNSET && keywords == NULL && alternate_of == NULL && is_for_update == GS_APP_QUERY_TRISTATE_UNSET) || is_curated == GS_APP_QUERY_TRISTATE_FALSE || is_installed == GS_APP_QUERY_TRISTATE_FALSE || is_for_update == 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; } data->results_list = gs_app_list_new (); /* Listing installed apps requires calling a different libsnapd method, * so check that first. */ if (is_installed != GS_APP_QUERY_TRISTATE_UNSET) { data->n_pending_ops++; snapd_client_get_snaps_async (client, SNAPD_GET_SNAPS_FLAGS_NONE, NULL, cancellable, list_installed_apps_cb, g_steal_pointer (&task)); return; } /* Get the list of refreshable snaps */ if (is_for_update == GS_APP_QUERY_TRISTATE_TRUE) { data->n_pending_ops++; snapd_client_find_refreshable_async (client, cancellable, list_apps_for_update_cb, g_steal_pointer (&task)); return; } /* Listing alternates also requires special handling. */ if (alternate_of != NULL) { /* If it is a snap, find the channels that snap provides, otherwise find snaps that match on common id */ if (gs_app_has_management_plugin (alternate_of, plugin)) { const gchar *snap_name; snap_name = gs_app_get_metadata_item (alternate_of, "snap::name"); data->n_pending_ops++; get_store_snap_async (self, client, snap_name, TRUE, cancellable, list_alternate_apps_snap_cb, g_steal_pointer (&task)); /* The id can be NULL for example for local package files */ } else if (gs_app_get_id (alternate_of) != NULL) { data->n_pending_ops++; snapd_client_find_category_async (client, SNAPD_FIND_FLAGS_SCOPE_WIDE | SNAPD_FIND_FLAGS_MATCH_COMMON_ID, NULL, gs_app_get_id (alternate_of), cancellable, list_alternate_apps_nonsnap_cb, g_steal_pointer (&task)); } else { g_clear_object (&data->results_list); g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_NOT_SUPPORTED, "Unsupported app without id"); } return; } /* Querying with keywords also requires calling the method differently. * snapd will tokenise and stem @query internally. */ if (keywords != NULL) { g_autofree gchar *query_str = NULL; query_str = g_strjoinv (" ", (gchar **) keywords); data->n_pending_ops++; snapd_client_find_category_async (client, SNAPD_FIND_FLAGS_SCOPE_WIDE, NULL, query_str, cancellable, list_apps_cb, g_steal_pointer (&task)); return; } /* Work out which sections we’re querying for. */ if (is_curated != GS_APP_QUERY_TRISTATE_UNSET) { sections = curated_sections; } else if (category != NULL) { g_autofree gchar *category_path = NULL; /* * Unused categories: * * health-and-fitness * personalisation * devices-and-iot * security * server-and-cloud * entertainment */ const struct { const gchar *category_path; const gchar *sections[4]; } category_to_sections_map[] = { { "play/featured", { "games", NULL, }}, { "create/featured", { "photo-and-video", "art-and-design", "music-and-video", NULL, }}, { "socialize/featured", { "social", "news-and-weather", NULL, }}, { "work/featured", { "productivity", "finance", "utilities", NULL, }}, { "develop/featured", { "development", NULL, }}, { "learn/featured", { "education", "science", "books-and-reference", NULL, }}, }; category_path = category_build_full_path (category); for (gsize i = 0; i < G_N_ELEMENTS (category_to_sections_map); i++) { if (g_str_equal (category_to_sections_map[i].category_path, category_path)) { sections = category_to_sections_map[i].sections; break; } } } /* Start a query for each of the sections we’re interested in, keeping a * counter of pending operations which is initialised to 1 until all * the operations are started. */ data->n_pending_ops = 1; for (gsize i = 0; sections != NULL && sections[i] != NULL; i++) { data->n_pending_ops++; snapd_client_find_category_async (client, SNAPD_FIND_FLAGS_SCOPE_WIDE, sections[i], NULL, cancellable, list_apps_cb, g_object_ref (task)); } finish_list_apps_op (task, NULL); } static void list_installed_apps_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { SnapdClient *client = SNAPD_CLIENT (source_object); g_autoptr(GTask) task = G_TASK (user_data); GsPluginSnap *self = g_task_get_source_object (task); ListAppsData *data = g_task_get_task_data (task); g_autoptr(GPtrArray) snaps = NULL; g_autoptr(GError) local_error = NULL; snaps = snapd_client_get_snaps_finish (client, result, &local_error); if (snaps == NULL) { snapd_error_convert (&local_error); } for (guint i = 0; snaps != NULL && i < snaps->len; i++) { SnapdSnap *snap = g_ptr_array_index (snaps, i); g_autoptr(GsApp) app = NULL; app = snap_to_app (self, snap, NULL); gs_app_list_add (data->results_list, app); } finish_list_apps_op (task, g_steal_pointer (&local_error)); } static void list_alternate_apps_snap_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { GsPluginSnap *self = GS_PLUGIN_SNAP (source_object); g_autoptr(GTask) task = G_TASK (user_data); ListAppsData *data = g_task_get_task_data (task); g_autoptr(SnapdSnap) snap = NULL; g_autoptr(GError) local_error = NULL; snap = get_store_snap_finish (self, result, &local_error); if (snap != NULL) add_channels (self, snap, data->results_list); finish_list_apps_op (task, g_steal_pointer (&local_error)); } static void list_alternate_apps_nonsnap_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { SnapdClient *client = SNAPD_CLIENT (source_object); g_autoptr(GTask) task = G_TASK (user_data); GsPluginSnap *self = g_task_get_source_object (task); GCancellable *cancellable = g_task_get_cancellable (task); ListAppsData *data = g_task_get_task_data (task); g_autoptr(GPtrArray) snaps = NULL; g_autoptr(GError) local_error = NULL; snaps = snapd_client_find_category_finish (client, result, NULL, &local_error); if (snaps == NULL) { snapd_error_convert (&local_error); finish_list_apps_op (task, g_steal_pointer (&local_error)); return; } store_snap_cache_update (self, snaps, FALSE); for (guint i = 0; snaps != NULL && i < snaps->len; i++) { SnapdSnap *snap = g_ptr_array_index (snaps, i); data->n_pending_ops++; get_store_snap_async (self, client, snapd_snap_get_name (snap), TRUE, cancellable, list_alternative_apps_nonsnap_get_store_snap_cb, g_object_ref (task)); } finish_list_apps_op (task, NULL); } static void list_alternative_apps_nonsnap_get_store_snap_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { GsPluginSnap *self = GS_PLUGIN_SNAP (source_object); g_autoptr(GTask) task = G_TASK (user_data); ListAppsData *data = g_task_get_task_data (task); g_autoptr(SnapdSnap) store_snap = NULL; g_autoptr(GError) local_error = NULL; store_snap = get_store_snap_finish (self, result, &local_error); if (store_snap != NULL) add_channels (self, store_snap, data->results_list); finish_list_apps_op (task, g_steal_pointer (&local_error)); } static void list_apps_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { SnapdClient *client = SNAPD_CLIENT (source_object); g_autoptr(GTask) task = G_TASK (user_data); GsPluginSnap *self = g_task_get_source_object (task); ListAppsData *data = g_task_get_task_data (task); g_autoptr(GPtrArray) snaps = NULL; g_autoptr(GError) local_error = NULL; snaps = snapd_client_find_category_finish (client, result, NULL, &local_error); if (snaps != NULL) { store_snap_cache_update (self, snaps, FALSE); for (guint i = 0; i < snaps->len; i++) { SnapdSnap *snap = g_ptr_array_index (snaps, i); g_autoptr(GsApp) app = NULL; app = snap_to_app (self, snap, NULL); gs_app_list_add (data->results_list, app); } } else { snapd_error_convert (&local_error); } finish_list_apps_op (task, g_steal_pointer (&local_error)); } static void list_apps_for_update_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { SnapdClient *client = SNAPD_CLIENT (source_object); g_autoptr(GTask) task = G_TASK (g_steal_pointer (&user_data)); GsPluginSnap *self = g_task_get_source_object (task); ListAppsData *data = g_task_get_task_data (task); g_autoptr(GPtrArray) snaps = NULL; g_autoptr(GError) local_error = NULL; snaps = snapd_client_find_refreshable_finish (client, result, &local_error); if (snaps != NULL) { store_snap_cache_update (self, snaps, FALSE); for (guint i = 0; i < snaps->len; i++) { SnapdSnap *snap = g_ptr_array_index (snaps, i); g_autoptr(GsApp) app = NULL; app = snap_to_app (self, snap, NULL); /* If for some reason the app is already getting updated, then * don't change its state */ if (gs_app_get_state (app) != GS_APP_STATE_INSTALLING) gs_app_set_state (app, GS_APP_STATE_UPDATABLE_LIVE); gs_app_list_add (data->results_list, app); } } else { snapd_error_convert (&local_error); } finish_list_apps_op (task, g_steal_pointer (&local_error)); } /* @error is (transfer full) if non-%NULL */ static void finish_list_apps_op (GTask *task, GError *error) { ListAppsData *data = g_task_get_task_data (task); g_autoptr(GsAppList) results_list = NULL; g_autoptr(GError) error_owned = g_steal_pointer (&error); if (error_owned != NULL && data->saved_error == NULL) data->saved_error = g_steal_pointer (&error_owned); else if (error_owned != NULL) g_debug ("Additional error while listing apps: %s", error_owned->message); g_assert (data->n_pending_ops > 0); data->n_pending_ops--; if (data->n_pending_ops > 0) return; /* Get the results of the parallel ops. */ results_list = g_steal_pointer (&data->results_list); if (data->saved_error != NULL) g_task_return_error (task, g_steal_pointer (&data->saved_error)); else g_task_return_pointer (task, g_steal_pointer (&results_list), g_object_unref); } static GsAppList * gs_plugin_snap_list_apps_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_pointer (G_TASK (result), error); } static SnapdSnap * get_store_snap (GsPluginSnap *self, SnapdClient *client, const gchar *name, gboolean need_details, GCancellable *cancellable, GError **error) { SnapdSnap *snap = NULL; g_autoptr(GPtrArray) snaps = NULL; /* use cached version if available */ snap = store_snap_cache_lookup (self, name, need_details); if (snap != NULL) return g_object_ref (snap); snaps = find_snaps (self, client, SNAPD_FIND_FLAGS_SCOPE_WIDE | SNAPD_FIND_FLAGS_MATCH_NAME, NULL, name, cancellable, error); if (snaps == NULL || snaps->len < 1) return NULL; return g_object_ref (g_ptr_array_index (snaps, 0)); } static void get_store_snap_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void get_store_snap_async (GsPluginSnap *self, SnapdClient *client, const gchar *name, gboolean need_details, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { g_autoptr(GTask) task = NULL; SnapdSnap *snap = NULL; task = g_task_new (self, cancellable, callback, user_data); g_task_set_source_tag (task, get_store_snap_async); /* use cached version if available */ snap = store_snap_cache_lookup (self, name, need_details); if (snap != NULL) { g_task_return_pointer (task, g_object_ref (snap), (GDestroyNotify) g_object_unref); return; } snapd_client_find_category_async (client, SNAPD_FIND_FLAGS_SCOPE_WIDE | SNAPD_FIND_FLAGS_MATCH_NAME, NULL, name, cancellable, get_store_snap_cb, g_steal_pointer (&task)); } static void get_store_snap_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { SnapdClient *client = SNAPD_CLIENT (source_object); g_autoptr(GTask) task = g_steal_pointer (&user_data); GsPluginSnap *self = g_task_get_source_object (task); g_autoptr(GPtrArray) snaps = NULL; g_autoptr(GError) local_error = NULL; snaps = snapd_client_find_category_finish (client, result, NULL, &local_error); if (snaps == NULL || snaps->len < 1) { snapd_error_convert (&local_error); g_task_return_error (task, g_steal_pointer (&local_error)); } else { store_snap_cache_update (self, snaps, TRUE); g_task_return_pointer (task, g_object_ref (g_ptr_array_index (snaps, 0)), (GDestroyNotify) g_object_unref); } } static SnapdSnap * get_store_snap_finish (GsPluginSnap *self, GAsyncResult *result, GError **error) { return g_task_propagate_pointer (G_TASK (result), error); } static int track_value (const gchar *track, GStrv tracks) { int r = 0; while (tracks[r] != NULL && strcmp (track, tracks[r]) != 0) r++; return r; } static int risk_value (const gchar *risk) { if (strcmp (risk, "stable") == 0) return 0; else if (strcmp (risk, "candidate") == 0) return 1; else if (strcmp (risk, "beta") == 0) return 2; else if (strcmp (risk, "edge") == 0) return 3; else return 4; } static int compare_channel (gconstpointer a, gconstpointer b, gpointer user_data) { SnapdChannel *channel_a = *(SnapdChannel **)a, *channel_b = *(SnapdChannel **)b; GStrv tracks = user_data; int r; r = track_value (snapd_channel_get_track (channel_a), tracks) - track_value (snapd_channel_get_track (channel_b), tracks); if (r != 0) return r; r = g_strcmp0 (snapd_channel_get_risk (channel_a), snapd_channel_get_risk (channel_b)); if (r != 0) { int r2; r2 = risk_value (snapd_channel_get_risk (channel_a)) - risk_value (snapd_channel_get_risk (channel_b)); if (r2 != 0) return r2; else return r; } return g_strcmp0 (snapd_channel_get_branch (channel_a), snapd_channel_get_branch (channel_b)); } static gchar * expand_channel_name (const gchar *name) { g_auto(GStrv) tokens = NULL; const gchar *risks[] = { "stable", "candidate", "beta", "edge", NULL }; if (name == NULL) return NULL; tokens = g_strsplit (name, "/", -1); for (int i = 0; risks[i] != NULL; i++) { if (strcmp (tokens[0], risks[i]) == 0) return g_strconcat ("latest/", name, NULL); } return g_strdup (name); } static void add_channels (GsPluginSnap *self, SnapdSnap *snap, GsAppList *list) { GStrv tracks; GPtrArray *channels; g_autoptr(GPtrArray) sorted_channels = NULL; tracks = snapd_snap_get_tracks (snap); channels = snapd_snap_get_channels (snap); sorted_channels = g_ptr_array_new (); for (guint i = 0; i < channels->len; i++) { SnapdChannel *channel = g_ptr_array_index (channels, i); g_ptr_array_add (sorted_channels, channel); } g_ptr_array_sort_with_data (sorted_channels, compare_channel, tracks); for (guint i = 0; i < sorted_channels->len; i++) { SnapdChannel *channel = g_ptr_array_index (sorted_channels, i); g_autoptr(GsApp) app = NULL; g_autofree gchar *expanded_name = NULL; expanded_name = expand_channel_name (snapd_channel_get_name (channel)); app = snap_to_app (self, snap, expanded_name); gs_app_list_add (list, app); } } static gboolean app_name_matches_snap_name (SnapdSnap *snap, SnapdApp *app) { return g_strcmp0 (snapd_snap_get_name (snap), snapd_app_get_name (app)) == 0; } static SnapdApp * get_primary_app (SnapdSnap *snap) { GPtrArray *apps; guint i; SnapdApp *primary_app = NULL; /* Pick the "main" app from the snap. In order of * preference, we want to pick: * * 1. the main app, provided it has a desktop file * 2. the first app with a desktop file * 3. the main app * 4. the first app * * The "main app" is one whose name matches the snap name. */ apps = snapd_snap_get_apps (snap); for (i = 0; i < apps->len; i++) { SnapdApp *app = apps->pdata[i]; if (primary_app == NULL || (snapd_app_get_desktop_file (primary_app) == NULL && snapd_app_get_desktop_file (app) != NULL) || (!app_name_matches_snap_name (snap, primary_app) && app_name_matches_snap_name (snap, app))) primary_app = app; } return primary_app; } static void refine_icons (GsApp *app, SnapdSnap *snap) { GPtrArray *media; guint i; media = snapd_snap_get_media (snap); for (i = 0; i < media->len; i++) { SnapdMedia *m = media->pdata[i]; g_autoptr(GIcon) icon = NULL; if (g_strcmp0 (snapd_media_get_media_type (m), "icon") != 0) continue; /* Unfortunately the snapd client API doesn’t expose information * about icon scales, so leave that unset for now. */ icon = gs_remote_icon_new (snapd_media_get_url (m)); gs_icon_set_width (icon, snapd_media_get_width (m)); gs_icon_set_height (icon, snapd_media_get_height (m)); gs_app_add_icon (app, icon); } } static void serialize_node (SnapdMarkdownNode *node, GString *text, guint indentation); static gboolean is_block_node (SnapdMarkdownNode *node) { switch (snapd_markdown_node_get_node_type (node)) { case SNAPD_MARKDOWN_NODE_TYPE_PARAGRAPH: case SNAPD_MARKDOWN_NODE_TYPE_UNORDERED_LIST: case SNAPD_MARKDOWN_NODE_TYPE_CODE_BLOCK: return TRUE; default: return FALSE; } } static void serialize_nodes (GPtrArray *nodes, GString *text, guint indentation) { for (guint i = 0; i < nodes->len; i++) { SnapdMarkdownNode *node = g_ptr_array_index (nodes, i); if (i != 0) { SnapdMarkdownNode *last_node = g_ptr_array_index (nodes, i - 1); if (is_block_node (node) && is_block_node (last_node)) g_string_append (text, "\n"); } serialize_node (node, text, indentation); } } static void serialize_node (SnapdMarkdownNode *node, GString *text, guint indentation) { GPtrArray *children = snapd_markdown_node_get_children (node); g_autofree gchar *escaped_text = NULL; g_autoptr(GString) url = NULL; switch (snapd_markdown_node_get_node_type (node)) { case SNAPD_MARKDOWN_NODE_TYPE_TEXT: escaped_text = g_markup_escape_text (snapd_markdown_node_get_text (node), -1); g_string_append (text, escaped_text); return; case SNAPD_MARKDOWN_NODE_TYPE_PARAGRAPH: serialize_nodes (children, text, indentation); g_string_append (text, "\n"); return; case SNAPD_MARKDOWN_NODE_TYPE_UNORDERED_LIST: serialize_nodes (children, text, indentation); return; case SNAPD_MARKDOWN_NODE_TYPE_LIST_ITEM: for (guint i = 0; i < indentation; i++) { g_string_append (text, " "); } g_string_append_printf (text, " • "); serialize_nodes (children, text, indentation + 1); return; case SNAPD_MARKDOWN_NODE_TYPE_CODE_BLOCK: case SNAPD_MARKDOWN_NODE_TYPE_CODE_SPAN: g_string_append (text, ""); serialize_nodes (children, text, indentation); g_string_append (text, ""); return; case SNAPD_MARKDOWN_NODE_TYPE_EMPHASIS: g_string_append (text, ""); serialize_nodes (children, text, indentation); g_string_append (text, ""); return; case SNAPD_MARKDOWN_NODE_TYPE_STRONG_EMPHASIS: g_string_append (text, ""); serialize_nodes (children, text, indentation); g_string_append (text, ""); return; case SNAPD_MARKDOWN_NODE_TYPE_URL: url = g_string_new (""); serialize_nodes (children, url, indentation); g_string_append_printf (text, "%s", url->str, url->str); return; default: g_assert_not_reached(); } } static gchar * gs_plugin_snap_get_markup_description (SnapdSnap *snap) { g_autoptr(SnapdMarkdownParser) parser = snapd_markdown_parser_new (SNAPD_MARKDOWN_VERSION_0); g_autoptr(GPtrArray) nodes = NULL; g_autoptr(GString) text = g_string_new (""); nodes = snapd_markdown_parser_parse (parser, snapd_snap_get_description (snap)); serialize_nodes (nodes, text, 0); return g_string_free (g_steal_pointer (&text), FALSE); } static void refine_screenshots (GsApp *app, SnapdSnap *snap) { GPtrArray *media; guint i; media = snapd_snap_get_media (snap); for (i = 0; i < media->len; i++) { SnapdMedia *m = media->pdata[i]; const gchar *url; g_autofree gchar *filename = NULL; g_autoptr(AsScreenshot) ss = NULL; g_autoptr(AsImage) image = NULL; if (g_strcmp0 (snapd_media_get_media_type (m), "screenshot") != 0) continue; /* skip screenshots used for banner when app is featured */ url = snapd_media_get_url (m); filename = g_path_get_basename (url); if (is_banner_image (filename) || is_banner_icon_image (filename)) continue; ss = as_screenshot_new (); as_screenshot_set_kind (ss, AS_SCREENSHOT_KIND_EXTRA); image = as_image_new (); as_image_set_url (image, snapd_media_get_url (m)); as_image_set_kind (image, AS_IMAGE_KIND_SOURCE); as_image_set_width (image, snapd_media_get_width (m)); as_image_set_height (image, snapd_media_get_height (m)); as_screenshot_add_image (ss, image); gs_app_add_screenshot (app, ss); } } static gboolean gs_snap_file_size_include_cb (const gchar *filename, GFileTest file_kind, gpointer user_data) { return file_kind != G_FILE_TEST_IS_SYMLINK && g_strcmp0 (filename, "common") != 0 && g_strcmp0 (filename, "current") != 0; } static guint64 gs_snap_get_app_directory_size (const gchar *snap_name, gboolean is_cache_size, GCancellable *cancellable) { g_autofree gchar *filename = NULL; if (is_cache_size) filename = g_build_filename (g_get_home_dir (), "snap", snap_name, "common", NULL); else filename = g_build_filename (g_get_home_dir (), "snap", snap_name, NULL); return gs_utils_get_file_size (filename, is_cache_size ? NULL : gs_snap_file_size_include_cb, NULL, cancellable); } static SnapdSnap * find_snap_in_array (GPtrArray *snaps, const gchar *snap_name) { for (guint i = 0; i < snaps->len; i++) { SnapdSnap *snap = SNAPD_SNAP (snaps->pdata[i]); if (g_strcmp0 (snapd_snap_get_name (snap), snap_name) == 0) return snap; } return NULL; } static void get_snaps_cb (GObject *object, GAsyncResult *result, gpointer user_data); static void gs_plugin_snap_refine_async (GsPlugin *plugin, GsAppList *list, GsPluginRefineFlags flags, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { GsPluginSnap *self = GS_PLUGIN_SNAP (plugin); g_autoptr(SnapdClient) client = NULL; g_autoptr(GPtrArray) snap_names = g_ptr_array_new_with_free_func (NULL); g_autoptr(GTask) task = NULL; g_autoptr(GsAppList) snap_apps = NULL; g_autoptr(GsPluginRefineData) data = NULL; gboolean interactive = gs_plugin_has_flags (plugin, GS_PLUGIN_FLAGS_INTERACTIVE); g_autoptr(GError) local_error = NULL; task = g_task_new (plugin, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_snap_refine_async); /* Filter out apps that aren't managed by us */ snap_apps = gs_app_list_new (); for (guint i = 0; i < gs_app_list_length (list); i++) { GsApp *app = gs_app_list_index (list, i); if (!gs_app_has_management_plugin (app, plugin)) continue; gs_app_list_add (snap_apps, app); } data = gs_plugin_refine_data_new (snap_apps, flags); g_task_set_task_data (task, g_steal_pointer (&data), (GDestroyNotify) gs_plugin_refine_data_free); client = get_client (self, interactive, &local_error); if (client == NULL) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } /* Get information from locally installed snaps */ for (guint i = 0; i < gs_app_list_length (snap_apps); i++) { GsApp *app = gs_app_list_index (snap_apps, i); g_ptr_array_add (snap_names, (gpointer) gs_app_get_metadata_item (app, "snap::name")); } g_ptr_array_add (snap_names, NULL); /* NULL terminator */ snapd_client_get_snaps_async (client, SNAPD_GET_SNAPS_FLAGS_NONE, (gchar **) snap_names->pdata, cancellable, get_snaps_cb, g_steal_pointer (&task)); } static void get_icon_cb (GObject *object, GAsyncResult *result, gpointer user_data); static void get_snaps_cb (GObject *object, GAsyncResult *result, gpointer user_data) { SnapdClient *client = SNAPD_CLIENT (object); g_autoptr(GTask) task = g_steal_pointer (&user_data); GsPluginSnap *self = g_task_get_source_object (task); GCancellable *cancellable = g_task_get_cancellable (task); GsPluginRefineData *data = g_task_get_task_data (task); GsAppList *list = data->list; GsPluginRefineFlags flags = data->flags; g_autoptr(GsAppList) get_icons_list = NULL; g_autoptr(GPtrArray) local_snaps = NULL; g_autoptr(GError) local_error = NULL; local_snaps = snapd_client_get_snaps_finish (client, result, &local_error); if (local_snaps == NULL) { 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); const gchar *snap_name, *name, *website, *contact, *version; g_autofree gchar *channel = NULL; g_autofree gchar *store_channel = NULL; g_autofree gchar *tracking_channel = NULL; gboolean need_details = FALSE; SnapdConfinement confinement = SNAPD_CONFINEMENT_UNKNOWN; SnapdSnap *local_snap, *snap; g_autoptr(SnapdSnap) store_snap = NULL; const gchar *developer_name; g_autofree gchar *description = NULL; guint64 release_date = 0; snap_name = gs_app_get_metadata_item (app, "snap::name"); channel = g_strdup (gs_app_get_branch (app)); /* get information from locally installed snaps and information we already have */ local_snap = find_snap_in_array (local_snaps, snap_name); store_snap = store_snap_cache_lookup (self, snap_name, FALSE); if (store_snap != NULL) store_channel = expand_channel_name (snapd_snap_get_channel (store_snap)); /* check if requested information requires us to go to the Snap Store */ if (flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_SCREENSHOTS) need_details = TRUE; if (channel != NULL && g_strcmp0 (store_channel, channel) != 0) need_details = TRUE; if (need_details) { g_clear_object (&store_snap); store_snap = get_store_snap (self, client, snap_name, need_details, cancellable, NULL); } /* we don't know anything about this snap */ if (local_snap == NULL && store_snap == NULL) continue; if (local_snap != NULL) tracking_channel = expand_channel_name (snapd_snap_get_tracking_channel (local_snap)); /* Get default channel to install */ if (channel == NULL) { if (local_snap != NULL) channel = g_strdup (tracking_channel); else channel = expand_channel_name (snapd_snap_get_channel (store_snap)); gs_app_set_branch (app, channel); } if (local_snap != NULL && g_strcmp0 (tracking_channel, channel) == 0) { /* Do not set to installed state if app is updatable */ if (gs_app_get_state (app) != GS_APP_STATE_UPDATABLE_LIVE) { gs_app_set_state (app, GS_APP_STATE_INSTALLED); } } else gs_app_set_state (app, GS_APP_STATE_AVAILABLE); gs_app_add_quirk (app, GS_APP_QUIRK_DO_NOT_AUTO_UPDATE); /* use store information for basic metadata over local information */ snap = store_snap != NULL ? store_snap : local_snap; name = snapd_snap_get_title (snap); if (name == NULL || g_strcmp0 (name, "") == 0) name = snapd_snap_get_name (snap); gs_app_set_name (app, GS_APP_QUALITY_NORMAL, name); website = snapd_snap_get_website (snap); if (g_strcmp0 (website, "") == 0) website = NULL; gs_app_set_url (app, AS_URL_KIND_HOMEPAGE, website); contact = snapd_snap_get_contact (snap); if (g_strcmp0 (contact, "") == 0) contact = NULL; gs_app_set_url (app, AS_URL_KIND_CONTACT, contact); gs_app_set_summary (app, GS_APP_QUALITY_NORMAL, snapd_snap_get_summary (snap)); description = gs_plugin_snap_get_markup_description (snap); gs_app_set_description (app, GS_APP_QUALITY_NORMAL, description); gs_app_set_license (app, GS_APP_QUALITY_NORMAL, snapd_snap_get_license (snap)); developer_name = snapd_snap_get_publisher_display_name (snap); if (developer_name == NULL) developer_name = snapd_snap_get_publisher_username (snap); gs_app_set_developer_name (app, developer_name); if (snapd_snap_get_publisher_validation (snap) == SNAPD_PUBLISHER_VALIDATION_VERIFIED) gs_app_add_quirk (app, GS_APP_QUIRK_DEVELOPER_VERIFIED); snap = local_snap != NULL ? local_snap : store_snap; version = snapd_snap_get_version (snap); confinement = snapd_snap_get_confinement (snap); if (channel != NULL && store_snap != NULL) { GPtrArray *channels = snapd_snap_get_channels (store_snap); for (guint j = 0; j < channels->len; j++) { SnapdChannel *c = channels->pdata[j]; g_autofree gchar *expanded_name = NULL; GDateTime *dt; expanded_name = expand_channel_name (snapd_channel_get_name (c)); if (g_strcmp0 (expanded_name, channel) != 0) continue; version = snapd_channel_get_version (c); confinement = snapd_channel_get_confinement (c); dt = snapd_channel_get_released_at (c); if (dt) release_date = (guint64) g_date_time_to_unix (dt); } } gs_app_set_version (app, version); gs_app_set_release_date (app, release_date); if (confinement != SNAPD_CONFINEMENT_UNKNOWN) { GEnumClass *enum_class = g_type_class_ref (SNAPD_TYPE_CONFINEMENT); gs_app_set_metadata (app, "snap::confinement", g_enum_get_value (enum_class, confinement)->value_nick); g_type_class_unref (enum_class); } if (flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_KUDOS && self->system_confinement == SNAPD_SYSTEM_CONFINEMENT_STRICT && confinement == SNAPD_CONFINEMENT_STRICT) gs_app_add_kudo (app, GS_APP_KUDO_SANDBOXED); gs_app_set_kind (app, snap_guess_component_kind (snap)); /* add information specific to installed snaps */ if (local_snap != NULL) { SnapdApp *snap_app; GDateTime *install_date; gint64 installed_size_bytes; install_date = snapd_snap_get_install_date (local_snap); installed_size_bytes = snapd_snap_get_installed_size (local_snap); gs_app_set_size_installed (app, (installed_size_bytes > 0) ? GS_SIZE_TYPE_VALID : GS_SIZE_TYPE_UNKNOWN, (guint64) installed_size_bytes); gs_app_set_install_date (app, install_date != NULL ? g_date_time_to_unix (install_date) : GS_APP_INSTALL_DATE_UNKNOWN); snap_app = get_primary_app (local_snap); if (snap_app != NULL) { gs_app_set_metadata (app, "snap::launch-name", snapd_app_get_name (snap_app)); gs_app_set_metadata (app, "snap::launch-desktop", snapd_app_get_desktop_file (snap_app)); } else { gs_app_add_quirk (app, GS_APP_QUIRK_NOT_LAUNCHABLE); } } /* add information specific to store snaps */ if (store_snap != NULL) { gint64 download_size_bytes; gs_app_set_origin (app, self->store_name); gs_app_set_origin_hostname (app, self->store_hostname); download_size_bytes = snapd_snap_get_download_size (store_snap); gs_app_set_size_download (app, (download_size_bytes > 0) ? GS_SIZE_TYPE_VALID : GS_SIZE_TYPE_UNKNOWN, (guint64) download_size_bytes); if (flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_SCREENSHOTS && gs_app_get_screenshots (app)->len == 0) refine_screenshots (app, store_snap); } /* load icon if requested */ if ((flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_ICON) != 0 && !gs_app_has_icons (app)) { if (get_icons_list == NULL) get_icons_list = gs_app_list_new (); gs_app_list_add (get_icons_list, app); refine_icons (app, snap); } if ((flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_SIZE_DATA) != 0 && gs_app_is_installed (app) && gs_app_get_kind (app) != AS_COMPONENT_KIND_RUNTIME) { if (gs_app_get_size_cache_data (app, NULL) != GS_SIZE_TYPE_VALID) gs_app_set_size_cache_data (app, GS_SIZE_TYPE_VALID, gs_snap_get_app_directory_size (snap_name, TRUE, cancellable)); if (gs_app_get_size_user_data (app, NULL) != GS_SIZE_TYPE_VALID) gs_app_set_size_user_data (app, GS_SIZE_TYPE_VALID, gs_snap_get_app_directory_size (snap_name, FALSE, cancellable)); if (g_cancellable_is_cancelled (cancellable)) { gs_app_set_size_cache_data (app, GS_SIZE_TYPE_UNKNOWABLE, 0); gs_app_set_size_user_data (app, GS_SIZE_TYPE_UNKNOWABLE, 0); } } } /* Icons require async calls to get */ if ((flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_ICON) != 0 && get_icons_list != NULL) { GsApp *app; g_clear_object (&data->list); data->list = g_steal_pointer (&get_icons_list); app = gs_app_list_index (data->list, 0); snapd_client_get_icon_async (client, gs_app_get_metadata_item (app, "snap::name"), cancellable, get_icon_cb, g_steal_pointer (&task)); } else { g_task_return_boolean (task, TRUE); } } static void get_icon_cb (GObject *object, GAsyncResult *result, gpointer user_data) { SnapdClient *client = SNAPD_CLIENT (object); g_autoptr(GTask) task = g_steal_pointer (&user_data); GCancellable *cancellable = g_task_get_cancellable (task); GsPluginRefineData *data = g_task_get_task_data (task); GsApp *app; g_autoptr(SnapdIcon) snap_icon = NULL; g_autoptr(GError) local_error = NULL; app = gs_app_list_index (data->list, 0); snap_icon = snapd_client_get_icon_finish (client, result, &local_error); if (snap_icon != NULL) { g_autoptr(GIcon) icon = g_bytes_icon_new (snapd_icon_get_data (snap_icon)); gs_app_add_icon (app, icon); } /* Get next icon in the list or done */ gs_app_list_remove (data->list, app); if (gs_app_list_length (data->list) > 0) { app = gs_app_list_index (data->list, 0); snapd_client_get_icon_async (client, gs_app_get_metadata_item (app, "snap::name"), cancellable, get_icon_cb, g_steal_pointer (&task)); } else { g_task_return_boolean (task, TRUE); } } static gboolean gs_plugin_snap_refine_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } static void progress_cb (SnapdClient *client, SnapdChange *change, gpointer deprecated, gpointer user_data) { GsApp *app = user_data; GPtrArray *tasks; guint i; gint64 done = 0, total = 0; tasks = snapd_change_get_tasks (change); for (i = 0; i < tasks->len; i++) { SnapdTask *task = tasks->pdata[i]; done += snapd_task_get_progress_done (task); total += snapd_task_get_progress_total (task); } gs_app_set_progress (app, (guint) (100 * done / total)); } typedef struct { /* Input data. */ GsPluginInstallAppsFlags flags; GsPluginProgressCallback progress_callback; gpointer progress_user_data; /* In-progress data. */ guint n_pending_ops; GError *saved_error; /* (owned) (nullable) */ /* For progress reporting. */ guint n_installs_started; } InstallAppsData; static void install_apps_data_free (InstallAppsData *data) { /* Error should have been propagated by now, and all pending ops completed. */ g_assert (data->saved_error == NULL); g_assert (data->n_pending_ops == 0); g_free (data); } G_DEFINE_AUTOPTR_CLEANUP_FUNC (InstallAppsData, install_apps_data_free) typedef struct { GTask *task; /* (owned) */ GsApp *app; /* (owned) */ gchar *name; /* (owned) (not nullable) */ gchar *channel; /* (owned) (not nullable) */ } InstallSingleAppData; static void install_single_app_data_free (InstallSingleAppData *data) { g_clear_object (&data->app); g_clear_object (&data->task); g_free (data->name); g_free (data->channel); g_free (data); } G_DEFINE_AUTOPTR_CLEANUP_FUNC (InstallSingleAppData, install_single_app_data_free) static void install_progress_cb (SnapdClient *client, SnapdChange *change, gpointer deprecated, gpointer user_data); static void install_app_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void install_refresh_app_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void finish_install_apps_op (GTask *task, GError *error); static void gs_plugin_snap_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) { GsPluginSnap *self = GS_PLUGIN_SNAP (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(SnapdClient) client = NULL; g_autoptr(GError) local_error = NULL; task = g_task_new (self, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_snap_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; g_task_set_task_data (task, g_steal_pointer (&data_owned), (GDestroyNotify) install_apps_data_free); if (flags & (GS_PLUGIN_INSTALL_APPS_FLAGS_NO_DOWNLOAD | GS_PLUGIN_INSTALL_APPS_FLAGS_NO_APPLY)) { /* snap only seems to support downloading and applying installs * at the same time, rather than pre-downloading them and * applying them separately. */ g_autoptr(GsPluginEvent) event = NULL; g_set_error_literal (&local_error, G_IO_ERROR, G_IO_ERROR_NOT_SUPPORTED, "snap doesn’t support split download/apply"); 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; } client = get_client (self, interactive, &local_error); if (client == NULL) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } /* Start a load of operations in parallel to install the apps. * * When all installs are finished for all apps, finish_install_apps_op() * will return success/error for the overall #GTask. */ data->n_pending_ops = 1; data->n_installs_started = 0; for (guint i = 0; i < gs_app_list_length (apps); i++) { GsApp *app = gs_app_list_index (apps, i); g_autoptr(InstallSingleAppData) app_data = NULL; const gchar *name, *channel; SnapdInstallFlags install_flags = SNAPD_INSTALL_FLAGS_NONE; /* We can only install apps we know of */ if (!gs_app_has_management_plugin (app, GS_PLUGIN (self))) continue; name = gs_app_get_metadata_item (app, "snap::name"); channel = gs_app_get_branch (app); app_data = g_new0 (InstallSingleAppData, 1); app_data->task = g_object_ref (task); app_data->app = g_object_ref (app); app_data->name = g_strdup (name); app_data->channel = g_strdup (channel); gs_app_set_state (app, GS_APP_STATE_INSTALLING); if (g_strcmp0 (gs_app_get_metadata_item (app, "snap::confinement"), "classic") == 0) install_flags |= SNAPD_INSTALL_FLAGS_CLASSIC; data->n_pending_ops++; data->n_installs_started++; snapd_client_install2_async (client, install_flags, name, channel, NULL /* revision */, install_progress_cb, app_data, cancellable, install_app_cb, app_data /* steal ownership */); app_data = NULL; } finish_install_apps_op (task, NULL); } static void install_progress_cb (SnapdClient *client, SnapdChange *change, gpointer deprecated, gpointer user_data) { InstallSingleAppData *app_data = user_data; GTask *task = app_data->task; GsPluginSnap *self = g_task_get_source_object (task); InstallAppsData *data = g_task_get_task_data (task); GPtrArray *tasks; gint64 done = 0, total = 0; guint percentage; tasks = snapd_change_get_tasks (change); for (guint i = 0; i < tasks->len; i++) { SnapdTask *snap_task = tasks->pdata[i]; done += snapd_task_get_progress_done (snap_task); total += snapd_task_get_progress_total (snap_task); } if (total > 0) percentage = (guint) (100 * done / total); else percentage = GS_APP_PROGRESS_UNKNOWN; gs_app_set_progress (app_data->app, percentage); /* Basic progress reporting for the whole operation. If there’s more * than one app being installed, it reports the number of completed * installs. If there’s only one, it reports the same percentage as * above. */ if (data->progress_callback != NULL) { guint overall_percentage; if (data->n_installs_started <= 1) overall_percentage = percentage; else overall_percentage = (100 * (data->n_installs_started - data->n_pending_ops)) / data->n_installs_started; data->progress_callback (GS_PLUGIN (self), overall_percentage, data->progress_user_data); } } static void install_app_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { SnapdClient *client = SNAPD_CLIENT (source_object); g_autoptr(InstallSingleAppData) app_data = g_steal_pointer (&user_data); GTask *task = app_data->task; GsPluginSnap *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) local_error = NULL; snapd_client_install2_finish (client, result, &local_error); /* if already installed then just try to switch channel */ if (g_error_matches (local_error, SNAPD_ERROR, SNAPD_ERROR_ALREADY_INSTALLED)) { g_clear_error (&local_error); snapd_client_refresh_async (client, app_data->name, app_data->channel, install_progress_cb, app_data, cancellable, install_refresh_app_cb, app_data /* steals ownership */); app_data = NULL; return; } else if (local_error != NULL) { g_autoptr(GsPluginEvent) event = NULL; gs_app_set_state_recover (app_data->app); snapd_error_convert (&local_error); event = gs_plugin_event_new ("error", local_error, "app", app_data->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); finish_install_apps_op (task, g_steal_pointer (&local_error)); return; } /* Installed! */ gs_app_set_state (app_data->app, GS_APP_STATE_INSTALLED); finish_install_apps_op (task, NULL); } static void install_refresh_app_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { SnapdClient *client = SNAPD_CLIENT (source_object); g_autoptr(InstallSingleAppData) app_data = g_steal_pointer (&user_data); GTask *task = app_data->task; g_autoptr(GError) local_error = NULL; if (!snapd_client_refresh_finish (client, result, &local_error)) { gs_app_set_state_recover (app_data->app); snapd_error_convert (&local_error); finish_install_apps_op (task, g_steal_pointer (&local_error)); return; } /* Installed! */ gs_app_set_state (app_data->app, GS_APP_STATE_INSTALLED); finish_install_apps_op (task, NULL); } /* @error is (transfer full) if non-%NULL */ static void finish_install_apps_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_error == NULL) data->saved_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_ops > 0); data->n_pending_ops--; if (data->n_pending_ops > 0) return; /* Get the results of the parallel ops. */ if (data->saved_error != NULL) g_task_return_error (task, g_steal_pointer (&data->saved_error)); else g_task_return_boolean (task, TRUE); } static gboolean gs_plugin_snap_install_apps_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } /* Check if an app is graphical by checking if it uses a known GUI interface. This doesn't necessarily mean that every binary uses this interfaces, but is probably true. https://bugs.launchpad.net/bugs/1595023 */ static void gs_plugin_snap_launch_got_connections_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { g_autoptr(GTask) task = user_data; g_autoptr(GPtrArray) plugs = NULL; g_autoptr(GAppInfo) appinfo = NULL; g_autoptr(GError) local_error = NULL; g_autofree gchar *commandline = NULL; const gchar *app_snap_name; const gchar *launch_name; GsPluginLaunchData *data = g_task_get_task_data (task); GAppInfoCreateFlags flags = G_APP_INFO_CREATE_NONE; gboolean is_graphical = FALSE; app_snap_name = gs_app_get_metadata_item (data->app, "snap::name"); launch_name = gs_app_get_metadata_item (data->app, "snap::launch-name"); if (!snapd_client_get_connections2_finish (SNAPD_CLIENT (source_object), result, NULL, NULL, &plugs, NULL, &local_error)) { g_debug ("%s: Failed to get connections: %s", G_STRFUNC, local_error->message); g_clear_error (&local_error); } else { for (guint i = 0; i < plugs->len && !is_graphical; i++) { SnapdPlug *plug = plugs->pdata[i]; const gchar *interface; /* Only looks at the plugs for this snap */ if (g_strcmp0 (snapd_plug_get_snap (plug), app_snap_name) != 0) continue; interface = snapd_plug_get_interface (plug); if (interface == NULL) continue; if (g_strcmp0 (interface, "unity7") == 0 || g_strcmp0 (interface, "x11") == 0 || g_strcmp0 (interface, "mir") == 0) is_graphical = TRUE; } } if (g_strcmp0 (launch_name, app_snap_name) == 0) commandline = g_strdup_printf ("snap run %s", launch_name); else commandline = g_strdup_printf ("snap run %s.%s", app_snap_name, launch_name); if (!is_graphical) flags |= G_APP_INFO_CREATE_NEEDS_TERMINAL; appinfo = g_app_info_create_from_commandline (commandline, NULL, flags, &local_error); if (appinfo != NULL) g_task_return_pointer (task, appinfo, g_object_unref); else g_task_return_error (task, g_steal_pointer (&local_error)); } static void gs_plugin_snap_launch_async (GsPlugin *plugin, GsApp *app, GsPluginLaunchFlags flags, GCancellable *cancellable, GAsyncReadyCallback callback, gpointer user_data) { GsPluginSnap *self = GS_PLUGIN_SNAP (plugin); const gchar *launch_name; const gchar *launch_desktop; g_autoptr(GAppInfo) info = NULL; g_autoptr(GTask) task = NULL; g_autoptr(GError) local_error = NULL; gboolean interactive = (flags & GS_PLUGIN_LAUNCH_FLAGS_INTERACTIVE) != 0; task = gs_plugin_launch_data_new_task (plugin, app, flags, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_snap_launch_async); /* We can only launch apps we know of */ if (!gs_app_has_management_plugin (app, plugin)) { g_task_return_pointer (task, NULL, NULL); return; } launch_name = gs_app_get_metadata_item (app, "snap::launch-name"); launch_desktop = gs_app_get_metadata_item (app, "snap::launch-desktop"); if (!launch_name) { g_task_return_pointer (task, NULL, NULL); return; } if (launch_desktop) { info = (GAppInfo *)g_desktop_app_info_new_from_filename (launch_desktop); } else { g_autoptr(SnapdClient) client = NULL; client = get_client (self, interactive, &local_error); if (client == NULL) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } snapd_client_get_connections2_async (client, SNAPD_GET_CONNECTIONS_FLAGS_SELECT_ALL, NULL, NULL, cancellable, gs_plugin_snap_launch_got_connections_cb, g_steal_pointer (&task)); return; } g_task_return_pointer (task, g_steal_pointer (&info), g_object_unref); } static gboolean gs_plugin_snap_launch_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { GdkDisplay *display; g_autoptr(GAppLaunchContext) context = NULL; g_autoptr(GAppInfo) appinfo = NULL; GError *local_error = NULL; appinfo = g_task_propagate_pointer (G_TASK (result), &local_error); if (local_error != NULL) { g_propagate_error (error, g_steal_pointer (&local_error)); return FALSE; } else if (appinfo == NULL) { /* app is not supported by this plugin */ return TRUE; } display = gdk_display_get_default (); context = G_APP_LAUNCH_CONTEXT (gdk_display_get_app_launch_context (display)); return g_app_info_launch (appinfo, NULL, context, error); } typedef struct { /* Input data. */ guint n_apps; GsPluginUninstallAppsFlags flags; GsPluginProgressCallback progress_callback; gpointer progress_user_data; /* In-progress data. */ guint n_pending_ops; GError *saved_error; /* (owned) (nullable) */ /* For progress reporting. */ guint n_uninstalls_started; } UninstallAppsData; static void uninstall_apps_data_free (UninstallAppsData *data) { /* Error should have been propagated by now, and all pending ops completed. */ g_assert (data->saved_error == NULL); g_assert (data->n_pending_ops == 0); g_free (data); } G_DEFINE_AUTOPTR_CLEANUP_FUNC (UninstallAppsData, uninstall_apps_data_free) typedef struct { GTask *task; /* (owned) */ GsApp *app; /* (owned) */ gchar *name; /* (owned) (not nullable) */ gchar *channel; /* (owned) (not nullable) */ } UninstallSingleAppData; static void uninstall_single_app_data_free (UninstallSingleAppData *data) { g_clear_object (&data->app); g_clear_object (&data->task); g_free (data->name); g_free (data->channel); g_free (data); } G_DEFINE_AUTOPTR_CLEANUP_FUNC (UninstallSingleAppData, uninstall_single_app_data_free) static void uninstall_progress_cb (SnapdClient *client, SnapdChange *change, gpointer deprecated, gpointer user_data); static void uninstall_app_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void finish_uninstall_apps_op (GTask *task, GError *error); static void gs_plugin_snap_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) { GsPluginSnap *self = GS_PLUGIN_SNAP (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(SnapdClient) client = NULL; g_autoptr(GError) local_error = NULL; task = g_task_new (self, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_snap_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->n_apps = gs_app_list_length (apps); g_task_set_task_data (task, g_steal_pointer (&data_owned), (GDestroyNotify) uninstall_apps_data_free); client = get_client (self, interactive, &local_error); if (client == NULL) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } /* Start a load of operations in parallel to uninstall the apps. * * When all uninstalls are finished for all apps, finish_uninstall_apps_op() * will return success/error for the overall #GTask. */ data->n_pending_ops = 1; data->n_uninstalls_started = 0; for (guint i = 0; i < data->n_apps; i++) { GsApp *app = gs_app_list_index (apps, i); g_autoptr(UninstallSingleAppData) app_data = NULL; const gchar *name; /* We can only install apps we know of */ if (!gs_app_has_management_plugin (app, GS_PLUGIN (self))) continue; name = gs_app_get_metadata_item (app, "snap::name"); app_data = g_new0 (UninstallSingleAppData, 1); app_data->task = g_object_ref (task); app_data->app = g_object_ref (app); app_data->name = g_strdup (name); gs_app_set_state (app, GS_APP_STATE_REMOVING); data->n_pending_ops++; data->n_uninstalls_started++; snapd_client_remove2_async (client, SNAPD_REMOVE_FLAGS_NONE, name, uninstall_progress_cb, app_data, cancellable, uninstall_app_cb, app_data /* steal ownership */); app_data = NULL; } finish_uninstall_apps_op (task, NULL); } static void uninstall_progress_cb (SnapdClient *client, SnapdChange *change, gpointer deprecated, gpointer user_data) { UninstallSingleAppData *app_data = user_data; GTask *task = app_data->task; GsPluginSnap *self = g_task_get_source_object (task); UninstallAppsData *data = g_task_get_task_data (task); GPtrArray *tasks; gint64 done = 0, total = 0; guint percentage; tasks = snapd_change_get_tasks (change); for (guint i = 0; i < tasks->len; i++) { SnapdTask *snap_task = tasks->pdata[i]; done += snapd_task_get_progress_done (snap_task); total += snapd_task_get_progress_total (snap_task); } if (total > 0) percentage = (guint) (100 * done / total); else percentage = GS_APP_PROGRESS_UNKNOWN; gs_app_set_progress (app_data->app, percentage); /* Basic progress reporting for the whole operation. If there’s more * than one app being uninstalled, it reports the number of completed * uninstalls. If there’s only one, it reports the same percentage as * above. */ if (data->progress_callback != NULL) { guint overall_percentage; if (data->n_uninstalls_started <= 1) overall_percentage = percentage; else overall_percentage = (100 * (data->n_uninstalls_started - data->n_pending_ops)) / data->n_uninstalls_started; data->progress_callback (GS_PLUGIN (self), overall_percentage, data->progress_user_data); } } static void uninstall_app_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { SnapdClient *client = SNAPD_CLIENT (source_object); g_autoptr(UninstallSingleAppData) app_data = g_steal_pointer (&user_data); GTask *task = app_data->task; GsPluginSnap *self = g_task_get_source_object (task); UninstallAppsData *data = g_task_get_task_data (task); gboolean interactive = (data->flags & GS_PLUGIN_UNINSTALL_APPS_FLAGS_INTERACTIVE); g_autoptr(GError) local_error = NULL; snapd_client_remove2_finish (client, result, &local_error); if (local_error != NULL) { g_autoptr(GsPluginEvent) event = NULL; gs_app_set_state_recover (app_data->app); snapd_error_convert (&local_error); event = gs_plugin_event_new ("error", local_error, "app", app_data->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); finish_uninstall_apps_op (task, g_steal_pointer (&local_error)); return; } /* Uninstalled! */ gs_app_set_state (app_data->app, GS_APP_STATE_AVAILABLE); finish_uninstall_apps_op (task, NULL); } /* @error is (transfer full) if non-%NULL */ static void finish_uninstall_apps_op (GTask *task, GError *error) { UninstallAppsData *data = g_task_get_task_data (task); g_autoptr(GError) error_owned = g_steal_pointer (&error); if (error_owned != NULL && data->saved_error == NULL) data->saved_error = g_steal_pointer (&error_owned); else if (error_owned != NULL) g_debug ("Additional error while uninstalling apps: %s", error_owned->message); g_assert (data->n_pending_ops > 0); data->n_pending_ops--; if (data->n_pending_ops > 0) return; /* Get the results of the parallel ops. */ if (data->saved_error != NULL) g_task_return_error (task, g_steal_pointer (&data->saved_error)); else g_task_return_boolean (task, TRUE); } static gboolean gs_plugin_snap_uninstall_apps_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } typedef struct { /* Input data. */ guint n_apps; GsPluginProgressCallback progress_callback; gpointer progress_user_data; /* In-progress data. */ guint n_pending_ops; GError *saved_error; /* (owned) (nullable) */ } UpdateAppsData; static void update_apps_data_free (UpdateAppsData *data) { /* Error should have been propagated by now, and all pending ops completed. */ g_assert (data->saved_error == NULL); g_assert (data->n_pending_ops == 0); g_free (data); } G_DEFINE_AUTOPTR_CLEANUP_FUNC (UpdateAppsData, update_apps_data_free) typedef struct { GTask *task; /* (owned) */ GsApp *app; /* (owned) */ guint index; /* zero-based */ } RefreshAppData; static void refresh_app_data_free (RefreshAppData *data) { g_clear_object (&data->app); g_clear_object (&data->task); g_free (data); } G_DEFINE_AUTOPTR_CLEANUP_FUNC (RefreshAppData, refresh_app_data_free) static void update_app_cb (GObject *source_object, GAsyncResult *result, gpointer user_data); static void finish_update_apps_op (GTask *task, GError *error); static void gs_plugin_snap_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) { GsPluginSnap *self = GS_PLUGIN_SNAP (plugin); g_autoptr(GTask) task = NULL; UpdateAppsData *data; g_autoptr(UpdateAppsData) data_owned = NULL; gboolean interactive = (flags & GS_PLUGIN_UPDATE_APPS_FLAGS_INTERACTIVE); g_autoptr(SnapdClient) client = NULL; g_autoptr(GError) local_error = NULL; task = g_task_new (plugin, cancellable, callback, user_data); g_task_set_source_tag (task, gs_plugin_snap_update_apps_async); data = data_owned = g_new0 (UpdateAppsData, 1); data->progress_callback = progress_callback; data->progress_user_data = progress_user_data; data->n_apps = gs_app_list_length (apps); g_task_set_task_data (task, g_steal_pointer (&data_owned), (GDestroyNotify) update_apps_data_free); if (flags & GS_PLUGIN_UPDATE_APPS_FLAGS_NO_APPLY) { /* snap only seems to support downloading and applying updates * at the same time, rather than pre-downloading them and * applying them separately. */ g_task_return_boolean (task, TRUE); return; } client = get_client (self, interactive, &local_error); if (client == NULL) { g_task_return_error (task, g_steal_pointer (&local_error)); return; } /* Start an update operation for each of the sections we’re interested * in, keeping a counter of pending operations which is initialised to 1 * until all the operations are started. * * For some reason, updating an app is called ‘refreshing’ it in snap * land. */ data->n_pending_ops = 1; for (guint i = 0; i < gs_app_list_length (apps); i++) { GsApp *app = gs_app_list_index (apps, i); const gchar *name; g_autoptr(RefreshAppData) app_data = NULL; /* only process this app if was created by this plugin */ if (!gs_app_has_management_plugin (app, plugin)) continue; /* Get the name of the snap to refresh */ name = gs_app_get_metadata_item (app, "snap::name"); /* Refresh the snap */ gs_app_set_state (app, GS_APP_STATE_INSTALLING); app_data = g_new0 (RefreshAppData, 1); app_data->index = i; app_data->task = g_object_ref (task); app_data->app = g_object_ref (app); data->n_pending_ops++; snapd_client_refresh_async (client, name, NULL, progress_cb, app, cancellable, update_app_cb, g_steal_pointer (&app_data)); } finish_update_apps_op (task, NULL); } static void update_app_cb (GObject *source_object, GAsyncResult *result, gpointer user_data) { SnapdClient *client = SNAPD_CLIENT (source_object); g_autoptr(RefreshAppData) app_data = g_steal_pointer (&user_data); GTask *task = app_data->task; GsPluginSnap *self = g_task_get_source_object (task); UpdateAppsData *data = g_task_get_task_data (task); g_autoptr(GError) local_error = NULL; if (!snapd_client_refresh_finish (client, result, &local_error)) { gs_app_set_state_recover (app_data->app); snapd_error_convert (&local_error); } else { gs_app_set_state (app_data->app, GS_APP_STATE_INSTALLED); } /* Simple progress reporting. */ if (data->progress_callback != NULL) { data->progress_callback (GS_PLUGIN (self), 100 * ((gdouble) (app_data->index + 1) / data->n_apps), data->progress_user_data); } finish_update_apps_op (task, g_steal_pointer (&local_error)); } /* @error is (transfer full) if non-%NULL */ static void finish_update_apps_op (GTask *task, GError *error) { UpdateAppsData *data = g_task_get_task_data (task); g_autoptr(GError) error_owned = g_steal_pointer (&error); if (error_owned != NULL && data->saved_error == NULL) data->saved_error = g_steal_pointer (&error_owned); else if (error_owned != NULL) g_debug ("Additional error while updating apps: %s", error_owned->message); g_assert (data->n_pending_ops > 0); data->n_pending_ops--; if (data->n_pending_ops > 0) return; /* Get the results of the parallel ops. */ if (data->saved_error != NULL) g_task_return_error (task, g_steal_pointer (&data->saved_error)); else g_task_return_boolean (task, TRUE); } static gboolean gs_plugin_snap_update_apps_finish (GsPlugin *plugin, GAsyncResult *result, GError **error) { return g_task_propagate_boolean (G_TASK (result), error); } static void gs_plugin_snap_class_init (GsPluginSnapClass *klass) { GObjectClass *object_class = G_OBJECT_CLASS (klass); GsPluginClass *plugin_class = GS_PLUGIN_CLASS (klass); object_class->dispose = gs_plugin_snap_dispose; object_class->finalize = gs_plugin_snap_finalize; plugin_class->setup_async = gs_plugin_snap_setup_async; plugin_class->setup_finish = gs_plugin_snap_setup_finish; plugin_class->refine_async = gs_plugin_snap_refine_async; plugin_class->refine_finish = gs_plugin_snap_refine_finish; plugin_class->list_apps_async = gs_plugin_snap_list_apps_async; plugin_class->list_apps_finish = gs_plugin_snap_list_apps_finish; plugin_class->install_apps_async = gs_plugin_snap_install_apps_async; plugin_class->install_apps_finish = gs_plugin_snap_install_apps_finish; plugin_class->uninstall_apps_async = gs_plugin_snap_uninstall_apps_async; plugin_class->uninstall_apps_finish = gs_plugin_snap_uninstall_apps_finish; plugin_class->update_apps_async = gs_plugin_snap_update_apps_async; plugin_class->update_apps_finish = gs_plugin_snap_update_apps_finish; plugin_class->launch_async = gs_plugin_snap_launch_async; plugin_class->launch_finish = gs_plugin_snap_launch_finish; plugin_class->url_to_app_async = gs_plugin_snap_url_to_app_async; plugin_class->url_to_app_finish = gs_plugin_snap_url_to_app_finish; } GType gs_plugin_query_type (void) { return GS_TYPE_PLUGIN_SNAP; }