diff -urNp gnome-settings-daemon-3.32.0.old/meson.build gnome-settings-daemon-3.32.0/meson.build

--- gnome-settings-daemon-3.32.0.old/meson.build	2019-06-17 13:01:46.867338656 +0100

+++ gnome-settings-daemon-3.32.0/meson.build	2019-06-17 13:01:59.245311865 +0100

@@ -97,6 +97,7 @@ libcanberra_gtk_dep = dependency('libcan

 libgeoclue_dep = dependency('libgeoclue-2.0', version: '>= 2.3.1')

 libnotify_dep = dependency('libnotify', version: '>= 0.7.3')

 libpulse_mainloop_glib_dep = dependency('libpulse-mainloop-glib', version: '>= 2.0')

+jsonglib_dep = dependency('json-glib-1.0', version: '>= 1.1.1')

 pango_dep = dependency('pango', version: '>= 1.20.0')

 polkit_gobject_dep = dependency('polkit-gobject-1', version: '>= 0.103')

 upower_glib_dep = dependency('upower-glib', version: '>= 0.99.0')

diff -urNp gnome-settings-daemon-3.32.0.old/plugins/meson.build gnome-settings-daemon-3.32.0/plugins/meson.build

--- gnome-settings-daemon-3.32.0.old/plugins/meson.build	2019-06-17 13:01:46.867338656 +0100

+++ gnome-settings-daemon-3.32.0/plugins/meson.build	2019-06-17 13:01:59.245311865 +0100

@@ -3,6 +3,7 @@ enabled_plugins = [

   ['account', 'Account'],

   ['clipboard', 'Clipboard'],

   ['color', 'Color'],

+  ['subman', 'Subscription'],

   ['datetime', 'Datetime'],

   ['dummy', ''],

   ['power', 'Power'],

diff -urNp gnome-settings-daemon-3.32.0.old/plugins/subman/gsd-subman-common.c gnome-settings-daemon-3.32.0/plugins/subman/gsd-subman-common.c

--- gnome-settings-daemon-3.32.0.old/plugins/subman/gsd-subman-common.c	1970-01-01 01:00:00.000000000 +0100

+++ gnome-settings-daemon-3.32.0/plugins/subman/gsd-subman-common.c	2019-06-17 13:01:59.246311863 +0100

@@ -0,0 +1,36 @@

+/* -*- Mode: C; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 8 -*-

+ *

+ * Copyright (C) 2019 Richard Hughes <rhughes@redhat.com>

+ *

+ * 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, see <http://www.gnu.org/licenses/>.

+ *

+ */

+

+#include "config.h"

+

+#include "gsd-subman-common.h"

+

+const gchar *

+gsd_subman_subscription_status_to_string (GsdSubmanSubscriptionStatus status)

+{

+	if (status == GSD_SUBMAN_SUBSCRIPTION_STATUS_VALID)

+		return "valid";

+	if (status == GSD_SUBMAN_SUBSCRIPTION_STATUS_INVALID)

+		return "invalid";

+	if (status == GSD_SUBMAN_SUBSCRIPTION_STATUS_DISABLED)

+		return "disabled";

+	if (status == GSD_SUBMAN_SUBSCRIPTION_STATUS_PARTIALLY_VALID)

+		return "partially-valid";

+	return "unknown";

+}

diff -urNp gnome-settings-daemon-3.32.0.old/plugins/subman/gsd-subman-common.h gnome-settings-daemon-3.32.0/plugins/subman/gsd-subman-common.h

--- gnome-settings-daemon-3.32.0.old/plugins/subman/gsd-subman-common.h	1970-01-01 01:00:00.000000000 +0100

+++ gnome-settings-daemon-3.32.0/plugins/subman/gsd-subman-common.h	2019-06-17 13:01:59.246311863 +0100

@@ -0,0 +1,40 @@

+/* -*- Mode: C; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 8 -*-

+ *

+ * Copyright (C) 2019 Richard Hughes <rhughes@redhat.com>

+ *

+ * 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, see <http://www.gnu.org/licenses/>.

+ *

+ */

+

+#ifndef __GSD_SUBMAN_COMMON_H

+#define __GSD_SUBMAN_COMMON_H

+

+#include <glib-object.h>

+

+G_BEGIN_DECLS

+

+typedef enum {

+	GSD_SUBMAN_SUBSCRIPTION_STATUS_UNKNOWN,

+	GSD_SUBMAN_SUBSCRIPTION_STATUS_VALID,

+	GSD_SUBMAN_SUBSCRIPTION_STATUS_INVALID,

+	GSD_SUBMAN_SUBSCRIPTION_STATUS_DISABLED,

+	GSD_SUBMAN_SUBSCRIPTION_STATUS_PARTIALLY_VALID,

+	GSD_SUBMAN_SUBSCRIPTION_STATUS_LAST

+} GsdSubmanSubscriptionStatus;

+

+const gchar	*gsd_subman_subscription_status_to_string	(GsdSubmanSubscriptionStatus	 status);

+

+G_END_DECLS

+

+#endif /* __GSD_SUBMAN_COMMON_H */

diff -urNp gnome-settings-daemon-3.32.0.old/plugins/subman/gsd-subman-helper.c gnome-settings-daemon-3.32.0/plugins/subman/gsd-subman-helper.c

--- gnome-settings-daemon-3.32.0.old/plugins/subman/gsd-subman-helper.c	1970-01-01 01:00:00.000000000 +0100

+++ gnome-settings-daemon-3.32.0/plugins/subman/gsd-subman-helper.c	2019-06-17 13:01:59.247311860 +0100

@@ -0,0 +1,378 @@

+/* -*- Mode: C; tab-width: 8; indent-tabs-mode: t; c-basic-offset: 8 -*-

+ *

+ * Copyright (C) 2019 Richard Hughes <rhughes@redhat.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.

+ */

+

+#include "config.h"

+

+#include <sys/types.h>

+#include <unistd.h>

+#include <stdlib.h>

+

+#include <gio/gio.h>

+#include <json-glib/json-glib.h>

+

+static void

+_helper_convert_error (const gchar *json_txt, GError **error)

+{

+	JsonNode *json_root;

+	JsonObject *json_obj;

+	const gchar *message;

+	g_autoptr(JsonParser) json_parser = json_parser_new ();

+

+	/* this may be plain text or JSON :| */

+	if (!json_parser_load_from_data (json_parser, json_txt, -1, NULL)) {

+		g_set_error_literal (error,

+				     G_IO_ERROR,

+				     G_IO_ERROR_NOT_SUPPORTED,

+				     json_txt);

+		return;

+	}

+	json_root = json_parser_get_root (json_parser);

+	json_obj = json_node_get_object (json_root);

+	if (!json_object_has_member (json_obj, "message")) {

+		g_set_error (error,

+			     G_IO_ERROR,

+			     G_IO_ERROR_INVALID_DATA,

+			     "no message' in %s", json_txt);

+		return;

+	}

+	message = json_object_get_string_member (json_obj, "message");

+	if (g_strstr_len (message, -1, "Invalid user credentials") != NULL) {

+		g_set_error_literal (error,

+				     G_IO_ERROR,

+				     G_IO_ERROR_PERMISSION_DENIED,

+				     message);

+		return;

+	}

+	g_set_error_literal (error,

+			     G_IO_ERROR,

+			     G_IO_ERROR_NOT_SUPPORTED,

+			     message);

+}

+

+static gboolean

+_helper_unregister (GError **error)

+{

+	g_autoptr(GDBusProxy) proxy = NULL;

+	g_autoptr(GVariantBuilder) proxy_options = NULL;

+	g_autoptr(GVariant) res = NULL;

+

+	g_debug ("unregistering");

+	proxy = g_dbus_proxy_new_for_bus_sync (G_BUS_TYPE_SYSTEM,

+					       G_DBUS_PROXY_FLAGS_DO_NOT_LOAD_PROPERTIES |

+					       G_DBUS_PROXY_FLAGS_DO_NOT_CONNECT_SIGNALS,

+					       NULL,

+					       "com.redhat.RHSM1",

+					       "/com/redhat/RHSM1/Unregister",

+					       "com.redhat.RHSM1.Unregister",

+					       NULL, error);

+	if (proxy == NULL) {

+		g_prefix_error (error, "Failed to get proxy: ");

+		return FALSE;

+	}

+	proxy_options = g_variant_builder_new (G_VARIANT_TYPE_VARDICT);

+	res = g_dbus_proxy_call_sync (proxy,

+				      "Unregister",

+				      g_variant_new ("(a{sv}s)",

+						     proxy_options,

+						     ""), /* lang */

+				      G_DBUS_CALL_FLAGS_NONE,

+				      -1, NULL, error);

+	return res != NULL;

+}

+

+static gboolean

+_helper_auto_attach (GError **error)

+{

+	const gchar *str = NULL;

+	g_autoptr(GDBusProxy) proxy = NULL;

+	g_autoptr(GVariantBuilder) proxy_options = NULL;

+	g_autoptr(GVariant) res = NULL;

+

+	g_debug ("auto-attaching subscriptions");

+	proxy = g_dbus_proxy_new_for_bus_sync (G_BUS_TYPE_SYSTEM,

+					       G_DBUS_PROXY_FLAGS_DO_NOT_LOAD_PROPERTIES |

+					       G_DBUS_PROXY_FLAGS_DO_NOT_CONNECT_SIGNALS,

+					       NULL,

+					       "com.redhat.RHSM1",

+					       "/com/redhat/RHSM1/Attach",

+					       "com.redhat.RHSM1.Attach",

+					       NULL, error);

+	if (proxy == NULL) {

+		g_prefix_error (error, "Failed to get proxy: ");

+		return FALSE;

+	}

+	proxy_options = g_variant_builder_new (G_VARIANT_TYPE_VARDICT);

+	res = g_dbus_proxy_call_sync (proxy,

+				      "AutoAttach",

+				      g_variant_new ("(sa{sv}s)",

+						     "", /* now? */

+						     proxy_options,

+						     ""), /* lang */

+				      G_DBUS_CALL_FLAGS_NONE,

+				      -1, NULL, error);

+	if (res == NULL)

+		return FALSE;

+	g_variant_get (res, "(&s)", &str);

+	g_debug ("Attach.AutoAttach: %s", str);

+	return TRUE;

+}

+

+static gboolean

+_helper_save_config (const gchar *key, const gchar *value, GError **error)

+{

+	g_autoptr(GDBusProxy) proxy = NULL;

+	g_autoptr(GVariant) res = NULL;

+	proxy = g_dbus_proxy_new_for_bus_sync (G_BUS_TYPE_SYSTEM,

+					       G_DBUS_PROXY_FLAGS_DO_NOT_LOAD_PROPERTIES |

+					       G_DBUS_PROXY_FLAGS_DO_NOT_CONNECT_SIGNALS,

+					       NULL,

+					       "com.redhat.RHSM1",

+					       "/com/redhat/RHSM1/Config",

+					       "com.redhat.RHSM1.Config",

+					       NULL, error);

+	if (proxy == NULL) {

+		g_prefix_error (error, "Failed to get proxy: ");

+		return FALSE;

+	}

+	res = g_dbus_proxy_call_sync (proxy, "Set",

+				      g_variant_new ("(svs)",

+						     key,

+						     g_variant_new_string (value),

+						     ""), /* lang */

+				      G_DBUS_CALL_FLAGS_NONE,

+				      -1, NULL, error);

+	return res != NULL;

+}

+

+int

+main (int argc, char *argv[])

+{

+	const gchar *userlang = ""; /* as root, so no translations */

+	g_autofree gchar *activation_key = NULL;

+	g_autofree gchar *address = NULL;

+	g_autofree gchar *hostname = NULL;

+	g_autofree gchar *kind = NULL;

+	g_autofree gchar *organisation = NULL;

+	g_autofree gchar *password = NULL;

+	g_autofree gchar *port = NULL;

+	g_autofree gchar *prefix = NULL;

+	g_autofree gchar *proxy_server = NULL;

+	g_autofree gchar *username = NULL;

+	g_autoptr(GDBusConnection) conn_private = NULL;

+	g_autoptr(GDBusProxy) proxy = NULL;

+	g_autoptr(GError) error = NULL;

+	g_autoptr(GOptionContext) context = g_option_context_new (NULL);

+	g_autoptr(GVariantBuilder) proxy_options = NULL;

+	g_autoptr(GVariantBuilder) subman_conopts = NULL;

+	g_autoptr(GVariantBuilder) subman_options = NULL;

+

+	const GOptionEntry options[] = {

+		{ "kind", '\0', G_OPTION_FLAG_NONE, G_OPTION_ARG_STRING,

+			&kind, "Kind, e.g. 'username' or 'key'", NULL },

+		{ "address", '\0', G_OPTION_FLAG_NONE, G_OPTION_ARG_STRING,

+			&address, "UNIX address", NULL },

+		{ "username", '\0', G_OPTION_FLAG_NONE, G_OPTION_ARG_STRING,

+			&username, "Username", NULL },

+		{ "password", '\0', G_OPTION_FLAG_NONE, G_OPTION_ARG_STRING,

+			&password, "Password", NULL },

+		{ "organisation", '\0', G_OPTION_FLAG_NONE, G_OPTION_ARG_STRING,

+			&organisation, "Organisation", NULL },

+		{ "activation-key", '\0', G_OPTION_FLAG_NONE, G_OPTION_ARG_STRING,

+			&activation_key, "Activation keys", NULL },

+		{ "hostname", '\0', G_OPTION_FLAG_HIDDEN, G_OPTION_ARG_STRING,

+			&hostname, "Registration server hostname", NULL },

+		{ "prefix", '\0', G_OPTION_FLAG_HIDDEN, G_OPTION_ARG_STRING,

+			&prefix, "Registration server prefix", NULL },

+		{ "port", '\0', G_OPTION_FLAG_HIDDEN, G_OPTION_ARG_STRING,

+			&port, "Registration server port", NULL },

+		{ "proxy", '\0', G_OPTION_FLAG_HIDDEN, G_OPTION_ARG_STRING,

+			&proxy_server, "Proxy settings", NULL },

+		{ NULL}

+	};

+

+	/* check calling UID */

+	if (getuid () != 0 || geteuid () != 0) {

+		g_printerr ("This program can only be used by the root user\n");

+		return G_IO_ERROR_NOT_SUPPORTED;

+	}

+	g_option_context_add_main_entries (context, options, NULL);

+	if (!g_option_context_parse (context, &argc, &argv, &error)) {

+		g_printerr ("Failed to parse arguments: %s\n", error->message);

+		return G_IO_ERROR_NOT_SUPPORTED;

+	}

+

+	/* uncommon actions */

+	if (kind == NULL) {

+		g_printerr ("No --kind specified\n");

+		return G_IO_ERROR_INVALID_DATA;

+	}

+	if (g_strcmp0 (kind, "unregister") == 0) {

+		if (!_helper_unregister (&error)) {

+			g_printerr ("Failed to Unregister: %s\n", error->message);

+			return G_IO_ERROR_NOT_INITIALIZED;

+		}

+		return EXIT_SUCCESS;

+	}

+	if (g_strcmp0 (kind, "auto-attach") == 0) {

+		if (!_helper_auto_attach (&error)) {

+			g_printerr ("Failed to AutoAttach: %s\n", error->message);

+			return G_IO_ERROR_NOT_INITIALIZED;

+		}

+		return EXIT_SUCCESS;

+	}

+

+	/* connect to abstract socket for reasons */

+	if (address == NULL) {

+		g_printerr ("No --address specified\n");

+		return G_IO_ERROR_INVALID_DATA;

+	}

+	conn_private = g_dbus_connection_new_for_address_sync (address,

+							       G_DBUS_CONNECTION_FLAGS_AUTHENTICATION_CLIENT,

+							       NULL, NULL,

+							       &error);

+	if (conn_private == NULL) {

+		g_printerr ("Invalid --address specified: %s\n", error->message);

+		return G_IO_ERROR_INVALID_DATA;

+	}

+	proxy = g_dbus_proxy_new_sync (conn_private,

+				       G_DBUS_PROXY_FLAGS_DO_NOT_LOAD_PROPERTIES,

+				       NULL, /* GDBusInterfaceInfo */

+				       NULL, /* name */

+				       "/com/redhat/RHSM1/Register",

+				       "com.redhat.RHSM1.Register",

+				       NULL, &error);

+	if (proxy == NULL) {

+		g_printerr ("Count not contact RHSM: %s\n", error->message);

+		return G_IO_ERROR_NOT_FOUND;

+	}

+

+	/* no options */

+	subman_options = g_variant_builder_new (G_VARIANT_TYPE("a{ss}"));

+

+	/* set registration server */

+	if (hostname == NULL || hostname[0] == '\0')

+		hostname = g_strdup ("subscription.rhsm.redhat.com");

+	if (prefix == NULL || prefix[0] == '\0')

+		prefix = g_strdup ("/subscription");

+	if (port == NULL || port[0] == '\0')

+		port = g_strdup ("443");

+	subman_conopts = g_variant_builder_new (G_VARIANT_TYPE("a{ss}"));

+	g_variant_builder_add (subman_conopts, "{ss}", "host", hostname);

+	g_variant_builder_add (subman_conopts, "{ss}", "handler", prefix);

+	g_variant_builder_add (subman_conopts, "{ss}", "port", port);

+

+	/* call into RHSM */

+	if (g_strcmp0 (kind, "register-with-key") == 0) {

+		g_auto(GStrv) activation_keys = NULL;

+		g_autoptr(GError) error_local = NULL;

+		g_autoptr(GVariant) res = NULL;

+

+		if (activation_key == NULL) {

+			g_printerr ("Required --activation-key\n");

+			return G_IO_ERROR_INVALID_DATA;

+		}

+		if (organisation == NULL) {

+			g_printerr ("Required --organisation\n");

+			return G_IO_ERROR_INVALID_DATA;

+		}

+

+		g_debug ("registering using activation key");

+		activation_keys = g_strsplit (activation_key, ",", -1);

+		res = g_dbus_proxy_call_sync (proxy,

+					      "RegisterWithActivationKeys",

+					      g_variant_new ("(s^asa{ss}a{ss}s)",

+							     organisation,

+							     activation_keys,

+							     subman_options,

+							     subman_conopts,

+							     userlang),

+					      G_DBUS_CALL_FLAGS_NO_AUTO_START,

+					      -1, NULL, &error_local);

+		if (res == NULL) {

+			g_dbus_error_strip_remote_error (error_local);

+			_helper_convert_error (error_local->message, &error);

+			g_printerr ("Failed to RegisterWithActivationKeys: %s\n", error->message);

+			return error->code;

+		}

+	} else if (g_strcmp0 (kind, "register-with-username") == 0) {

+		g_autoptr(GError) error_local = NULL;

+		g_autoptr(GVariant) res = NULL;

+

+		g_debug ("registering using username and password");

+		if (username == NULL) {

+			g_printerr ("Required --username\n");

+			return G_IO_ERROR_INVALID_DATA;

+		}

+		if (password == NULL) {

+			g_printerr ("Required --password\n");

+			return G_IO_ERROR_INVALID_DATA;

+		}

+		if (organisation == NULL) {

+			g_printerr ("Required --organisation\n");

+			return G_IO_ERROR_INVALID_DATA;

+		}

+		res = g_dbus_proxy_call_sync (proxy,

+					      "Register",

+					      g_variant_new ("(sssa{ss}a{ss}s)",

+							     organisation,

+							     username,

+							     password,

+							     subman_options,

+							     subman_conopts,

+							     userlang),

+					      G_DBUS_CALL_FLAGS_NO_AUTO_START,

+					      -1, NULL, &error_local);

+		if (res == NULL) {

+			g_dbus_error_strip_remote_error (error_local);

+			_helper_convert_error (error_local->message, &error);

+			g_printerr ("Failed to Register: %s\n", error->message);

+			return error->code;

+		}

+	} else {

+		g_printerr ("Invalid --kind specified: %s\n", kind);

+		return G_IO_ERROR_INVALID_DATA;

+	}

+

+	/* set the new hostname */

+	if (!_helper_save_config ("server.hostname", hostname, &error)) {

+		g_printerr ("Failed to save hostname: %s\n", error->message);

+		return G_IO_ERROR_NOT_INITIALIZED;

+	}

+	if (!_helper_save_config ("server.prefix", prefix, &error)) {

+		g_printerr ("Failed to save prefix: %s\n", error->message);

+		return G_IO_ERROR_NOT_INITIALIZED;

+	}

+	if (!_helper_save_config ("server.port", port, &error)) {

+		g_printerr ("Failed to save port: %s\n", error->message);

+		return G_IO_ERROR_NOT_INITIALIZED;

+	}

+

+	/* wait for rhsmd to notice the new config */

+	g_usleep (G_USEC_PER_SEC * 5);

+

+	/* auto-attach */

+	if (!_helper_auto_attach (&error)) {

+		g_printerr ("Failed to AutoAttach: %s\n", error->message);

+		return G_IO_ERROR_NOT_INITIALIZED;

+	}

+

+	return EXIT_SUCCESS;

+}

diff -urNp gnome-settings-daemon-3.32.0.old/plugins/subman/gsd-subscription-manager.c gnome-settings-daemon-3.32.0/plugins/subman/gsd-subscription-manager.c

--- gnome-settings-daemon-3.32.0.old/plugins/subman/gsd-subscription-manager.c	1970-01-01 01:00:00.000000000 +0100

+++ gnome-settings-daemon-3.32.0/plugins/subman/gsd-subscription-manager.c	2019-06-17 13:01:59.247311860 +0100

@@ -0,0 +1,998 @@

+/* -*- Mode: C; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 8 -*-

+ *

+ * Copyright (C) 2019 Richard Hughes <richard@hughsie.com>

+ *

+ * 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, see <http://www.gnu.org/licenses/>.

+ *

+ */

+

+#include "config.h"

+

+#include <glib/gi18n.h>

+#include <gdk/gdk.h>

+#include <gtk/gtk.h>

+#include <json-glib/json-glib.h>

+#include <libnotify/notify.h>

+

+#include "gnome-settings-profile.h"

+#include "gsd-subman-common.h"

+#include "gsd-subscription-manager.h"

+

+#define GSD_DBUS_NAME "org.gnome.SettingsDaemon"

+#define GSD_DBUS_PATH "/org/gnome/SettingsDaemon"

+#define GSD_DBUS_BASE_INTERFACE "org.gnome.SettingsDaemon"

+

+#define GSD_SUBSCRIPTION_DBUS_NAME		GSD_DBUS_NAME ".Subscription"

+#define GSD_SUBSCRIPTION_DBUS_PATH		GSD_DBUS_PATH "/Subscription"

+#define GSD_SUBSCRIPTION_DBUS_INTERFACE		GSD_DBUS_BASE_INTERFACE ".Subscription"

+

+static const gchar introspection_xml[] =

+"<node>"

+"  <interface name='org.gnome.SettingsDaemon.Subscription'>"

+"    <method name='Register'>"

+"      <arg type='a{sv}' name='options' direction='in'/>"

+"    </method>"

+"    <method name='Unregister'/>"

+"    <property name='SubscriptionStatus' type='u' access='read'/>"

+"  </interface>"

+"</node>";

+

+#define GSD_SUBSCRIPTION_MANAGER_GET_PRIVATE(o) (G_TYPE_INSTANCE_GET_PRIVATE ((o), GSD_TYPE_SUBSCRIPTION_MANAGER, GsdSubscriptionManagerPrivate))

+

+typedef enum {

+	_RHSM_INTERFACE_CONFIG,

+	_RHSM_INTERFACE_REGISTER_SERVER,

+	_RHSM_INTERFACE_ATTACH,

+	_RHSM_INTERFACE_ENTITLEMENT,

+	_RHSM_INTERFACE_PRODUCTS,

+	_RHSM_INTERFACE_CONSUMER,

+	_RHSM_INTERFACE_SYSPURPOSE,

+	_RHSM_INTERFACE_LAST

+} _RhsmInterface;

+

+struct GsdSubscriptionManagerPrivate

+{

+	/* D-Bus */

+	guint		 name_id;

+	GDBusNodeInfo	*introspection_data;

+	GDBusConnection	*connection;

+	GCancellable	*bus_cancellable;

+

+	GDBusProxy	*proxies[_RHSM_INTERFACE_LAST];

+	const gchar	*userlang;	/* owned by GLib internally */

+	GHashTable	*config; 	/* str:str */

+	gchar		*address;

+

+	guint		 check_registration_timeout_id;

+	GTimer		*timer_last_notified;

+	NotifyNotification	*notification_expired;

+	NotifyNotification	*notification_registered;

+	NotifyNotification	*notification_registration_required;

+	GsdSubmanSubscriptionStatus	 subscription_status;

+	GsdSubmanSubscriptionStatus	 subscription_status_last;

+};

+

+enum {

+	PROP_0,

+};

+

+static void     gsd_subscription_manager_class_init  (GsdSubscriptionManagerClass *klass);

+static void     gsd_subscription_manager_init        (GsdSubscriptionManager      *subscription_manager);

+static void     gsd_subscription_manager_finalize    (GObject             *object);

+

+G_DEFINE_TYPE (GsdSubscriptionManager, gsd_subscription_manager, G_TYPE_OBJECT)

+

+static gpointer manager_object = NULL;

+

+GQuark

+gsd_subscription_manager_error_quark (void)

+{

+	static GQuark quark = 0;

+	if (!quark)

+		quark = g_quark_from_static_string ("gsd_subscription_manager_error");

+	return quark;

+}

+

+static GsdSubmanSubscriptionStatus

+_client_subscription_status_from_text (const gchar *status_txt)

+{

+	if (g_strcmp0 (status_txt, "Unknown") == 0)

+		return GSD_SUBMAN_SUBSCRIPTION_STATUS_UNKNOWN;

+	if (g_strcmp0 (status_txt, "Current") == 0)

+		return GSD_SUBMAN_SUBSCRIPTION_STATUS_VALID;

+	if (g_strcmp0 (status_txt, "Invalid") == 0)

+		return GSD_SUBMAN_SUBSCRIPTION_STATUS_INVALID;

+	if (g_strcmp0 (status_txt, "Disabled") == 0)

+		return GSD_SUBMAN_SUBSCRIPTION_STATUS_DISABLED;

+	if (g_strcmp0 (status_txt, "Insufficient") == 0)

+		return GSD_SUBMAN_SUBSCRIPTION_STATUS_PARTIALLY_VALID;

+	g_warning ("Unknown subscription status: %s", status_txt); // 'Current'?

+	return GSD_SUBMAN_SUBSCRIPTION_STATUS_UNKNOWN;

+}

+

+static gboolean

+_client_subscription_status_update (GsdSubscriptionManager *manager, GError **error)

+{

+	GsdSubscriptionManagerPrivate *priv = manager->priv;

+	JsonNode *json_root;

+	JsonObject *json_obj;

+	const gchar *json_txt = NULL;

+	const gchar *status_txt = NULL;

+	g_autoptr(GVariant) val = NULL;

+	g_autoptr(JsonParser) json_parser = json_parser_new ();

+

+	/* save old value */

+	priv->subscription_status_last = priv->subscription_status;

+

+	val = g_dbus_proxy_call_sync (priv->proxies[_RHSM_INTERFACE_ENTITLEMENT],

+				      "GetStatus",

+				      g_variant_new ("(ss)",

+						     "", /* assumed as 'now' */

+						     priv->userlang),

+				      G_DBUS_CALL_FLAGS_NONE,

+				      -1, NULL, error);

+	if (val == NULL)

+		return FALSE;

+	g_variant_get (val, "(&s)", &json_txt);

+	g_debug ("Entitlement.GetStatus JSON: %s", json_txt);

+	if (!json_parser_load_from_data (json_parser, json_txt, -1, error))

+		return FALSE;

+	json_root = json_parser_get_root (json_parser);

+	json_obj = json_node_get_object (json_root);

+	if (!json_object_has_member (json_obj, "status")) {

+		g_set_error (error, G_IO_ERROR, G_IO_ERROR_INVALID_DATA,

+			     "no Entitlement.GetStatus status in %s", json_txt);

+		return FALSE;

+	}

+

+	status_txt = json_object_get_string_member (json_obj, "status");

+	g_debug ("Entitlement.GetStatus: %s", status_txt);

+	priv->subscription_status = _client_subscription_status_from_text (status_txt);

+	return TRUE;

+}

+

+static gboolean

+_client_syspurpose_update (GsdSubscriptionManager *manager, GError **error)

+{

+	GsdSubscriptionManagerPrivate *priv = manager->priv;

+	JsonNode *json_root;

+	JsonObject *json_obj;

+	const gchar *json_txt = NULL;

+	g_autoptr(GVariant) val = NULL;

+	g_autoptr(JsonParser) json_parser = json_parser_new ();

+

+	val = g_dbus_proxy_call_sync (priv->proxies[_RHSM_INTERFACE_SYSPURPOSE],

+				      "GetSyspurpose",

+				      g_variant_new ("(s)", priv->userlang),

+				      G_DBUS_CALL_FLAGS_NONE,

+				      -1, NULL, error);

+	if (val == NULL)

+		return FALSE;

+	g_variant_get (val, "(&s)", &json_txt);

+	g_debug ("Syspurpose.GetSyspurpose JSON: %s", json_txt);

+	if (!json_parser_load_from_data (json_parser, json_txt, -1, error))

+		return FALSE;

+	json_root = json_parser_get_root (json_parser);

+	json_obj = json_node_get_object (json_root);

+	if (!json_object_has_member (json_obj, "status")) {

+		g_debug ("Syspurpose.GetSyspurpose: Unknown");

+		return TRUE;

+	}

+	g_debug ("Syspurpose.GetSyspurpose: '%s", json_object_get_string_member (json_obj, "status"));

+	return TRUE;

+}

+

+static gboolean

+_client_register_start (GsdSubscriptionManager *manager, GError **error)

+{

+	GsdSubscriptionManagerPrivate *priv = manager->priv;

+	const gchar *address = NULL;

+	g_autoptr(GDBusProxy) proxy = NULL;

+	g_autoptr(GVariant) val = NULL;

+

+	/* already started */

+	if (priv->address != NULL)

+		return TRUE;

+

+	/* apparently: "we can't send registration credentials over the regular

+	 * system or session bus since those aren't really locked down..." */

+	proxy = g_dbus_proxy_new_for_bus_sync (G_BUS_TYPE_SYSTEM,

+					       G_DBUS_PROXY_FLAGS_NONE,

+					       NULL,

+					       "com.redhat.RHSM1",

+					       "/com/redhat/RHSM1/RegisterServer",

+					       "com.redhat.RHSM1.RegisterServer",

+					       NULL, error);

+	if (proxy == NULL)

+		return FALSE;

+	val = g_dbus_proxy_call_sync (proxy, "Start",

+				      g_variant_new ("(s)", priv->userlang),

+				      G_DBUS_CALL_FLAGS_NONE,

+				      -1, NULL, error);

+	if (val == NULL)

+		return FALSE;

+	g_variant_get (val, "(&s)", &address);

+	g_debug ("RegisterServer.Start: %s", address);

+	priv->address = g_strdup (address);