Don't leak errors
[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   for (i = 0; i < matchrule_array->len; i++)
554   {
555     char *matchrule = g_ptr_array_index (matchrule_array, i);
556     dbus_error_init (&d_error);
557     dbus_bus_add_match (_atspi_bus(), matchrule, &d_error);
558     if (dbus_error_is_set (&d_error))
559       {
560         g_warning ("Atspi: Adding match: %s", d_error.message);
561         dbus_error_free (&d_error);
562         /* TODO: Set error */
563       }
564
565     g_free (matchrule);
566   }
567   g_ptr_array_free (matchrule_array, TRUE);
568
569   message = dbus_message_new_method_call (atspi_bus_registry,
570         atspi_path_registry,
571         atspi_interface_registry,
572         "RegisterEvent");
573   if (!message)
574     return FALSE;
575   dbus_message_append_args (message, DBUS_TYPE_STRING, &event_type, DBUS_TYPE_INVALID);
576   reply = _atspi_dbus_send_with_reply_and_block (message, error);
577   if (reply)
578     dbus_message_unref (reply);
579
580   return TRUE;
581 }
582
583 /**
584  * atspi_event_listener_register_no_data:
585  * @callback: (scope notified): the #AtspiEventListenerSimpleCB to be
586  *            registered against an event type.
587  * @callback_destroyed: A #GDestroyNotify called when the callback is destroyed.
588  * @event_type: a character string indicating the type of events for which
589  *            notification is requested.  Format is
590  *            EventClass:major_type:minor_type:detail
591  *            where all subfields other than EventClass are optional.
592  *            EventClasses include "object", "window", "mouse",
593  *            and toolkit events (e.g. "Gtk", "AWT").
594  *            Examples: "focus:", "Gtk:GtkWidget:button_press_event".
595  *
596  * Registers an #AtspiEventListenetSimpleCB. The method is similar to 
597  * #atspi_event_listener_register, but @callback takes no user_data.
598  *
599  * Returns: #TRUE if successfull, otherwise #FALSE.
600  **/
601 gboolean
602 atspi_event_listener_register_no_data (AtspiEventListenerSimpleCB callback,
603                                  GDestroyNotify callback_destroyed,
604                                  const gchar              *event_type,
605                                  GError **error)
606 {
607   return atspi_event_listener_register_from_callback (remove_datum, callback,
608                                                       callback_destroyed,
609                                                       event_type, error);
610 }
611
612 static gboolean
613 is_superset (const gchar *super, const gchar *sub)
614 {
615   if (!super || !super [0])
616     return TRUE;
617   return (strcmp (super, sub) == 0);
618 }
619
620 /**
621  * atspi_event_listener_deregister:
622  * @listener: The #AtspiEventListener to deregister.
623  * @event_type: a string specifying the event type for which this
624  *             listener is to be deregistered.
625  *
626  * Deregisters an #AtspiEventListener from the registry, for a specific
627  *             event type.
628  *
629  * Returns: #TRUE if successful, otherwise #FALSE.
630  **/
631 gboolean
632 atspi_event_listener_deregister (AtspiEventListener *listener,
633                                                const gchar              *event_type,
634                                                GError **error)
635 {
636   return atspi_event_listener_deregister_from_callback (listener->callback,
637                                                         listener->user_data,
638                                                         event_type, error);
639 }
640
641 /**
642  * atspi_event_listener_deregister_from_callback:
643  * @callback: (scope call): the #AtspiEventListenerCB registered against an
644  *            event type.
645  * @user_data: (closure): User data that was passed in for this callback.
646  * @event_type: a string specifying the event type for which this
647  *             listener is to be deregistered.
648  *
649  * Deregisters an #AtspiEventListenerCB from the registry, for a specific
650  *             event type.
651  *
652  * Returns: #TRUE if successful, otherwise #FALSE.
653  **/
654 gboolean
655 atspi_event_listener_deregister_from_callback (AtspiEventListenerCB callback,
656                                                void *user_data,
657                                                const gchar              *event_type,
658                                                GError **error)
659 {
660   char *category, *name, *detail;
661   GPtrArray *matchrule_array;
662   gint i;
663   GList *l;
664
665   if (!convert_event_type_to_dbus (event_type, &category, &name, &detail, &matchrule_array))
666   {
667     return FALSE;
668   }
669   if (!callback)
670     {
671       return FALSE;
672     }
673
674   for (l = event_listeners; l;)
675   {
676     EventListenerEntry *e = l->data;
677     if (e->callback == callback &&
678         e->user_data == user_data &&
679         is_superset (category, e->category) &&
680         is_superset (name, e->name) &&
681         is_superset (detail, e->detail))
682     {
683       gboolean need_replace;
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_bus_remove_match (_atspi_bus(), matchrule, NULL);
693       }
694       message = dbus_message_new_method_call (atspi_bus_registry,
695             atspi_path_registry,
696             atspi_interface_registry,
697             "DeregisterEvent");
698       if (!message)
699       return FALSE;
700       dbus_message_append_args (message, DBUS_TYPE_STRING, &event_type, DBUS_TYPE_INVALID);
701       reply = _atspi_dbus_send_with_reply_and_block (message, error);
702       if (reply)
703         dbus_message_unref (reply);
704
705       listener_entry_free (e);
706     }
707     else l = g_list_next (l);
708   }
709   g_free (category);
710   g_free (name);
711   if (detail) g_free (detail);
712   for (i = 0; i < matchrule_array->len; i++)
713     g_free (g_ptr_array_index (matchrule_array, i));
714   g_ptr_array_free (matchrule_array, TRUE);
715   return TRUE;
716 }
717
718 /**
719  * atspi_event_listener_deregister_no_data:
720  * @callback: (scope call): the #AtspiEventListenerSimpleCB registered against
721  *            an event type.
722  * @event_type: a string specifying the event type for which this
723  *             listener is to be deregistered.
724  *
725  * deregisters an #AtspiEventListenerSimpleCB from the registry, for a specific
726  *             event type.
727  *
728  * Returns: #TRUE if successful, otherwise #FALSE.
729  **/
730 gboolean
731 atspi_event_listener_deregister_no_data (AtspiEventListenerSimpleCB callback,
732                                    const gchar              *event_type,
733                                    GError **error)
734 {
735   return atspi_event_listener_deregister_from_callback (remove_datum, callback,
736                                                         event_type,
737                                                         error);
738 }
739
740 static AtspiEvent *
741 atspi_event_copy (AtspiEvent *src)
742 {
743   AtspiEvent *dst = g_new0 (AtspiEvent, 1);
744   dst->type = g_strdup (src->type);
745   dst->source = g_object_ref (src->source);
746   dst->detail1 = src->detail1;
747   dst->detail2 = src->detail2;
748   g_value_init (&dst->any_data, G_VALUE_TYPE (&src->any_data));
749   g_value_copy (&src->any_data, &dst->any_data);
750   return dst;
751 }
752
753 static void
754 atspi_event_free (AtspiEvent *event)
755 {
756   g_object_unref (event->source);
757   g_free (event->type);
758   g_value_unset (&event->any_data);
759   g_free (event);
760 }
761
762 static gboolean
763 detail_matches_listener (const char *event_detail, const char *listener_detail)
764 {
765   if (!listener_detail)
766     return TRUE;
767
768   return !(listener_detail [strcspn (listener_detail, ":")] == '\0'
769                ? strncmp (listener_detail, event_detail,
770                           strcspn (event_detail, ":"))
771                : strcmp (listener_detail, event_detail));
772 }
773
774 void
775 _atspi_send_event (AtspiEvent *e)
776 {
777   char *category, *name, *detail;
778   GList *l;
779
780   /* Ensure that the value is set to avoid a Python exception */
781   /* TODO: Figure out how to do this without using a private field */
782   if (e->any_data.g_type == 0)
783   {
784     g_value_init (&e->any_data, G_TYPE_INT);
785     g_value_set_int (&e->any_data, 0);
786   }
787
788   if (!convert_event_type_to_dbus (e->type, &category, &name, &detail, NULL))
789   {
790     g_warning ("Atspi: Couldn't parse event: %s\n", e->type);
791     return;
792   }
793   for (l = event_listeners; l; l = g_list_next (l))
794   {
795     EventListenerEntry *entry = l->data;
796     if (!strcmp (category, entry->category) &&
797         (entry->name == NULL || !strcmp (name, entry->name)) &&
798         detail_matches_listener (detail, entry->detail))
799     {
800         entry->callback (atspi_event_copy (e), entry->user_data);
801     }
802   }
803   if (detail) g_free (detail);
804   g_free (name);
805   g_free (category);
806 }
807
808 DBusHandlerResult
809 _atspi_dbus_handle_event (DBusConnection *bus, DBusMessage *message, void *data)
810 {
811   char *detail = NULL;
812   const char *category = dbus_message_get_interface (message);
813   const char *member = dbus_message_get_member (message);
814   const char *signature = dbus_message_get_signature (message);
815   gchar *name;
816   gchar *converted_type;
817   DBusMessageIter iter, iter_variant;
818   dbus_message_iter_init (message, &iter);
819   AtspiEvent e;
820   dbus_int32_t detail1, detail2;
821   char *p;
822
823   if (strcmp (signature, "siiv(so)") != 0)
824   {
825     g_warning ("Got invalid signature %s for signal %s from interface %s\n", signature, member, category);
826     return DBUS_HANDLER_RESULT_HANDLED;
827   }
828
829   memset (&e, 0, sizeof (e));
830
831   if (category)
832   {
833     category = g_utf8_strrchr (category, -1, '.');
834     if (category == NULL)
835     {
836       // TODO: Error
837       return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
838     }
839     category++;
840   }
841   dbus_message_iter_get_basic (&iter, &detail);
842   dbus_message_iter_next (&iter);
843   dbus_message_iter_get_basic (&iter, &detail1);
844   e.detail1 = detail1;
845   dbus_message_iter_next (&iter);
846   dbus_message_iter_get_basic (&iter, &detail2);
847   e.detail2 = detail2;
848   dbus_message_iter_next (&iter);
849
850   converted_type = convert_name_from_dbus (category, FALSE);
851   name = convert_name_from_dbus (member, FALSE);
852   detail = convert_name_from_dbus (detail, TRUE);
853
854   if (strcasecmp  (category, name) != 0)
855   {
856     p = g_strconcat (converted_type, ":", name, NULL);
857     g_free (converted_type);
858     converted_type = p;
859   }
860   else if (detail [0] == '\0')
861   {
862     p = g_strconcat (converted_type, ":",  NULL);
863     g_free (converted_type);
864     converted_type = p;
865   }
866
867   if (detail[0] != '\0')
868   {
869     p = g_strconcat (converted_type, ":", detail, NULL);
870     g_free (converted_type);
871     converted_type = p;
872   }
873   e.type = converted_type;
874   e.source = _atspi_ref_accessible (dbus_message_get_sender(message), dbus_message_get_path(message));
875
876   dbus_message_iter_recurse (&iter, &iter_variant);
877   switch (dbus_message_iter_get_arg_type (&iter_variant))
878   {
879     case DBUS_TYPE_STRUCT:
880     {
881       AtspiRect rect;
882       if (demarshal_rect (&iter_variant, &rect))
883       {
884         g_value_init (&e.any_data, ATSPI_TYPE_RECT);
885         g_value_set_boxed (&e.any_data, &rect);
886       }
887       else
888       {
889         AtspiAccessible *accessible;
890         accessible = _atspi_dbus_return_accessible_from_iter (&iter_variant);
891         g_value_init (&e.any_data, ATSPI_TYPE_ACCESSIBLE);
892         g_value_set_instance (&e.any_data, accessible);
893         if (accessible)
894           g_object_unref (accessible);  /* value now owns it */
895       }
896       break;
897     }
898     case DBUS_TYPE_STRING:
899     {
900       dbus_message_iter_get_basic (&iter_variant, &p);
901       g_value_init (&e.any_data, G_TYPE_STRING);
902       g_value_set_string (&e.any_data, p);
903       break;
904     }
905   default:
906     break;
907   }
908
909   if (!strncmp (e.type, "object:children-changed", 23))
910   {
911     cache_process_children_changed (&e);
912   }
913   else if (!strncmp (e.type, "object:property-change", 22))
914   {
915     cache_process_property_change (&e);
916   }
917   else if (!strncmp (e.type, "object:state-changed", 20))
918   {
919     cache_process_state_changed (&e);
920   }
921   else if (!strncmp (e.type, "focus", 5))
922   {
923     /* BGO#663992 - TODO: figure out the real problem */
924     e.source->cached_properties &= ~(ATSPI_CACHE_STATES);
925   }
926
927   _atspi_send_event (&e);
928
929   g_free (converted_type);
930   g_free (name);
931   g_free (detail);
932   g_object_unref (e.source);
933   g_value_unset (&e.any_data);
934   return DBUS_HANDLER_RESULT_HANDLED;
935 }
936
937 G_DEFINE_BOXED_TYPE (AtspiEvent, atspi_event, atspi_event_copy, atspi_event_free)