2 * empathy-roster-model-aggregator.c
4 * Implementation of EmpathyRosterModel using FolksIndividualAggregator as
7 * Copyright (C) 2012 Collabora Ltd. <http://www.collabora.co.uk/>
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.
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.
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
25 #include "empathy-roster-model-aggregator.h"
27 #include <folks/folks-telepathy.h>
30 * SECTION: empathy-roster-model-aggregator
31 * @title: EmpathyRosterModelAggregator
32 * @short_description: TODO
38 * EmpathyRosterModelAggregator:
40 * Data structure representing a #EmpathyRosterModelAggregator.
46 * EmpathyRosterModelAggregatorClass:
48 * The class of a #EmpathyRosterModelAggregator.
53 static void roster_model_iface_init (EmpathyRosterModelInterface
*iface
);
55 G_DEFINE_TYPE_WITH_CODE (EmpathyRosterModelAggregator
,
56 empathy_roster_model_aggregator
,
58 G_IMPLEMENT_INTERFACE (EMPATHY_TYPE_ROSTER_MODEL
, roster_model_iface_init
))
74 static guint signals[LAST_SIGNAL];
77 struct _EmpathyRosterModelAggregatorPriv
79 FolksIndividualAggregator
*aggregator
;
80 GHashTable
*filtered_individuals
; /* Individual -> Individual */
82 EmpathyRosterModelAggregatorFilterFunc filter_func
;
87 individual_group_changed_cb (FolksIndividual
*individual
,
90 EmpathyRosterModelAggregator
*self
)
92 empathy_roster_model_fire_groups_changed (EMPATHY_ROSTER_MODEL (self
),
93 individual
, group
, is_member
);
97 add_to_filtered_individuals (EmpathyRosterModelAggregator
*self
,
98 FolksIndividual
*individual
)
100 g_hash_table_add (self
->priv
->filtered_individuals
,
101 g_object_ref (individual
));
103 tp_g_signal_connect_object (individual
, "group-changed",
104 G_CALLBACK (individual_group_changed_cb
), self
, 0);
106 empathy_roster_model_fire_individual_added (EMPATHY_ROSTER_MODEL (self
),
111 remove_from_filtered_individuals (EmpathyRosterModelAggregator
*self
,
112 FolksIndividual
*individual
)
114 g_signal_handlers_disconnect_by_func (individual
,
115 individual_group_changed_cb
, self
);
117 g_hash_table_remove (self
->priv
->filtered_individuals
, individual
);
119 empathy_roster_model_fire_individual_removed (EMPATHY_ROSTER_MODEL (self
),
124 individual_notify_cb (FolksIndividual
*individual
,
126 EmpathyRosterModelAggregator
*self
)
128 if (!self
->priv
->filter_func (EMPATHY_ROSTER_MODEL (self
), individual
, self
)
129 && g_hash_table_contains (self
->priv
->filtered_individuals
, individual
))
130 remove_from_filtered_individuals (self
, individual
);
132 if (self
->priv
->filter_func (EMPATHY_ROSTER_MODEL (self
), individual
, self
)
133 && !g_hash_table_contains (self
->priv
->filtered_individuals
, individual
))
134 add_to_filtered_individuals (self
, individual
);
138 add_individual (EmpathyRosterModelAggregator
*self
,
139 FolksIndividual
*individual
)
141 if (self
->priv
->filter_func
!= NULL
)
143 tp_g_signal_connect_object (individual
, "notify",
144 G_CALLBACK (individual_notify_cb
), self
, 0);
146 if (!self
->priv
->filter_func (EMPATHY_ROSTER_MODEL (self
), individual
,
151 add_to_filtered_individuals (self
, individual
);
155 remove_individual (EmpathyRosterModelAggregator
*self
,
156 FolksIndividual
*individual
)
158 if (self
->priv
->filter_func
!= NULL
)
159 g_signal_handlers_disconnect_by_func (individual
,
160 individual_notify_cb
, self
);
162 if (g_hash_table_contains (self
->priv
->filtered_individuals
,
164 remove_from_filtered_individuals (self
, individual
);
168 populate_individuals (EmpathyRosterModelAggregator
*self
)
171 GeeMapIterator
*iter
;
173 individuals
= folks_individual_aggregator_get_individuals (
174 self
->priv
->aggregator
);
175 iter
= gee_map_map_iterator (individuals
);
176 while (gee_map_iterator_next (iter
))
178 FolksIndividual
*individual
= gee_map_iterator_get_value (iter
);
179 add_individual (self
, individual
);
180 g_object_unref (individual
);
182 g_clear_object (&iter
);
186 aggregator_individuals_changed_cb (FolksIndividualAggregator
*aggregator
,
191 FolksGroupDetailsChangeReason reason
,
192 EmpathyRosterModelAggregator
*self
)
194 if (gee_collection_get_size (GEE_COLLECTION (added
)) > 0)
196 GeeIterator
*iter
= gee_iterable_iterator (GEE_ITERABLE (added
));
198 while (iter
!= NULL
&& gee_iterator_next (iter
))
200 FolksIndividual
*individual
= gee_iterator_get (iter
);
201 add_individual (self
, individual
);
202 g_object_unref (individual
);
204 g_clear_object (&iter
);
207 if (gee_collection_get_size (GEE_COLLECTION (removed
)) > 0)
209 GeeIterator
*iter
= gee_iterable_iterator (GEE_ITERABLE (removed
));
211 while (iter
!= NULL
&& gee_iterator_next (iter
))
213 FolksIndividual
*individual
= gee_iterator_get (iter
);
214 remove_individual (self
, individual
);
215 g_object_unref (individual
);
217 g_clear_object (&iter
);
222 empathy_roster_model_aggregator_get_property (GObject
*object
,
227 EmpathyRosterModelAggregator
*self
= EMPATHY_ROSTER_MODEL_AGGREGATOR (object
);
231 case PROP_AGGREGATOR
:
232 g_value_set_object (value
, self
->priv
->aggregator
);
234 case PROP_FILTER_FUNC
:
235 g_value_set_pointer (value
, self
->priv
->filter_func
);
237 case PROP_FILTER_DATA
:
238 g_value_set_pointer (value
, self
->priv
->filter_data
);
241 G_OBJECT_WARN_INVALID_PROPERTY_ID (object
, property_id
, pspec
);
247 empathy_roster_model_aggregator_set_property (GObject
*object
,
252 EmpathyRosterModelAggregator
*self
= EMPATHY_ROSTER_MODEL_AGGREGATOR (object
);
256 case PROP_AGGREGATOR
:
257 g_assert (self
->priv
->aggregator
== NULL
); /* construct only */
258 self
->priv
->aggregator
= g_value_dup_object (value
);
260 case PROP_FILTER_FUNC
:
261 g_assert (self
->priv
->filter_func
== NULL
); /* construct only */
262 self
->priv
->filter_func
= g_value_get_pointer (value
);
264 case PROP_FILTER_DATA
:
265 g_assert (self
->priv
->filter_data
== NULL
); /* construct only */
266 self
->priv
->filter_data
= g_value_get_pointer (value
);
269 G_OBJECT_WARN_INVALID_PROPERTY_ID (object
, property_id
, pspec
);
275 empathy_roster_model_aggregator_constructed (GObject
*object
)
277 EmpathyRosterModelAggregator
*self
= EMPATHY_ROSTER_MODEL_AGGREGATOR (object
);
278 void (*chain_up
) (GObject
*) =
279 ((GObjectClass
*) empathy_roster_model_aggregator_parent_class
)->constructed
;
281 if (chain_up
!= NULL
)
284 if (self
->priv
->aggregator
== NULL
)
285 self
->priv
->aggregator
= folks_individual_aggregator_dup ();
287 g_assert (FOLKS_IS_INDIVIDUAL_AGGREGATOR (self
->priv
->aggregator
));
289 tp_g_signal_connect_object (self
->priv
->aggregator
, "individuals-changed",
290 G_CALLBACK (aggregator_individuals_changed_cb
), self
, 0);
292 folks_individual_aggregator_prepare (self
->priv
->aggregator
, NULL
, NULL
);
294 populate_individuals (self
);
298 empathy_roster_model_aggregator_dispose (GObject
*object
)
300 EmpathyRosterModelAggregator
*self
= EMPATHY_ROSTER_MODEL_AGGREGATOR (object
);
301 void (*chain_up
) (GObject
*) =
302 ((GObjectClass
*) empathy_roster_model_aggregator_parent_class
)->dispose
;
304 g_clear_object (&self
->priv
->aggregator
);
305 g_clear_pointer (&self
->priv
->filtered_individuals
, g_hash_table_unref
);
307 if (chain_up
!= NULL
)
312 empathy_roster_model_aggregator_finalize (GObject
*object
)
314 //EmpathyRosterModelAggregator *self = EMPATHY_ROSTER_MODEL_AGGREGATOR (object);
315 void (*chain_up
) (GObject
*) =
316 ((GObjectClass
*) empathy_roster_model_aggregator_parent_class
)->finalize
;
318 if (chain_up
!= NULL
)
323 empathy_roster_model_aggregator_class_init (
324 EmpathyRosterModelAggregatorClass
*klass
)
326 GObjectClass
*oclass
= G_OBJECT_CLASS (klass
);
329 oclass
->get_property
= empathy_roster_model_aggregator_get_property
;
330 oclass
->set_property
= empathy_roster_model_aggregator_set_property
;
331 oclass
->constructed
= empathy_roster_model_aggregator_constructed
;
332 oclass
->dispose
= empathy_roster_model_aggregator_dispose
;
333 oclass
->finalize
= empathy_roster_model_aggregator_finalize
;
335 spec
= g_param_spec_object ("aggregator", "Aggregator",
336 "FolksIndividualAggregator",
337 FOLKS_TYPE_INDIVIDUAL_AGGREGATOR
,
338 G_PARAM_READWRITE
| G_PARAM_CONSTRUCT_ONLY
| G_PARAM_STATIC_STRINGS
);
339 g_object_class_install_property (oclass
, PROP_AGGREGATOR
, spec
);
341 spec
= g_param_spec_pointer ("filter-func", "Filter-Func",
342 "EmpathyRosterModelAggregatorFilterFunc",
343 G_PARAM_READWRITE
| G_PARAM_CONSTRUCT_ONLY
| G_PARAM_STATIC_STRINGS
);
344 g_object_class_install_property (oclass
, PROP_FILTER_FUNC
, spec
);
346 spec
= g_param_spec_pointer ("filter-data", "Filter-Data",
348 G_PARAM_READWRITE
| G_PARAM_CONSTRUCT_ONLY
| G_PARAM_STATIC_STRINGS
);
349 g_object_class_install_property (oclass
, PROP_FILTER_DATA
, spec
);
351 g_type_class_add_private (klass
, sizeof (EmpathyRosterModelAggregatorPriv
));
355 empathy_roster_model_aggregator_init (EmpathyRosterModelAggregator
*self
)
357 self
->priv
= G_TYPE_INSTANCE_GET_PRIVATE (self
,
358 EMPATHY_TYPE_ROSTER_MODEL_AGGREGATOR
, EmpathyRosterModelAggregatorPriv
);
360 self
->priv
->filtered_individuals
= g_hash_table_new_full (NULL
, NULL
, NULL
,
364 EmpathyRosterModelAggregator
*
365 empathy_roster_model_aggregator_new (
366 EmpathyRosterModelAggregatorFilterFunc filter_func
,
369 return g_object_new (EMPATHY_TYPE_ROSTER_MODEL_AGGREGATOR
,
370 "filter-func", filter_func
,
371 "filter-data", user_data
,
375 EmpathyRosterModelAggregator
*
376 empathy_roster_model_aggregator_new_with_aggregator (
377 FolksIndividualAggregator
*aggregator
,
378 EmpathyRosterModelAggregatorFilterFunc filter_func
,
381 g_return_val_if_fail (FOLKS_IS_INDIVIDUAL_AGGREGATOR (aggregator
), NULL
);
383 return g_object_new (EMPATHY_TYPE_ROSTER_MODEL_AGGREGATOR
,
384 "aggregator", aggregator
,
385 "filter-func", filter_func
,
386 "filter-data", user_data
,
391 empathy_roster_model_aggregator_get_individuals (EmpathyRosterModel
*model
)
393 EmpathyRosterModelAggregator
*self
= EMPATHY_ROSTER_MODEL_AGGREGATOR (model
);
395 return g_hash_table_get_values (self
->priv
->filtered_individuals
);
399 empathy_roster_model_aggregator_dup_groups_for_individual (
400 EmpathyRosterModel
*model
,
401 FolksIndividual
*individual
)
403 GList
*groups_list
= NULL
;
406 groups_set
= folks_group_details_get_groups (
407 FOLKS_GROUP_DETAILS (individual
));
408 if (gee_collection_get_size (GEE_COLLECTION (groups_set
)) > 0)
410 GeeIterator
*iter
= gee_iterable_iterator (GEE_ITERABLE (groups_set
));
412 while (iter
!= NULL
&& gee_iterator_next (iter
))
414 /* Transfer ownership: */
415 groups_list
= g_list_prepend (groups_list
, gee_iterator_get (iter
));
417 g_clear_object (&iter
);
424 roster_model_iface_init (EmpathyRosterModelInterface
*iface
)
426 iface
->get_individuals
= empathy_roster_model_aggregator_get_individuals
;
427 iface
->dup_groups_for_individual
=
428 empathy_roster_model_aggregator_dup_groups_for_individual
;