X-Git-Url: https://git.0d.be/?p=empathy.git;a=blobdiff_plain;f=goa-mc-plugin%2Fmcp-account-manager-goa.c;h=cdd3f6044e3c7f3eeec87f52701687a3b6fe4ffb;hp=5fd014ed596a1e807ab22c742df5bb99269a5699;hb=8cf2c6933763caf5653ede5b343e57f09f968cbd;hpb=99d9177da27ddc4c4aaf5d40a6eae5b458084536 diff --git a/goa-mc-plugin/mcp-account-manager-goa.c b/goa-mc-plugin/mcp-account-manager-goa.c index 5fd014ed..cdd3f604 100644 --- a/goa-mc-plugin/mcp-account-manager-goa.c +++ b/goa-mc-plugin/mcp-account-manager-goa.c @@ -4,7 +4,7 @@ * McpAccountManagerGoa - a Mission Control plugin to expose GNOME Online * Accounts with chat capabilities (e.g. Facebook) to Mission Control * - * Copyright (C) 2010-2011 Collabora Ltd. + * Copyright (C) 2010-2014 Collabora Ltd. * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Lesser General Public @@ -24,28 +24,47 @@ */ #include "config.h" - -#include - -#include +#include "mcp-account-manager-goa.h" #define GOA_API_IS_SUBJECT_TO_CHANGE /* awesome! */ #include -#include "mcp-account-manager-goa.h" - #define DEBUG g_debug #define GET_PRIVATE(self) (((McpAccountManagerGoa *) self)->priv) #define DECLARE_GASYNC_CALLBACK(name) \ static void name (GObject *, GAsyncResult *, gpointer); #define PLUGIN_NAME "goa" -#define PLUGIN_PRIORITY (MCP_ACCOUNT_STORAGE_PLUGIN_PRIO_KEYRING + 10) #define PLUGIN_DESCRIPTION "Provide Telepathy Accounts from GOA" #define PLUGIN_PROVIDER EMPATHY_GOA_PROVIDER #define INITIAL_COMMENT "Parameters of GOA Telepathy accounts" +#ifdef MCP_API_VERSION_5_18 + +# define RESTRICTIONS TpStorageRestrictionFlags +# define WAS_CONST /* nothing */ + /* Its historical value was based on the KEYRING priority which no longer + * exists. Using a large number is OK, because it uses unusual account names + * which are unlikely to collide. */ +# define PLUGIN_PRIORITY (10010) + /* McpAccountStorageSetResult enum is defined by MC */ + +#else /* MC 5.16 or older */ + +# define RESTRICTIONS guint +# define WAS_CONST const +# define PLUGIN_PRIORITY (MCP_ACCOUNT_STORAGE_PLUGIN_PRIO_KEYRING + 10) + + /* we use this in helper functions */ + typedef enum { + MCP_ACCOUNT_STORAGE_SET_RESULT_FAILED, + MCP_ACCOUNT_STORAGE_SET_RESULT_UNCHANGED, + MCP_ACCOUNT_STORAGE_SET_RESULT_CHANGED + } McpAccountStorageSetResult; + +#endif /* MC 5.16 or older */ + static void account_storage_iface_init (McpAccountStorageIface *iface); G_DEFINE_TYPE_WITH_CODE (McpAccountManagerGoa, @@ -127,29 +146,6 @@ get_tp_parameters (GoaAccount *account) PARAM ("param-extra-certificate-identities", "talk.google.com"); PARAM ("param-require-encryption", "true"); } - else if (!tp_strdiff (type, "facebook")) - { - PARAM ("manager", "gabble"); - PARAM ("protocol", "jabber"); - PARAM ("Icon", "im-facebook"); - PARAM ("Service", "facebook"); - - PARAM ("param-account", "chat.facebook.com"); - PARAM ("param-server", "chat.facebook.com"); - PARAM ("param-require-encryption", "true"); - PARAM ("param-fallback-servers", - "chat.facebook.com:443"); - } - else if (!tp_strdiff (type, "windows_live")) - { - PARAM ("manager", "gabble"); - PARAM ("protocol", "jabber"); - PARAM ("Icon", "im-msn"); - PARAM ("Service", "windows-live"); - - PARAM ("param-account", "messenger.live.com"); - PARAM ("param-require-encryption", "true"); - } else { DEBUG ("Unknown account type %s", type); @@ -196,12 +192,16 @@ object_chat_changed_cb (GoaObject *object, char *name = get_tp_account_name (account); gboolean enabled; + if (name == NULL) + return; + enabled = (goa_object_peek_chat (object) != NULL); DEBUG ("%s %s", name, enabled ? "enabled" : "disabled"); if (self->priv->ready) - g_signal_emit_by_name (self, "toggled", name, enabled); + mcp_account_storage_emit_toggled (MCP_ACCOUNT_STORAGE (self), + name, enabled); } static void @@ -219,7 +219,8 @@ _new_account (McpAccountManagerGoa *self, g_object_ref (object)); if (self->priv->ready) - g_signal_emit_by_name (self, "created", account_name); + mcp_account_storage_emit_created (MCP_ACCOUNT_STORAGE (self), + account_name); tp_g_signal_connect_object (object, "notify::chat", G_CALLBACK (object_chat_changed_cb), self, 0); @@ -260,6 +261,11 @@ mcp_account_manager_goa_init (McpAccountManagerGoa *self) self->priv = G_TYPE_INSTANCE_GET_PRIVATE (self, MCP_TYPE_ACCOUNT_MANAGER_GOA, McpAccountManagerGoaPrivate); +#ifdef MCP_API_VERSION_5_18 + /* the ready callback no longer exists, we may emit signals at any time */ + self->priv->ready = TRUE; +#endif + self->priv->accounts = g_hash_table_new_full (g_str_hash, g_str_equal, g_free, g_object_unref); @@ -291,8 +297,11 @@ _account_removed_cb (GoaClient *client, GoaAccount *account = goa_object_peek_account (object); char *name = get_tp_account_name (account); + if (name == NULL) + return; + if (self->priv->ready) - g_signal_emit_by_name (self, "deleted", name); + mcp_account_storage_emit_deleted (MCP_ACCOUNT_STORAGE (self), name); g_hash_table_remove (self->priv->accounts, name); @@ -333,8 +342,8 @@ _goa_client_new_cb (GObject *obj, static GList * -mcp_account_manager_goa_list (const McpAccountStorage *self, - const McpAccountManager *am) +mcp_account_manager_goa_list (WAS_CONST McpAccountStorage *self, + WAS_CONST McpAccountManager *am) { McpAccountManagerGoaPrivate *priv = GET_PRIVATE (self); GList *accounts = NULL; @@ -351,30 +360,112 @@ mcp_account_manager_goa_list (const McpAccountStorage *self, } -static void -get_enabled (const McpAccountStorage *self, - const McpAccountManager *am, - const gchar *acct, - GoaObject *object) +#ifdef MCP_API_VERSION_5_18 + +static GVariant * +get_item (McpAccountManagerGoa *self, + McpAccountManager *am, + const gchar *acc, + const gchar *key, + const GVariantType *type) { - mcp_account_manager_set_value (am, acct, "Enabled", - goa_object_peek_chat (object) != NULL ? "true" : "false"); + GoaObject *object; + GoaAccount *account; + GHashTable *bits; + gchar *esc; + GVariant *ret = NULL; + + DEBUG ("%s: %s, %s", G_STRFUNC, acc, key); + + object = g_hash_table_lookup (self->priv->accounts, acc); + + g_return_val_if_fail (object != NULL, NULL); + + account = goa_object_peek_account (object); + + g_return_val_if_fail (account != NULL, NULL); + + if (!tp_strdiff (key, "Enabled")) + { + return g_variant_ref_sink (g_variant_new_boolean ( + !goa_account_get_chat_disabled (account))); + } + + bits = get_tp_parameters (account); + + esc = g_hash_table_lookup (bits, key); + + if (esc == NULL) + esc = g_key_file_get_value (self->priv->store, acc, key, NULL); + else + esc = g_strdup (esc); + + if (esc != NULL) + { + ret = mcp_account_manager_unescape_variant_from_keyfile (am, + esc, type, NULL); + + g_free (esc); + } + + g_hash_table_unref (bits); + return ret; +} + +static GVariant * +mcp_account_manager_goa_get_attribute (McpAccountStorage *self, + McpAccountManager *am, + const gchar *acc, + const gchar *attribute, + const GVariantType *type, + McpAttributeFlags *flags) +{ + return get_item (MCP_ACCOUNT_MANAGER_GOA (self), am, acc, attribute, type); } +static GVariant * +mcp_account_manager_goa_get_parameter (McpAccountStorage *storage, + McpAccountManager *am, + const gchar *acc, + const gchar *parameter, + const GVariantType *type, + McpParameterFlags *flags) +{ + gchar *key; + GVariant *ret; + + key = g_strdup_printf ("param-%s", parameter); + + ret = get_item (MCP_ACCOUNT_MANAGER_GOA (storage), am, acc, key, type); + g_free (key); + return ret; +} + +#else /* MC 5.16 or older */ + +static void +get_enabled (WAS_CONST McpAccountStorage *self, + WAS_CONST McpAccountManager *am, + const gchar *acc, + GoaAccount *account) +{ + mcp_account_manager_set_value (am, acc, "Enabled", + goa_account_get_chat_disabled (account) == FALSE ? "true" : "false"); +} static gboolean -mcp_account_manager_goa_get (const McpAccountStorage *self, - const McpAccountManager *am, - const gchar *acct, +mcp_account_manager_goa_get (WAS_CONST McpAccountStorage *self, + WAS_CONST McpAccountManager *am, + const gchar *acc, const gchar *key) { McpAccountManagerGoaPrivate *priv = GET_PRIVATE (self); GoaObject *object; GoaAccount *account; - DEBUG ("%s: %s, %s", G_STRFUNC, acct, key); + DEBUG ("%s: %s, %s", G_STRFUNC, acc, key); - object = g_hash_table_lookup (priv->accounts, acct); + object = g_hash_table_lookup (priv->accounts, acc); if (object == NULL) return FALSE; @@ -389,28 +480,28 @@ mcp_account_manager_goa_get (const McpAccountStorage *self, /* load all keys */ GHashTable *params = get_tp_parameters (account); GHashTableIter iter; - gpointer key, value; + gpointer k, value; GStrv keys; guint i; - gssize nkeys = 0; + gsize nkeys = 0; /* Properties from GOA */ g_hash_table_iter_init (&iter, params); - while (g_hash_table_iter_next (&iter, &key, &value)) - mcp_account_manager_set_value (am, acct, key, value); + while (g_hash_table_iter_next (&iter, &k, &value)) + mcp_account_manager_set_value (am, acc, k, value); g_hash_table_unref (params); /* Stored properties */ - keys = g_key_file_get_keys (priv->store, acct, &nkeys, NULL); + keys = g_key_file_get_keys (priv->store, acc, &nkeys, NULL); for (i = 0; i < nkeys; i++) { - gchar *v = g_key_file_get_value (priv->store, acct, keys[i], NULL); + gchar *v = g_key_file_get_value (priv->store, acc, keys[i], NULL); if (v != NULL) { - mcp_account_manager_set_value (am, acct, keys[i], v); + mcp_account_manager_set_value (am, acc, keys[i], v); g_free (v); } } @@ -418,11 +509,11 @@ mcp_account_manager_goa_get (const McpAccountStorage *self, g_strfreev (keys); /* Enabled */ - get_enabled (self, am, acct, object); + get_enabled (self, am, acc, account); } else if (!tp_strdiff (key, "Enabled")) { - get_enabled (self, am, acct, object); + get_enabled (self, am, acc, account); } else { @@ -433,11 +524,11 @@ mcp_account_manager_goa_get (const McpAccountStorage *self, value = g_hash_table_lookup (params, key); if (value == NULL) - value = g_key_file_get_value (priv->store, acct, key, NULL); + value = g_key_file_get_value (priv->store, acc, key, NULL); else value = g_strdup (value); - mcp_account_manager_set_value (am, acct, key, value); + mcp_account_manager_set_value (am, acc, key, value); g_hash_table_unref (params); g_free (value); @@ -446,15 +537,173 @@ mcp_account_manager_goa_get (const McpAccountStorage *self, return TRUE; } +#endif /* MC 5.16 or older */ + + static gboolean -account_is_in_goa (const McpAccountStorage *self, +account_is_in_goa (WAS_CONST McpAccountStorage *self, const gchar *account) { McpAccountManagerGoaPrivate *priv = GET_PRIVATE (self); - return (g_hash_table_lookup (priv->accounts, acct) != NULL); + return (g_hash_table_lookup (priv->accounts, account) != NULL); } +static McpAccountStorageSetResult +mcp_account_manager_goa_set_enabled (McpAccountStorage *self, + const gchar *account, + gboolean enabled) +{ + McpAccountManagerGoaPrivate *priv = GET_PRIVATE (self); + GoaObject *object; + GoaAccount *acc; + + object = g_hash_table_lookup (priv->accounts, account); + + if (object == NULL) + return MCP_ACCOUNT_STORAGE_SET_RESULT_FAILED; + + acc = goa_object_peek_account (object); + + if (acc == NULL) + return MCP_ACCOUNT_STORAGE_SET_RESULT_FAILED; + + if (goa_account_get_chat_disabled (acc) == !enabled) + return MCP_ACCOUNT_STORAGE_SET_RESULT_UNCHANGED; + + goa_account_set_chat_disabled (acc, !enabled); + return MCP_ACCOUNT_STORAGE_SET_RESULT_CHANGED; +} + +#ifdef MCP_API_VERSION_5_18 + +static McpAccountStorageSetResult +mcp_account_manager_goa_set_attribute (McpAccountStorage *storage, + McpAccountManager *am, + const gchar *account_name, + const gchar *attribute, + GVariant *value, + McpAttributeFlags flags) +{ + McpAccountManagerGoaPrivate *priv = GET_PRIVATE (storage); + McpAccountStorageSetResult ret = MCP_ACCOUNT_STORAGE_SET_RESULT_FAILED; + + g_return_val_if_fail (account_is_in_goa (storage, account_name), + MCP_ACCOUNT_STORAGE_SET_RESULT_FAILED); + + if (!tp_strdiff (attribute, "Enabled")) + { + g_return_val_if_fail ( + g_variant_classify (value) == G_VARIANT_CLASS_BOOLEAN, + MCP_ACCOUNT_STORAGE_SET_RESULT_FAILED); + + return mcp_account_manager_goa_set_enabled (storage, account_name, + g_variant_get_boolean (value)); + } + /* FIXME: filter out manager, protocol, Icon, Service? */ + else if (value != NULL) + { + gchar *esc = mcp_account_manager_escape_variant_for_keyfile (am, + value); + gchar *old; + + if (esc == NULL) + return MCP_ACCOUNT_STORAGE_SET_RESULT_FAILED; + + old = g_key_file_get_value (priv->store, account_name, attribute, NULL); + + if (tp_strdiff (old, esc)) + { + g_key_file_set_value (priv->store, account_name, attribute, esc); + ret = MCP_ACCOUNT_STORAGE_SET_RESULT_CHANGED; + } + else + { + ret = MCP_ACCOUNT_STORAGE_SET_RESULT_UNCHANGED; + } + + g_free (esc); + g_free (old); + } + else + { + if (g_key_file_has_key (priv->store, account_name, attribute, NULL)) + { + g_key_file_remove_key (priv->store, account_name, attribute, NULL); + ret = MCP_ACCOUNT_STORAGE_SET_RESULT_CHANGED; + } + else + { + ret = MCP_ACCOUNT_STORAGE_SET_RESULT_UNCHANGED; + } + } + + return ret; +} + +static McpAccountStorageSetResult +mcp_account_manager_goa_set_parameter (McpAccountStorage *storage, + McpAccountManager *am, + const gchar *account_name, + const gchar *parameter, + GVariant *value, + McpParameterFlags flags) +{ + McpAccountManagerGoaPrivate *priv = GET_PRIVATE (storage); + McpAccountStorageSetResult ret = MCP_ACCOUNT_STORAGE_SET_RESULT_FAILED; + gchar *key = NULL; + gchar *esc = NULL; + gchar *old = NULL; + + g_return_val_if_fail (account_is_in_goa (storage, account_name), + MCP_ACCOUNT_STORAGE_SET_RESULT_FAILED); + + key = g_strdup_printf ("param-%s", parameter); + + /* FIXME: filter out reserved keys for this account? */ + if (value != NULL) + { + esc = mcp_account_manager_escape_variant_for_keyfile (am, + value); + + if (esc == NULL) + goto out; + + old = g_key_file_get_value (priv->store, account_name, key, NULL); + + if (tp_strdiff (esc, old)) + { + g_key_file_set_value (priv->store, account_name, key, esc); + ret = MCP_ACCOUNT_STORAGE_SET_RESULT_CHANGED; + } + else + { + ret = MCP_ACCOUNT_STORAGE_SET_RESULT_UNCHANGED; + } + } + else + { + if (g_key_file_has_key (priv->store, account_name, key, NULL)) + { + g_key_file_remove_key (priv->store, account_name, key, NULL); + ret = MCP_ACCOUNT_STORAGE_SET_RESULT_CHANGED; + } + else + { + ret = MCP_ACCOUNT_STORAGE_SET_RESULT_UNCHANGED; + } + + } + +out: + g_free (key); + g_free (esc); + g_free (old); + return ret; +} + +#else /* MC 5.16 or older */ + static gboolean mcp_account_manager_goa_set (const McpAccountStorage *self, const McpAccountManager *am, @@ -467,13 +716,18 @@ mcp_account_manager_goa_set (const McpAccountStorage *self, if (!account_is_in_goa (self, account)) return FALSE; - /* No need to save Enabled, it's up to the GOA configuration if the account - * is configured or not. */ - if (!tp_strdiff (key, "Enabled")) - return TRUE; - DEBUG ("%s: (%s, %s, %s)", G_STRFUNC, account, key, val); + if (!tp_strdiff (key, "Enabled")) + { + if (mcp_account_manager_goa_set_enabled ((McpAccountStorage *) self, + account, + !tp_strdiff (val, "true")) != MCP_ACCOUNT_STORAGE_SET_RESULT_FAILED) + return TRUE; + else + return FALSE; + } + if (val != NULL) g_key_file_set_value (priv->store, account, key, val); else @@ -483,10 +737,12 @@ mcp_account_manager_goa_set (const McpAccountStorage *self, return TRUE; } +#endif /* MC 5.16 or older */ + static gboolean -mcp_account_manager_goa_delete (const McpAccountStorage *self, - const McpAccountManager *am, +mcp_account_manager_goa_delete (WAS_CONST McpAccountStorage *self, + WAS_CONST McpAccountManager *am, const gchar *account, const gchar *key) { @@ -511,11 +767,43 @@ mcp_account_manager_goa_delete (const McpAccountStorage *self, } +#ifdef MCP_API_VERSION_5_18 +static void +mcp_account_manager_goa_delete_async (McpAccountStorage *self, + McpAccountManager *am, + const gchar *account_name, + GCancellable *cancellable, + GAsyncReadyCallback callback, + gpointer user_data) +{ + GTask *task = g_task_new (self, cancellable, callback, user_data); + + if (mcp_account_manager_goa_delete (self, am, account_name, NULL)) + { + g_task_return_boolean (task, TRUE); + } + else + { + g_task_return_new_error (task, TP_ERROR, TP_ERROR_DOES_NOT_EXIST, + "Account does not exist in GOA"); + } + + g_object_unref (task); +} + static gboolean -mcp_account_manager_goa_commit (const McpAccountStorage *self, - const McpAccountManager *am) +mcp_account_manager_goa_delete_finish (McpAccountStorage *self, + GAsyncResult *res, + GError **error) { - McpAccountManagerGoaPrivate *priv = GET_PRIVATE (self); + return g_task_propagate_boolean (G_TASK (res), error); +} +#endif /* MC >= 5.18 API */ + +static gboolean +commit (McpAccountManagerGoa *self) +{ + McpAccountManagerGoaPrivate *priv = self->priv; gchar *data; gsize len; GError *error = NULL; @@ -545,37 +833,56 @@ mcp_account_manager_goa_commit (const McpAccountStorage *self, return TRUE; } +#ifdef MCP_API_VERSION_5_18 +static gboolean +mcp_account_manager_goa_commit (McpAccountStorage *self, + McpAccountManager *am, + const gchar *account) +{ + return commit (MCP_ACCOUNT_MANAGER_GOA (self)); +} +#else +static gboolean +mcp_account_manager_goa_commit (const McpAccountStorage *self, + const McpAccountManager *am) +{ + return commit (MCP_ACCOUNT_MANAGER_GOA (self)); +} +#endif + +#ifndef MCP_API_VERSION_5_18 +/* removed in 5.18, MC should now be ready to receive signals at any time */ static void -mcp_account_manager_goa_ready (const McpAccountStorage *self, - const McpAccountManager *am) +mcp_account_manager_goa_ready (WAS_CONST McpAccountStorage *self, + WAS_CONST McpAccountManager *am) { McpAccountManagerGoaPrivate *priv = GET_PRIVATE (self); priv->ready = TRUE; } +#endif -static guint -mcp_account_manager_goa_get_restrictions (const McpAccountStorage *self, +static RESTRICTIONS +mcp_account_manager_goa_get_restrictions (WAS_CONST McpAccountStorage *self, const gchar *account) { return TP_STORAGE_RESTRICTION_FLAG_CANNOT_SET_PARAMETERS | - TP_STORAGE_RESTRICTION_FLAG_CANNOT_SET_SERVICE | - TP_STORAGE_RESTRICTION_FLAG_CANNOT_SET_ENABLED; + TP_STORAGE_RESTRICTION_FLAG_CANNOT_SET_SERVICE; } static void -mcp_account_manager_goa_get_identifier (const McpAccountStorage *self, - const gchar *acct, +mcp_account_manager_goa_get_identifier (WAS_CONST McpAccountStorage *self, + const gchar *acc, GValue *identifier) { McpAccountManagerGoaPrivate *priv = GET_PRIVATE (self); GoaObject *object; GoaAccount *account; - object = g_hash_table_lookup (priv->accounts, acct); + object = g_hash_table_lookup (priv->accounts, acc); g_return_if_fail (object != NULL); account = goa_object_peek_account (object); @@ -589,20 +896,31 @@ mcp_account_manager_goa_get_identifier (const McpAccountStorage *self, static void account_storage_iface_init (McpAccountStorageIface *iface) { - mcp_account_storage_iface_set_name (iface, PLUGIN_NAME); - mcp_account_storage_iface_set_desc (iface, PLUGIN_DESCRIPTION); - mcp_account_storage_iface_set_priority (iface, PLUGIN_PRIORITY); - mcp_account_storage_iface_set_provider (iface, PLUGIN_PROVIDER); + iface->name = PLUGIN_NAME; + iface->desc = PLUGIN_DESCRIPTION; + iface->priority = PLUGIN_PRIORITY; + iface->provider = PLUGIN_PROVIDER; + +#define IMPLEMENT(x) iface->x = mcp_account_manager_goa_##x -#define IMPLEMENT(x) mcp_account_storage_iface_implement_##x(iface, \ - mcp_account_manager_goa_##x) - IMPLEMENT (get); IMPLEMENT (list); - IMPLEMENT (set); - IMPLEMENT (delete); IMPLEMENT (commit); - IMPLEMENT (ready); IMPLEMENT (get_restrictions); IMPLEMENT (get_identifier); + +#ifdef MCP_API_VERSION_5_18 + IMPLEMENT (delete_async); + IMPLEMENT (delete_finish); + IMPLEMENT (get_attribute); + IMPLEMENT (get_parameter); + IMPLEMENT (set_attribute); + IMPLEMENT (set_parameter); +#else + IMPLEMENT (get); + IMPLEMENT (set); + IMPLEMENT (delete); + IMPLEMENT (ready); +#endif + #undef IMPLEMENT }