Code clean-ups
[platform/upstream/at-spi2-core.git] / atspi / atspi-event-listener.c
1 /*
2  * AT-SPI - Assistive Technology Service Provider Interface
3  * (Gnome Accessibility Project; http://developer.gnome.org/projects/gap)
4  *
5  * Copyright 2002 Ximian Inc.
6  * Copyright 2002 Sun Microsystems, Inc.
7  * Copyright 2010, 2011 Novell, Inc.
8  *
9  * This library is free software; you can redistribute it and/or
10  * modify it under the terms of the GNU Library General Public
11  * License as published by the Free Software Foundation; either
12  * version 2 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  * Library General Public License for more details.
18  *
19  * You should have received a copy of the GNU Library General Public
20  * License along with this library; if not, write to the
21  * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
22  * Boston, MA 02111-1307, USA.
23  */
24
25 #include "atspi-private.h"
26 #include <string.h>
27 #include <ctype.h>
28
29 typedef struct
30 {
31   AtspiEventListenerCB callback;
32   void *user_data;
33   GDestroyNotify callback_destroyed;
34   char *category;
35   char *name;
36   char *detail;
37 } EventListenerEntry;
38
39 G_DEFINE_TYPE (AtspiEventListener, atspi_event_listener, G_TYPE_OBJECT)
40
41 void
42 atspi_event_listener_init (AtspiEventListener *listener)
43 {
44 }
45
46 void
47 atspi_event_listener_class_init (AtspiEventListenerClass *klass)
48 {
49 }
50
51 static void
52 remove_datum (const AtspiEvent *event, void *user_data)
53 {
54   AtspiEventListenerSimpleCB cb = user_data;
55   cb (event);
56 }
57
58 typedef struct
59 {
60   gpointer callback;
61   GDestroyNotify callback_destroyed;
62   gint ref_count;
63 } CallbackInfo;
64 static GHashTable *callbacks;
65
66 void
67 callback_ref (void *callback, GDestroyNotify callback_destroyed)
68 {
69   CallbackInfo *info;
70
71   if (!callbacks)
72   {
73     callbacks = g_hash_table_new (g_direct_hash, g_direct_equal);
74     if (!callbacks)
75       return;
76   }
77
78   info = g_hash_table_lookup (callbacks, callback);
79   if (!info)
80   {
81     info = g_new (CallbackInfo, 1);
82     info->callback = callback;
83     info->callback_destroyed = callback_destroyed;
84     info->ref_count = 1;
85     g_hash_table_insert (callbacks, callback, info);
86   }
87   else
88     info->ref_count++;
89 }
90
91 void
92 callback_unref (gpointer callback)
93 {
94   CallbackInfo *info;
95
96   if (!callbacks)
97     return;
98   info = g_hash_table_lookup (callbacks, callback);
99   if (!info)
100   {
101     g_warning ("Atspi: Dereferencing invalid callback %p\n", callback);
102     return;
103   }
104   info->ref_count--;
105   if (info->ref_count == 0)
106   {
107 #if 0
108     /* TODO: Figure out why this seg faults from Python */
109     if (info->callback_destroyed)
110       (*info->callback_destroyed) (info->callback);
111 #endif
112     g_free (info);
113     g_hash_table_remove (callbacks, callback);
114   }
115 }
116
117 /**
118  * atspi_event_listener_new:
119  * @callback: (scope notified): An #AtspiEventListenerSimpleCB to be called
120  * when an event is fired.
121  * @user_data: (closure): data to pass to the callback.
122  * @callback_destroyed: A #GDestroyNotify called when the listener is freed
123  * and data associated with the callback should be freed.  Can be NULL.
124  *
125  * Creates a new #AtspiEventListener associated with a specified @callback.
126  *
127  * Returns: (transfer full): A new #AtspiEventListener.
128  */
129 AtspiEventListener *
130 atspi_event_listener_new (AtspiEventListenerCB callback,
131                                  gpointer user_data,
132                                  GDestroyNotify callback_destroyed)
133 {
134   AtspiEventListener *listener = g_object_new (ATSPI_TYPE_EVENT_LISTENER, NULL);
135   listener->callback = callback;
136   callback_ref (callback, callback_destroyed);
137   listener->user_data = user_data;
138   listener->cb_destroyed = callback_destroyed;
139   return listener;
140 }
141
142 /**
143  * atspi_event_listener_new_simple:
144  * @callback: (scope notified): An #AtspiEventListenerSimpleCB to be called
145  * when an event is fired.
146  * @callback_destroyed: A #GDestroyNotify called when the listener is freed
147  * and data associated with the callback should be freed.  Can be NULL.
148  *
149  * Creates a new #AtspiEventListener associated with a specified @callback.
150  * Returns: (transfer full): A new #AtspiEventListener.
151  **/
152 AtspiEventListener *
153 atspi_event_listener_new_simple (AtspiEventListenerSimpleCB callback,
154                                  GDestroyNotify callback_destroyed)
155 {
156   AtspiEventListener *listener = g_object_new (ATSPI_TYPE_EVENT_LISTENER, NULL);
157   listener->callback = remove_datum;
158   callback_ref (remove_datum, callback_destroyed);
159   listener->user_data = callback;
160   listener->cb_destroyed = callback_destroyed;
161   return listener;
162 }
163
164 static GList *event_listeners = NULL;
165
166 static gchar *
167 convert_name_from_dbus (const char *name, gboolean path_hack)
168 {
169   gchar *ret = g_malloc (g_utf8_strlen (name, -1) * 2 + 1);
170   const char *p = name;
171   gchar *q = ret;
172
173   if (!ret)
174     return NULL;
175
176   while (*p)
177   {
178     if (isupper (*p))
179     {
180       if (q > ret)
181         *q++ = '-';
182       *q++ = tolower (*p++);
183     }
184     else if (path_hack && *p == '/')
185     {
186       *q++ = ':';
187       p++;
188     }
189     else
190       *q++ = *p++;
191   }
192   *q = '\0';
193   return ret;
194 }
195
196 static void
197 cache_process_children_changed (AtspiEvent *event)
198 {
199   AtspiAccessible *child;
200
201   if (!G_VALUE_HOLDS (&event->any_data, ATSPI_TYPE_ACCESSIBLE) ||
202       !(event->source->cached_properties & ATSPI_CACHE_CHILDREN) ||
203       atspi_state_set_contains (event->source->states, ATSPI_STATE_MANAGES_DESCENDANTS))
204     return;
205
206   child = g_value_get_object (&event->any_data);
207
208   if (!strncmp (event->type, "object:children-changed:add", 27))
209   {
210     if (g_list_find (event->source->children, child))
211       return;
212     event->source->children = g_list_insert (event->source->children,
213                                              g_object_ref (child),
214                                              event->detail1);
215   }
216   else if (g_list_find (event->source->children, child))
217   {
218     event->source->children = g_list_remove (event->source->children, child);
219     if (child == child->parent.app->root)
220       g_object_run_dispose (G_OBJECT (child->parent.app));
221     g_object_unref (child);
222   }
223 }
224
225 static void
226 cache_process_property_change (AtspiEvent *event)
227 {
228   if (!strcmp (event->type, "object:property-change:accessible-parent"))
229   {
230     if (event->source->accessible_parent)
231       g_object_unref (event->source->accessible_parent);
232     if (G_VALUE_HOLDS (&event->any_data, ATSPI_TYPE_ACCESSIBLE))
233     {
234       event->source->accessible_parent = g_value_dup_object (&event->any_data);
235       _atspi_accessible_add_cache (event->source, ATSPI_CACHE_PARENT);
236     }
237     else
238     {
239       event->source->accessible_parent = NULL;
240       event->source->cached_properties &= ~ATSPI_CACHE_PARENT;
241     }
242   }
243   else if (!strcmp (event->type, "object:property-change:accessible-name"))
244   {
245     if (event->source->name)
246       g_free (event->source->name);
247     if (G_VALUE_HOLDS_STRING (&event->any_data))
248     {
249       event->source->name = g_value_dup_string (&event->any_data);
250       _atspi_accessible_add_cache (event->source, ATSPI_CACHE_NAME);
251     }
252     else
253     {
254       event->source->name = NULL;
255       event->source->cached_properties &= ~ATSPI_CACHE_NAME;
256     }
257   }
258   else if (!strcmp (event->type, "object:property-change:accessible-description"))
259   {
260     if (event->source->description)
261       g_free (event->source->description);
262     if (G_VALUE_HOLDS_STRING (&event->any_data))
263     {
264       event->source->description = g_value_dup_string (&event->any_data);
265       _atspi_accessible_add_cache (event->source, ATSPI_CACHE_DESCRIPTION);
266     }
267     else
268     {
269       event->source->description = NULL;
270       event->source->cached_properties &= ~ATSPI_CACHE_DESCRIPTION;
271     }
272   }
273 }
274
275 static void
276 cache_process_state_changed (AtspiEvent *event)
277 {
278   if (event->source->states)
279     atspi_state_set_set_by_name (event->source->states, event->type + 21,
280                                  event->detail1);
281 }
282
283 static dbus_bool_t
284 demarshal_rect (DBusMessageIter *iter, AtspiRect *rect)
285 {
286   dbus_int32_t x, y, width, height;
287   DBusMessageIter iter_struct;
288
289   dbus_message_iter_recurse (iter, &iter_struct);
290   if (dbus_message_iter_get_arg_type (&iter_struct) != DBUS_TYPE_INT32) return FALSE;
291   dbus_message_iter_get_basic (&iter_struct, &x);
292   dbus_message_iter_next (&iter_struct);
293   if (dbus_message_iter_get_arg_type (&iter_struct) != DBUS_TYPE_INT32) return FALSE;
294   dbus_message_iter_get_basic (&iter_struct, &y);
295   dbus_message_iter_next (&iter_struct);
296   if (dbus_message_iter_get_arg_type (&iter_struct) != DBUS_TYPE_INT32) return FALSE;
297   dbus_message_iter_get_basic (&iter_struct, &width);
298   dbus_message_iter_next (&iter_struct);
299   if (dbus_message_iter_get_arg_type (&iter_struct) != DBUS_TYPE_INT32) return FALSE;
300   dbus_message_iter_get_basic (&iter_struct, &height);
301   rect->x = x;
302   rect->y = y;
303   rect->width = width;
304   rect->height = height;
305   return TRUE;
306 }
307
308 static gchar *
309 strdup_and_adjust_for_dbus (const char *s)
310 {
311   gchar *d = g_strdup (s);
312   gchar *p;
313   int parts = 0;
314
315   if (!d)
316     return NULL;
317
318   for (p = d; *p; p++)
319   {
320     if (*p == '-')
321     {
322       memmove (p, p + 1, g_utf8_strlen (p, -1));
323       *p = toupper (*p);
324     }
325     else if (*p == ':')
326     {
327       parts++;
328       if (parts == 2)
329         break;
330       p [1] = toupper (p [1]);
331     }
332   }
333
334   d [0] = toupper (d [0]);
335   return d;
336 }
337
338 static gboolean
339 convert_event_type_to_dbus (const char *eventType, char **categoryp, char **namep, char **detailp, GPtrArray **matchrule_array)
340 {
341   gchar *tmp = strdup_and_adjust_for_dbus (eventType);
342   char *category = NULL, *name = NULL, *detail = NULL;
343   char *saveptr = NULL;
344
345   if (tmp == NULL) return FALSE;
346   category = strtok_r (tmp, ":", &saveptr);
347   if (category) category = g_strdup (category);
348   name = strtok_r (NULL, ":", &saveptr);
349   if (name)
350   {
351     name = g_strdup (name);
352     detail = strtok_r (NULL, ":", &saveptr);
353     if (detail) detail = g_strdup (detail);
354   }
355   if (matchrule_array)
356   {
357     gchar *matchrule;
358     matchrule = g_strdup_printf ("type='signal',interface='org.a11y.atspi.Event.%s'", category);
359     if (name && name [0])
360     {
361       gchar *new_str = g_strconcat (matchrule, ",member='", name, "'", NULL);
362       g_free (matchrule);
363       matchrule = new_str;
364     }
365     (*matchrule_array) = g_ptr_array_new ();
366     if (detail && detail [0])
367     {
368       gchar *new_str = g_strconcat (matchrule, ",arg0='", detail, "'", NULL);
369       g_ptr_array_add (*matchrule_array, new_str);
370       new_str = g_strconcat (matchrule, ",arg0path='", detail, "/'", NULL);
371       g_ptr_array_add (*matchrule_array, new_str);
372       g_free (matchrule);
373     }
374     else
375       g_ptr_array_add (*matchrule_array, matchrule);
376   }
377   if (categoryp) *categoryp = category;
378   else g_free (category);
379   if (namep) *namep = name;
380   else if (name) g_free (name);
381   if (detailp) *detailp = detail;
382   else if (detail) g_free (detail);
383   g_free (tmp);
384   return TRUE;
385 }
386
387 static void
388 listener_entry_free (EventListenerEntry *e)
389 {
390   gpointer callback = (e->callback == remove_datum ? (gpointer)e->user_data : (gpointer)e->callback);
391   g_free (e->category);
392   g_free (e->name);
393   if (e->detail) g_free (e->detail);
394   callback_unref (callback);
395   g_free (e);
396 }
397
398 /**
399  * atspi_event_listener_register:
400  * @listener: The #AtspiEventListener to register against an event type.
401  * @event_type: a character string indicating the type of events for which
402  *            notification is requested.  Format is
403  *            EventClass:major_type:minor_type:detail
404  *            where all subfields other than EventClass are optional.
405  *            EventClasses include "object", "window", "mouse",
406  *            and toolkit events (e.g. "Gtk", "AWT").
407  *            Examples: "focus:", "Gtk:GtkWidget:button_press_event".
408  *
409  * Adds an in-process callback function to an existing #AtspiEventListener.
410  *
411  * Legal object event types:
412  *
413  *    (property change events)
414  *
415  *            object:property-change
416  *            object:property-change:accessible-name
417  *            object:property-change:accessible-description
418  *            object:property-change:accessible-parent
419  *            object:property-change:accessible-value
420  *            object:property-change:accessible-role
421  *            object:property-change:accessible-table-caption
422  *            object:property-change:accessible-table-column-description
423  *            object:property-change:accessible-table-column-header
424  *            object:property-change:accessible-table-row-description
425  *            object:property-change:accessible-table-row-header
426  *            object:property-change:accessible-table-summary
427  *
428  *    (other object events)
429  *
430  *            object:state-changed 
431  *            object:children-changed
432  *            object:visible-data-changed
433  *            object:selection-changed
434  *            object:text-selection-changed
435  *            object:text-changed
436  *            object:text-caret-moved
437  *            object:row-inserted
438  *            object:row-reordered
439  *            object:row-deleted
440  *            object:column-inserted
441  *            object:column-reordered
442  *            object:column-deleted
443  *            object:model-changed
444  *            object:active-descendant-changed
445  *
446  *  (window events)
447  *
448  *            window:minimize
449  *            window:maximize
450  *            window:restore
451  *            window:close
452  *            window:create
453  *            window:reparent
454  *            window:desktop-create
455  *            window:desktop-destroy
456  *            window:activate
457  *            window:deactivate
458  *            window:raise
459  *            window:lower
460  *            window:move
461  *            window:resize
462  *            window:shade
463  *            window:unshade
464  *            window:restyle
465  *
466  *  (other events)
467  *
468  *            focus:
469  *            mouse:abs
470  *            mouse:rel
471  *            mouse:b1p
472  *            mouse:b1r
473  *            mouse:b2p
474  *            mouse:b2r
475  *            mouse:b3p
476  *            mouse:b3r
477  *
478  * NOTE: this character string may be UTF-8, but should not contain byte 
479  * value 56
480  *            (ascii ':'), except as a delimiter, since non-UTF-8 string
481  *            delimiting functions are used internally.
482  *            In general, listening to
483  *            toolkit-specific events is not recommended.
484  *
485  *
486  * Returns: #TRUE if successful, otherwise #FALSE.
487  **/
488 gboolean
489 atspi_event_listener_register (AtspiEventListener *listener,
490                                              const gchar              *event_type,
491                                              GError **error)
492 {
493   /* TODO: Keep track of which events have been registered, so that we
494  * deregister all of them when the event listener is destroyed */
495
496   return atspi_event_listener_register_from_callback (listener->callback,
497                                                       listener->user_data,
498                                                       listener->cb_destroyed,
499                                                       event_type, error);
500 }
501
502 /**
503  * atspi_event_listener_register_from_callback:
504  * @callback: (scope notified): the #AtspiEventListenerCB to be registered 
505  * against an event type.
506  * @user_data: (closure): User data to be passed to the callback.
507  * @callback_destroyed: A #GDestroyNotify called when the callback is destroyed.
508  * @event_type: a character string indicating the type of events for which
509  *            notification is requested.  See #atspi_event_listener_register
510  * for a description of the format.
511  * 
512  * Registers an #AtspiEventListenerCB against an @event_type.
513  *
514  * Returns: #TRUE if successfull, otherwise #FALSE.
515  *
516  **/
517 gboolean
518 atspi_event_listener_register_from_callback (AtspiEventListenerCB callback,
519                                              void *user_data,
520                                              GDestroyNotify callback_destroyed,
521                                              const gchar              *event_type,
522                                              GError **error)
523 {
524   EventListenerEntry *e;
525   DBusError d_error;
526   DBusMessage *message, *reply;
527   GPtrArray *matchrule_array;
528   gint i;
529
530   if (!callback)
531     {
532       return FALSE;
533     }
534
535   if (!event_type)
536   {
537     g_warning ("called atspi_event_listener_register_from_callback with a NULL event_type");
538     return FALSE;
539   }
540
541   e = g_new (EventListenerEntry, 1);
542   e->callback = callback;
543   e->user_data = user_data;
544   e->callback_destroyed = callback_destroyed;
545   callback_ref (callback == remove_datum ? (gpointer)user_data : (gpointer)callback,
546                 callback_destroyed);
547   if (!convert_event_type_to_dbus (event_type, &e->category, &e->name, &e->detail, &matchrule_array))
548   {
549     g_free (e);
550     return FALSE;
551   }
552   event_listeners = g_list_prepend (event_listeners, e);
553   dbus_error_init (&d_error);
554   for (i = 0; i < matchrule_array->len; i++)
555   {
556     char *matchrule = g_ptr_array_index (matchrule_array, i);
557     dbus_bus_add_match (_atspi_bus(), matchrule, &d_error);
558     g_free (matchrule);
559   }
560   g_ptr_array_free (matchrule_array, TRUE);
561   if (d_error.message)
562   {
563     g_warning ("Atspi: Adding match: %s", d_error.message);
564     /* TODO: Set error */
565   }
566
567   dbus_error_init (&d_error);
568   message = dbus_message_new_method_call (atspi_bus_registry,
569         atspi_path_registry,
570         atspi_interface_registry,
571         "RegisterEvent");
572   if (!message)
573     return FALSE;
574   dbus_message_append_args (message, DBUS_TYPE_STRING, &event_type, DBUS_TYPE_INVALID);
575   reply = _atspi_dbus_send_with_reply_and_block (message, error);
576   if (reply)
577     dbus_message_unref (reply);
578
579   return TRUE;
580 }
581
582 /**
583  * atspi_event_listener_register_no_data:
584  * @callback: (scope notified): the #AtspiEventListenerSimpleCB to be
585  *            registered against an event type.
586  * @callback_destroyed: A #GDestroyNotify called when the callback is destroyed.
587  * @event_type: a character string indicating the type of events for which
588  *            notification is requested.  Format is
589  *            EventClass:major_type:minor_type:detail
590  *            where all subfields other than EventClass are optional.
591  *            EventClasses include "object", "window", "mouse",
592  *            and toolkit events (e.g. "Gtk", "AWT").
593  *            Examples: "focus:", "Gtk:GtkWidget:button_press_event".
594  *
595  * Registers an #AtspiEventListenetSimpleCB. The method is similar to 
596  * #atspi_event_listener_register, but @callback takes no user_data.
597  *
598  * Returns: #TRUE if successfull, otherwise #FALSE.
599  **/
600 gboolean
601 atspi_event_listener_register_no_data (AtspiEventListenerSimpleCB callback,
602                                  GDestroyNotify callback_destroyed,
603                                  const gchar              *event_type,
604                                  GError **error)
605 {
606   return atspi_event_listener_register_from_callback (remove_datum, callback,
607                                                       callback_destroyed,
608                                                       event_type, error);
609 }
610
611 static gboolean
612 is_superset (const gchar *super, const gchar *sub)
613 {
614   if (!super || !super [0])
615     return TRUE;
616   return (strcmp (super, sub) == 0);
617 }
618
619 /**
620  * atspi_event_listener_deregister:
621  * @listener: The #AtspiEventListener to deregister.
622  * @event_type: a string specifying the event type for which this
623  *             listener is to be deregistered.
624  *
625  * Deregisters an #AtspiEventListener from the registry, for a specific
626  *             event type.
627  *
628  * Returns: #TRUE if successful, otherwise #FALSE.
629  **/
630 gboolean
631 atspi_event_listener_deregister (AtspiEventListener *listener,
632                                                const gchar              *event_type,
633                                                GError **error)
634 {
635   return atspi_event_listener_deregister_from_callback (listener->callback,
636                                                         listener->user_data,
637                                                         event_type, error);
638 }
639
640 /**
641  * atspi_event_listener_deregister_from_callback:
642  * @callback: (scope call): the #AtspiEventListenerCB registered against an
643  *            event type.
644  * @user_data: (closure): User data that was passed in for this callback.
645  * @event_type: a string specifying the event type for which this
646  *             listener is to be deregistered.
647  *
648  * Deregisters an #AtspiEventListenerCB from the registry, for a specific
649  *             event type.
650  *
651  * Returns: #TRUE if successful, otherwise #FALSE.
652  **/
653 gboolean
654 atspi_event_listener_deregister_from_callback (AtspiEventListenerCB callback,
655                                                void *user_data,
656                                                const gchar              *event_type,
657                                                GError **error)
658 {
659   char *category, *name, *detail;
660   GPtrArray *matchrule_array;
661   gint i;
662   GList *l;
663
664   if (!convert_event_type_to_dbus (event_type, &category, &name, &detail, &matchrule_array))
665   {
666     return FALSE;
667   }
668   if (!callback)
669     {
670       return FALSE;
671     }
672
673   for (l = event_listeners; l;)
674   {
675     EventListenerEntry *e = l->data;
676     if (e->callback == callback &&
677         e->user_data == user_data &&
678         is_superset (category, e->category) &&
679         is_superset (name, e->name) &&
680         is_superset (detail, e->detail))
681     {
682       gboolean need_replace;
683       DBusError d_error;
684       DBusMessage *message, *reply;
685       need_replace = (l == event_listeners);
686       l = g_list_remove (l, e);
687       if (need_replace)
688         event_listeners = l;
689       for (i = 0; i < matchrule_array->len; i++)
690       {
691         char *matchrule = g_ptr_array_index (matchrule_array, i);
692         dbus_error_init (&d_error);
693         dbus_bus_remove_match (_atspi_bus(), matchrule, &d_error);
694       }
695       dbus_error_init (&d_error);
696       message = dbus_message_new_method_call (atspi_bus_registry,
697             atspi_path_registry,
698             atspi_interface_registry,
699             "DeregisterEvent");
700       if (!message)
701       return FALSE;
702       dbus_message_append_args (message, DBUS_TYPE_STRING, &event_type, DBUS_TYPE_INVALID);
703       reply = _atspi_dbus_send_with_reply_and_block (message, error);
704       if (reply)
705         dbus_message_unref (reply);
706
707       listener_entry_free (e);
708     }
709     else l = g_list_next (l);
710   }
711   g_free (category);
712   g_free (name);
713   if (detail) g_free (detail);
714   for (i = 0; i < matchrule_array->len; i++)
715     g_free (g_ptr_array_index (matchrule_array, i));
716   g_ptr_array_free (matchrule_array, TRUE);
717   return TRUE;
718 }
719
720 /**
721  * atspi_event_listener_deregister_no_data:
722  * @callback: (scope call): the #AtspiEventListenerSimpleCB registered against
723  *            an event type.
724  * @event_type: a string specifying the event type for which this
725  *             listener is to be deregistered.
726  *
727  * deregisters an #AtspiEventListenerSimpleCB from the registry, for a specific
728  *             event type.
729  *
730  * Returns: #TRUE if successful, otherwise #FALSE.
731  **/
732 gboolean
733 atspi_event_listener_deregister_no_data (AtspiEventListenerSimpleCB callback,
734                                    const gchar              *event_type,
735                                    GError **error)
736 {
737   return atspi_event_listener_deregister_from_callback (remove_datum, callback,
738                                                         event_type,
739                                                         error);
740 }
741
742 static AtspiEvent *
743 atspi_event_copy (AtspiEvent *src)
744 {
745   AtspiEvent *dst = g_new0 (AtspiEvent, 1);
746   dst->type = g_strdup (src->type);
747   dst->source = g_object_ref (src->source);
748   dst->detail1 = src->detail1;
749   dst->detail2 = src->detail2;
750   g_value_init (&dst->any_data, G_VALUE_TYPE (&src->any_data));
751   g_value_copy (&src->any_data, &dst->any_data);
752   return dst;
753 }
754
755 static void
756 atspi_event_free (AtspiEvent *event)
757 {
758   g_object_unref (event->source);
759   g_free (event->type);
760   g_value_unset (&event->any_data);
761   g_free (event);
762 }
763
764 static gboolean
765 detail_matches_listener (const char *event_detail, const char *listener_detail)
766 {
767   if (!listener_detail)
768     return TRUE;
769
770   return !(listener_detail [strcspn (listener_detail, ":")] == '\0'
771                ? strncmp (listener_detail, event_detail,
772                           strcspn (event_detail, ":"))
773                : strcmp (listener_detail, event_detail));
774 }
775
776 void
777 _atspi_send_event (AtspiEvent *e)
778 {
779   char *category, *name, *detail;
780   GList *l;
781
782   /* Ensure that the value is set to avoid a Python exception */
783   /* TODO: Figure out how to do this without using a private field */
784   if (e->any_data.g_type == 0)
785   {
786     g_value_init (&e->any_data, G_TYPE_INT);
787     g_value_set_int (&e->any_data, 0);
788   }
789
790   if (!convert_event_type_to_dbus (e->type, &category, &name, &detail, NULL))
791   {
792     g_warning ("Atspi: Couldn't parse event: %s\n", e->type);
793     return;
794   }
795   for (l = event_listeners; l; l = g_list_next (l))
796   {
797     EventListenerEntry *entry = l->data;
798     if (!strcmp (category, entry->category) &&
799         (entry->name == NULL || !strcmp (name, entry->name)) &&
800         detail_matches_listener (detail, entry->detail))
801     {
802         entry->callback (atspi_event_copy (e), entry->user_data);
803     }
804   }
805   if (detail) g_free (detail);
806   g_free (name);
807   g_free (category);
808 }
809
810 DBusHandlerResult
811 _atspi_dbus_handle_event (DBusConnection *bus, DBusMessage *message, void *data)
812 {
813   char *detail = NULL;
814   const char *category = dbus_message_get_interface (message);
815   const char *member = dbus_message_get_member (message);
816   const char *signature = dbus_message_get_signature (message);
817   gchar *name;
818   gchar *converted_type;
819   DBusMessageIter iter, iter_variant;
820   dbus_message_iter_init (message, &iter);
821   AtspiEvent e;
822   dbus_int32_t detail1, detail2;
823   char *p;
824
825   if (strcmp (signature, "siiv(so)") != 0)
826   {
827     g_warning ("Got invalid signature %s for signal %s from interface %s\n", signature, member, category);
828     return DBUS_HANDLER_RESULT_HANDLED;
829   }
830
831   memset (&e, 0, sizeof (e));
832
833   if (category)
834   {
835     category = g_utf8_strrchr (category, -1, '.');
836     if (category == NULL)
837     {
838       // TODO: Error
839       return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
840     }
841     category++;
842   }
843   dbus_message_iter_get_basic (&iter, &detail);
844   dbus_message_iter_next (&iter);
845   dbus_message_iter_get_basic (&iter, &detail1);
846   e.detail1 = detail1;
847   dbus_message_iter_next (&iter);
848   dbus_message_iter_get_basic (&iter, &detail2);
849   e.detail2 = detail2;
850   dbus_message_iter_next (&iter);
851
852   converted_type = convert_name_from_dbus (category, FALSE);
853   name = convert_name_from_dbus (member, FALSE);
854   detail = convert_name_from_dbus (detail, TRUE);
855
856   if (strcasecmp  (category, name) != 0)
857   {
858     p = g_strconcat (converted_type, ":", name, NULL);
859     g_free (converted_type);
860     converted_type = p;
861   }
862   else if (detail [0] == '\0')
863   {
864     p = g_strconcat (converted_type, ":",  NULL);
865     g_free (converted_type);
866     converted_type = p;
867   }
868
869   if (detail[0] != '\0')
870   {
871     p = g_strconcat (converted_type, ":", detail, NULL);
872     g_free (converted_type);
873     converted_type = p;
874   }
875   e.type = converted_type;
876   e.source = _atspi_ref_accessible (dbus_message_get_sender(message), dbus_message_get_path(message));
877
878   dbus_message_iter_recurse (&iter, &iter_variant);
879   switch (dbus_message_iter_get_arg_type (&iter_variant))
880   {
881     case DBUS_TYPE_STRUCT:
882     {
883       AtspiRect rect;
884       if (demarshal_rect (&iter_variant, &rect))
885       {
886         g_value_init (&e.any_data, ATSPI_TYPE_RECT);
887         g_value_set_boxed (&e.any_data, &rect);
888       }
889       else
890       {
891         AtspiAccessible *accessible;
892         accessible = _atspi_dbus_return_accessible_from_iter (&iter_variant);
893         g_value_init (&e.any_data, ATSPI_TYPE_ACCESSIBLE);
894         g_value_set_instance (&e.any_data, accessible);
895         if (accessible)
896           g_object_unref (accessible);  /* value now owns it */
897       }
898       break;
899     }
900     case DBUS_TYPE_STRING:
901     {
902       dbus_message_iter_get_basic (&iter_variant, &p);
903       g_value_init (&e.any_data, G_TYPE_STRING);
904       g_value_set_string (&e.any_data, p);
905       break;
906     }
907   default:
908     break;
909   }
910
911   if (!strncmp (e.type, "object:children-changed", 23))
912   {
913     cache_process_children_changed (&e);
914   }
915   else if (!strncmp (e.type, "object:property-change", 22))
916   {
917     cache_process_property_change (&e);
918   }
919   else if (!strncmp (e.type, "object:state-changed", 20))
920   {
921     cache_process_state_changed (&e);
922   }
923   else if (!strncmp (e.type, "focus", 5))
924   {
925     /* BGO#663992 - TODO: figure out the real problem */
926     e.source->cached_properties &= ~(ATSPI_CACHE_STATES);
927   }
928
929   _atspi_send_event (&e);
930
931   g_free (converted_type);
932   g_free (name);
933   g_free (detail);
934   g_object_unref (e.source);
935   g_value_unset (&e.any_data);
936   return DBUS_HANDLER_RESULT_HANDLED;
937 }
938
939 G_DEFINE_BOXED_TYPE (AtspiEvent, atspi_event, atspi_event_copy, atspi_event_free)