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