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 *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_individual (EmpathyRosterModelAggregator *self,
 101     FolksIndividual *individual)
 102 {
 103   if (self->priv->filter_func != NULL && !self->priv->filter_func (
 104           EMPATHY_ROSTER_MODEL (self), individual, self))
 105         return;
 106
 107   g_hash_table_add (self->priv->individuals,
 108       g_object_ref (individual));
 109
 110   g_signal_connect (individual, "group-changed",
 111       G_CALLBACK (individual_group_changed_cb), self);
 112
 113   empathy_roster_model_fire_individual_added (EMPATHY_ROSTER_MODEL (self),
 114       individual);
 115 }
 116
 117 static void
 118 remove_individual (EmpathyRosterModelAggregator *self,
 119     FolksIndividual *individual)
 120 {
 121   g_signal_handlers_disconnect_by_func (individual,
 122       individual_group_changed_cb, self);
 123
 124   g_hash_table_remove (self->priv->individuals, individual);
 125
 126   empathy_roster_model_fire_individual_removed (EMPATHY_ROSTER_MODEL (self),
 127       individual);
 128 }
 129
 130 static void
 131 populate_individuals (EmpathyRosterModelAggregator *self)
 132 {
 133   GeeMap *individuals;
 134   GeeMapIterator *iter;
 135
 136   individuals = folks_individual_aggregator_get_individuals (
 137       self->priv->aggregator);
 138   iter = gee_map_map_iterator (individuals);
 139   while (gee_map_iterator_next (iter))
 140     {
 141       add_individual (self, gee_map_iterator_get_value (iter));
 142     }
 143   g_clear_object (&iter);
 144 }
 145
 146 static void
 147 aggregator_individuals_changed_cb (FolksIndividualAggregator *aggregator,
 148     GeeSet *added,
 149     GeeSet *removed,
 150     gchar *message,
 151     FolksPersona *actor,
 152     FolksGroupDetailsChangeReason reason,
 153     EmpathyRosterModelAggregator *self)
 154 {
 155   if (gee_collection_get_size (GEE_COLLECTION (added)) > 0)
 156     {
 157       GeeIterator *iter = gee_iterable_iterator (GEE_ITERABLE (added));
 158
 159       while (iter != NULL && gee_iterator_next (iter))
 160         {
 161           add_individual (self, gee_iterator_get (iter));
 162         }
 163       g_clear_object (&iter);
 164     }
 165
 166   if (gee_collection_get_size (GEE_COLLECTION (removed)) > 0)
 167     {
 168       GeeIterator *iter = gee_iterable_iterator (GEE_ITERABLE (removed));
 169
 170       while (iter != NULL && gee_iterator_next (iter))
 171         {
 172           remove_individual (self, gee_iterator_get (iter));
 173         }
 174       g_clear_object (&iter);
 175     }
 176 }
 177
 178 static void
 179 empathy_roster_model_aggregator_get_property (GObject *object,
 180     guint property_id,
 181     GValue *value,
 182     GParamSpec *pspec)
 183 {
 184   EmpathyRosterModelAggregator *self = EMPATHY_ROSTER_MODEL_AGGREGATOR (object);
 185
 186   switch (property_id)
 187     {
 188       case PROP_AGGREGATOR:
 189         g_value_set_object (value, self->priv->aggregator);
 190         break;
 191       case PROP_FILTER_FUNC:
 192         g_value_set_pointer (value, self->priv->filter_func);
 193         break;
 194       case PROP_FILTER_DATA:
 195         g_value_set_pointer (value, self->priv->filter_data);
 196         break;
 197       default:
 198         G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec);
 199         break;
 200     }
 201 }
 202
 203 static void
 204 empathy_roster_model_aggregator_set_property (GObject *object,
 205     guint property_id,
 206     const GValue *value,
 207     GParamSpec *pspec)
 208 {
 209   EmpathyRosterModelAggregator *self = EMPATHY_ROSTER_MODEL_AGGREGATOR (object);
 210
 211   switch (property_id)
 212     {
 213       case PROP_AGGREGATOR:
 214         g_assert (self->priv->aggregator == NULL); /* construct only */
 215         self->priv->aggregator = g_value_dup_object (value);
 216         break;
 217       case PROP_FILTER_FUNC:
 218         g_assert (self->priv->filter_func == NULL); /* construct only */
 219         self->priv->filter_func = g_value_get_pointer (value);
 220         break;
 221       case PROP_FILTER_DATA:
 222         g_assert (self->priv->filter_data == NULL); /* construct only */
 223         self->priv->filter_data = g_value_get_pointer (value);
 224         break;
 225       default:
 226         G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec);
 227         break;
 228     }
 229 }
 230
 231 static void
 232 empathy_roster_model_aggregator_constructed (GObject *object)
 233 {
 234   EmpathyRosterModelAggregator *self = EMPATHY_ROSTER_MODEL_AGGREGATOR (object);
 235   void (*chain_up) (GObject *) =
 236       ((GObjectClass *) empathy_roster_model_aggregator_parent_class)->constructed;
 237
 238   if (chain_up != NULL)
 239     chain_up (object);
 240
 241   if (self->priv->aggregator == NULL)
 242     self->priv->aggregator = folks_individual_aggregator_new ();
 243
 244   g_assert (FOLKS_IS_INDIVIDUAL_AGGREGATOR (self->priv->aggregator));
 245
 246   tp_g_signal_connect_object (self->priv->aggregator, "individuals-changed",
 247       G_CALLBACK (aggregator_individuals_changed_cb), self, 0);
 248
 249   folks_individual_aggregator_prepare (self->priv->aggregator, NULL, NULL);
 250
 251   populate_individuals (self);
 252 }
 253
 254 static void
 255 empathy_roster_model_aggregator_dispose (GObject *object)
 256 {
 257   EmpathyRosterModelAggregator *self = EMPATHY_ROSTER_MODEL_AGGREGATOR (object);
 258   void (*chain_up) (GObject *) =
 259       ((GObjectClass *) empathy_roster_model_aggregator_parent_class)->dispose;
 260
 261   g_clear_object (&self->priv->aggregator);
 262
 263   if (chain_up != NULL)
 264     chain_up (object);
 265 }
 266
 267 static void
 268 empathy_roster_model_aggregator_finalize (GObject *object)
 269 {
 270   //EmpathyRosterModelAggregator *self = EMPATHY_ROSTER_MODEL_AGGREGATOR (object);
 271   void (*chain_up) (GObject *) =
 272       ((GObjectClass *) empathy_roster_model_aggregator_parent_class)->finalize;
 273
 274   if (chain_up != NULL)
 275     chain_up (object);
 276 }
 277
 278 static void
 279 empathy_roster_model_aggregator_class_init (
 280     EmpathyRosterModelAggregatorClass *klass)
 281 {
 282   GObjectClass *oclass = G_OBJECT_CLASS (klass);
 283   GParamSpec *spec;
 284
 285   oclass->get_property = empathy_roster_model_aggregator_get_property;
 286   oclass->set_property = empathy_roster_model_aggregator_set_property;
 287   oclass->constructed = empathy_roster_model_aggregator_constructed;
 288   oclass->dispose = empathy_roster_model_aggregator_dispose;
 289   oclass->finalize = empathy_roster_model_aggregator_finalize;
 290
 291   spec = g_param_spec_object ("aggregator", "Aggregator",
 292       "FolksIndividualAggregator",
 293       FOLKS_TYPE_INDIVIDUAL_AGGREGATOR,
 294       G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY | G_PARAM_STATIC_STRINGS);
 295   g_object_class_install_property (oclass, PROP_AGGREGATOR, spec);
 296
 297   spec = g_param_spec_pointer ("filter-func", "Filter-Func",
 298       "EmpathyRosterModelAggregatorFilterFunc",
 299       G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY | G_PARAM_STATIC_STRINGS);
 300   g_object_class_install_property (oclass, PROP_FILTER_FUNC, spec);
 301
 302   spec = g_param_spec_pointer ("filter-data", "Filter-Data",
 303       "GPointer",
 304       G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY | G_PARAM_STATIC_STRINGS);
 305   g_object_class_install_property (oclass, PROP_FILTER_DATA, spec);
 306
 307   g_type_class_add_private (klass, sizeof (EmpathyRosterModelAggregatorPriv));
 308 }
 309
 310 static void
 311 empathy_roster_model_aggregator_init (EmpathyRosterModelAggregator *self)
 312 {
 313   self->priv = G_TYPE_INSTANCE_GET_PRIVATE (self,
 314       EMPATHY_TYPE_ROSTER_MODEL_AGGREGATOR, EmpathyRosterModelAggregatorPriv);
 315
 316   self->priv->individuals = g_hash_table_new_full (NULL, NULL, NULL,
 317       g_object_unref);
 318 }
 319
 320 EmpathyRosterModelAggregator *
 321 empathy_roster_model_aggregator_new (
 322     EmpathyRosterModelAggregatorFilterFunc filter_func,
 323     gpointer user_data)
 324 {
 325   return g_object_new (EMPATHY_TYPE_ROSTER_MODEL_AGGREGATOR,
 326       "filter-func", filter_func,
 327       "filter-data", user_data,
 328       NULL);
 329 }
 330
 331 EmpathyRosterModelAggregator *
 332 empathy_roster_model_aggregator_new_with_aggregator (
 333     FolksIndividualAggregator *aggregator,
 334     EmpathyRosterModelAggregatorFilterFunc filter_func,
 335     gpointer user_data)
 336 {
 337   g_return_val_if_fail (FOLKS_IS_INDIVIDUAL_AGGREGATOR (aggregator), NULL);
 338
 339   return g_object_new (EMPATHY_TYPE_ROSTER_MODEL_AGGREGATOR,
 340       "aggregator", aggregator,
 341       "filter-func", filter_func,
 342       "filter-data", user_data,
 343       NULL);
 344 }
 345
 346 static GList *
 347 empathy_roster_model_aggregator_get_individuals (EmpathyRosterModel *model)
 348 {
 349   EmpathyRosterModelAggregator *self = EMPATHY_ROSTER_MODEL_AGGREGATOR (model);
 350
 351   return g_hash_table_get_values (self->priv->individuals);
 352 }
 353
 354 static GList *
 355 empathy_roster_model_aggregator_get_groups_for_individual (
 356     EmpathyRosterModel *model,
 357     FolksIndividual *individual)
 358 {
 359   GList *groups_list = NULL;
 360   GeeSet *groups_set;
 361
 362   groups_set = folks_group_details_get_groups (
 363       FOLKS_GROUP_DETAILS (individual));
 364   if (gee_collection_get_size (GEE_COLLECTION (groups_set)) > 0)
 365     {
 366       GeeIterator *iter = gee_iterable_iterator (GEE_ITERABLE (groups_set));
 367
 368       while (iter != NULL && gee_iterator_next (iter))
 369         {
 370           groups_list = g_list_prepend (groups_list, gee_iterator_get (iter));
 371         }
 372       g_clear_object (&iter);
 373     }
 374
 375   return groups_list;
 376 }
 377
 378 static void
 379 roster_model_iface_init (EmpathyRosterModelInterface *iface)
 380 {
 381   iface->get_individuals = empathy_roster_model_aggregator_get_individuals;
 382   iface->get_groups_for_individual =
 383     empathy_roster_model_aggregator_get_groups_for_individual;
 384 }