diff options
Diffstat (limited to 'goa-mc-plugin/mcp-account-manager-goa.c')
-rw-r--r-- | goa-mc-plugin/mcp-account-manager-goa.c | 589 |
1 files changed, 589 insertions, 0 deletions
diff --git a/goa-mc-plugin/mcp-account-manager-goa.c b/goa-mc-plugin/mcp-account-manager-goa.c new file mode 100644 index 000000000..d81c60816 --- /dev/null +++ b/goa-mc-plugin/mcp-account-manager-goa.c @@ -0,0 +1,589 @@ +/* + * mcp-account-manager-goa.c + * + * 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. + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License as published by the Free Software Foundation; either + * version 2.1 of the License, or (at your option) any later version. + * + * This library 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 + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this library; if not, see <http://www.gnu.org/licenses/>. + * + * Authors: + * Danielle Madeley <danielle.madeley@collabora.co.uk> + */ + +#include <glib/gi18n.h> + +#include <telepathy-glib/util.h> + +#define GOA_API_IS_SUBJECT_TO_CHANGE /* awesome! */ +#include <goa/goa.h> + +#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 "org.gnome.OnlineAccounts" + +#define INITIAL_COMMENT "Parameters of GOA Telepathy accounts" + +static void account_storage_iface_init (McpAccountStorageIface *iface); + +G_DEFINE_TYPE_WITH_CODE (McpAccountManagerGoa, + mcp_account_manager_goa, + G_TYPE_OBJECT, + G_IMPLEMENT_INTERFACE (MCP_TYPE_ACCOUNT_STORAGE, + account_storage_iface_init)) + +struct _McpAccountManagerGoaPrivate +{ + gboolean ready; + + GoaClient *client; + GHashTable *accounts; /* alloc'ed string -> ref'ed GoaObject */ + + GKeyFile *store; + gchar *filename; +}; + + +static void +mcp_account_manager_goa_dispose (GObject *self) +{ + McpAccountManagerGoaPrivate *priv = GET_PRIVATE (self); + + tp_clear_object (&priv->client); + + G_OBJECT_CLASS (mcp_account_manager_goa_parent_class)->dispose (self); +} + + +static void +mcp_account_manager_goa_finalize (GObject *self) +{ + McpAccountManagerGoaPrivate *priv = GET_PRIVATE (self); + + g_hash_table_destroy (priv->accounts); + g_key_file_free (priv->store); + g_free (priv->filename); + + G_OBJECT_CLASS (mcp_account_manager_goa_parent_class)->finalize (self); +} + + +static void +mcp_account_manager_goa_class_init (McpAccountManagerGoaClass *klass) +{ + GObjectClass *gobject_class = G_OBJECT_CLASS (klass); + + gobject_class->dispose = mcp_account_manager_goa_dispose; + gobject_class->finalize = mcp_account_manager_goa_finalize; + + g_type_class_add_private (gobject_class, + sizeof (McpAccountManagerGoaPrivate)); +} + +static GHashTable * +get_tp_parameters (GoaAccount *account) +{ + GHashTable *params = g_hash_table_new_full (g_str_hash, g_str_equal, + NULL, g_free); + const char *type = goa_account_get_provider_type (account); + +#define PARAM(key, value) g_hash_table_insert (params, key, g_strdup (value)); + + if (!tp_strdiff (type, "google")) + { + PARAM ("manager", "gabble"); + PARAM ("protocol", "jabber"); + PARAM ("Icon", "im-google-talk"); + PARAM ("Service", "google-talk"); + + PARAM ("param-account", goa_account_get_identity (account)); + PARAM ("param-server", "talk.google.com"); + PARAM ("param-fallback-servers", + "talkx.l.google.com;" + "talkx.l.google.com:443,oldssl;" + "talkx.l.google.com:80"); + PARAM ("param-extra-certificate-identities", "talk.google.com"); + PARAM ("param-require-encryption", "true"); + } + else + { + /* unknown account type */ + g_hash_table_destroy (params); + return NULL; + } + + /* TODO: add Facebook support */ + + /* generic properties */ + PARAM ("DisplayName", goa_account_get_presentation_identity (account)); + +#undef PARAM + + return params; +} + + +static char * +get_tp_account_name (GoaAccount *account) +{ + GHashTable *params = get_tp_parameters (account); + const char *type = goa_account_get_provider_type (account); + const char *id = goa_account_get_id (account); + char *name; + + if (params == NULL) + return NULL; + + name = g_strdup_printf ("%s/%s/goa_%s_%s", + (char *) g_hash_table_lookup (params, "manager"), + (char *) g_hash_table_lookup (params, "protocol"), + type, id); + + g_hash_table_destroy (params); + + return name; +} + +static void +object_chat_changed_cb (GoaObject *object, + GParamSpec *spec, + McpAccountManagerGoa *self) +{ + GoaAccount *account = goa_object_peek_account (object); + char *name = get_tp_account_name (account); + gboolean enabled; + + 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); +} + +static void +_new_account (McpAccountManagerGoa *self, + GoaObject *object) +{ + GoaAccount *account = goa_object_peek_account (object); + char *account_name = get_tp_account_name (account); + + if (account_name == NULL) + return; + + /* @account_name now is owned by the hash table */ + g_hash_table_insert (self->priv->accounts, account_name, + g_object_ref (object)); + + if (self->priv->ready) + g_signal_emit_by_name (self, "created", account_name); + + tp_g_signal_connect_object (object, "notify::chat", + G_CALLBACK (object_chat_changed_cb), self, 0); +} + + +DECLARE_GASYNC_CALLBACK (_goa_client_new_cb); + +static void +load_store (McpAccountManagerGoa *self) +{ + GError *error = NULL; + + if (!g_key_file_load_from_file (self->priv->store, self->priv->filename, + G_KEY_FILE_KEEP_COMMENTS, &error)) + { + gchar *dir; + + DEBUG ("Failed to load keyfile, creating a new one: %s", error->message); + + dir = g_path_get_dirname (self->priv->filename); + + g_mkdir_with_parents (dir, 0700); + g_free (dir); + + g_key_file_set_comment (self->priv->store, NULL, NULL, INITIAL_COMMENT, + NULL); + + g_error_free (error); + } +} + +static void +mcp_account_manager_goa_init (McpAccountManagerGoa *self) +{ + gchar *path; + + DEBUG ("GOA MC plugin initialised"); + + self->priv = G_TYPE_INSTANCE_GET_PRIVATE (self, + MCP_TYPE_ACCOUNT_MANAGER_GOA, McpAccountManagerGoaPrivate); + + self->priv->accounts = g_hash_table_new_full (g_str_hash, g_str_equal, + g_free, g_object_unref); + + goa_client_new (NULL, _goa_client_new_cb, self); + + /* key file store */ + self->priv->store = g_key_file_new (); + self->priv->filename = g_build_filename (g_get_user_data_dir (), "telepathy", + "mission-control", "accounts-goa.cfg", NULL); + + load_store (self); +} + + +static void +_account_added_cb (GoaClient *client, + GoaObject *object, + McpAccountManagerGoa *self) +{ + _new_account (self, object); +} + + +static void +_account_removed_cb (GoaClient *client, + GoaObject *object, + McpAccountManagerGoa *self) +{ + GoaAccount *account = goa_object_peek_account (object); + char *name = get_tp_account_name (account); + + if (self->priv->ready) + g_signal_emit_by_name (self, "deleted", name); + + g_hash_table_remove (self->priv->accounts, name); + + g_free (name); +} + +static void +_goa_client_new_cb (GObject *obj, + GAsyncResult *result, + gpointer user_data) +{ + McpAccountManagerGoa *self = user_data; + GoaClient *client; + GList *accounts, *ptr; + GError *error = NULL; + + self->priv->client = goa_client_new_finish (result, &error); + + if (error != NULL) + { + DEBUG ("Failed to connect to GOA"); + return; + } + + accounts = goa_client_get_accounts (self->priv->client); + + for (ptr = accounts; ptr != NULL; ptr = ptr->next) + { + _new_account (self, ptr->data); + } + + g_list_free_full (accounts, g_object_unref); + + g_signal_connect (self->priv->client, "account-added", + G_CALLBACK (_account_added_cb), self); + g_signal_connect (self->priv->client, "account-removed", + G_CALLBACK (_account_removed_cb), self); +} + + +static GList * +mcp_account_manager_goa_list (const McpAccountStorage *self, + const McpAccountManager *am) +{ + McpAccountManagerGoaPrivate *priv = GET_PRIVATE (self); + GList *accounts = NULL; + GHashTableIter iter; + gpointer key; + + DEBUG (G_STRFUNC); + + g_hash_table_iter_init (&iter, priv->accounts); + while (g_hash_table_iter_next (&iter, &key, NULL)) + accounts = g_list_prepend (accounts, g_strdup (key)); + + return accounts; +} + + +static void +get_enabled (const McpAccountStorage *self, + const McpAccountManager *am, + const gchar *acct, + GoaObject *object) +{ + mcp_account_manager_set_value (am, acct, "Enabled", + goa_object_peek_chat (object) != NULL ? "true" : "false"); +} + + +static gboolean +mcp_account_manager_goa_get (const McpAccountStorage *self, + const McpAccountManager *am, + const gchar *acct, + const gchar *key) +{ + McpAccountManagerGoaPrivate *priv = GET_PRIVATE (self); + GoaObject *object; + GoaAccount *account; + + DEBUG ("%s: %s, %s", G_STRFUNC, acct, key); + + object = g_hash_table_lookup (priv->accounts, acct); + + if (object == NULL) + return FALSE; + + account = goa_object_peek_account (object); + + if (account == NULL) + return FALSE; + + if (key == NULL) + { + /* load all keys */ + GHashTable *params = get_tp_parameters (account); + GHashTableIter iter; + gpointer key, value; + GStrv keys; + guint i; + gssize 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); + + g_hash_table_destroy (params); + + /* Stored properties */ + keys = g_key_file_get_keys (priv->store, acct, &nkeys, NULL); + + for (i = 0; i < nkeys; i++) + { + gchar *v = g_key_file_get_value (priv->store, acct, keys[i], NULL); + + if (v != NULL) + { + mcp_account_manager_set_value (am, acct, keys[i], v); + g_free (v); + } + } + + g_strfreev (keys); + + /* Enabled */ + get_enabled (self, am, acct, object); + } + else if (!tp_strdiff (key, "Enabled")) + { + get_enabled (self, am, acct, object); + } + else + { + /* get a specific key */ + GHashTable *params = get_tp_parameters (account); + gchar *value; + + value = g_hash_table_lookup (params, key); + + if (value == NULL) + value = g_key_file_get_value (priv->store, acct, key, NULL); + else + value = g_strdup (value); + + mcp_account_manager_set_value (am, acct, key, value); + + g_hash_table_destroy (params); + g_free (value); + } + + return TRUE; +} + +static gboolean +account_is_in_goa (const McpAccountStorage *self, + const gchar *account) +{ + McpAccountManagerGoaPrivate *priv = GET_PRIVATE (self); + + return (g_hash_table_lookup (priv->accounts, acct) != NULL); +} + +static gboolean +mcp_account_manager_goa_set (const McpAccountStorage *self, + const McpAccountManager *am, + const gchar *account, + const gchar *key, + const gchar *val) +{ + McpAccountManagerGoaPrivate *priv = GET_PRIVATE (self); + GError *error = NULL; + + 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 (val != NULL) + g_key_file_set_value (priv->store, account, key, val); + else + g_key_file_remove_key (priv->store, account, key, NULL); + + /* Pretend we save everything so MC won't save this in accounts.cfg */ + return TRUE; +} + + +static gboolean +mcp_account_manager_goa_delete (const McpAccountStorage *self, + const McpAccountManager *am, + const gchar *account, + const gchar *key) +{ + McpAccountManagerGoaPrivate *priv = GET_PRIVATE (self); + + if (!account_is_in_goa (self, account)) + return FALSE; + + DEBUG ("%s: (%s, %s)", G_STRFUNC, account, key); + + if (key == NULL) + { + g_key_file_remove_group (priv->store, account, NULL); + } + else + { + g_key_file_remove_key (priv->store, account, key, NULL); + } + + /* Pretend we deleted everything */ + return TRUE; +} + + +static gboolean +mcp_account_manager_goa_commit (const McpAccountStorage *self, + const McpAccountManager *am) +{ + McpAccountManagerGoaPrivate *priv = GET_PRIVATE (self); + gchar *data; + gsize len; + GError *error = NULL; + + DEBUG ("Save config to %s", priv->filename); + + data = g_key_file_to_data (priv->store, &len, &error); + if (data == NULL) + { + DEBUG ("Failed to get data from store: %s", error->message); + + g_error_free (error); + return FALSE; + } + + if (!g_file_set_contents (priv->filename, data, len, &error)) + { + DEBUG ("Failed to write file: %s", error->message); + + g_free (data); + g_error_free (error); + return FALSE; + } + + g_free (data); + + return TRUE; +} + + +static void +mcp_account_manager_goa_ready (const McpAccountStorage *self, + const McpAccountManager *am) +{ + McpAccountManagerGoaPrivate *priv = GET_PRIVATE (self); + + priv->ready = TRUE; +} + + +static guint +mcp_account_manager_goa_get_restrictions (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; +} + + +static void +mcp_account_manager_goa_get_identifier (const McpAccountStorage *self, + const gchar *acct, + GValue *identifier) +{ + McpAccountManagerGoaPrivate *priv = GET_PRIVATE (self); + GoaObject *object; + GoaAccount *account; + + object = g_hash_table_lookup (priv->accounts, acct); + g_return_if_fail (object != NULL); + + account = goa_object_peek_account (object); + g_return_if_fail (account != NULL); + + g_value_init (identifier, G_TYPE_STRING); + g_value_set_string (identifier, goa_account_get_id (account)); +} + + +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); + +#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); +#undef IMPLEMENT +} |