libempathy-gtk/empathy-roster-model-aggregator.c

   1 /*
   2  * empathy-roster-model-aggregator.c
   3  *
   4  * Implementation of EmpathyRosterModel using FolksIndividualAggregator as
   5  * source.
   6  *
   7  * Copyright (C) 2012 Collabora Ltd. <http://www.collabora.co.uk/>
   8  *
   9  * This library is free software; you can redistribute it and/or
  10  * modify it under the terms of the GNU Lesser General Public
  11  * License as published by the Free Software Foundation; either
  12  * version 2.1 of the License, or (at your option) any later version.
  13  *
  14  * This library is distributed in the hope that it will be useful,
  15  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  16  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  17  * Lesser General Public License for more details.
  18  *
  19  * You should have received a copy of the GNU Lesser General Public
  20  * License along with this library; if not, write to the Free Software
  21  * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
  22  */
  23
  24
  25 #include "config.h"
  26
  27 #include <folks/folks.h>
  28 #include <folks/folks-telepathy.h>
  29
  30 #include "empathy-roster-model-aggregator.h"
  31
  32 /**
  33  * SECTION: empathy-roster-model-aggregator
  34  * @title: EmpathyRosterModelAggregator
  35  * @short_description: TODO
  36  *
  37  * TODO
  38  */
  39
  40 /**
  41  * EmpathyRosterModelAggregator:
  42  *
  43  * Data structure representing a #EmpathyRosterModelAggregator.
  44  *
  45  * Since: UNRELEASED
  46  */
  47
  48 /**
  49  * EmpathyRosterModelAggregatorClass:
  50  *
  51  * The class of a #EmpathyRosterModelAggregator.
  52  *
  53  * Since: UNRELEASED
  54  */
  55
  56 static void roster_model_iface_init (EmpathyRosterModelInterface *iface);
  57
  58 G_DEFINE_TYPE_WITH_CODE (EmpathyRosterModelAggregator,
  59     empathy_roster_model_aggregator,
  60     G_TYPE_OBJECT,
  61     G_IMPLEMENT_INTERFACE (EMPATHY_TYPE_ROSTER_MODEL, roster_model_iface_init))
  62
  63 enum
  64 {
  65   PROP_AGGREGATOR = 1,
  66   PROP_FILTER_FUNC,
  67   PROP_FILTER_DATA,
  68   N_PROPS
  69 };
  70
  71 /*
  72 enum
  73 {
  74   LAST_SIGNAL
  75 };
  76
  77 static guint signals[LAST_SIGNAL];
  78 */
  79
  80 struct _EmpathyRosterModelAggregatorPriv
  81 {
  82   FolksIndividualAggregator *aggregator;
  83   GHashTable *filtered_individuals; /* Individual -> Individual */
  84
  85   EmpathyRosterModelAggregatorFilterFunc filter_func;
  86   gpointer filter_data;
  87 };
  88
  89 static void
  90 individual_group_changed_cb (FolksIndividual *individual,
  91     gchar *group,
  92     gboolean is_member,
  93     EmpathyRosterModelAggregator *self)
  94 {
  95   empathy_roster_model_fire_groups_changed (EMPATHY_ROSTER_MODEL (self),
  96       individual, group, is_member);
  97 }
  98
  99 static void
 100 add_to_filtered_individuals (EmpathyRosterModelAggregator *self,
 101     FolksIndividual *individual)
 102 {
 103   g_hash_table_add (self->priv->filtered_individuals,
 104       g_object_ref (individual));
 105
 106   tp_g_signal_connect_object (individual, "group-changed",
 107       G_CALLBACK (individual_group_changed_cb), self, 0);
 108
 109   empathy_roster_model_fire_individual_added (EMPATHY_ROSTER_MODEL (self),
 110       individual);
 111 }
 112
 113 static void
 114 remove_from_filtered_individuals (EmpathyRosterModelAggregator *self,
 115     FolksIndividual *individual)
 116 {
 117   g_signal_handlers_disconnect_by_func (individual,
 118       individual_group_changed_cb, self);
 119
 120   g_hash_table_remove (self->priv->filtered_individuals, individual);
 121
 122   empathy_roster_model_fire_individual_removed (EMPATHY_ROSTER_MODEL (self),
 123       individual);
 124 }
 125
 126 static void
 127 individual_notify_cb (FolksIndividual *individual,
 128     GParamSpec *param,
 129     EmpathyRosterModelAggregator *self)
 130 {
 131   if (!self->priv->filter_func (EMPATHY_ROSTER_MODEL (self), individual, self)
 132       && g_hash_table_contains (self->priv->filtered_individuals, individual))
 133     remove_from_filtered_individuals (self, individual);
 134
 135   if (self->priv->filter_func (EMPATHY_ROSTER_MODEL (self), individual, self)
 136       && !g_hash_table_contains (self->priv->filtered_individuals, individual))
 137     add_to_filtered_individuals (self, individual);
 138 }
 139
 140 static void
 141 add_individual (EmpathyRosterModelAggregator *self,
 142     FolksIndividual *individual)
 143 {
 144   if (self->priv->filter_func != NULL)
 145     {
 146       tp_g_signal_connect_object (individual, "notify",
 147           G_CALLBACK (individual_notify_cb), self, 0);
 148
 149       if (!self->priv->filter_func (EMPATHY_ROSTER_MODEL (self), individual,
 150               self))
 151         return;
 152     }
 153
 154   add_to_filtered_individuals (self, individual);
 155 }
 156
 157 static void
 158 remove_individual (EmpathyRosterModelAggregator *self,
 159     FolksIndividual *individual)
 160 {
 161   if (self->priv->filter_func != NULL)
 162     g_signal_handlers_disconnect_by_func (individual,
 163         individual_notify_cb, self);
 164
 165   if (g_hash_table_contains (self->priv->filtered_individuals,
 166           individual))
 167     remove_from_filtered_individuals (self, individual);
 168 }
 169
 170 static void
 171 populate_individuals (EmpathyRosterModelAggregator *self)
 172 {
 173   GeeMap *individuals;
 174   GeeMapIterator *iter;
 175
 176   individuals = folks_individual_aggregator_get_individuals (
 177       self->priv->aggregator);
 178   iter = gee_map_map_iterator (individuals);
 179   while (gee_map_iterator_next (iter))
 180     {
 181       add_individual (self, gee_map_iterator_get_value (iter));
 182     }
 183   g_clear_object (&iter);
 184 }
 185
 186 static void
 187 aggregator_individuals_changed_cb (FolksIndividualAggregator *aggregator,
 188     GeeSet *added,
 189     GeeSet *removed,
 190     gchar *message,
 191     FolksPersona *actor,
 192     FolksGroupDetailsChangeReason reason,
 193     EmpathyRosterModelAggregator *self)
 194 {
 195   if (gee_collection_get_size (GEE_COLLECTION (added)) > 0)
 196     {
 197       GeeIterator *iter = gee_iterable_iterator (GEE_ITERABLE (added));
 198
 199       while (iter != NULL && gee_iterator_next (iter))
 200         {
 201           add_individual (self, gee_iterator_get (iter));
 202         }
 203       g_clear_object (&iter);
 204     }
 205
 206   if (gee_collection_get_size (GEE_COLLECTION (removed)) > 0)
 207     {
 208       GeeIterator *iter = gee_iterable_iterator (GEE_ITERABLE (removed));
 209
 210       while (iter != NULL && gee_iterator_next (iter))
 211         {
 212           remove_individual (self, gee_iterator_get (iter));
 213         }
 214       g_clear_object (&iter);
 215     }
 216 }
 217
 218 static void
 219 empathy_roster_model_aggregator_get_property (GObject *object,
 220     guint property_id,
 221     GValue *value,
 222     GParamSpec *pspec)
 223 {
 224   EmpathyRosterModelAggregator *self = EMPATHY_ROSTER_MODEL_AGGREGATOR (object);
 225
 226   switch (property_id)
 227     {
 228       case PROP_AGGREGATOR:
 229         g_value_set_object (value, self->priv->aggregator);
 230         break;
 231       case PROP_FILTER_FUNC:
 232         g_value_set_pointer (value, self->priv->filter_func);
 233         break;
 234       case PROP_FILTER_DATA:
 235         g_value_set_pointer (value, self->priv->filter_data);
 236         break;
 237       default:
 238         G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec);
 239         break;
 240     }
 241 }
 242
 243 static void
 244 empathy_roster_model_aggregator_set_property (GObject *object,
 245     guint property_id,
 246     const GValue *value,
 247     GParamSpec *pspec)
 248 {
 249   EmpathyRosterModelAggregator *self = EMPATHY_ROSTER_MODEL_AGGREGATOR (object);
 250
 251   switch (property_id)
 252     {
 253       case PROP_AGGREGATOR:
 254         g_assert (self->priv->aggregator == NULL); /* construct only */
 255         self->priv->aggregator = g_value_dup_object (value);
 256         break;
 257       case PROP_FILTER_FUNC:
 258         g_assert (self->priv->filter_func == NULL); /* construct only */
 259         self->priv->filter_func = g_value_get_pointer (value);
 260         break;
 261       case PROP_FILTER_DATA:
 262         g_assert (self->priv->filter_data == NULL); /* construct only */
 263         self->priv->filter_data = g_value_get_pointer (value);
 264         break;
 265       default:
 266         G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec);
 267         break;
 268     }
 269 }
 270
 271 static void
 272 empathy_roster_model_aggregator_constructed (GObject *object)
 273 {
 274   EmpathyRosterModelAggregator *self = EMPATHY_ROSTER_MODEL_AGGREGATOR (object);
 275   void (*chain_up) (GObject *) =
 276       ((GObjectClass *) empathy_roster_model_aggregator_parent_class)->constructed;
 277
 278   if (chain_up != NULL)
 279     chain_up (object);
 280
 281   if (self->priv->aggregator == NULL)
 282     self->priv->aggregator = folks_individual_aggregator_new ();
 283
 284   g_assert (FOLKS_IS_INDIVIDUAL_AGGREGATOR (self->priv->aggregator));
 285
 286   tp_g_signal_connect_object (self->priv->aggregator, "individuals-changed",
 287       G_CALLBACK (aggregator_individuals_changed_cb), self, 0);
 288
 289   folks_individual_aggregator_prepare (self->priv->aggregator, NULL, NULL);
 290
 291   populate_individuals (self);
 292 }
 293
 294 static void
 295 empathy_roster_model_aggregator_dispose (GObject *object)
 296 {
 297   EmpathyRosterModelAggregator *self = EMPATHY_ROSTER_MODEL_AGGREGATOR (object);
 298   void (*chain_up) (GObject *) =
 299       ((GObjectClass *) empathy_roster_model_aggregator_parent_class)->dispose;
 300
 301   g_clear_object (&self->priv->aggregator);
 302   g_clear_pointer (&self->priv->filtered_individuals, g_hash_table_unref);
 303
 304   if (chain_up != NULL)
 305     chain_up (object);
 306 }
 307
 308 static void
 309 empathy_roster_model_aggregator_finalize (GObject *object)
 310 {
 311   //EmpathyRosterModelAggregator *self = EMPATHY_ROSTER_MODEL_AGGREGATOR (object);
 312   void (*chain_up) (GObject *) =
 313       ((GObjectClass *) empathy_roster_model_aggregator_parent_class)->finalize;
 314
 315   if (chain_up != NULL)
 316     chain_up (object);
 317 }
 318
 319 static void
 320 empathy_roster_model_aggregator_class_init (
 321     EmpathyRosterModelAggregatorClass *klass)
 322 {
 323   GObjectClass *oclass = G_OBJECT_CLASS (klass);
 324   GParamSpec *spec;
 325
 326   oclass->get_property = empathy_roster_model_aggregator_get_property;
 327   oclass->set_property = empathy_roster_model_aggregator_set_property;
 328   oclass->constructed = empathy_roster_model_aggregator_constructed;
 329   oclass->dispose = empathy_roster_model_aggregator_dispose;
 330   oclass->finalize = empathy_roster_model_aggregator_finalize;
 331
 332   spec = g_param_spec_object ("aggregator", "Aggregator",
 333       "FolksIndividualAggregator",
 334       FOLKS_TYPE_INDIVIDUAL_AGGREGATOR,
 335       G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY | G_PARAM_STATIC_STRINGS);
 336   g_object_class_install_property (oclass, PROP_AGGREGATOR, spec);
 337
 338   spec = g_param_spec_pointer ("filter-func", "Filter-Func",
 339       "EmpathyRosterModelAggregatorFilterFunc",
 340       G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY | G_PARAM_STATIC_STRINGS);
 341   g_object_class_install_property (oclass, PROP_FILTER_FUNC, spec);
 342
 343   spec = g_param_spec_pointer ("filter-data", "Filter-Data",
 344       "GPointer",
 345       G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY | G_PARAM_STATIC_STRINGS);
 346   g_object_class_install_property (oclass, PROP_FILTER_DATA, spec);
 347
 348   g_type_class_add_private (klass, sizeof (EmpathyRosterModelAggregatorPriv));
 349 }
 350
 351 static void
 352 empathy_roster_model_aggregator_init (EmpathyRosterModelAggregator *self)
 353 {
 354   self->priv = G_TYPE_INSTANCE_GET_PRIVATE (self,
 355       EMPATHY_TYPE_ROSTER_MODEL_AGGREGATOR, EmpathyRosterModelAggregatorPriv);
 356
 357   self->priv->filtered_individuals = g_hash_table_new_full (NULL, NULL, NULL,
 358       g_object_unref);
 359 }
 360
 361 EmpathyRosterModelAggregator *
 362 empathy_roster_model_aggregator_new (
 363     EmpathyRosterModelAggregatorFilterFunc filter_func,
 364     gpointer user_data)
 365 {
 366   return g_object_new (EMPATHY_TYPE_ROSTER_MODEL_AGGREGATOR,
 367       "filter-func", filter_func,
 368       "filter-data", user_data,
 369       NULL);
 370 }
 371
 372 EmpathyRosterModelAggregator *
 373 empathy_roster_model_aggregator_new_with_aggregator (
 374     FolksIndividualAggregator *aggregator,
 375     EmpathyRosterModelAggregatorFilterFunc filter_func,
 376     gpointer user_data)
 377 {
 378   g_return_val_if_fail (FOLKS_IS_INDIVIDUAL_AGGREGATOR (aggregator), NULL);
 379
 380   return g_object_new (EMPATHY_TYPE_ROSTER_MODEL_AGGREGATOR,
 381       "aggregator", aggregator,
 382       "filter-func", filter_func,
 383       "filter-data", user_data,
 384       NULL);
 385 }
 386
 387 static GList *
 388 empathy_roster_model_aggregator_get_individuals (EmpathyRosterModel *model)
 389 {
 390   EmpathyRosterModelAggregator *self = EMPATHY_ROSTER_MODEL_AGGREGATOR (model);
 391
 392   return g_hash_table_get_values (self->priv->filtered_individuals);
 393 }
 394
 395 static GList *
 396 empathy_roster_model_aggregator_get_groups_for_individual (
 397     EmpathyRosterModel *model,
 398     FolksIndividual *individual)
 399 {
 400   GList *groups_list = NULL;
 401   GeeSet *groups_set;
 402
 403   groups_set = folks_group_details_get_groups (
 404       FOLKS_GROUP_DETAILS (individual));
 405   if (gee_collection_get_size (GEE_COLLECTION (groups_set)) > 0)
 406     {
 407       GeeIterator *iter = gee_iterable_iterator (GEE_ITERABLE (groups_set));
 408
 409       while (iter != NULL && gee_iterator_next (iter))
 410         {
 411           groups_list = g_list_prepend (groups_list, gee_iterator_get (iter));
 412         }
 413       g_clear_object (&iter);
 414     }
 415
 416   return groups_list;
 417 }
 418
 419 static void
 420 roster_model_iface_init (EmpathyRosterModelInterface *iface)
 421 {
 422   iface->get_individuals = empathy_roster_model_aggregator_get_individuals;
 423   iface->get_groups_for_individual =
 424     empathy_roster_model_aggregator_get_groups_for_individual;
 425 }