individual-menu: remove link-contacts-activated signal

[empathy.git] / libempathy / empathy-connection-aggregator.c

diff --git a/libempathy/empathy-connection-aggregator.c b/libempathy/empathy-connection-aggregator.c
index 7074e5186b7d35e9b67bdd2011060c5595d5b2d5..fde365c27eaa25995f494394b048a90542b435db 100644 (file)
--- a/libempathy/empathy-connection-aggregator.c
+++ b/libempathy/empathy-connection-aggregator.c
@@ -31,9 +31,16 @@
 
 #include "extensions/extensions.h"
 
-G_DEFINE_TYPE (EmpathyConnectionAggregator, empathy_connection_aggregator, 
+G_DEFINE_TYPE (EmpathyConnectionAggregator, empathy_connection_aggregator,
     G_TYPE_OBJECT);
 
+enum {
+  EVENT_CONTACT_LIST_CHANGED,
+  LAST_SIGNAL
+};
+
+static guint signals[LAST_SIGNAL];
+
 struct _EmpathyConnectionAggregatorPriv {
   TpAccountManager *mgr;
 
@@ -62,9 +69,28 @@ empathy_connection_aggregator_class_init (
 
   oclass->dispose = empathy_connection_aggregator_dispose;
 
+  signals[EVENT_CONTACT_LIST_CHANGED] =
+    g_signal_new ("contact-list-changed",
+      G_TYPE_FROM_CLASS (klass),
+      G_SIGNAL_RUN_LAST,
+      0,
+      NULL, NULL,
+      g_cclosure_marshal_generic,
+      G_TYPE_NONE,
+      2, G_TYPE_PTR_ARRAY, G_TYPE_PTR_ARRAY);
+
   g_type_class_add_private (klass, sizeof (EmpathyConnectionAggregatorPriv));
 }
 
+static void
+contact_list_changed_cb (TpConnection *conn,
+    GPtrArray *added,
+    GPtrArray *removed,
+    EmpathyConnectionAggregator *self)
+{
+  g_signal_emit (self, signals[EVENT_CONTACT_LIST_CHANGED], 0, added, removed);
+}
+
 static void
 conn_invalidated_cb (TpConnection *conn,
     guint domain,
@@ -81,12 +107,28 @@ static void
 check_connection (EmpathyConnectionAggregator *self,
     TpConnection *conn)
 {
+  GPtrArray *contacts;
+
   if (g_list_find (self->priv->conns, conn) != NULL)
     return;
 
   self->priv->conns = g_list_prepend (self->priv->conns,
       g_object_ref (conn));
 
+  tp_g_signal_connect_object (conn, "contact-list-changed",
+      G_CALLBACK (contact_list_changed_cb), self, 0);
+
+  contacts = tp_connection_dup_contact_list (conn);
+  if (contacts != NULL)
+    {
+      GPtrArray *empty;
+
+      empty = g_ptr_array_new ();
+
+      contact_list_changed_cb (conn, contacts, empty, self);
+      g_ptr_array_unref (empty);
+    }
+
   tp_g_signal_connect_object (conn, "invalidated",
       G_CALLBACK (conn_invalidated_cb), self, 0);
 }
@@ -189,6 +231,7 @@ empathy_connection_aggregator_dup_singleton (void)
   return aggregator;
 }
 
+/* (transfer container) */
 GList *
 empathy_connection_aggregator_get_all_groups (EmpathyConnectionAggregator *self)
 {
@@ -216,3 +259,32 @@ empathy_connection_aggregator_get_all_groups (EmpathyConnectionAggregator *self)
 
   return keys;
 }
+
+GPtrArray *
+empathy_connection_aggregator_dup_all_contacts (
+    EmpathyConnectionAggregator *self)
+{
+  GPtrArray *result;
+  GList *l;
+
+  result = g_ptr_array_new_with_free_func (g_object_unref);
+
+  for (l = self->priv->conns; l != NULL; l = g_list_next (l))
+    {
+      TpConnection *conn = l->data;
+      GPtrArray *contacts;
+
+      contacts = tp_connection_dup_contact_list (conn);
+      if (contacts == NULL)
+        continue;
+
+      tp_g_ptr_array_extend (result, contacts);
+
+      /* tp_g_ptr_array_extend() doesn't give us an extra ref */
+      g_ptr_array_foreach (contacts, (GFunc) g_object_ref, NULL);
+
+      g_ptr_array_unref (contacts);
+    }
+
+  return result;
+}