2 * Copyright (C) 2008 Collabora Ltd.
4 * This library is free software; you can redistribute it and/or
5 * modify it under the terms of the GNU Lesser General Public
6 * License as published by the Free Software Foundation; either
7 * version 2.1 of the License, or (at your option) any later version.
9 * This library is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
12 * Lesser General Public License for more details.
14 * You should have received a copy of the GNU Lesser General Public
15 * License along with this library; if not, write to the Free Software
16 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
18 * Authors: Cosimo Cecchi <cosimo.cecchi@collabora.co.uk>
19 * Sjoerd Simons <sjoerd.simons@collabora.co.uk>
24 #include <telepathy-glib/util.h>
25 #include <telepathy-glib/account-manager.h>
26 #include <telepathy-glib/enums.h>
27 #include <telepathy-glib/defs.h>
28 #include <telepathy-glib/dbus.h>
29 #include <telepathy-glib/interfaces.h>
31 #include "empathy-account-manager.h"
32 #include "empathy-marshal.h"
33 #include "empathy-utils.h"
35 #define DEBUG_FLAG EMPATHY_DEBUG_ACCOUNT
36 #include <libempathy/empathy-debug.h>
38 #define GET_PRIV(obj) EMPATHY_GET_PRIV (obj, EmpathyAccountManager)
40 #define MC5_BUS_NAME "org.freedesktop.Telepathy.MissionControl5"
43 /* (owned) unique name -> (reffed) EmpathyAccount */
49 TpAccountManager *tp_manager;
53 EmpathyAccount *global_account;
55 TpConnectionPresenceType global_presence;
57 gchar *global_status_message;
59 /* desired global presence, could be different
60 * from the actual global one.
62 TpConnectionPresenceType desired_presence;
63 gchar *desired_status;
64 gchar *desired_status_message;
66 GHashTable *create_results;
67 } EmpathyAccountManagerPriv;
75 ACCOUNT_CONNECTION_CHANGED,
76 GLOBAL_PRESENCE_CHANGED,
85 static guint signals[LAST_SIGNAL];
86 static EmpathyAccountManager *manager_singleton = NULL;
88 G_DEFINE_TYPE (EmpathyAccountManager, empathy_account_manager, G_TYPE_OBJECT);
91 emp_account_connection_cb (EmpathyAccount *account,
95 TpConnection *connection = empathy_account_get_connection (account);
97 DEBUG ("Signalling connection %p of account %s",
98 connection, empathy_account_get_unique_name (account));
100 if (connection != NULL)
101 g_signal_emit (manager, signals[NEW_CONNECTION], 0, connection);
105 emp_account_enabled_cb (EmpathyAccount *account,
109 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
111 if (empathy_account_is_enabled (account))
113 g_signal_emit (manager, signals[ACCOUNT_ENABLED], 0, account);
115 /* set the desired global presence on the account */
116 empathy_account_request_presence (account, priv->desired_presence,
117 priv->desired_status, priv->desired_status_message);
120 g_signal_emit (manager, signals[ACCOUNT_DISABLED], 0, account);
124 emp_account_status_changed_cb (EmpathyAccount *account,
125 TpConnectionStatus old,
126 TpConnectionStatus new,
127 TpConnectionStatusReason reason,
130 EmpathyAccountManager *manager = EMPATHY_ACCOUNT_MANAGER (user_data);
131 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
135 case TP_CONNECTION_STATUS_CONNECTING:
138 case TP_CONNECTION_STATUS_CONNECTED:
147 case TP_CONNECTION_STATUS_CONNECTING:
150 case TP_CONNECTION_STATUS_CONNECTED:
157 g_signal_emit (manager, signals[ACCOUNT_CONNECTION_CHANGED], 0,
158 account, reason, new, old);
162 emp_account_manager_update_global_presence (EmpathyAccountManager *manager)
164 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
165 TpConnectionPresenceType presence = TP_CONNECTION_PRESENCE_TYPE_OFFLINE;
166 EmpathyAccount *account = NULL;
170 g_hash_table_iter_init (&iter, priv->accounts);
171 while (g_hash_table_iter_next (&iter, NULL, &value))
173 EmpathyAccount *a = EMPATHY_ACCOUNT (value);
174 TpConnectionPresenceType p;
176 g_object_get (a, "presence", &p, NULL);
178 if (tp_connection_presence_type_cmp_availability (p, presence) > 0)
185 priv->global_account = account;
186 g_free (priv->global_status);
187 g_free (priv->global_status_message);
191 priv->global_status = NULL;
192 priv->global_status_message = NULL;
196 g_object_get (account,
197 "presence", &priv->global_presence,
198 "status", &priv->global_status,
199 "status-message", &priv->global_status_message,
204 emp_account_presence_changed_cb (EmpathyAccount *account,
205 TpConnectionPresenceType presence,
207 const gchar *status_message,
210 EmpathyAccountManager *manager = EMPATHY_ACCOUNT_MANAGER (user_data);
211 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
213 if (tp_connection_presence_type_cmp_availability (presence,
214 priv->global_presence) > 0)
216 priv->global_account = account;
218 priv->global_presence = presence;
220 g_free (priv->global_status);
221 priv->global_status = g_strdup (status);
223 g_free (priv->global_status_message);
224 priv->global_status_message = g_strdup (status_message);
228 else if (priv->global_account == account)
230 emp_account_manager_update_global_presence (manager);
236 g_signal_emit (manager, signals[GLOBAL_PRESENCE_CHANGED], 0,
237 priv->global_presence, priv->global_status, priv->global_status_message);
241 emp_account_removed_cb (EmpathyAccount *account, gpointer user_data)
243 EmpathyAccountManager *manager = EMPATHY_ACCOUNT_MANAGER (user_data);
244 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
246 g_object_ref (account);
247 g_hash_table_remove (priv->accounts,
248 empathy_account_get_unique_name (account));
250 g_signal_emit (manager, signals[ACCOUNT_DELETED], 0, account);
251 g_object_unref (account);
255 empathy_account_manager_check_ready (EmpathyAccountManager *manager)
257 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
264 g_hash_table_iter_init (&iter, priv->accounts);
265 while (g_hash_table_iter_next (&iter, NULL, &value))
267 EmpathyAccount *account = EMPATHY_ACCOUNT (value);
270 g_object_get (account, "ready", &ready, NULL);
277 g_object_notify (G_OBJECT (manager), "ready");
281 account_manager_account_ready_cb (GObject *obj,
285 EmpathyAccountManager *manager = EMPATHY_ACCOUNT_MANAGER (user_data);
286 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
287 EmpathyAccount *account = EMPATHY_ACCOUNT (obj);
288 GSimpleAsyncResult *result;
291 g_object_get (account, "ready", &ready, NULL);
296 /* see if there's any pending callbacks for this account */
297 result = g_hash_table_lookup (priv->create_results, account);
300 g_simple_async_result_set_op_res_gpointer (
301 G_SIMPLE_ASYNC_RESULT (result), account, NULL);
303 g_simple_async_result_complete (result);
305 g_hash_table_remove (priv->create_results, account);
306 g_object_unref (result);
309 g_signal_emit (manager, signals[ACCOUNT_CREATED], 0, account);
311 g_signal_connect (account, "notify::connection",
312 G_CALLBACK (emp_account_connection_cb), manager);
314 g_signal_connect (account, "notify::enabled",
315 G_CALLBACK (emp_account_enabled_cb), manager);
317 g_signal_connect (account, "status-changed",
318 G_CALLBACK (emp_account_status_changed_cb), manager);
320 g_signal_connect (account, "presence-changed",
321 G_CALLBACK (emp_account_presence_changed_cb), manager);
323 g_signal_connect (account, "removed",
324 G_CALLBACK (emp_account_removed_cb), manager);
326 empathy_account_manager_check_ready (manager);
329 static EmpathyAccount *
330 account_manager_add_account (EmpathyAccountManager *manager,
333 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
334 EmpathyAccount *account;
336 account = g_hash_table_lookup (priv->accounts, path);
340 account = empathy_account_new (priv->dbus, path);
341 g_hash_table_insert (priv->accounts, g_strdup (path), account);
343 g_signal_connect (account, "notify::ready",
344 G_CALLBACK (account_manager_account_ready_cb), manager);
350 account_manager_got_all_cb (TpProxy *proxy,
351 GHashTable *properties,
354 GObject *weak_object)
356 EmpathyAccountManager *manager = EMPATHY_ACCOUNT_MANAGER (weak_object);
362 DEBUG ("Failed to get account manager properties: %s", error->message);
366 accounts = tp_asv_get_boxed (properties, "ValidAccounts",
367 EMPATHY_ARRAY_TYPE_OBJECT);
369 for (i = 0; i < accounts->len; i++)
371 gchar *name = g_ptr_array_index (accounts, i);
373 account_manager_add_account (manager, name);
376 empathy_account_manager_check_ready (manager);
380 account_validity_changed_cb (TpAccountManager *proxy,
384 GObject *weak_object)
386 EmpathyAccountManager *manager = EMPATHY_ACCOUNT_MANAGER (weak_object);
391 account_manager_add_account (manager, path);
395 account_manager_name_owner_cb (TpDBusDaemon *proxy,
397 const gchar *new_owner,
400 EmpathyAccountManager *manager = EMPATHY_ACCOUNT_MANAGER (user_data);
401 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
403 tp_dbus_daemon_cancel_name_owner_watch (proxy, name,
404 account_manager_name_owner_cb, user_data);
406 priv->tp_manager = tp_account_manager_new (priv->dbus);
408 tp_cli_account_manager_connect_to_account_validity_changed (
410 account_validity_changed_cb,
416 tp_cli_dbus_properties_call_get_all (priv->tp_manager, -1,
417 TP_IFACE_ACCOUNT_MANAGER,
418 account_manager_got_all_cb,
425 empathy_account_manager_init (EmpathyAccountManager *manager)
427 EmpathyAccountManagerPriv *priv;
430 priv = G_TYPE_INSTANCE_GET_PRIVATE (manager,
431 EMPATHY_TYPE_ACCOUNT_MANAGER, EmpathyAccountManagerPriv);
433 manager->priv = priv;
434 priv->connected = priv->connecting = 0;
435 priv->global_presence = TP_CONNECTION_PRESENCE_TYPE_UNSET;
437 priv->accounts = g_hash_table_new_full (g_str_hash, g_str_equal,
438 g_free, (GDestroyNotify) g_object_unref);
440 priv->create_results = g_hash_table_new (g_direct_hash, g_direct_equal);
442 priv->dbus = tp_dbus_daemon_dup (NULL);
444 tp_dbus_daemon_watch_name_owner (priv->dbus,
445 TP_ACCOUNT_MANAGER_BUS_NAME,
446 account_manager_name_owner_cb,
450 /* trigger MC5 starting */
451 mc5_proxy = g_object_new (TP_TYPE_PROXY,
452 "dbus-daemon", priv->dbus,
453 "dbus-connection", tp_proxy_get_dbus_connection (TP_PROXY (priv->dbus)),
454 "bus-name", MC5_BUS_NAME,
458 tp_cli_dbus_peer_call_ping (mc5_proxy, -1, NULL, NULL, NULL, NULL);
460 g_object_unref (mc5_proxy);
464 do_finalize (GObject *obj)
466 EmpathyAccountManager *manager = EMPATHY_ACCOUNT_MANAGER (obj);
467 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
469 g_hash_table_destroy (priv->create_results);
470 g_hash_table_destroy (priv->accounts);
472 g_free (priv->global_status);
473 g_free (priv->global_status_message);
475 g_free (priv->desired_status);
476 g_free (priv->desired_status_message);
478 G_OBJECT_CLASS (empathy_account_manager_parent_class)->finalize (obj);
482 do_dispose (GObject *obj)
484 EmpathyAccountManager *manager = EMPATHY_ACCOUNT_MANAGER (obj);
485 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
487 if (priv->dispose_run)
490 priv->dispose_run = TRUE;
492 if (priv->create_results != NULL &&
493 g_hash_table_size (priv->create_results) > 0)
495 /* the manager is being destroyed while there are account creation
496 * processes pending; this should not happen, but emit the callbacks
497 * with an error anyway.
500 GSimpleAsyncResult *result;
502 g_hash_table_iter_init (&iter, priv->create_results);
503 while (g_hash_table_iter_next (&iter, NULL, (gpointer *) &result))
505 g_simple_async_result_set_error (result, G_IO_ERROR,
506 G_IO_ERROR_CANCELLED, "The account manager was disposed while "
507 "creating the account");
508 g_simple_async_result_complete (result);
509 g_object_unref (result);
513 tp_dbus_daemon_cancel_name_owner_watch (priv->dbus,
514 TP_ACCOUNT_MANAGER_BUS_NAME, account_manager_name_owner_cb, manager);
516 if (priv->dbus != NULL)
518 g_object_unref (priv->dbus);
522 G_OBJECT_CLASS (empathy_account_manager_parent_class)->dispose (obj);
526 do_constructor (GType type,
527 guint n_construct_params,
528 GObjectConstructParam *construct_params)
532 if (!manager_singleton)
534 retval = G_OBJECT_CLASS (empathy_account_manager_parent_class)->constructor (type,
537 manager_singleton = EMPATHY_ACCOUNT_MANAGER (retval);
538 g_object_add_weak_pointer (retval, (gpointer) &manager_singleton);
542 retval = g_object_ref (manager_singleton);
549 do_get_property (GObject *object,
554 EmpathyAccountManager *manager = EMPATHY_ACCOUNT_MANAGER (object);
555 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
560 g_value_set_boolean (value, priv->ready);
563 G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
569 empathy_account_manager_class_init (EmpathyAccountManagerClass *klass)
571 GObjectClass *oclass = G_OBJECT_CLASS (klass);
573 oclass->finalize = do_finalize;
574 oclass->dispose = do_dispose;
575 oclass->constructor = do_constructor;
576 oclass->get_property = do_get_property;
578 g_object_class_install_property (oclass, PROP_READY,
579 g_param_spec_boolean ("ready",
581 "Whether the initial state dump from the account manager is finished",
583 G_PARAM_STATIC_STRINGS | G_PARAM_READABLE));
585 signals[ACCOUNT_CREATED] =
586 g_signal_new ("account-created",
587 G_TYPE_FROM_CLASS (klass),
591 g_cclosure_marshal_VOID__OBJECT,
593 1, EMPATHY_TYPE_ACCOUNT);
595 signals[ACCOUNT_DELETED] =
596 g_signal_new ("account-deleted",
597 G_TYPE_FROM_CLASS (klass),
601 g_cclosure_marshal_VOID__OBJECT,
603 1, EMPATHY_TYPE_ACCOUNT);
605 signals[ACCOUNT_ENABLED] =
606 g_signal_new ("account-enabled",
607 G_TYPE_FROM_CLASS (klass),
611 g_cclosure_marshal_VOID__OBJECT,
613 1, EMPATHY_TYPE_ACCOUNT);
615 signals[ACCOUNT_DISABLED] =
616 g_signal_new ("account-disabled",
617 G_TYPE_FROM_CLASS (klass),
621 g_cclosure_marshal_VOID__OBJECT,
623 1, EMPATHY_TYPE_ACCOUNT);
625 signals[ACCOUNT_CHANGED] =
626 g_signal_new ("account-changed",
627 G_TYPE_FROM_CLASS (klass),
631 g_cclosure_marshal_VOID__OBJECT,
633 1, EMPATHY_TYPE_ACCOUNT);
635 signals[ACCOUNT_CONNECTION_CHANGED] =
636 g_signal_new ("account-connection-changed",
637 G_TYPE_FROM_CLASS (klass),
641 _empathy_marshal_VOID__OBJECT_INT_UINT_UINT,
643 4, EMPATHY_TYPE_ACCOUNT,
644 G_TYPE_INT, /* reason */
645 G_TYPE_UINT, /* actual connection */
646 G_TYPE_UINT); /* previous connection */
648 signals[GLOBAL_PRESENCE_CHANGED] =
649 g_signal_new ("global-presence-changed",
650 G_TYPE_FROM_CLASS (klass),
654 _empathy_marshal_VOID__UINT_STRING_STRING,
656 3, G_TYPE_UINT, /* Presence type */
657 G_TYPE_STRING, /* status */
658 G_TYPE_STRING); /* stauts message*/
660 signals[NEW_CONNECTION] =
661 g_signal_new ("new-connection",
662 G_TYPE_FROM_CLASS (klass),
666 g_cclosure_marshal_VOID__OBJECT,
668 1, TP_TYPE_CONNECTION);
670 g_type_class_add_private (oclass, sizeof (EmpathyAccountManagerPriv));
675 EmpathyAccountManager *
676 empathy_account_manager_dup_singleton (void)
678 return g_object_new (EMPATHY_TYPE_ACCOUNT_MANAGER, NULL);
682 empathy_account_manager_is_ready (EmpathyAccountManager *manager)
684 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
690 empathy_account_manager_get_connected_accounts (EmpathyAccountManager *manager)
692 EmpathyAccountManagerPriv *priv;
694 g_return_val_if_fail (EMPATHY_IS_ACCOUNT_MANAGER (manager), 0);
696 priv = GET_PRIV (manager);
698 return priv->connected;
702 empathy_account_manager_get_connecting_accounts (EmpathyAccountManager *manager)
704 EmpathyAccountManagerPriv *priv;
706 g_return_val_if_fail (EMPATHY_IS_ACCOUNT_MANAGER (manager), 0);
708 priv = GET_PRIV (manager);
710 return priv->connecting;
714 * empathy_account_manager_get_count:
715 * @manager: a #EmpathyAccountManager
717 * Get the number of accounts.
719 * Returns: the number of accounts.
722 empathy_account_manager_get_count (EmpathyAccountManager *manager)
724 EmpathyAccountManagerPriv *priv;
726 g_return_val_if_fail (EMPATHY_IS_ACCOUNT_MANAGER (manager), 0);
728 priv = GET_PRIV (manager);
730 return g_hash_table_size (priv->accounts);
734 empathy_account_manager_get_account (EmpathyAccountManager *manager,
735 TpConnection *connection)
737 EmpathyAccountManagerPriv *priv;
741 g_return_val_if_fail (EMPATHY_IS_ACCOUNT_MANAGER (manager), 0);
743 priv = GET_PRIV (manager);
745 g_hash_table_iter_init (&iter, priv->accounts);
746 while (g_hash_table_iter_next (&iter, NULL, &value))
748 EmpathyAccount *account = EMPATHY_ACCOUNT (value);
750 if (connection == empathy_account_get_connection (account))
758 empathy_account_manager_lookup (EmpathyAccountManager *manager,
759 const gchar *unique_name)
761 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
762 EmpathyAccount *account;
764 account = g_hash_table_lookup (priv->accounts, unique_name);
767 g_object_ref (account);
773 empathy_account_manager_dup_accounts (EmpathyAccountManager *manager)
775 EmpathyAccountManagerPriv *priv;
778 g_return_val_if_fail (EMPATHY_IS_ACCOUNT_MANAGER (manager), NULL);
780 priv = GET_PRIV (manager);
782 ret = g_hash_table_get_values (priv->accounts);
783 g_list_foreach (ret, (GFunc) g_object_ref, NULL);
789 * empathy_account_manager_dup_connections:
790 * @manager: a #EmpathyAccountManager
792 * Get a #GList of all ready #TpConnection. The list must be freed with
793 * g_list_free, and its elements must be unreffed.
795 * Returns: the list of connections
798 empathy_account_manager_dup_connections (EmpathyAccountManager *manager)
800 EmpathyAccountManagerPriv *priv;
805 g_return_val_if_fail (EMPATHY_IS_ACCOUNT_MANAGER (manager), NULL);
807 priv = GET_PRIV (manager);
809 g_hash_table_iter_init (&iter, priv->accounts);
810 while (g_hash_table_iter_next (&iter, NULL, &value))
812 EmpathyAccount *account = EMPATHY_ACCOUNT (value);
813 TpConnection *connection;
815 connection = empathy_account_get_connection (account);
816 if (connection != NULL)
817 ret = g_list_prepend (ret, g_object_ref (connection));
824 empathy_account_manager_remove (EmpathyAccountManager *manager,
825 EmpathyAccount *account)
832 empathy_account_manager_request_global_presence (
833 EmpathyAccountManager *manager,
834 TpConnectionPresenceType type,
836 const gchar *message)
838 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
842 g_hash_table_iter_init (&iter, priv->accounts);
843 while (g_hash_table_iter_next (&iter, NULL, &value))
845 EmpathyAccount *account = EMPATHY_ACCOUNT (value);
848 g_object_get (account, "ready", &ready, NULL);
851 empathy_account_request_presence (account, type, status, message);
854 /* save the requested global presence, to use it in case we create
857 priv->desired_presence = type;
859 if (tp_strdiff (priv->desired_status, status))
861 g_free (priv->desired_status);
862 priv->desired_status = g_strdup (status);
865 if (tp_strdiff (priv->desired_status_message, message))
867 g_free (priv->desired_status_message);
868 priv->desired_status_message = g_strdup (message);
872 TpConnectionPresenceType
873 empathy_account_manager_get_global_presence (
874 EmpathyAccountManager *manager,
878 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
881 *status = g_strdup (priv->global_status);
883 *message = g_strdup (priv->global_status_message);
885 return priv->global_presence;
889 empathy_account_manager_created_cb (TpAccountManager *proxy,
890 const gchar *account_path,
893 GObject *weak_object)
895 EmpathyAccountManager *manager = EMPATHY_ACCOUNT_MANAGER (weak_object);
896 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
897 GSimpleAsyncResult *my_res = user_data;
898 EmpathyAccount *account;
902 g_simple_async_result_set_from_error (my_res,
904 g_simple_async_result_complete (my_res);
905 g_object_unref (my_res);
910 account = account_manager_add_account (manager, account_path);
912 g_hash_table_insert (priv->create_results, account, my_res);
916 empathy_account_manager_create_account_async (EmpathyAccountManager *manager,
917 const gchar *connection_manager,
918 const gchar *protocol, const gchar *display_name,
919 GHashTable *parameters, GHashTable *properties,
920 GAsyncReadyCallback callback, gpointer user_data)
922 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
923 GSimpleAsyncResult *res;
925 res = g_simple_async_result_new
926 (G_OBJECT (manager), callback, user_data,
927 empathy_account_manager_create_account_finish);
929 tp_cli_account_manager_call_create_account (priv->tp_manager,
936 empathy_account_manager_created_cb,
943 empathy_account_manager_create_account_finish (
944 EmpathyAccountManager *manager, GAsyncResult *result, GError **error)
946 EmpathyAccount *retval;
948 if (g_simple_async_result_propagate_error (G_SIMPLE_ASYNC_RESULT (result),
952 g_return_val_if_fail (g_simple_async_result_is_valid (result,
953 G_OBJECT (manager), empathy_account_manager_create_account_finish), NULL);
955 retval = EMPATHY_ACCOUNT (g_simple_async_result_get_op_res_gpointer (
956 G_SIMPLE_ASYNC_RESULT (result)));