[gnome-software/wip/hughsie/flatpak: 1/3] Add a flatpak plugin
- From: Richard Hughes <rhughes src gnome org>
- To: commits-list gnome org
- Cc:
- Subject: [gnome-software/wip/hughsie/flatpak: 1/3] Add a flatpak plugin
- Date: Thu, 12 May 2016 09:01:33 +0000 (UTC)
commit 84ed5a51b4faede280f20f7676330a3909623d1f
Author: Richard Hughes <richard hughsie com>
Date: Tue May 10 10:45:47 2016 +0100
Add a flatpak plugin
Flatpak is the new name for xdg-app and also breaks API in several places.
configure.ac | 25 +-
contrib/gnome-software.spec.in | 4 +-
src/plugins/Makefile.am | 15 +
src/plugins/gs-appstream.c | 16 +-
src/plugins/gs-plugin-appstream.c | 3 +-
src/plugins/gs-plugin-flatpak.c | 1500 +++++++++++++++++++++++++++++++++++++
src/plugins/gs-plugin-odrs.c | 1 +
7 files changed, 1551 insertions(+), 13 deletions(-)
---
diff --git a/configure.ac b/configure.ac
index 70c5cbe..efc7cf7 100644
--- a/configure.ac
+++ b/configure.ac
@@ -61,7 +61,7 @@ dnl ---------------------------------------------------------------------------
dnl - Check library dependencies
dnl ---------------------------------------------------------------------------
PKG_CHECK_MODULES(GTK, gtk+-3.0 >= 3.18.2 gio-unix-2.0 gtkspell3-3.0)
-PKG_CHECK_MODULES(APPSTREAM, appstream-glib >= 0.5.12)
+PKG_CHECK_MODULES(APPSTREAM, appstream-glib >= 0.5.15)
PKG_CHECK_MODULES(GDK_PIXBUF, gdk-pixbuf-2.0 >= 2.31.5)
PKG_CHECK_MODULES(JSON_GLIB, json-glib-1.0 >= 1.1.1)
PKG_CHECK_MODULES(SQLITE, sqlite3)
@@ -185,6 +185,28 @@ AS_IF([test "x$have_xdg_app" = "xyes"], [
])
AM_CONDITIONAL(HAVE_XDG_APP, test "$have_xdg_app" != no)
+# flatpak
+AC_ARG_ENABLE(flatpak,
+ [AS_HELP_STRING([--enable-flatpak],
+ [enable flatpak support [default=auto]])],,
+ enable_flatpak=maybe)
+AS_IF([test "x$enable_flatpak" != "xno"], [
+ PKG_CHECK_MODULES(FLATPAK,
+ [flatpak >= 0.4.14],
+ [have_flatpak=yes],
+ [have_flatpak=no])
+], [
+ have_flatpak=no
+])
+AS_IF([test "x$have_flatpak" = "xyes"], [
+ AC_DEFINE(HAVE_FLATPAK,1,[Build flatpak support])
+], [
+ AS_IF([test "x$enable_flatpak" = "xyes"], [
+ AC_MSG_ERROR([flatpak support requested but 'flatpak' was not found])
+ ])
+])
+AM_CONDITIONAL(HAVE_FLATPAK, test "$have_flatpak" != no)
+
# ostree
AC_ARG_ENABLE(ostree,
[AS_HELP_STRING([--enable-ostree],
@@ -335,6 +357,7 @@ echo "
Firmware support: ${have_firmware}
Limba support: ${have_limba}
XDG-APP support: ${have_xdg_app}
+ Flatpak support: ${have_flatpak}
OSTree support: ${have_ostree}
RPM support: ${have_rpm}
Steam support: ${enable_steam}
diff --git a/contrib/gnome-software.spec.in b/contrib/gnome-software.spec.in
index 8385e66..e7656be 100644
--- a/contrib/gnome-software.spec.in
+++ b/contrib/gnome-software.spec.in
@@ -6,7 +6,7 @@
%global libsoup_version 2.51.92
%global gsettings_desktop_schemas_version 3.11.5
%global gnome_desktop_version 3.17.92
-%global xdg_app_version 0.4.14
+%global flatpak_version 0.5.2
%define alphatag #ALPHATAG#
%define distrotag 23
@@ -52,7 +52,7 @@ BuildRequires: libappstream-glib-devel >= %{appstream_glib_version}
BuildRequires: libsoup-devel
BuildRequires: PackageKit-glib-devel >= %{packagekit_version}
BuildRequires: polkit-devel
-BuildRequires: xdg-app-devel >= %{xdg_app_version}
+BuildRequires: flatpak-devel >= %{flatpak_version}
# this is not a library version
%define gs_plugin_version 10
diff --git a/src/plugins/Makefile.am b/src/plugins/Makefile.am
index 7be0e5e..e8c0f85 100644
--- a/src/plugins/Makefile.am
+++ b/src/plugins/Makefile.am
@@ -14,6 +14,7 @@ AM_CPPFLAGS = \
$(LIMBA_CFLAGS) \
$(OSTREE_CFLAGS) \
$(XDG_APP_CFLAGS) \
+ $(FLATPAK_CFLAGS) \
$(RPM_CFLAGS) \
-DBINDIR=\"$(bindir)\" \
-DDATADIR=\"$(datadir)\" \
@@ -71,6 +72,10 @@ if HAVE_XDG_APP
plugin_LTLIBRARIES += libgs_plugin_xdg-app.la
endif
+if HAVE_FLATPAK
+plugin_LTLIBRARIES += libgs_plugin_flatpak.la
+endif
+
if HAVE_OSTREE
plugin_LTLIBRARIES += libgs_plugin_ostree.la
endif
@@ -168,6 +173,16 @@ libgs_plugin_xdg_app_la_LDFLAGS = -module -avoid-version
libgs_plugin_xdg_app_la_CFLAGS = $(GS_PLUGIN_CFLAGS) $(WARN_CFLAGS)
endif
+if HAVE_FLATPAK
+libgs_plugin_flatpak_la_SOURCES = \
+ gs-appstream.c \
+ gs-appstream.h \
+ gs-plugin-flatpak.c
+libgs_plugin_flatpak_la_LIBADD = $(GS_PLUGIN_LIBS) $(FLATPAK_LIBS)
+libgs_plugin_flatpak_la_LDFLAGS = -module -avoid-version
+libgs_plugin_flatpak_la_CFLAGS = $(GS_PLUGIN_CFLAGS) $(WARN_CFLAGS)
+endif
+
if HAVE_OSTREE
libgs_plugin_ostree_la_SOURCES = gs-plugin-ostree.c
libgs_plugin_ostree_la_LIBADD = $(GS_PLUGIN_LIBS) $(OSTREE_LIBS)
diff --git a/src/plugins/gs-appstream.c b/src/plugins/gs-appstream.c
index 763e283..896e155 100644
--- a/src/plugins/gs-appstream.c
+++ b/src/plugins/gs-appstream.c
@@ -293,11 +293,14 @@ gs_refine_item_management_plugin (GsApp *app, AsApp *item)
bundles = as_app_get_bundles (item);
for (i = 0; i < bundles->len; i++) {
AsBundle *bundle = g_ptr_array_index (bundles, i);
- if (as_bundle_get_kind (bundle) == AS_BUNDLE_KIND_XDG_APP) {
- gs_app_set_management_plugin (app, "xdg-app");
- gs_app_add_source (app, as_bundle_get_id (bundle));
+ AsBundleKind kind = as_bundle_get_kind (bundle);
- /* automatically add runtime */
+ /* common to all bundle formats */
+ gs_app_set_management_plugin (app, as_bundle_kind_to_string (kind));
+ gs_app_add_source (app, as_bundle_get_id (bundle));
+
+ /* automatically add runtime */
+ if (kind == AS_BUNDLE_KIND_XDG_APP) {
runtime = as_bundle_get_runtime (bundle);
if (runtime != NULL) {
g_autoptr(GsApp) app2 = NULL;
@@ -310,11 +313,6 @@ gs_refine_item_management_plugin (GsApp *app, AsApp *item)
}
break;
}
- if (as_bundle_get_kind (bundle) == AS_BUNDLE_KIND_LIMBA) {
- gs_app_set_management_plugin (app, "limba");
- gs_app_add_source (app, as_bundle_get_id (bundle));
- break;
- }
}
}
diff --git a/src/plugins/gs-plugin-appstream.c b/src/plugins/gs-plugin-appstream.c
index 1938490..27fd631 100644
--- a/src/plugins/gs-plugin-appstream.c
+++ b/src/plugins/gs-plugin-appstream.c
@@ -171,7 +171,8 @@ gs_plugin_setup (GsPlugin *plugin, GCancellable *cancellable, GError **error)
AS_STORE_LOAD_FLAG_APP_INFO_USER |
AS_STORE_LOAD_FLAG_APPDATA |
AS_STORE_LOAD_FLAG_DESKTOP |
- AS_STORE_LOAD_FLAG_XDG_APP_USER |
+ AS_STORE_LOAD_FLAG_FLATPAK_USER |
+ AS_STORE_LOAD_FLAG_FLATPAK_SYSTEM |
AS_STORE_LOAD_FLAG_APP_INSTALL,
NULL,
error);
diff --git a/src/plugins/gs-plugin-flatpak.c b/src/plugins/gs-plugin-flatpak.c
new file mode 100644
index 0000000..7e2c8f0
--- /dev/null
+++ b/src/plugins/gs-plugin-flatpak.c
@@ -0,0 +1,1500 @@
+/* -*- Mode: C; tab-width: 8; indent-tabs-mode: t; c-basic-offset: 8 -*-
+ *
+ * Copyright (C) 2015 Richard Hughes <richard hughsie com>
+ *
+ * Licensed under the GNU General Public License Version 2
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
+ */
+
+/* Notes:
+ *
+ * All GsApp's created have management-plugin set to flatpak
+ * Some GsApp's created have have flatpak::kind of app or runtime
+ * The GsApp:origin is the remote name, e.g. test-repo
+ */
+
+#include <config.h>
+
+#include <flatpak.h>
+#include <gnome-software.h>
+
+#include "gs-appstream.h"
+
+static gboolean gs_plugin_refine_item_metadata (GsPlugin *plugin,
+ GsApp *app,
+ GCancellable *cancellable,
+ GError **error);
+
+struct GsPluginData {
+ FlatpakInstallation *installation;
+ GFileMonitor *monitor;
+};
+
+/**
+ * gs_plugin_order_after:
+ */
+const gchar **
+gs_plugin_order_after (GsPlugin *plugin)
+{
+ static const gchar *deps[] = {
+ "appstream",
+ NULL };
+ return deps;
+}
+
+/**
+ * gs_plugin_get_conflicts:
+ */
+const gchar **
+gs_plugin_get_conflicts (GsPlugin *plugin)
+{
+ static const gchar *deps[] = {
+ "xdg-app",
+ NULL };
+ return deps;
+}
+
+/**
+ * gs_plugin_initialize:
+ */
+void
+gs_plugin_initialize (GsPlugin *plugin)
+{
+ gs_plugin_alloc_data (plugin, sizeof(GsPluginData));
+}
+
+/**
+ * gs_plugin_destroy:
+ */
+void
+gs_plugin_destroy (GsPlugin *plugin)
+{
+ GsPluginData *priv = gs_plugin_get_data (plugin);
+ if (priv->installation != NULL)
+ g_object_unref (priv->installation);
+ if (priv->monitor != NULL)
+ g_object_unref (priv->monitor);
+}
+
+/**
+ * gs_plugin_adopt_app:
+ */
+void
+gs_plugin_adopt_app (GsPlugin *plugin, GsApp *app)
+{
+ if (g_str_has_prefix (gs_app_get_id (app), "user-flatpak:") ||
+ g_str_has_prefix (gs_app_get_id (app), "flatpak:")) {
+ gs_app_set_management_plugin (app, gs_plugin_get_name (plugin));
+ }
+}
+
+/* helpers */
+#define gs_app_get_flatpak_kind_as_str(app) gs_app_get_metadata_item(app,"flatpak::kind")
+#define gs_app_get_flatpak_name(app) gs_app_get_metadata_item(app,"flatpak::name")
+#define gs_app_get_flatpak_arch(app) gs_app_get_metadata_item(app,"flatpak::arch")
+#define gs_app_get_flatpak_branch(app) gs_app_get_metadata_item(app,"flatpak::branch")
+#define gs_app_get_flatpak_commit(app) gs_app_get_metadata_item(app,"flatpak::commit")
+#define gs_app_set_flatpak_name(app,val) gs_app_set_metadata(app,"flatpak::name",val)
+#define gs_app_set_flatpak_arch(app,val) gs_app_set_metadata(app,"flatpak::arch",val)
+#define gs_app_set_flatpak_branch(app,val) gs_app_set_metadata(app,"flatpak::branch",val)
+#define gs_app_set_flatpak_commit(app,val) gs_app_set_metadata(app,"flatpak::commit",val)
+
+/**
+ * gs_app_get_flatpak_kind:
+ */
+static FlatpakRefKind
+gs_app_get_flatpak_kind (GsApp *app)
+{
+ const gchar *kind = gs_app_get_metadata_item (app, "flatpak::kind");
+ if (g_strcmp0 (kind, "app") == 0)
+ return FLATPAK_REF_KIND_APP;
+ if (g_strcmp0 (kind, "runtime") == 0)
+ return FLATPAK_REF_KIND_RUNTIME;
+ g_warning ("unknown flatpak kind: %s", kind);
+ return FLATPAK_REF_KIND_APP;
+}
+
+/**
+ * gs_app_set_flatpak_kind:
+ */
+static void
+gs_app_set_flatpak_kind (GsApp *app, FlatpakRefKind kind)
+{
+ if (kind == FLATPAK_REF_KIND_APP)
+ gs_app_set_metadata (app, "flatpak::kind", "app");
+ else if (kind == FLATPAK_REF_KIND_RUNTIME)
+ gs_app_set_metadata (app, "flatpak::kind", "runtime");
+ else
+ g_assert_not_reached ();
+}
+
+#ifndef HAVE_PACKAGEKIT
+/**
+ * gs_plugin_add_popular:
+ */
+gboolean
+gs_plugin_add_popular (GsPlugin *plugin,
+ GList **list,
+ GCancellable *cancellable,
+ GError **error)
+{
+ guint i;
+ const gchar *apps[] = {
+ "org.gnome.Builder.desktop",
+ "org.gnome.Calculator.desktop",
+ "org.gnome.clocks.desktop",
+ "org.gnome.Dictionary.desktop",
+ "org.gnome.Documents.desktop",
+ "org.gnome.Evince.desktop",
+ "org.gnome.gedit.desktop",
+ "org.gnome.Maps.desktop",
+ "org.gnome.Weather.desktop",
+ NULL };
+
+ /* just add all */
+ for (i = 0; apps[i] != NULL; i++) {
+ g_autoptr(GsApp) app = NULL;
+ app = gs_app_new (apps[i]);
+ gs_app_list_add (list, app);
+ }
+ return TRUE;
+}
+#endif
+
+/**
+ * gs_plugin_flatpak_changed_cb:
+ */
+static void
+gs_plugin_flatpak_changed_cb (GFileMonitor *monitor,
+ GFile *child,
+ GFile *other_file,
+ GFileMonitorEvent event_type,
+ GsPlugin *plugin)
+{
+ gs_plugin_updates_changed (plugin);
+}
+
+/**
+ * gs_plugin_refresh_appstream:
+ */
+static gboolean
+gs_plugin_refresh_appstream (GsPlugin *plugin,
+ guint cache_age,
+ GCancellable *cancellable,
+ GError **error)
+{
+ GsPluginData *priv = gs_plugin_get_data (plugin);
+ gboolean ret;
+ guint i;
+ g_autoptr(GPtrArray) xremotes = NULL;
+
+ xremotes = flatpak_installation_list_remotes (priv->installation,
+ cancellable,
+ error);
+ if (xremotes == NULL)
+ return FALSE;
+ for (i = 0; i < xremotes->len; i++) {
+ guint tmp;
+ g_autoptr(GError) error_local = NULL;
+ g_autoptr(GFile) file = NULL;
+ g_autoptr(GFile) file_timestamp = NULL;
+ g_autofree gchar *appstream_fn = NULL;
+ FlatpakRemote *xremote = g_ptr_array_index (xremotes, i);
+
+ /* skip known-broken repos */
+ if (g_strcmp0 (flatpak_remote_get_name (xremote), "gnome-sdk") == 0)
+ continue;
+ if (g_strcmp0 (flatpak_remote_get_name (xremote), "test-apps") == 0)
+ continue;
+
+ /* is the timestamp new enough */
+ file_timestamp = flatpak_remote_get_appstream_timestamp (xremote, NULL);
+ tmp = gs_utils_get_file_age (file_timestamp);
+ if (tmp < cache_age) {
+ g_autofree gchar *fn = g_file_get_path (file_timestamp);
+ g_debug ("%s is only %i seconds old, so ignoring refresh",
+ fn, tmp);
+ continue;
+ }
+
+ /* download new data */
+ g_debug ("%s is %i seconds old, so downloading new data",
+ flatpak_remote_get_name (xremote), tmp);
+ ret = flatpak_installation_update_appstream_sync (priv->installation,
+ flatpak_remote_get_name (xremote),
+ NULL, /* arch */
+ NULL, /* out_changed */
+ cancellable,
+ &error_local);
+ if (!ret) {
+ if (g_error_matches (error_local,
+ G_IO_ERROR,
+ G_IO_ERROR_FAILED)) {
+ g_debug ("Failed to get AppStream metadata: %s",
+ error_local->message);
+ continue;
+ }
+ g_set_error (error,
+ GS_PLUGIN_ERROR,
+ GS_PLUGIN_ERROR_NOT_SUPPORTED,
+ "Failed to get AppStream metadata: %s",
+ error_local->message);
+ return FALSE;
+ }
+
+ /* add the new AppStream repo to the shared store */
+ file = flatpak_remote_get_appstream_dir (xremote, NULL);
+ appstream_fn = g_file_get_path (file);
+ g_debug ("using AppStream metadata found at: %s", appstream_fn);
+ }
+ return TRUE;
+}
+
+/**
+ * gs_plugin_setup:
+ */
+gboolean
+gs_plugin_setup (GsPlugin *plugin, GCancellable *cancellable, GError **error)
+{
+ GsPluginData *priv = gs_plugin_get_data (plugin);
+ g_autoptr(AsProfileTask) ptask = NULL;
+
+ /* we use a permissions helper to elevate privs */
+ ptask = as_profile_start_literal (gs_plugin_get_profile (plugin),
+ "flatpak::ensure-origin");
+ priv->installation = flatpak_installation_new_system (cancellable, error);
+ if (priv->installation == NULL)
+ return FALSE;
+
+ /* watch for changes */
+ priv->monitor =
+ flatpak_installation_create_monitor (priv->installation,
+ cancellable,
+ error);
+ if (priv->monitor == NULL)
+ return FALSE;
+ g_signal_connect (priv->monitor, "changed",
+ G_CALLBACK (gs_plugin_flatpak_changed_cb), plugin);
+
+ /* success */
+ return TRUE;
+}
+
+/**
+ * gs_plugin_flatpak_set_metadata:
+ */
+static void
+gs_plugin_flatpak_set_metadata (GsApp *app, FlatpakRef *xref)
+{
+ gs_app_set_management_plugin (app, "flatpak");
+ gs_app_set_flatpak_kind (app, flatpak_ref_get_kind (xref));
+ gs_app_set_flatpak_name (app, flatpak_ref_get_name (xref));
+ gs_app_set_flatpak_arch (app, flatpak_ref_get_arch (xref));
+ gs_app_set_flatpak_branch (app, flatpak_ref_get_branch (xref));
+ gs_app_set_flatpak_commit (app, flatpak_ref_get_commit (xref));
+}
+
+/**
+ * gs_plugin_flatpak_set_metadata_installed:
+ */
+static void
+gs_plugin_flatpak_set_metadata_installed (GsApp *app, FlatpakInstalledRef *xref)
+{
+ guint64 mtime;
+ guint64 size_installed;
+ g_autofree gchar *metadata_fn = NULL;
+ g_autoptr(GFile) file = NULL;
+ g_autoptr(GFileInfo) info = NULL;
+
+ /* for all types */
+ gs_plugin_flatpak_set_metadata (app, FLATPAK_REF (xref));
+
+ /* get the last time the app was updated */
+ metadata_fn = g_build_filename (flatpak_installed_ref_get_deploy_dir (xref),
+ "..",
+ "active",
+ NULL);
+ file = g_file_new_for_path (metadata_fn);
+ info = g_file_query_info (file,
+ G_FILE_ATTRIBUTE_TIME_MODIFIED,
+ G_FILE_QUERY_INFO_NOFOLLOW_SYMLINKS,
+ NULL, NULL);
+ if (info != NULL) {
+ mtime = g_file_info_get_attribute_uint64 (info, G_FILE_ATTRIBUTE_TIME_MODIFIED);
+ gs_app_set_install_date (app, mtime);
+ }
+
+ /* this is faster than resolving */
+ gs_app_set_origin (app, flatpak_installed_ref_get_origin (xref));
+
+ /* this is faster than flatpak_installation_fetch_remote_size_sync() */
+ size_installed = flatpak_installed_ref_get_installed_size (xref);
+ if (size_installed != 0)
+ gs_app_set_size_installed (app, size_installed);
+}
+
+/**
+ * gs_plugin_flatpak_build_id:
+ */
+static gchar *
+gs_plugin_flatpak_build_id (FlatpakRef *xref)
+{
+ if (flatpak_ref_get_kind (xref) == FLATPAK_REF_KIND_APP)
+ return g_strdup_printf ("user-flatpak:%s.desktop", flatpak_ref_get_name (xref));
+ return g_strdup_printf ("user-flatpak:%s.runtime", flatpak_ref_get_name (xref));
+}
+
+/**
+ * gs_plugin_flatpak_create_installed:
+ */
+static GsApp *
+gs_plugin_flatpak_create_installed (GsPlugin *plugin,
+ FlatpakInstalledRef *xref,
+ GError **error)
+{
+ g_autofree gchar *id = NULL;
+ g_autoptr(AsIcon) icon = NULL;
+ g_autoptr(GsApp) app = NULL;
+
+ g_return_val_if_fail (xref != NULL, NULL);
+
+ /*
+ * Only show the current application in GNOME Software
+ *
+ * You can have multiple versions/branches of a particular app-id
+ * installed but only one of them is "current" where this means:
+ * 1) the default to launch unless you specify a version
+ * 2) The one that gets its exported files exported
+ */
+ if (!flatpak_installed_ref_get_is_current (xref) &&
+ flatpak_ref_get_kind (FLATPAK_REF(xref)) == FLATPAK_REF_KIND_APP) {
+ g_set_error (error,
+ GS_PLUGIN_ERROR,
+ GS_PLUGIN_ERROR_NOT_SUPPORTED,
+ "%s not current, ignoring",
+ flatpak_ref_get_name (FLATPAK_REF (xref)));
+ return NULL;
+ }
+
+ /* create new object */
+ id = gs_plugin_flatpak_build_id (FLATPAK_REF (xref));
+ app = gs_app_new (id);
+ gs_plugin_flatpak_set_metadata_installed (app, xref);
+
+ switch (flatpak_ref_get_kind (FLATPAK_REF(xref))) {
+ case FLATPAK_REF_KIND_APP:
+ gs_app_set_kind (app, AS_APP_KIND_DESKTOP);
+ break;
+ case FLATPAK_REF_KIND_RUNTIME:
+ gs_app_set_flatpak_kind (app, FLATPAK_REF_KIND_RUNTIME);
+ gs_app_set_kind (app, AS_APP_KIND_RUNTIME);
+ gs_app_set_name (app, GS_APP_QUALITY_NORMAL,
+ flatpak_ref_get_name (FLATPAK_REF (xref)));
+ gs_app_set_summary (app, GS_APP_QUALITY_NORMAL,
+ "Framework for applications");
+ gs_app_set_version (app, flatpak_ref_get_branch (FLATPAK_REF (xref)));
+ icon = as_icon_new ();
+ as_icon_set_kind (icon, AS_ICON_KIND_STOCK);
+ as_icon_set_name (icon, "system-run-symbolic");
+ gs_app_set_icon (app, icon);
+ break;
+ default:
+ g_set_error_literal (error,
+ GS_PLUGIN_ERROR,
+ GS_PLUGIN_ERROR_NOT_SUPPORTED,
+ "FlatpakRefKind not known");
+ return NULL;
+ }
+ return g_object_ref (app);
+}
+
+/**
+ * gs_plugin_flatpak_progress_cb:
+ */
+static void
+gs_plugin_flatpak_progress_cb (const gchar *status,
+ guint progress,
+ gboolean estimating,
+ gpointer user_data)
+{
+ GsApp *app = GS_APP (user_data);
+ gs_app_set_progress (app, progress);
+}
+
+/**
+ * gs_plugin_add_installed:
+ */
+gboolean
+gs_plugin_add_installed (GsPlugin *plugin,
+ GList **list,
+ GCancellable *cancellable,
+ GError **error)
+{
+ GsPluginData *priv = gs_plugin_get_data (plugin);
+ g_autoptr(GError) error_md = NULL;
+ g_autoptr(GPtrArray) xrefs = NULL;
+ guint i;
+
+ /* if we've never ever run before, get the AppStream data */
+ if (!gs_plugin_refresh_appstream (plugin,
+ G_MAXUINT,
+ cancellable,
+ &error_md)) {
+ g_warning ("failed to get initial available data: %s",
+ error_md->message);
+ }
+
+ /* get apps and runtimes */
+ xrefs = flatpak_installation_list_installed_refs (priv->installation,
+ cancellable, error);
+ if (xrefs == NULL)
+ return FALSE;
+ for (i = 0; i < xrefs->len; i++) {
+ FlatpakInstalledRef *xref = g_ptr_array_index (xrefs, i);
+ g_autoptr(GError) error_local = NULL;
+ g_autoptr(GsApp) app = NULL;
+
+ /* only apps */
+ if (flatpak_ref_get_kind (FLATPAK_REF (xref)) != FLATPAK_REF_KIND_APP)
+ continue;
+
+ app = gs_plugin_flatpak_create_installed (plugin, xref, &error_local);
+ if (app == NULL) {
+ g_warning ("failed to add flatpak: %s", error_local->message);
+ continue;
+ }
+ gs_app_set_state (app, AS_APP_STATE_INSTALLED);
+ gs_app_list_add (list, app);
+ }
+
+ return TRUE;
+}
+
+/**
+ * gs_plugin_add_sources:
+ */
+gboolean
+gs_plugin_add_sources (GsPlugin *plugin,
+ GList **list,
+ GCancellable *cancellable,
+ GError **error)
+{
+ GsPluginData *priv = gs_plugin_get_data (plugin);
+ g_autoptr(GPtrArray) xremotes = NULL;
+ guint i;
+
+ xremotes = flatpak_installation_list_remotes (priv->installation,
+ cancellable,
+ error);
+ if (xremotes == NULL)
+ return FALSE;
+ for (i = 0; i < xremotes->len; i++) {
+ FlatpakRemote *xremote = g_ptr_array_index (xremotes, i);
+ g_autoptr(GsApp) app = NULL;
+
+ /* apps installed from bundles add their own remote that only
+ * can be used for updating that app only -- so hide them */
+ if (flatpak_remote_get_noenumerate (xremote))
+ continue;
+
+ app = gs_app_new (flatpak_remote_get_name (xremote));
+ gs_app_set_management_plugin (app, gs_plugin_get_name (plugin));
+ gs_app_set_kind (app, AS_APP_KIND_SOURCE);
+ gs_app_set_state (app, AS_APP_STATE_INSTALLED);
+ gs_app_set_name (app,
+ GS_APP_QUALITY_LOWEST,
+ flatpak_remote_get_name (xremote));
+ gs_app_set_summary (app,
+ GS_APP_QUALITY_LOWEST,
+ flatpak_remote_get_title (xremote));
+ gs_app_set_url (app,
+ AS_URL_KIND_HOMEPAGE,
+ flatpak_remote_get_url (xremote));
+ gs_app_list_add (list, app);
+ }
+ return TRUE;
+}
+
+/**
+ * gs_plugin_add_updates:
+ */
+gboolean
+gs_plugin_add_updates (GsPlugin *plugin,
+ GList **list,
+ GCancellable *cancellable,
+ GError **error)
+{
+ GsPluginData *priv = gs_plugin_get_data (plugin);
+ guint i;
+ g_autoptr(GPtrArray) xrefs = NULL;
+
+ /* get all the installed apps (no network I/O) */
+ xrefs = flatpak_installation_list_installed_refs (priv->installation,
+ cancellable,
+ error);
+ if (xrefs == NULL)
+ return FALSE;
+ for (i = 0; i < xrefs->len; i++) {
+ FlatpakInstalledRef *xref = g_ptr_array_index (xrefs, i);
+ const gchar *commit;
+ const gchar *latest_commit;
+ g_autoptr(GsApp) app = NULL;
+ g_autoptr(GError) error_local = NULL;
+
+ /* check the application has already been downloaded */
+ commit = flatpak_ref_get_commit (FLATPAK_REF (xref));
+ latest_commit = flatpak_installed_ref_get_latest_commit (xref);
+ if (g_strcmp0 (commit, latest_commit) == 0) {
+ g_debug ("no downloaded update for %s",
+ flatpak_ref_get_name (FLATPAK_REF (xref)));
+ continue;
+ }
+
+ /* we have an update to show */
+ g_debug ("%s has a downloaded update %s->%s",
+ flatpak_ref_get_name (FLATPAK_REF (xref)),
+ commit, latest_commit);
+ app = gs_plugin_flatpak_create_installed (plugin, xref, &error_local);
+ if (app == NULL) {
+ g_warning ("failed to add flatpak: %s", error_local->message);
+ continue;
+ }
+ if (gs_app_get_state (app) == AS_APP_STATE_INSTALLED)
+ gs_app_set_state (app, AS_APP_STATE_UNKNOWN);
+ gs_app_set_state (app, AS_APP_STATE_UPDATABLE_LIVE);
+ gs_app_list_add (list, app);
+ }
+
+ return TRUE;
+}
+
+/**
+ * gs_plugin_refresh:
+ */
+gboolean
+gs_plugin_refresh (GsPlugin *plugin,
+ guint cache_age,
+ GsPluginRefreshFlags flags,
+ GCancellable *cancellable,
+ GError **error)
+{
+ GsPluginData *priv = gs_plugin_get_data (plugin);
+ guint i;
+ g_autoptr(GPtrArray) xrefs = NULL;
+
+ /* update AppStream metadata */
+ if (flags & GS_PLUGIN_REFRESH_FLAGS_METADATA) {
+ if (!gs_plugin_refresh_appstream (plugin, cache_age,
+ cancellable, error))
+ return FALSE;
+ }
+
+ /* no longer interesting */
+ if ((flags & GS_PLUGIN_REFRESH_FLAGS_PAYLOAD) == 0)
+ return TRUE;
+
+ /* get all the updates available from all remotes */
+ xrefs = flatpak_installation_list_installed_refs_for_update (priv->installation,
+ cancellable,
+ error);
+ if (xrefs == NULL)
+ return FALSE;
+ for (i = 0; i < xrefs->len; i++) {
+ FlatpakInstalledRef *xref = g_ptr_array_index (xrefs, i);
+ g_autoptr(GsApp) app = NULL;
+ g_autoptr(FlatpakInstalledRef) xref2 = NULL;
+
+ /* try to create a GsApp so we can do progress reporting */
+ app = gs_plugin_flatpak_create_installed (plugin, xref, NULL);
+
+ /* fetch but do not deploy */
+ g_debug ("pulling update for %s",
+ flatpak_ref_get_name (FLATPAK_REF (xref)));
+ xref2 = flatpak_installation_update (priv->installation,
+ FLATPAK_UPDATE_FLAGS_NO_DEPLOY,
+ flatpak_ref_get_kind (FLATPAK_REF (xref)),
+ flatpak_ref_get_name (FLATPAK_REF (xref)),
+ flatpak_ref_get_arch (FLATPAK_REF (xref)),
+ flatpak_ref_get_branch (FLATPAK_REF (xref)),
+ gs_plugin_flatpak_progress_cb, app,
+ cancellable, error);
+ if (xref2 == NULL)
+ return FALSE;
+ }
+
+ return TRUE;
+}
+
+/**
+ * gs_plugin_refine_item_origin_ui:
+ */
+static gboolean
+gs_plugin_refine_item_origin_ui (GsPlugin *plugin,
+ GsApp *app,
+ GCancellable *cancellable,
+ GError **error)
+{
+ GsPluginData *priv = gs_plugin_get_data (plugin);
+ const gchar *origin;
+ guint i;
+ g_autoptr(GPtrArray) xremotes = NULL;
+ g_autoptr(AsProfileTask) ptask = NULL;
+
+ /* already set */
+ origin = gs_app_get_origin_ui (app);
+ if (origin != NULL)
+ return TRUE;
+
+ /* find list of remotes */
+ ptask = as_profile_start_literal (gs_plugin_get_profile (plugin),
+ "flatpak::refine-origin-ui");
+ xremotes = flatpak_installation_list_remotes (priv->installation,
+ cancellable,
+ error);
+ if (xremotes == NULL)
+ return FALSE;
+ for (i = 0; i < xremotes->len; i++) {
+ FlatpakRemote *xremote = g_ptr_array_index (xremotes, i);
+ if (g_strcmp0 (gs_app_get_origin (app),
+ flatpak_remote_get_name (xremote)) == 0) {
+ gs_app_set_origin_ui (app, flatpak_remote_get_title (xremote));
+ break;
+ }
+ }
+
+ return TRUE;
+}
+
+/**
+ * gs_plugin_refine_item_origin:
+ */
+static gboolean
+gs_plugin_refine_item_origin (GsPlugin *plugin,
+ GsApp *app,
+ GCancellable *cancellable,
+ GError **error)
+{
+ GsPluginData *priv = gs_plugin_get_data (plugin);
+ guint i;
+ g_autoptr(GPtrArray) xremotes = NULL;
+ g_autoptr(AsProfileTask) ptask = NULL;
+
+ /* already set */
+ if (gs_app_get_origin (app) != NULL)
+ return TRUE;
+
+ /* ensure metadata exists */
+ ptask = as_profile_start_literal (gs_plugin_get_profile (plugin),
+ "flatpak::refine-origin");
+ if (!gs_plugin_refine_item_metadata (plugin, app, cancellable, error))
+ return FALSE;
+
+ /* find list of remotes */
+ g_debug ("looking for a remote for %s/%s/%s",
+ gs_app_get_flatpak_name (app),
+ gs_app_get_flatpak_arch (app),
+ gs_app_get_flatpak_branch (app));
+ xremotes = flatpak_installation_list_remotes (priv->installation,
+ cancellable,
+ error);
+ if (xremotes == NULL)
+ return FALSE;
+ for (i = 0; i < xremotes->len; i++) {
+ const gchar *remote_name;
+ FlatpakRemote *xremote = g_ptr_array_index (xremotes, i);
+ g_autoptr(FlatpakRemoteRef) xref = NULL;
+ remote_name = flatpak_remote_get_name (xremote);
+ g_debug ("looking at remote %s", remote_name);
+ xref = flatpak_installation_fetch_remote_ref_sync (priv->installation,
+ remote_name,
+ gs_app_get_flatpak_kind (app),
+ gs_app_get_flatpak_name (app),
+ gs_app_get_flatpak_arch (app),
+ gs_app_get_flatpak_branch (app),
+ cancellable,
+ NULL);
+ if (xref != NULL) {
+ g_debug ("found remote %s", remote_name);
+ gs_app_set_origin (app, remote_name);
+ return TRUE;
+ }
+ }
+ g_set_error (error,
+ GS_PLUGIN_ERROR,
+ GS_PLUGIN_ERROR_NOT_SUPPORTED,
+ "Not found %s/%s/%s",
+ gs_app_get_flatpak_name (app),
+ gs_app_get_flatpak_arch (app),
+ gs_app_get_flatpak_branch (app));
+ return FALSE;
+}
+
+#if 0
+/**
+ * gs_plugin_refine_item_commit:
+ */
+static gboolean
+gs_plugin_refine_item_commit (GsPlugin *plugin,
+ GsApp *app,
+ GCancellable *cancellable,
+ GError **error)
+{
+ GsPluginData *priv = gs_plugin_get_data (plugin);
+ g_autoptr(AsProfileTask) ptask = NULL;
+ g_autoptr(FlatpakRemoteRef) xref_remote = NULL;
+
+ if (gs_app_get_flatpak_commit (app) != NULL)
+ return TRUE;
+ if (gs_app_get_origin (app) == NULL) {
+ g_debug ("no origin got commit, so refining origin first");
+ if (!gs_plugin_refine_item_origin (plugin, app, cancellable, error))
+ return FALSE;
+ }
+
+ ptask = as_profile_start_literal (gs_plugin_get_profile (plugin),
+ "flatpak::fetch-remote-ref");
+ xref_remote = flatpak_installation_fetch_remote_ref_sync (priv->installation,
+ gs_app_get_origin (app),
+ gs_app_get_flatpak_kind (app),
+ gs_app_get_flatpak_name (app),
+ gs_app_get_flatpak_arch (app),
+ gs_app_get_flatpak_branch (app),
+ cancellable,
+ error);
+ if (xref_remote == NULL)
+ return FALSE;
+ gs_app_set_flatpak_commit (app, flatpak_ref_get_commit (FLATPAK_REF (xref_remote)));
+ return TRUE;
+}
+#endif
+
+/**
+ * gs_plugin_flatpak_is_xref:
+ */
+static gboolean
+gs_plugin_flatpak_is_xref (GsApp *app, FlatpakRef *xref)
+{
+ g_autofree gchar *id = NULL;
+
+ /* check ID */
+ id = gs_plugin_flatpak_build_id (xref);
+ if (g_strcmp0 (id, gs_app_get_id (app)) == 0)
+ return TRUE;
+
+ /* check source ID */
+// if (g_strcmp0 (id, gs_app_get_id (app)) == 0)
+// return TRUE;
+
+ /* do all the metadata items match? */
+ if (g_strcmp0 (gs_app_get_flatpak_name (app),
+ flatpak_ref_get_name (xref)) == 0 &&
+ g_strcmp0 (gs_app_get_flatpak_arch (app),
+ flatpak_ref_get_arch (xref)) == 0 &&
+ g_strcmp0 (gs_app_get_flatpak_branch (app),
+ flatpak_ref_get_branch (xref)) == 0)
+ return TRUE;
+
+ /* sad panda */
+ return FALSE;
+}
+
+/**
+ * gs_plugin_flatpak_create_fake_ref:
+ */
+static FlatpakRef *
+gs_plugin_flatpak_create_fake_ref (GsApp *app, GError **error)
+{
+ g_autofree gchar *id = NULL;
+ id = g_strdup_printf ("%s/%s/%s/%s",
+ gs_app_get_flatpak_kind_as_str (app),
+ gs_app_get_flatpak_name (app),
+ gs_app_get_flatpak_arch (app),
+ gs_app_get_flatpak_branch (app));
+ return flatpak_ref_parse (id, error);
+}
+
+/**
+ * gs_plugin_refine_item_metadata:
+ */
+static gboolean
+gs_plugin_refine_item_metadata (GsPlugin *plugin,
+ GsApp *app,
+ GCancellable *cancellable,
+ GError **error)
+{
+ g_autoptr(FlatpakRef) xref = NULL;
+
+ /* already set */
+ if (gs_app_get_metadata_item (app, "flatpak::kind") != NULL)
+ return TRUE;
+
+ /* AppStream sets the source to appname/arch/branch, if this isn't set
+ * we can't break out the fields */
+ if (gs_app_get_source_default (app) == NULL) {
+ g_warning ("no source set by appstream for %s", gs_plugin_get_name (plugin));
+ return TRUE;
+ }
+
+ /* parse the ref */
+ xref = flatpak_ref_parse (gs_app_get_source_default (app), error);
+ if (xref == NULL) {
+ g_prefix_error (error, "failed to parse '%s': ",
+ gs_app_get_source_default (app));
+ return FALSE;
+ }
+ gs_plugin_flatpak_set_metadata (app, xref);
+
+ /* success */
+ return TRUE;
+}
+
+/**
+ * gs_plugin_refine_item_state:
+ */
+static gboolean
+gs_plugin_refine_item_state (GsPlugin *plugin,
+ GsApp *app,
+ GCancellable *cancellable,
+ GError **error)
+{
+ GsPluginData *priv = gs_plugin_get_data (plugin);
+ guint i;
+ g_autoptr(GPtrArray) xrefs = NULL;
+ g_autoptr(AsProfileTask) ptask = NULL;
+
+ /* already found */
+ if (gs_app_get_state (app) != AS_APP_STATE_UNKNOWN)
+ return TRUE;
+
+ /* need broken out metadata */
+ if (!gs_plugin_refine_item_metadata (plugin, app, cancellable, error))
+ return FALSE;
+
+ /* get apps and runtimes */
+ ptask = as_profile_start_literal (gs_plugin_get_profile (plugin),
+ "flatpak::refine-action");
+ xrefs = flatpak_installation_list_installed_refs (priv->installation,
+ cancellable, error);
+ if (xrefs == NULL)
+ return FALSE;
+ for (i = 0; i < xrefs->len; i++) {
+ FlatpakInstalledRef *xref = g_ptr_array_index (xrefs, i);
+
+ /* check xref is app */
+ if (!gs_plugin_flatpak_is_xref (app, FLATPAK_REF(xref)))
+ continue;
+
+ /* mark as installed */
+ g_debug ("marking %s as installed with flatpak",
+ gs_app_get_id (app));
+ gs_plugin_flatpak_set_metadata_installed (app, xref);
+ if (gs_app_get_state (app) == AS_APP_STATE_UNKNOWN)
+ gs_app_set_state (app, AS_APP_STATE_INSTALLED);
+ }
+
+ /* anything not installed just check the remote is still present */
+ if (gs_app_get_state (app) == AS_APP_STATE_UNKNOWN &&
+ gs_app_get_origin (app) != NULL) {
+ g_autoptr(FlatpakRemote) xremote = NULL;
+ xremote = flatpak_installation_get_remote_by_name (priv->installation,
+ gs_app_get_origin (app),
+ cancellable, NULL);
+ if (xremote != NULL) {
+ g_debug ("marking %s as available with flatpak",
+ gs_app_get_id (app));
+ gs_app_set_state (app, AS_APP_STATE_AVAILABLE);
+ } else {
+ g_warning ("failed to find flatpak remote %s for %s",
+ gs_app_get_origin (app),
+ gs_app_get_id (app));
+ }
+ }
+
+ /* success */
+ return TRUE;
+}
+
+/**
+ * gs_plugin_flatpak_set_app_metadata:
+ */
+static gboolean
+gs_plugin_flatpak_set_app_metadata (GsApp *app,
+ const gchar *data,
+ gsize length,
+ GError **error)
+{
+ g_autofree gchar *name = NULL;
+ g_autofree gchar *runtime = NULL;
+ g_autofree gchar *source = NULL;
+ g_autoptr(GKeyFile) kf = NULL;
+ g_autoptr(GsApp) app_runtime = NULL;
+
+ kf = g_key_file_new ();
+ if (!g_key_file_load_from_data (kf, data, length, G_KEY_FILE_NONE, error))
+ return FALSE;
+ name = g_key_file_get_string (kf, "Application", "name", error);
+ if (name == NULL)
+ return FALSE;
+ gs_app_set_flatpak_name (app, name);
+ runtime = g_key_file_get_string (kf, "Application", "runtime", error);
+ if (runtime == NULL)
+ return FALSE;
+ g_debug ("runtime for %s is %s", name, runtime);
+
+ /* create runtime */
+ app_runtime = gs_appstream_create_runtime (app, runtime);
+ if (app_runtime != NULL)
+ gs_app_set_runtime (app, app_runtime);
+
+ return TRUE;
+}
+
+/**
+ * gs_plugin_refine_item_runtime:
+ */
+static gboolean
+gs_plugin_refine_item_runtime (GsPlugin *plugin,
+ GsApp *app,
+ GCancellable *cancellable,
+ GError **error)
+{
+ GsPluginData *priv = gs_plugin_get_data (plugin);
+ const gchar *str;
+ gsize len = -1;
+ g_autofree gchar *contents = NULL;
+ g_autofree gchar *installation_path_str = NULL;
+ g_autofree gchar *install_path = NULL;
+ g_autoptr(GBytes) data = NULL;
+ g_autoptr(GFile) installation_path = NULL;
+
+ /* not applicable */
+ if (gs_app_get_flatpak_kind (app) != FLATPAK_REF_KIND_APP)
+ return TRUE;
+
+ /* already exists */
+ if (gs_app_get_runtime (app) != NULL)
+ return TRUE;
+
+ /* this is quicker than doing network IO */
+ installation_path = flatpak_installation_get_path (priv->installation);
+ installation_path_str = g_file_get_path (installation_path);
+ install_path = g_build_filename (installation_path_str,
+ gs_app_get_flatpak_kind_as_str (app),
+ gs_app_get_flatpak_name (app),
+ gs_app_get_flatpak_arch (app),
+ gs_app_get_flatpak_branch (app),
+ "active",
+ "metadata",
+ NULL);
+ if (g_file_test (install_path, G_FILE_TEST_EXISTS)) {
+ if (!g_file_get_contents (install_path, &contents, &len, error))
+ return FALSE;
+ str = contents;
+ } else {
+ g_autoptr(FlatpakRef) xref = NULL;
+
+ /* fetch from the server */
+ xref = gs_plugin_flatpak_create_fake_ref (app, error);
+ if (xref == NULL)
+ return FALSE;
+ data = flatpak_installation_fetch_remote_metadata_sync (priv->installation,
+ gs_app_get_origin (app),
+ xref,
+ cancellable,
+ error);
+ if (data == NULL)
+ return FALSE;
+ str = g_bytes_get_data (data, &len);
+ }
+
+ /* parse key file */
+ if (!gs_plugin_flatpak_set_app_metadata (app, str, len, error))
+ return FALSE;
+ return TRUE;
+}
+
+/**
+ * gs_plugin_refine_item_size:
+ */
+static gboolean
+gs_plugin_refine_item_size (GsPlugin *plugin,
+ GsApp *app,
+ GCancellable *cancellable,
+ GError **error)
+{
+ GsPluginData *priv = gs_plugin_get_data (plugin);
+ gboolean ret;
+ guint64 download_size;
+ guint64 installed_size;
+ g_autoptr(AsProfileTask) ptask = NULL;
+ g_autoptr(FlatpakRef) xref = NULL;
+ g_autoptr(GError) error_local = NULL;
+
+ /* already set */
+ if (gs_app_get_size_installed (app) > 0 &&
+ gs_app_get_size_download (app) > 0)
+ return TRUE;
+
+ /* need runtime */
+ if (!gs_plugin_refine_item_runtime (plugin, app, cancellable, error))
+ return FALSE;
+
+ /* calculate the platform size too if the app is not installed */
+ if (gs_app_get_state (app) == AS_APP_STATE_AVAILABLE &&
+ gs_app_get_flatpak_kind (app) == FLATPAK_REF_KIND_APP) {
+ GsApp *app_runtime;
+
+ /* find out what runtime the application depends on */
+ if (!gs_plugin_refine_item_runtime (plugin,
+ app,
+ cancellable,
+ error))
+ return FALSE;
+
+ /* is the app_runtime already installed? */
+ app_runtime = gs_app_get_runtime (app);
+ if (!gs_plugin_refine_item_state (plugin,
+ app_runtime,
+ cancellable,
+ error))
+ return FALSE;
+ if (gs_app_get_state (app_runtime) == AS_APP_STATE_INSTALLED) {
+ g_debug ("runtime %s is already installed, so not adding size",
+ gs_app_get_id (app_runtime));
+ } else {
+ if (!gs_plugin_refine_item_size (plugin,
+ app_runtime,
+ cancellable,
+ error))
+ return FALSE;
+ }
+ }
+
+ /* just get the size of the app */
+ ptask = as_profile_start_literal (gs_plugin_get_profile (plugin),
+ "flatpak::refine-size");
+ if (!gs_plugin_refine_item_origin (plugin, app, cancellable, error))
+ return FALSE;
+ xref = gs_plugin_flatpak_create_fake_ref (app, error);
+ if (xref == NULL)
+ return FALSE;
+ ret = flatpak_installation_fetch_remote_size_sync (priv->installation,
+ gs_app_get_origin (app),
+ xref,
+ &download_size,
+ &installed_size,
+ cancellable, &error_local);
+ if (!ret) {
+ g_warning ("libflatpak failed to return application size: %s",
+ error_local->message);
+ gs_app_set_size_installed (app, GS_APP_SIZE_UNKNOWABLE);
+ gs_app_set_size_download (app, GS_APP_SIZE_UNKNOWABLE);
+ } else {
+ gs_app_set_size_installed (app, installed_size);
+ gs_app_set_size_download (app, download_size);
+ }
+ return TRUE;
+}
+
+/**
+ * gs_plugin_flatpak_refine_app:
+ */
+static gboolean
+gs_plugin_flatpak_refine_app (GsPlugin *plugin,
+ GsApp *app,
+ GsPluginRefineFlags flags,
+ GCancellable *cancellable,
+ GError **error)
+{
+ g_autoptr(AsProfileTask) ptask = NULL;
+
+ /* only process this app if was created by this plugin */
+ if (g_strcmp0 (gs_app_get_management_plugin (app),
+ gs_plugin_get_name (plugin)) != 0)
+ return TRUE;
+
+ /* profile */
+ ptask = as_profile_start (gs_plugin_get_profile (plugin),
+ "flatpak::refine{%s}",
+ gs_app_get_id (app));
+
+ /* AppStream sets the source to appname/arch/branch */
+ if (!gs_plugin_refine_item_metadata (plugin, app, cancellable, error))
+ return FALSE;
+
+ /* check the installed state */
+ if (!gs_plugin_refine_item_state (plugin, app, cancellable, error))
+ return FALSE;
+
+ /* version fallback */
+ if (flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_VERSION) {
+ if (gs_app_get_version (app) == NULL) {
+ const gchar *branch;
+ branch = gs_app_get_flatpak_branch (app);
+ gs_app_set_version (app, branch);
+ }
+ }
+
+ /* size */
+ if (flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_SIZE) {
+ if (!gs_plugin_refine_item_size (plugin, app, cancellable, error))
+ return FALSE;
+ }
+
+ /* origin */
+ if (flags & GS_PLUGIN_REFINE_FLAGS_REQUIRE_ORIGIN) {
+ if (!gs_plugin_refine_item_origin_ui (plugin, app, cancellable, error))
+ return FALSE;
+ }
+
+ return TRUE;
+}
+
+/**
+ * gs_plugin_refine_app:
+ */
+gboolean
+gs_plugin_refine_app (GsPlugin *plugin,
+ GsApp *app,
+ GsPluginRefineFlags flags,
+ GCancellable *cancellable,
+ GError **error)
+{ return gs_plugin_flatpak_refine_app (plugin, app, flags, cancellable, error);
+}
+
+/**
+ * gs_plugin_launch:
+ */
+gboolean
+gs_plugin_launch (GsPlugin *plugin,
+ GsApp *app,
+ GCancellable *cancellable,
+ GError **error)
+{
+ GsPluginData *priv = gs_plugin_get_data (plugin);
+ const gchar *branch = NULL;
+
+ /* only process this app if was created by this plugin */
+ if (g_strcmp0 (gs_app_get_management_plugin (app),
+ gs_plugin_get_name (plugin)) != 0)
+ return TRUE;
+
+ branch = gs_app_get_flatpak_branch (app);
+ if (branch == NULL)
+ branch = "master";
+ return flatpak_installation_launch (priv->installation,
+ gs_app_get_flatpak_name (app),
+ NULL,
+ branch,
+ NULL,
+ cancellable,
+ error);
+}
+
+/**
+ * gs_plugin_app_remove:
+ */
+gboolean
+gs_plugin_app_remove (GsPlugin *plugin,
+ GsApp *app,
+ GCancellable *cancellable,
+ GError **error)
+{
+ GsPluginData *priv = gs_plugin_get_data (plugin);
+
+ /* only process this app if was created by this plugin */
+ if (g_strcmp0 (gs_app_get_management_plugin (app),
+ gs_plugin_get_name (plugin)) != 0)
+ return TRUE;
+
+ /* remove */
+ gs_app_set_state (app, AS_APP_STATE_REMOVING);
+ if (!flatpak_installation_uninstall (priv->installation,
+ FLATPAK_REF_KIND_APP,
+ gs_app_get_flatpak_name (app),
+ gs_app_get_flatpak_arch (app),
+ gs_app_get_flatpak_branch (app),
+ gs_plugin_flatpak_progress_cb, app,
+ cancellable, error)) {
+ gs_app_set_state_recover (app);
+ return FALSE;
+ }
+
+ /* state is not known: we don't know if we can re-install this app */
+ gs_app_set_state (app, AS_APP_STATE_UNKNOWN);
+ return TRUE;
+}
+
+/**
+ * gs_plugin_app_install:
+ */
+gboolean
+gs_plugin_app_install (GsPlugin *plugin,
+ GsApp *app,
+ GCancellable *cancellable,
+ GError **error)
+{
+ GsPluginData *priv = gs_plugin_get_data (plugin);
+ g_autoptr(FlatpakInstalledRef) xref = NULL;
+
+ /* only process this app if was created by this plugin */
+ if (g_strcmp0 (gs_app_get_management_plugin (app),
+ gs_plugin_get_name (plugin)) != 0)
+ return TRUE;
+
+ /* ensure we have metadata and state */
+ if (!gs_plugin_flatpak_refine_app (plugin, app, 0, cancellable, error))
+ return FALSE;
+
+ /* install */
+ gs_app_set_state (app, AS_APP_STATE_INSTALLING);
+
+ /* install required runtime if not already installed */
+ if (gs_app_get_kind (app) == AS_APP_KIND_DESKTOP) {
+ GsApp *runtime;
+ runtime = gs_app_get_runtime (app);
+
+ /* the runtime could come from a different remote to the app */
+ if (!gs_plugin_refine_item_metadata (plugin, runtime, cancellable, error))
+ return FALSE;
+ if (!gs_plugin_refine_item_origin (plugin, runtime, cancellable, error))
+ return FALSE;
+ if (!gs_plugin_refine_item_state (plugin, runtime, cancellable, error))
+ return FALSE;
+ if (gs_app_get_state (runtime) == AS_APP_STATE_UNKNOWN) {
+ g_set_error (error,
+ GS_PLUGIN_ERROR,
+ GS_PLUGIN_ERROR_NOT_SUPPORTED,
+ "Failed to find runtime %s",
+ gs_app_get_source_default (runtime));
+ return FALSE;
+ }
+
+ /* not installed */
+ if (gs_app_get_state (runtime) == AS_APP_STATE_AVAILABLE) {
+ g_debug ("%s is not already installed, so installing",
+ gs_app_get_id (runtime));
+ gs_app_set_state (runtime, AS_APP_STATE_INSTALLING);
+ xref = flatpak_installation_install (priv->installation,
+ gs_app_get_origin (runtime),
+ gs_app_get_flatpak_kind (runtime),
+ gs_app_get_flatpak_name (runtime),
+ gs_app_get_flatpak_arch (runtime),
+ gs_app_get_flatpak_branch (runtime),
+ gs_plugin_flatpak_progress_cb, app,
+ cancellable, error);
+ if (xref == NULL) {
+ gs_app_set_state_recover (runtime);
+ return FALSE;
+ }
+ gs_app_set_state (runtime, AS_APP_STATE_INSTALLED);
+ } else {
+ g_debug ("%s is already installed, so skipping",
+ gs_app_get_id (runtime));
+ }
+ }
+
+ /* use the source for local apps */
+ if (gs_app_get_state (app) == AS_APP_STATE_AVAILABLE_LOCAL) {
+ xref = flatpak_installation_install_bundle (priv->installation,
+ gs_app_get_local_file (app),
+ gs_plugin_flatpak_progress_cb,
+ app,
+ cancellable, error);
+ } else {
+ g_debug ("installing %s", gs_app_get_id (app));
+ xref = flatpak_installation_install (priv->installation,
+ gs_app_get_origin (app),
+ gs_app_get_flatpak_kind (app),
+ gs_app_get_flatpak_name (app),
+ gs_app_get_flatpak_arch (app),
+ gs_app_get_flatpak_branch (app),
+ gs_plugin_flatpak_progress_cb, app,
+ cancellable, error);
+ }
+ if (xref == NULL) {
+ gs_app_set_state_recover (app);
+ return FALSE;
+ }
+
+ /* state is known */
+ gs_app_set_state (app, AS_APP_STATE_INSTALLED);
+ return TRUE;
+}
+
+/**
+ * gs_plugin_update_app:
+ */
+gboolean
+gs_plugin_update_app (GsPlugin *plugin,
+ GsApp *app,
+ GCancellable *cancellable,
+ GError **error)
+{
+ GsPluginData *priv = gs_plugin_get_data (plugin);
+ g_autoptr(FlatpakInstalledRef) xref = NULL;
+
+ /* only process this app if was created by this plugin */
+ if (g_strcmp0 (gs_app_get_management_plugin (app),
+ gs_plugin_get_name (plugin)) != 0)
+ return TRUE;
+
+ /* install */
+ gs_app_set_state (app, AS_APP_STATE_INSTALLING);
+ xref = flatpak_installation_update (priv->installation,
+ FLATPAK_UPDATE_FLAGS_NONE,
+ gs_app_get_flatpak_kind (app),
+ gs_app_get_flatpak_name (app),
+ gs_app_get_flatpak_arch (app),
+ gs_app_get_flatpak_branch (app),
+ gs_plugin_flatpak_progress_cb, app,
+ cancellable, error);
+ if (xref == NULL) {
+ gs_app_set_state_recover (app);
+ return FALSE;
+ }
+
+ /* state is known */
+ gs_app_set_state (app, AS_APP_STATE_INSTALLED);
+ return TRUE;
+}
+
+/**
+ * gs_plugin_file_to_app:
+ */
+gboolean
+gs_plugin_file_to_app (GsPlugin *plugin,
+ GList **list,
+ GFile *file,
+ GCancellable *cancellable,
+ GError **error)
+{
+ g_autofree gchar *content_type = NULL;
+ g_autofree gchar *id_prefixed = NULL;
+ g_autoptr(GBytes) appstream_gz = NULL;
+ g_autoptr(GBytes) icon_data = NULL;
+ g_autoptr(GBytes) metadata = NULL;
+ g_autoptr(GsApp) app = NULL;
+ g_autoptr(FlatpakBundleRef) xref_bundle = NULL;
+ const gchar *mimetypes[] = {
+ "application/vnd.flatpak",
+ NULL };
+
+ /* does this match any of the mimetypes we support */
+ content_type = gs_utils_get_content_type (file, cancellable, error);
+ if (content_type == NULL)
+ return FALSE;
+ if (!g_strv_contains (mimetypes, content_type))
+ return TRUE;
+
+ /* load bundle */
+ xref_bundle = flatpak_bundle_ref_new (file, error);
+ if (xref_bundle == NULL) {
+ g_prefix_error (error, "error loading bundle: ");
+ return FALSE;
+ }
+
+ /* create a virtual ID */
+ id_prefixed = gs_plugin_flatpak_build_id (FLATPAK_REF (xref_bundle));
+
+ /* load metadata */
+ app = gs_app_new (id_prefixed);
+ gs_app_set_kind (app, AS_APP_KIND_DESKTOP);
+ gs_app_set_state (app, AS_APP_STATE_AVAILABLE_LOCAL);
+ gs_app_set_size_installed (app, flatpak_bundle_ref_get_installed_size (xref_bundle));
+ gs_plugin_flatpak_set_metadata (app, FLATPAK_REF (xref_bundle));
+ metadata = flatpak_bundle_ref_get_metadata (xref_bundle);
+ if (!gs_plugin_flatpak_set_app_metadata (app,
+ g_bytes_get_data (metadata, NULL),
+ g_bytes_get_size (metadata),
+ error))
+ return FALSE;
+
+ /* load AppStream */
+ appstream_gz = flatpak_bundle_ref_get_appstream (xref_bundle);
+ if (appstream_gz != NULL) {
+ g_autoptr(GZlibDecompressor) decompressor = NULL;
+ g_autoptr(GInputStream) stream_gz = NULL;
+ g_autoptr(GInputStream) stream_data = NULL;
+ g_autoptr(GBytes) appstream = NULL;
+ g_autoptr(AsStore) store = NULL;
+ g_autofree gchar *id = NULL;
+ AsApp *item;
+
+ /* decompress data */
+ decompressor = g_zlib_decompressor_new (G_ZLIB_COMPRESSOR_FORMAT_GZIP);
+ stream_gz = g_memory_input_stream_new_from_bytes (appstream_gz);
+ if (stream_gz == NULL)
+ return FALSE;
+ stream_data = g_converter_input_stream_new (stream_gz,
+ G_CONVERTER (decompressor));
+
+ appstream = g_input_stream_read_bytes (stream_data,
+ 0x100000, /* 1Mb */
+ cancellable,
+ error);
+ if (appstream == NULL)
+ return FALSE;
+ store = as_store_new ();
+ if (!as_store_from_bytes (store, appstream, cancellable, error))
+ return FALSE;
+
+ /* find app */
+ id = g_strdup_printf ("%s.desktop", gs_app_get_flatpak_name (app));
+ item = as_store_get_app_by_id (store, id);
+ if (item == NULL) {
+ g_set_error (error,
+ GS_PLUGIN_ERROR,
+ GS_PLUGIN_ERROR_FAILED,
+ "application %s not found",
+ id);
+ return FALSE;
+ }
+
+ /* copy details from AppStream to app */
+ if (!gs_appstream_refine_app (plugin, app, item, error))
+ return FALSE;
+ }
+
+ /* load icon */
+ icon_data = flatpak_bundle_ref_get_icon (xref_bundle,
+ 64 * gs_plugin_get_scale (plugin));
+ if (icon_data == NULL)
+ icon_data = flatpak_bundle_ref_get_icon (xref_bundle, 64);
+ if (icon_data != NULL) {
+ g_autoptr(GInputStream) stream_icon = NULL;
+ g_autoptr(GdkPixbuf) pixbuf = NULL;
+ stream_icon = g_memory_input_stream_new_from_bytes (icon_data);
+ pixbuf = gdk_pixbuf_new_from_stream (stream_icon, cancellable, error);
+ if (pixbuf == NULL)
+ return FALSE;
+ gs_app_set_pixbuf (app, pixbuf);
+ } else {
+ g_autoptr(AsIcon) icon = NULL;
+ icon = as_icon_new ();
+ as_icon_set_kind (icon, AS_ICON_KIND_STOCK);
+ as_icon_set_name (icon, "application-x-executable");
+ gs_app_set_icon (app, icon);
+ }
+
+ /* not quite true: this just means we can update this specific app */
+ if (flatpak_bundle_ref_get_origin (xref_bundle))
+ gs_app_add_quirk (app, AS_APP_QUIRK_HAS_SOURCE);
+
+ g_debug ("created local app: %s", gs_app_to_string (app));
+ gs_app_list_add (list, app);
+ return TRUE;
+}
diff --git a/src/plugins/gs-plugin-odrs.c b/src/plugins/gs-plugin-odrs.c
index 40f5ac8..86d8f5c 100644
--- a/src/plugins/gs-plugin-odrs.c
+++ b/src/plugins/gs-plugin-odrs.c
@@ -78,6 +78,7 @@ gs_plugin_order_after (GsPlugin *plugin)
static const gchar *deps[] = {
"appstream", /* need application IDs */
"xdg-app", /* need version */
+ "flatpak", /* need version */
NULL };
return deps;
}
[
Date Prev][
Date Next] [
Thread Prev][
Thread Next]
[
Thread Index]
[
Date Index]
[
Author Index]
