libempathy/empathy-individual-manager.c

   1 /* -*- Mode: C; tab-width: 8; indent-tabs-mode: t; c-basic-offset: 8 -*- */
   2 /*
   3  * Copyright (C) 2007-2010 Collabora Ltd.
   4  *
   5  * This library is free software; you can redistribute it and/or
   6  * modify it under the terms of the GNU Lesser General Public
   7  * License as published by the Free Software Foundation; either
   8  * version 2.1 of the License, or (at your option) any later version.
   9  *
  10  * This library is distributed in the hope that it will be useful,
  11  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  13  * Lesser General Public License for more details.
  14  *
  15  * You should have received a copy of the GNU Lesser General Public
  16  * License along with this library; if not, write to the Free Software
  17  * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
  18  *
  19  * Authors: Xavier Claessens <xclaesse@gmail.com>
  20  *          Travis Reitter <travis.reitter@collabora.co.uk>
  21  */
  22
  23 #include <config.h>
  24
  25 #include <string.h>
  26
  27 #include <telepathy-glib/account-manager.h>
  28 #include <telepathy-glib/enums.h>
  29 #include <telepathy-glib/proxy-subclass.h>
  30 #include <telepathy-glib/util.h>
  31
  32 #include <folks/folks.h>
  33
  34 #include <extensions/extensions.h>
  35
  36 #include "empathy-individual-manager.h"
  37 #include "empathy-contact-manager.h"
  38 #include "empathy-contact-list.h"
  39 #include "empathy-marshal.h"
  40 #include "empathy-utils.h"
  41
  42 #define DEBUG_FLAG EMPATHY_DEBUG_CONTACT
  43 #include "empathy-debug.h"
  44
  45 #define GET_PRIV(obj) EMPATHY_GET_PRIV (obj, EmpathyIndividualManager)
  46
  47 /* This class doesn't store or ref any of the individuals, since they're already
  48  * stored and referenced in the aggregator.
  49  *
  50  * This class merely forwards along signals from the aggregator and individuals
  51  * and wraps aggregator functions for other client code. */
  52 typedef struct
  53 {
  54   FolksIndividualAggregator *aggregator;
  55   EmpathyContactManager *contact_manager;
  56 } EmpathyIndividualManagerPriv;
  57
  58 enum
  59 {
  60   FAVOURITES_CHANGED,
  61   GROUPS_CHANGED,
  62   MEMBERS_CHANGED,
  63   LAST_SIGNAL
  64 };
  65
  66 static guint signals[LAST_SIGNAL] = { 0 };
  67
  68 G_DEFINE_TYPE (EmpathyIndividualManager, empathy_individual_manager,
  69     G_TYPE_OBJECT);
  70
  71 static EmpathyIndividualManager *manager_singleton = NULL;
  72
  73 static void
  74 individual_group_changed_cb (FolksIndividual *individual,
  75     gchar *group,
  76     gboolean is_member,
  77     EmpathyIndividualManager *self)
  78 {
  79   g_signal_emit (self, signals[GROUPS_CHANGED], 0, individual, group,
  80       is_member);
  81 }
  82
  83 static void
  84 individual_notify_is_favourite_cb (FolksIndividual *individual,
  85     GParamSpec *pspec,
  86     EmpathyIndividualManager *self)
  87 {
  88   gboolean is_favourite = folks_favourite_get_is_favourite (
  89       FOLKS_FAVOURITE (individual));
  90   g_signal_emit (self, signals[FAVOURITES_CHANGED], 0, individual,
  91       is_favourite);
  92 }
  93
  94 static void
  95 aggregator_individuals_added_cb (FolksIndividualAggregator *aggregator,
  96     GList *individuals,
  97     EmpathyIndividualManager *self)
  98 {
  99   GList *l;
 100
 101   for (l = individuals; l; l = l->next)
 102     {
 103       g_signal_connect (l->data, "group-changed",
 104           G_CALLBACK (individual_group_changed_cb), self);
 105       g_signal_connect (l->data, "notify::is-favourite",
 106           G_CALLBACK (individual_notify_is_favourite_cb), self);
 107     }
 108
 109   /* TODO: don't hard-code the reason or message */
 110   g_signal_emit (self, signals[MEMBERS_CHANGED], 0, "individual(s) added",
 111       individuals, NULL, TP_CHANNEL_GROUP_CHANGE_REASON_NONE, TRUE);
 112 }
 113
 114 static void
 115 aggregator_individuals_removed_cb (FolksIndividualAggregator *aggregator,
 116     GList *individuals,
 117     EmpathyIndividualManager *self)
 118 {
 119   GList *l;
 120
 121   for (l = individuals; l; l = l->next)
 122     {
 123       g_signal_handlers_disconnect_by_func (l->data,
 124           individual_group_changed_cb, self);
 125       g_signal_handlers_disconnect_by_func (l->data,
 126           individual_notify_is_favourite_cb, self);
 127     }
 128
 129   /* TODO: don't hard-code the reason or message */
 130   g_signal_emit (self, signals[MEMBERS_CHANGED], 0, "individual(s) removed",
 131       NULL, individuals, TP_CHANNEL_GROUP_CHANGE_REASON_NONE, TRUE);
 132 }
 133
 134 static void
 135 individual_manager_dispose (GObject *object)
 136 {
 137   EmpathyIndividualManagerPriv *priv = GET_PRIV (object);
 138
 139   tp_clear_object (&priv->contact_manager);
 140   tp_clear_object (&priv->aggregator);
 141
 142   G_OBJECT_CLASS (empathy_individual_manager_parent_class)->dispose (object);
 143 }
 144
 145 static GObject *
 146 individual_manager_constructor (GType type,
 147     guint n_props,
 148     GObjectConstructParam *props)
 149 {
 150   GObject *retval;
 151
 152   if (manager_singleton)
 153     {
 154       retval = g_object_ref (manager_singleton);
 155     }
 156   else
 157     {
 158       retval =
 159           G_OBJECT_CLASS (empathy_individual_manager_parent_class)->
 160           constructor (type, n_props, props);
 161
 162       manager_singleton = EMPATHY_INDIVIDUAL_MANAGER (retval);
 163       g_object_add_weak_pointer (retval, (gpointer) & manager_singleton);
 164     }
 165
 166   return retval;
 167 }
 168
 169 /**
 170  * empathy_individual_manager_initialized:
 171  *
 172  * Reports whether or not the singleton has already been created.
 173  *
 174  * There can be instances where you want to access the #EmpathyIndividualManager
 175  * only if it has been set up for this process.
 176  *
 177  * Returns: %TRUE if the #EmpathyIndividualManager singleton has previously
 178  * been initialized.
 179  */
 180 gboolean
 181 empathy_individual_manager_initialized (void)
 182 {
 183   return (manager_singleton != NULL);
 184 }
 185
 186 static void
 187 empathy_individual_manager_class_init (EmpathyIndividualManagerClass *klass)
 188 {
 189   GObjectClass *object_class = G_OBJECT_CLASS (klass);
 190
 191   object_class->dispose = individual_manager_dispose;
 192   object_class->constructor = individual_manager_constructor;
 193
 194   signals[GROUPS_CHANGED] =
 195       g_signal_new ("groups-changed",
 196           G_TYPE_FROM_CLASS (klass),
 197           G_SIGNAL_RUN_LAST,
 198           0,
 199           NULL, NULL,
 200           _empathy_marshal_VOID__OBJECT_STRING_BOOLEAN,
 201           G_TYPE_NONE, 3, FOLKS_TYPE_INDIVIDUAL, G_TYPE_STRING, G_TYPE_BOOLEAN);
 202
 203   signals[FAVOURITES_CHANGED] =
 204       g_signal_new ("favourites-changed",
 205           G_TYPE_FROM_CLASS (klass),
 206           G_SIGNAL_RUN_LAST,
 207           0,
 208           NULL, NULL,
 209           _empathy_marshal_VOID__OBJECT_BOOLEAN,
 210           G_TYPE_NONE, 2, FOLKS_TYPE_INDIVIDUAL, G_TYPE_BOOLEAN);
 211
 212   signals[MEMBERS_CHANGED] =
 213       g_signal_new ("members-changed",
 214           G_TYPE_FROM_CLASS (klass),
 215           G_SIGNAL_RUN_LAST,
 216           0,
 217           NULL, NULL,
 218           _empathy_marshal_VOID__STRING_OBJECT_OBJECT_UINT,
 219           G_TYPE_NONE,
 220           4, G_TYPE_STRING, G_TYPE_POINTER, G_TYPE_POINTER, G_TYPE_UINT);
 221
 222   g_type_class_add_private (object_class,
 223       sizeof (EmpathyIndividualManagerPriv));
 224 }
 225
 226 static void
 227 empathy_individual_manager_init (EmpathyIndividualManager *self)
 228 {
 229   EmpathyIndividualManagerPriv *priv = G_TYPE_INSTANCE_GET_PRIVATE (self,
 230       EMPATHY_TYPE_INDIVIDUAL_MANAGER, EmpathyIndividualManagerPriv);
 231
 232   self->priv = priv;
 233   priv->contact_manager = empathy_contact_manager_dup_singleton ();
 234
 235   priv->aggregator = folks_individual_aggregator_new ();
 236   g_signal_connect (priv->aggregator, "individuals-added",
 237       G_CALLBACK (aggregator_individuals_added_cb), self);
 238   g_signal_connect (priv->aggregator, "individuals-removed",
 239       G_CALLBACK (aggregator_individuals_removed_cb), self);
 240 }
 241
 242 EmpathyIndividualManager *
 243 empathy_individual_manager_dup_singleton (void)
 244 {
 245   return g_object_new (EMPATHY_TYPE_INDIVIDUAL_MANAGER, NULL);
 246 }
 247
 248 GList *
 249 empathy_individual_manager_get_members (EmpathyIndividualManager *self)
 250 {
 251   EmpathyIndividualManagerPriv *priv = GET_PRIV (self);
 252   GHashTable *individuals;
 253
 254   g_return_val_if_fail (EMPATHY_IS_INDIVIDUAL_MANAGER (self), NULL);
 255
 256   individuals = folks_individual_aggregator_get_individuals (priv->aggregator);
 257   return individuals ? g_hash_table_get_values (individuals) : NULL;
 258 }
 259
 260 FolksIndividual *
 261 empathy_individual_manager_lookup_member (EmpathyIndividualManager *self,
 262     const gchar *id)
 263 {
 264   EmpathyIndividualManagerPriv *priv = GET_PRIV (self);
 265   GHashTable *individuals;
 266
 267   g_return_val_if_fail (EMPATHY_IS_INDIVIDUAL_MANAGER (self), NULL);
 268
 269   individuals = folks_individual_aggregator_get_individuals (priv->aggregator);
 270   if (individuals != NULL)
 271     return g_hash_table_lookup (individuals, id);
 272
 273   return NULL;
 274 }
 275
 276 static void
 277 aggregator_add_persona_from_details_cb (GObject *source,
 278     GAsyncResult *result,
 279     gpointer user_data)
 280 {
 281   FolksIndividualAggregator *aggregator = FOLKS_INDIVIDUAL_AGGREGATOR (source);
 282   EmpathyContact *contact = EMPATHY_CONTACT (user_data);
 283   FolksPersona *persona;
 284   GError *error = NULL;
 285
 286   persona = folks_individual_aggregator_add_persona_from_details_finish (
 287       aggregator, result, &error);
 288   if (error != NULL)
 289     {
 290       g_warning ("failed to add individual from contact: %s", error->message);
 291       g_clear_error (&error);
 292     }
 293
 294   /* We can unref the contact now */
 295   g_object_unref (contact);
 296 }
 297
 298 void
 299 empathy_individual_manager_add_from_contact (EmpathyIndividualManager *self,
 300     EmpathyContact *contact)
 301 {
 302   EmpathyIndividualManagerPriv *priv;
 303   GHashTable* details;
 304   TpAccount *account;
 305   const gchar *store_id;
 306
 307   g_return_if_fail (EMPATHY_IS_INDIVIDUAL_MANAGER (self));
 308   g_return_if_fail (EMPATHY_IS_CONTACT (contact));
 309
 310   priv = GET_PRIV (self);
 311
 312   /* We need to ref the contact since otherwise its linked TpHandle will be
 313    * destroyed. */
 314   g_object_ref (contact);
 315
 316   DEBUG ("adding individual from contact %s (%s)",
 317       empathy_contact_get_id (contact), empathy_contact_get_name (contact));
 318
 319   account = empathy_contact_get_account (contact);
 320   store_id = tp_proxy_get_object_path (TP_PROXY (account));
 321
 322   details = g_hash_table_new (g_str_hash, g_str_equal);
 323   g_hash_table_insert (details, "contact",
 324       (gchar*) empathy_contact_get_id (contact));
 325
 326   folks_individual_aggregator_add_persona_from_details (
 327       priv->aggregator, NULL, "telepathy", store_id, details,
 328       aggregator_add_persona_from_details_cb, contact);
 329
 330   g_hash_table_destroy (details);
 331 }
 332
 333 /**
 334  * Removes the inner contact from the server (and thus the Individual). Not
 335  * meant for de-shelling inner personas from an Individual.
 336  */
 337 void
 338 empathy_individual_manager_remove (EmpathyIndividualManager *self,
 339     FolksIndividual *individual,
 340     const gchar *message)
 341 {
 342   EmpathyIndividualManagerPriv *priv;
 343
 344   g_return_if_fail (EMPATHY_IS_INDIVIDUAL_MANAGER (self));
 345   g_return_if_fail (FOLKS_IS_INDIVIDUAL (individual));
 346
 347   priv = GET_PRIV (self);
 348
 349   DEBUG ("removing individual %s (%s)",
 350       folks_individual_get_id (individual),
 351       folks_individual_get_alias (individual));
 352
 353   folks_individual_aggregator_remove_individual (priv->aggregator, individual);
 354 }
 355
 356 static void
 357 remove_group_cb (const gchar *id, FolksIndividual *individual,
 358     const gchar *group)
 359 {
 360   folks_groups_change_group (FOLKS_GROUPS (individual), group, FALSE);
 361 }
 362
 363 void
 364 empathy_individual_manager_remove_group (EmpathyIndividualManager *manager,
 365     const gchar *group)
 366 {
 367   EmpathyIndividualManagerPriv *priv;
 368   GHashTable *individuals;
 369
 370   g_return_if_fail (EMPATHY_IS_INDIVIDUAL_MANAGER (manager));
 371   g_return_if_fail (group != NULL);
 372
 373   priv = GET_PRIV (manager);
 374
 375   DEBUG ("removing group %s", group);
 376
 377   /* Remove every individual from the group */
 378   individuals = folks_individual_aggregator_get_individuals (priv->aggregator);
 379   g_hash_table_foreach (individuals, (GHFunc) remove_group_cb,
 380       (gpointer) group);
 381 }
 382
 383 EmpathyIndividualManagerFlags
 384 empathy_individual_manager_get_flags_for_connection (
 385     EmpathyIndividualManager *self,
 386     TpConnection *connection)
 387 {
 388   EmpathyIndividualManagerPriv *priv;
 389   EmpathyContactListFlags list_flags;
 390   EmpathyIndividualManagerFlags flags;
 391
 392   g_return_val_if_fail (EMPATHY_IS_INDIVIDUAL_MANAGER (self),
 393       EMPATHY_INDIVIDUAL_MANAGER_NO_FLAGS);
 394
 395   priv = GET_PRIV (self);
 396
 397   list_flags = empathy_contact_manager_get_flags_for_connection (
 398     priv->contact_manager, connection);
 399
 400   flags = EMPATHY_INDIVIDUAL_MANAGER_NO_FLAGS;
 401   if (list_flags & EMPATHY_CONTACT_LIST_CAN_ADD)
 402     flags |= EMPATHY_INDIVIDUAL_MANAGER_CAN_ADD;
 403   if (list_flags & EMPATHY_CONTACT_LIST_CAN_REMOVE)
 404     flags |= EMPATHY_INDIVIDUAL_MANAGER_CAN_REMOVE;
 405   if (list_flags & EMPATHY_CONTACT_LIST_CAN_ALIAS)
 406     flags |= EMPATHY_INDIVIDUAL_MANAGER_CAN_ALIAS;
 407   if (list_flags & EMPATHY_CONTACT_LIST_CAN_GROUP)
 408     flags |= EMPATHY_INDIVIDUAL_MANAGER_CAN_GROUP;
 409
 410   return flags;
 411 }