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/interfaces.h>
30 #include "empathy-account-manager.h"
31 #include "empathy-marshal.h"
32 #include "empathy-utils.h"
34 #define DEBUG_FLAG EMPATHY_DEBUG_ACCOUNT
35 #include <libempathy/empathy-debug.h>
37 #define GET_PRIV(obj) EMPATHY_GET_PRIV (obj, EmpathyAccountManager)
39 #define MC5_BUS_NAME "org.freedesktop.Telepathy.MissionControl5"
42 /* (owned) unique name -> (reffed) EmpathyAccount */
48 TpProxySignalConnection *proxy_signal;
49 TpAccountManager *tp_manager;
53 EmpathyAccount *global_account;
55 TpConnectionPresenceType global_presence;
57 gchar *global_status_message;
58 } EmpathyAccountManagerPriv;
66 ACCOUNT_CONNECTION_CHANGED,
67 GLOBAL_PRESENCE_CHANGED,
76 static guint signals[LAST_SIGNAL];
77 static EmpathyAccountManager *manager_singleton = NULL;
79 G_DEFINE_TYPE (EmpathyAccountManager, empathy_account_manager, G_TYPE_OBJECT);
82 emp_account_connection_cb (EmpathyAccount *account,
86 TpConnection *connection = empathy_account_get_connection (account);
88 DEBUG ("Signalling connection %p of account %s",
89 connection, empathy_account_get_unique_name (account));
91 if (connection != NULL)
92 g_signal_emit (manager, signals[NEW_CONNECTION], 0, connection);
96 emp_account_enabled_cb (EmpathyAccount *account,
100 if (empathy_account_is_enabled (account))
101 g_signal_emit (manager, signals[ACCOUNT_ENABLED], 0, account);
103 g_signal_emit (manager, signals[ACCOUNT_DISABLED], 0, account);
107 emp_account_status_changed_cb (EmpathyAccount *account,
108 TpConnectionStatus old,
109 TpConnectionStatus new,
110 TpConnectionStatusReason reason,
113 EmpathyAccountManager *manager = EMPATHY_ACCOUNT_MANAGER (user_data);
114 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
118 case TP_CONNECTION_STATUS_CONNECTING:
121 case TP_CONNECTION_STATUS_CONNECTED:
130 case TP_CONNECTION_STATUS_CONNECTING:
133 case TP_CONNECTION_STATUS_CONNECTED:
140 g_signal_emit (manager, signals[ACCOUNT_CONNECTION_CHANGED], 0,
141 account, reason, new, old);
145 emp_account_manager_update_global_presence (EmpathyAccountManager *manager)
147 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
148 TpConnectionPresenceType presence = TP_CONNECTION_PRESENCE_TYPE_UNSET;
149 EmpathyAccount *account = NULL;
153 g_hash_table_iter_init (&iter, priv->accounts);
154 while (g_hash_table_iter_next (&iter, NULL, &value))
156 EmpathyAccount *a = EMPATHY_ACCOUNT (value);
157 TpConnectionPresenceType p;
159 g_object_get (a, "presence", &p, NULL);
161 if (tp_connection_presence_type_cmp_availability (p, presence) > 0)
168 priv->global_account = account;
169 g_free (priv->global_status);
170 g_free (priv->global_status_message);
174 priv->global_status = NULL;
175 priv->global_status_message = NULL;
179 g_object_get (account,
180 "presence", &priv->global_presence,
181 "status", &priv->global_status,
182 "status-message", &priv->global_status_message,
187 emp_account_presence_changed_cb (EmpathyAccount *account,
188 TpConnectionPresenceType presence,
190 const gchar *status_message,
193 EmpathyAccountManager *manager = EMPATHY_ACCOUNT_MANAGER (user_data);
194 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
196 if (tp_connection_presence_type_cmp_availability (presence,
197 priv->global_presence) > 0)
199 priv->global_account = account;
201 priv->global_presence = presence;
203 g_free (priv->global_status);
204 priv->global_status = g_strdup (status);
206 g_free (priv->global_status_message);
207 priv->global_status_message = g_strdup (status_message);
211 else if (priv->global_account == account)
213 emp_account_manager_update_global_presence (manager);
219 g_signal_emit (manager, signals[GLOBAL_PRESENCE_CHANGED], 0,
220 priv->global_presence, priv->global_status, priv->global_status_message);
224 empathy_account_manager_check_ready (EmpathyAccountManager *manager)
226 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
233 g_hash_table_iter_init (&iter, priv->accounts);
234 while (g_hash_table_iter_next (&iter, NULL, &value))
236 EmpathyAccount *account = EMPATHY_ACCOUNT (value);
239 g_object_get (account, "ready", &ready, NULL);
246 g_object_notify (G_OBJECT (manager), "ready");
250 emp_account_ready_cb (GObject *obj, GParamSpec *spec, gpointer user_data)
252 EmpathyAccountManager *manager = EMPATHY_ACCOUNT_MANAGER (user_data);
253 EmpathyAccount *account = EMPATHY_ACCOUNT (obj);
256 g_object_get (account, "ready", &ready, NULL);
261 g_signal_emit (manager, signals[ACCOUNT_CREATED], 0, account);
263 g_signal_connect (account, "notify::connection",
264 G_CALLBACK (emp_account_connection_cb), manager);
266 g_signal_connect (account, "notify::enabled",
267 G_CALLBACK (emp_account_enabled_cb), manager);
269 g_signal_connect (account, "status-changed",
270 G_CALLBACK (emp_account_status_changed_cb), manager);
272 g_signal_connect (account, "presence-changed",
273 G_CALLBACK (emp_account_presence_changed_cb), manager);
275 empathy_account_manager_check_ready (manager);
279 account_manager_got_all_cb (TpProxy *proxy,
280 GHashTable *properties,
283 GObject *weak_object)
285 EmpathyAccountManager *manager = EMPATHY_ACCOUNT_MANAGER (weak_object);
286 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
292 DEBUG ("Failed to get account manager properties: %s", error->message);
296 accounts = tp_asv_get_boxed (properties, "ValidAccounts",
297 EMPATHY_ARRAY_TYPE_OBJECT);
299 for (i = 0; i < accounts->len; i++)
301 EmpathyAccount *account;
302 gchar *name = g_ptr_array_index (accounts, i);
304 account = empathy_account_new (priv->dbus, name);
305 g_hash_table_insert (priv->accounts, g_strdup (name), account);
307 g_signal_connect (account, "notify::ready",
308 G_CALLBACK (emp_account_ready_cb), manager);
311 empathy_account_manager_check_ready (manager);
315 account_manager_name_owner_changed_cb (TpDBusDaemon *proxy,
320 GObject *weak_object)
322 EmpathyAccountManager *manager = EMPATHY_ACCOUNT_MANAGER (weak_object);
323 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
325 tp_proxy_signal_connection_disconnect (priv->proxy_signal);
326 priv->proxy_signal = NULL;
328 priv->tp_manager = tp_account_manager_new (priv->dbus);
329 tp_cli_dbus_properties_call_get_all (priv->tp_manager, -1,
330 TP_IFACE_ACCOUNT_MANAGER,
331 account_manager_got_all_cb,
338 empathy_account_manager_init (EmpathyAccountManager *manager)
340 EmpathyAccountManagerPriv *priv;
343 priv = G_TYPE_INSTANCE_GET_PRIVATE (manager,
344 EMPATHY_TYPE_ACCOUNT_MANAGER, EmpathyAccountManagerPriv);
346 manager->priv = priv;
347 priv->connected = priv->connecting = 0;
348 priv->global_presence = TP_CONNECTION_PRESENCE_TYPE_UNSET;
350 priv->accounts = g_hash_table_new_full (g_str_hash, g_str_equal,
351 g_free, (GDestroyNotify) g_object_unref);
353 priv->dbus = tp_dbus_daemon_dup (NULL);
355 priv->proxy_signal = tp_cli_dbus_daemon_connect_to_name_owner_changed (
357 account_manager_name_owner_changed_cb,
358 TP_ACCOUNT_MANAGER_BUS_NAME,
363 /* trigger MC5 starting */
364 mc5_proxy = g_object_new (TP_TYPE_PROXY,
365 "dbus-daemon", priv->dbus,
366 "dbus-connection", tp_proxy_get_dbus_connection (TP_PROXY (priv->dbus)),
367 "bus-name", MC5_BUS_NAME,
371 tp_cli_dbus_peer_call_ping (mc5_proxy, -1, NULL, NULL, NULL, NULL);
373 g_object_unref (mc5_proxy);
377 do_finalize (GObject *obj)
379 EmpathyAccountManager *manager = EMPATHY_ACCOUNT_MANAGER (obj);
380 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
382 g_hash_table_destroy (priv->accounts);
384 G_OBJECT_CLASS (empathy_account_manager_parent_class)->finalize (obj);
388 do_dispose (GObject *obj)
390 EmpathyAccountManager *manager = EMPATHY_ACCOUNT_MANAGER (obj);
391 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
393 if (priv->dispose_run)
396 priv->dispose_run = TRUE;
398 if (priv->dbus == NULL)
399 g_object_unref (priv->dbus);
402 G_OBJECT_CLASS (empathy_account_manager_parent_class)->dispose (obj);
406 do_constructor (GType type,
407 guint n_construct_params,
408 GObjectConstructParam *construct_params)
412 if (!manager_singleton)
414 retval = G_OBJECT_CLASS (empathy_account_manager_parent_class)->constructor (type,
417 manager_singleton = EMPATHY_ACCOUNT_MANAGER (retval);
418 g_object_add_weak_pointer (retval, (gpointer) &manager_singleton);
422 retval = g_object_ref (manager_singleton);
429 do_get_property (GObject *object,
434 EmpathyAccountManager *manager = EMPATHY_ACCOUNT_MANAGER (object);
435 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
440 g_value_set_boolean (value, priv->ready);
443 G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
449 empathy_account_manager_class_init (EmpathyAccountManagerClass *klass)
451 GObjectClass *oclass = G_OBJECT_CLASS (klass);
453 oclass->finalize = do_finalize;
454 oclass->dispose = do_dispose;
455 oclass->constructor = do_constructor;
456 oclass->get_property = do_get_property;
458 g_object_class_install_property (oclass, PROP_READY,
459 g_param_spec_boolean ("ready",
461 "Whether the initial state dump from the account manager is finished",
463 G_PARAM_STATIC_STRINGS | G_PARAM_READABLE));
465 signals[ACCOUNT_CREATED] =
466 g_signal_new ("account-created",
467 G_TYPE_FROM_CLASS (klass),
471 g_cclosure_marshal_VOID__OBJECT,
473 1, EMPATHY_TYPE_ACCOUNT);
475 signals[ACCOUNT_DELETED] =
476 g_signal_new ("account-deleted",
477 G_TYPE_FROM_CLASS (klass),
481 g_cclosure_marshal_VOID__OBJECT,
483 1, EMPATHY_TYPE_ACCOUNT);
485 signals[ACCOUNT_ENABLED] =
486 g_signal_new ("account-enabled",
487 G_TYPE_FROM_CLASS (klass),
491 g_cclosure_marshal_VOID__OBJECT,
493 1, EMPATHY_TYPE_ACCOUNT);
495 signals[ACCOUNT_DISABLED] =
496 g_signal_new ("account-disabled",
497 G_TYPE_FROM_CLASS (klass),
501 g_cclosure_marshal_VOID__OBJECT,
503 1, EMPATHY_TYPE_ACCOUNT);
505 signals[ACCOUNT_CHANGED] =
506 g_signal_new ("account-changed",
507 G_TYPE_FROM_CLASS (klass),
511 g_cclosure_marshal_VOID__OBJECT,
513 1, EMPATHY_TYPE_ACCOUNT);
515 signals[ACCOUNT_CONNECTION_CHANGED] =
516 g_signal_new ("account-connection-changed",
517 G_TYPE_FROM_CLASS (klass),
521 _empathy_marshal_VOID__OBJECT_INT_UINT_UINT,
523 4, EMPATHY_TYPE_ACCOUNT,
524 G_TYPE_INT, /* reason */
525 G_TYPE_UINT, /* actual connection */
526 G_TYPE_UINT); /* previous connection */
528 signals[GLOBAL_PRESENCE_CHANGED] =
529 g_signal_new ("global-presence-changed",
530 G_TYPE_FROM_CLASS (klass),
534 _empathy_marshal_VOID__UINT_STRING_STRING,
536 3, G_TYPE_UINT, /* Presence type */
537 G_TYPE_STRING, /* status */
538 G_TYPE_STRING); /* stauts message*/
540 signals[NEW_CONNECTION] =
541 g_signal_new ("new-connection",
542 G_TYPE_FROM_CLASS (klass),
546 g_cclosure_marshal_VOID__OBJECT,
548 1, TP_TYPE_CONNECTION);
550 g_type_class_add_private (oclass, sizeof (EmpathyAccountManagerPriv));
555 EmpathyAccountManager *
556 empathy_account_manager_dup_singleton (void)
558 return g_object_new (EMPATHY_TYPE_ACCOUNT_MANAGER, NULL);
562 empathy_account_manager_create (EmpathyAccountManager *manager,
563 const gchar *connection_manager,
564 const gchar *protocol,
565 const gchar *display_name)
573 empathy_account_manager_is_ready (EmpathyAccountManager *manager)
575 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
581 empathy_account_manager_get_connected_accounts (EmpathyAccountManager *manager)
583 EmpathyAccountManagerPriv *priv;
585 g_return_val_if_fail (EMPATHY_IS_ACCOUNT_MANAGER (manager), 0);
587 priv = GET_PRIV (manager);
589 return priv->connected;
593 empathy_account_manager_get_connecting_accounts (EmpathyAccountManager *manager)
595 EmpathyAccountManagerPriv *priv;
597 g_return_val_if_fail (EMPATHY_IS_ACCOUNT_MANAGER (manager), 0);
599 priv = GET_PRIV (manager);
601 return priv->connecting;
605 * empathy_account_manager_get_count:
606 * @manager: a #EmpathyAccountManager
608 * Get the number of accounts.
610 * Returns: the number of accounts.
613 empathy_account_manager_get_count (EmpathyAccountManager *manager)
615 EmpathyAccountManagerPriv *priv;
617 g_return_val_if_fail (EMPATHY_IS_ACCOUNT_MANAGER (manager), 0);
619 priv = GET_PRIV (manager);
621 return g_hash_table_size (priv->accounts);
625 empathy_account_manager_get_account (EmpathyAccountManager *manager,
626 TpConnection *connection)
628 EmpathyAccountManagerPriv *priv;
632 g_return_val_if_fail (EMPATHY_IS_ACCOUNT_MANAGER (manager), 0);
634 priv = GET_PRIV (manager);
636 g_hash_table_iter_init (&iter, priv->accounts);
637 while (g_hash_table_iter_next (&iter, NULL, &value))
639 EmpathyAccount *account = EMPATHY_ACCOUNT (value);
641 if (connection == empathy_account_get_connection (account))
649 empathy_account_manager_lookup (EmpathyAccountManager *manager,
650 const gchar *unique_name)
652 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
653 EmpathyAccount *account;
655 account = g_hash_table_lookup (priv->accounts, unique_name);
658 g_object_ref (account);
664 empathy_account_manager_dup_accounts (EmpathyAccountManager *manager)
666 EmpathyAccountManagerPriv *priv;
669 g_return_val_if_fail (EMPATHY_IS_ACCOUNT_MANAGER (manager), NULL);
671 priv = GET_PRIV (manager);
673 ret = g_hash_table_get_values (priv->accounts);
674 g_list_foreach (ret, (GFunc) g_object_ref, NULL);
680 * empathy_account_manager_dup_connections:
681 * @manager: a #EmpathyAccountManager
683 * Get a #GList of all ready #TpConnection. The list must be freed with
684 * g_list_free, and its elements must be unreffed.
686 * Returns: the list of connections
689 empathy_account_manager_dup_connections (EmpathyAccountManager *manager)
691 EmpathyAccountManagerPriv *priv;
696 g_return_val_if_fail (EMPATHY_IS_ACCOUNT_MANAGER (manager), NULL);
698 priv = GET_PRIV (manager);
700 g_hash_table_iter_init (&iter, priv->accounts);
701 while (g_hash_table_iter_next (&iter, NULL, &value))
703 EmpathyAccount *account = EMPATHY_ACCOUNT (value);
704 TpConnection *connection;
706 connection = empathy_account_get_connection (account);
707 if (connection != NULL)
708 ret = g_list_prepend (ret, g_object_ref (connection));
715 empathy_account_manager_remove (EmpathyAccountManager *manager,
716 EmpathyAccount *account)
723 empathy_account_manager_request_global_presence (
724 EmpathyAccountManager *manager,
725 TpConnectionPresenceType type,
727 const gchar *message)
729 /* FIXME should remember requested presence and set it on new accounts
731 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
735 g_hash_table_iter_init (&iter, priv->accounts);
736 while (g_hash_table_iter_next (&iter, NULL, &value))
738 EmpathyAccount *account = EMPATHY_ACCOUNT (value);
741 g_object_get (account, "ready", &ready, NULL);
744 empathy_account_request_presence (account, type, status, message);
748 TpConnectionPresenceType
749 empathy_account_manager_get_global_presence (
750 EmpathyAccountManager *manager,
754 EmpathyAccountManagerPriv *priv = GET_PRIV (manager);
757 *status = g_strdup (priv->global_status);
759 *message = g_strdup (priv->global_status_message);
761 return priv->global_presence;