remove old blocking API

[empathy.git] / libempathy / empathy-contact-manager.c

diff --git a/libempathy/empathy-contact-manager.c b/libempathy/empathy-contact-manager.c
index 302fad3c53f269ded86efbd39a3a25befebc2ca0..88012bf35f0abcd49ccf4cdfd9d29eb2a35e2fe1 100644 (file)
--- a/libempathy/empathy-contact-manager.c
+++ b/libempathy/empathy-contact-manager.c
@@ -23,11 +23,12 @@
 
 #include <string.h>
 
+#include <telepathy-glib/account-manager.h>
 #include <telepathy-glib/enums.h>
+#include <telepathy-glib/proxy-subclass.h>
+#include <telepathy-glib/util.h>
 
 #include "empathy-contact-manager.h"
-#include "empathy-account-manager.h"
-#include "empathy-contact-monitor.h"
 #include "empathy-contact-list.h"
 #include "empathy-utils.h"
 
@@ -36,9 +37,10 @@
 
 #define GET_PRIV(obj) EMPATHY_GET_PRIV (obj, EmpathyContactManager)
 typedef struct {
+       /* Owned (TpConnection *) => Owned (TpContactList *)
+          The contact list associated with each connected connection */
        GHashTable     *lists;
-       EmpathyAccountManager *account_manager;
-       EmpathyContactMonitor *contact_monitor;
+       TpAccountManager *account_manager;
 } EmpathyContactManagerPriv;
 
 static void contact_manager_iface_init         (EmpathyContactListIface    *iface);
@@ -132,14 +134,25 @@ contact_manager_disconnect_foreach (gpointer key,
 }
 
 static void
-contact_manager_new_connection_cb (EmpathyAccountManager *account_manager,
-                                  TpConnection *connection,
+contact_manager_status_changed_cb (TpAccount *account,
+                                  guint old_status,
+                                  guint new_status,
+                                  guint reason,
+                                  gchar *dbus_error_name,
+                                  GHashTable *details,
                                   EmpathyContactManager *self)
 {
        EmpathyContactManagerPriv *priv = GET_PRIV (self);
        EmpathyTpContactList      *list;
+       TpConnection              *connection;
 
-       if (g_hash_table_lookup (priv->lists, connection)) {
+       if (new_status == TP_CONNECTION_STATUS_DISCONNECTED)
+               /* No point to start tracking a connection which is about to die */
+               return;
+
+       connection = tp_account_get_connection (account);
+
+       if (connection == NULL || g_hash_table_lookup (priv->lists, connection)) {
                return;
        }
 
@@ -164,6 +177,19 @@ contact_manager_new_connection_cb (EmpathyAccountManager *account_manager,
                          self);
 }
 
+static void
+contact_manager_validity_changed_cb (TpAccountManager *account_manager,
+                                    TpAccount *account,
+                                    gboolean valid,
+                                    EmpathyContactManager *manager)
+{
+       if (valid) {
+               tp_g_signal_connect_object (account, "status-changed",
+                           G_CALLBACK (contact_manager_status_changed_cb),
+                           manager, 0);
+       }
+}
+
 static void
 contact_manager_finalize (GObject *object)
 {
@@ -174,14 +200,7 @@ contact_manager_finalize (GObject *object)
                              object);
        g_hash_table_destroy (priv->lists);
 
-       g_signal_handlers_disconnect_by_func (priv->account_manager,
-                                             contact_manager_new_connection_cb,
-                                             object);
        g_object_unref (priv->account_manager);
-
-       if (priv->contact_monitor) {
-               g_object_unref (priv->contact_monitor);
-       }
 }
 
 static GObject *
@@ -232,10 +251,47 @@ empathy_contact_manager_class_init (EmpathyContactManagerClass *klass)
        g_type_class_add_private (object_class, sizeof (EmpathyContactManagerPriv));
 }
 
+static void
+account_manager_prepared_cb (GObject *source_object,
+                            GAsyncResult *result,
+                            gpointer user_data)
+{
+       GList *accounts, *l;
+       EmpathyContactManager *manager = user_data;
+       TpAccountManager *account_manager = TP_ACCOUNT_MANAGER (source_object);
+       GError *error = NULL;
+
+       if (!tp_proxy_prepare_finish (account_manager, result, &error)) {
+               DEBUG ("Failed to prepare account manager: %s", error->message);
+               g_error_free (error);
+               return;
+       }
+
+       accounts = tp_account_manager_get_valid_accounts (account_manager);
+
+       for (l = accounts; l != NULL; l = l->next) {
+               TpAccount *account = l->data;
+               TpConnection *conn = tp_account_get_connection (account);
+
+               if (conn != NULL) {
+                       contact_manager_status_changed_cb (account, 0, 0, 0,
+                                                          NULL, NULL, manager);
+               }
+
+               tp_g_signal_connect_object (account, "status-changed",
+                   G_CALLBACK (contact_manager_status_changed_cb),
+                   manager, 0);
+       }
+       g_list_free (accounts);
+
+       tp_g_signal_connect_object (account_manager, "account-validity-changed",
+                            G_CALLBACK (contact_manager_validity_changed_cb),
+                            manager, 0);
+}
+
 static void
 empathy_contact_manager_init (EmpathyContactManager *manager)
 {
-       GList *connections, *l;
        EmpathyContactManagerPriv *priv = G_TYPE_INSTANCE_GET_PRIVATE (manager,
                EMPATHY_TYPE_CONTACT_MANAGER, EmpathyContactManagerPriv);
 
@@ -244,21 +300,11 @@ empathy_contact_manager_init (EmpathyContactManager *manager)
                                             empathy_proxy_equal,
                                             (GDestroyNotify) g_object_unref,
                                             (GDestroyNotify) g_object_unref);
-       priv->account_manager = empathy_account_manager_dup_singleton ();
-       priv->contact_monitor = NULL;
-
-       g_signal_connect (priv->account_manager, "new-connection",
-                         G_CALLBACK (contact_manager_new_connection_cb),
-                         manager);
-
-       /* Get ContactList for existing connections */
-       connections = empathy_account_manager_dup_connections (priv->account_manager);
-       for (l = connections; l; l = l->next) {
-               contact_manager_new_connection_cb (priv->account_manager,
-                                                  l->data, manager);
-               g_object_unref (l->data);
-       }
-       g_list_free (connections);
+
+       priv->account_manager = tp_account_manager_dup ();
+
+       tp_proxy_prepare_async (priv->account_manager, NULL,
+           account_manager_prepared_cb, manager);
 }
 
 EmpathyContactManager *
@@ -343,18 +389,6 @@ contact_manager_get_members (EmpathyContactList *manager)
        return contacts;
 }
 
-static EmpathyContactMonitor *
-contact_manager_get_monitor (EmpathyContactList *manager)
-{
-       EmpathyContactManagerPriv *priv = GET_PRIV (manager);
-
-       if (priv->contact_monitor == NULL) {
-               priv->contact_monitor = empathy_contact_monitor_new_for_iface (manager);
-       }
-
-       return priv->contact_monitor;
-}
-
 static void
 contact_manager_get_pendings_foreach (TpConnection          *connection,
                                      EmpathyTpContactList  *list,
@@ -534,7 +568,6 @@ contact_manager_iface_init (EmpathyContactListIface *iface)
        iface->add               = contact_manager_add;
        iface->remove            = contact_manager_remove;
        iface->get_members       = contact_manager_get_members;
-       iface->get_monitor       = contact_manager_get_monitor;
        iface->get_pendings      = contact_manager_get_pendings;
        iface->get_all_groups    = contact_manager_get_all_groups;
        iface->get_groups        = contact_manager_get_groups;