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 3dc21c3321e1aa39d2e42bc67a0de7bc8d1bcc4c..88012bf35f0abcd49ccf4cdfd9d29eb2a35e2fe1 100644 (file)
--- a/libempathy/empathy-contact-manager.c
+++ b/libempathy/empathy-contact-manager.c
@@ -25,9 +25,10 @@
 
 #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-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;
        TpAccountManager *account_manager;
-       EmpathyContactMonitor *contact_monitor;
 } EmpathyContactManagerPriv;
 
 static void contact_manager_iface_init         (EmpathyContactListIface    *iface);
@@ -144,6 +146,10 @@ contact_manager_status_changed_cb (TpAccount *account,
        EmpathyTpContactList      *list;
        TpConnection              *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)) {
@@ -171,6 +177,19 @@ contact_manager_status_changed_cb (TpAccount *account,
                          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)
 {
@@ -182,10 +201,6 @@ contact_manager_finalize (GObject *object)
        g_hash_table_destroy (priv->lists);
 
        g_object_unref (priv->account_manager);
-
-       if (priv->contact_monitor) {
-               g_object_unref (priv->contact_monitor);
-       }
 }
 
 static GObject *
@@ -244,8 +259,11 @@ account_manager_prepared_cb (GObject *source_object,
        GList *accounts, *l;
        EmpathyContactManager *manager = user_data;
        TpAccountManager *account_manager = TP_ACCOUNT_MANAGER (source_object);
+       GError *error = NULL;
 
-       if (!tp_account_manager_prepare_finish (account_manager, result, NULL)) {
+       if (!tp_proxy_prepare_finish (account_manager, result, &error)) {
+               DEBUG ("Failed to prepare account manager: %s", error->message);
+               g_error_free (error);
                return;
        }
 
@@ -260,11 +278,15 @@ account_manager_prepared_cb (GObject *source_object,
                                                           NULL, NULL, manager);
                }
 
-               empathy_signal_connect_weak (account, "status-changed",
+               tp_g_signal_connect_object (account, "status-changed",
                    G_CALLBACK (contact_manager_status_changed_cb),
-                   G_OBJECT (manager));
+                   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
@@ -278,10 +300,10 @@ empathy_contact_manager_init (EmpathyContactManager *manager)
                                             empathy_proxy_equal,
                                             (GDestroyNotify) g_object_unref,
                                             (GDestroyNotify) g_object_unref);
+
        priv->account_manager = tp_account_manager_dup ();
-       priv->contact_monitor = NULL;
 
-       tp_account_manager_prepare_async (priv->account_manager, NULL,
+       tp_proxy_prepare_async (priv->account_manager, NULL,
            account_manager_prepared_cb, manager);
 }
 
@@ -367,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,
@@ -558,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;