2003-06-26 Padraig O'Briain <padraig.obriain@sun.com>
[platform/core/uifw/at-spi2-atk.git] / atk-bridge / bridge.c
index 6c66892..1d3c732 100644 (file)
@@ -2,7 +2,8 @@
  * AT-SPI - Assistive Technology Service Provider Interface
  * (Gnome Accessibility Project; http://developer.gnome.org/projects/gap)
  *
- * Copyright 2001 Sun Microsystems Inc.
+ * Copyright 2001, 2002, 2003 Sun Microsystems Inc.,
+ * Copyright 2001, 2002, 2003 Ximian, Inc.
  *
  * This library is free software; you can redistribute it and/or
  * modify it under the terms of the GNU Library General Public
  * Boston, MA 02111-1307, USA.
  */
 
+#include <string.h>
 #include <stdio.h>
 #include <stdlib.h>
+#include <stdarg.h>
 #include <libbonobo.h>
 #include <orbit/orbit.h>
 #include <atk/atk.h>
 #include <atk/atkobject.h>
 #include <atk/atknoopobject.h>
 #include <libspi/Accessibility.h>
+#include <libspi/spi-private.h>
 #include "accessible.h"
 #include "application.h"
 
-#define SPI_BRIDGE_DEBUG 1
+#include <bonobo-activation/bonobo-activation-register.h>
 
-#define APP_STATIC_BUFF_SZ 64
+#undef SPI_BRIDGE_DEBUG
 
-typedef struct _ArgStruct ArgStruct;
-
-struct _ArgStruct {
-  gint c;
-  char **v;
-};
+#define DBG(a,b) if(_dbg>=(a))b
 
+static int _dbg = 0;
 static CORBA_Environment ev;
-static Accessibility_Registry registry;
-static SpiApplication *this_app;
-
-static gboolean bridge_register_app (gpointer p);
-static void bridge_focus_tracker (AtkObject *object);
-static void bridge_exit_func(void);
-static gboolean bridge_register_event_listener ();
-static void register_atk_event_listeners();
-static gboolean bridge_property_event_listener (GSignalInvocationHint *signal_hint,
-                                               guint n_param_values,
-                                               const GValue *param_values,
-                                               gpointer data);
-static gboolean bridge_state_event_listener (GSignalInvocationHint *signal_hint,
-                                            guint n_param_values,
-                                            const GValue *param_values,
-                                            gpointer data);
-static gboolean bridge_signal_listener (GSignalInvocationHint *signal_hint,
-                                       guint n_param_values,
-                                       const GValue *param_values,
-                                       gpointer data);
+static Accessibility_Registry registry = CORBA_OBJECT_NIL;
+static Accessibility_DeviceEventController device_event_controller = CORBA_OBJECT_NIL;
+static SpiApplication *this_app = NULL;
+static gboolean registry_died = FALSE;
+static gboolean atk_listeners_registered = FALSE;
+static gint toplevels = 0;
 
-static gint bridge_key_listener (AtkImplementor *atk_impl,
-                                AtkKeyEventStruct *event,
-                                gpointer data);
+static guint atk_signal_text_changed;
+static guint atk_signal_children_changed;
+static guint atk_signal_active_descendant_changed;
+static guint atk_signal_text_selection_changed;
 
-int
-gtk_module_init(gint *argc, gchar **argv[])
+/* NOT YET USED
+   static guint atk_signal_row_reordered;
+   static guint atk_signal_row_inserted;
+   static guint atk_signal_row_deleted;
+   static guint atk_signal_column_reordered;
+   static guint atk_signal_column_inserted;
+   static guint atk_signal_column_deleted;
+*/
+
+static guint atk_signal_link_selected;
+
+static Accessibility_Registry spi_atk_bridge_get_registry (void);
+static void     spi_atk_bridge_do_registration         (void);
+static void     spi_atk_bridge_toplevel_added          (AtkObject             *object,
+                                                        guint                 index,
+                                                        AtkObject             *child);
+static void     spi_atk_bridge_toplevel_removed        (AtkObject             *object,
+                                                        guint                 index,
+                                                        AtkObject             *child);
+
+static void     spi_atk_bridge_exit_func               (void);
+static void     spi_atk_register_event_listeners       (void);
+static void     spi_atk_deregister_event_listeners     (void);
+static void     spi_atk_bridge_focus_tracker           (AtkObject             *object);
+static void     spi_atk_bridge_register_application    (Accessibility_Registry registry);
+static gboolean spi_atk_bridge_property_event_listener (GSignalInvocationHint *signal_hint,
+                                                       guint                  n_param_values,
+                                                       const GValue          *param_values,
+                                                       gpointer               data);
+static gboolean
+spi_atk_bridge_window_event_listener (GSignalInvocationHint *signal_hint,
+                               guint n_param_values,
+                               const GValue *param_values,
+                               gpointer data);
+static gboolean
+spi_atk_bridge_state_event_listener (GSignalInvocationHint *signal_hint,
+                                    guint n_param_values,
+                                    const GValue *param_values,
+                                    gpointer data);
+static gboolean spi_atk_bridge_signal_listener         (GSignalInvocationHint *signal_hint,
+                                                       guint                  n_param_values,
+                                                       const GValue          *param_values,
+                                                       gpointer               data);
+static gint     spi_atk_bridge_key_listener            (AtkKeyEventStruct     *event,
+                                                       gpointer               data);
+static void     spi_atk_tidy_windows                   (void);
+static void     deregister_application                 (BonoboObject          *app);
+static void     reinit_register_vars                   (void);
+
+/* For automatic libgnome init */
+extern void gnome_accessibility_module_init     (void);
+extern void gnome_accessibility_module_shutdown (void);
+
+static int     atk_bridge_initialized = FALSE;
+static guint   atk_bridge_focus_tracker_id = 0;
+static guint   atk_bridge_key_event_listener_id = 0;
+static GArray *listener_ids = NULL;
+
+/*
+ *   These exported symbols are hooked by gnome-program
+ * to provide automatic module initialization and shutdown.
+ */
+extern void gnome_accessibility_module_init     (void);
+extern void gnome_accessibility_module_shutdown (void);
+
+static void
+spi_atk_bridge_init_event_type_consts ()
 {
-  ArgStruct *args = (ArgStruct *) g_new0(ArgStruct, 1);
-  args->c = *argc;
-  args->v = *argv;
-  g_idle_add (bridge_register_app, args);
-  g_atexit (bridge_exit_func);
+  static gboolean done = FALSE;
+
+  if (done)
+    return;
+
+  atk_signal_children_changed = g_signal_lookup ("children_changed", 
+                                             ATK_TYPE_OBJECT);
+  atk_signal_text_changed = g_signal_lookup ("text_changed", 
+                                            ATK_TYPE_TEXT);
+  atk_signal_active_descendant_changed = 
+         g_signal_lookup ("active_descendant_changed", 
+                         ATK_TYPE_OBJECT);
+  atk_signal_link_selected = g_signal_lookup ("link_selected", 
+                                             ATK_TYPE_HYPERTEXT);
+  atk_signal_text_selection_changed = g_signal_lookup ("text_selection_changed", 
+                                             ATK_TYPE_TEXT);
+  done = TRUE;
 }
 
-static gboolean
-bridge_register_app (gpointer gp)
+static int
+atk_bridge_init (gint *argc, gchar **argv[])
 {
-  CORBA_Object oclient;
-  AtkObject *atko;
-  char *obj_id;
-  ArgStruct *args = (ArgStruct *)gp;
+  const char *debug_env_string = g_getenv ("AT_SPI_DEBUG");
 
-  CORBA_exception_init(&ev);
+  if (atk_bridge_initialized)
+    {
+      return 0;
+    }
+  atk_bridge_initialized = TRUE;
 
-  if (!bonobo_init (&(args->c), args->v))
+  if (debug_env_string)
+    _dbg = (int) g_ascii_strtod (debug_env_string, NULL);
+
+  if (!bonobo_init (argc, argv ? *argv : NULL))
     {
       g_error ("Could not initialize Bonobo");
     }
 
-  /* Create the accesssible application server object */
-  this_app = spi_application_new(atk_get_root ());
+  /*
+   * We only want to enable the bridge for top level
+   * applications, we detect bonobo components by seeing
+   * if they were activated with the intention of extracting
+   * an impl. by IID - very solid.
+   */
+  if (bonobo_activation_iid_get ())
+    {
+      DBG (1, g_message ("Found Bonobo component\n"));
+      g_signal_connect (atk_get_root (), 
+                        "children-changed::add",
+                        (GCallback) spi_atk_bridge_toplevel_added, 
+                        NULL);
+      g_signal_connect (atk_get_root (), 
+                        "children-changed::remove",
+                        (GCallback) spi_atk_bridge_toplevel_removed, 
+                        NULL);
+    }
+  else
+    {
+      spi_atk_bridge_do_registration ();
+      spi_atk_bridge_init_event_type_consts ();
+    }
+  return 0;
+}
+
 
-  obj_id = "OAFIID:Accessibility_Registry:proto0.1";
+static void
+spi_atk_bridge_do_registration (void)
+{
+  CORBA_Environment ev;
 
-  oclient = bonobo_activation_activate_from_id (obj_id, 0, NULL, &ev);
-  if (ev._major != CORBA_NO_EXCEPTION) {
-    fprintf(stderr,
-            ("Accessibility app error: exception during registry activation from id: %s\n"),
-            CORBA_exception_id(&ev));
-    CORBA_exception_free(&ev);
-    exit(-1);
-  }
+  CORBA_exception_init(&ev);
 
-  if (CORBA_Object_is_nil (oclient, &ev))
+  if (spi_atk_bridge_get_registry () == CORBA_OBJECT_NIL)
     {
       g_error ("Could not locate registry");
     }
 
-  registry = (Accessibility_Registry) oclient;
+  bonobo_activate ();
 
-  fprintf(stderr, "About to register application\n");
+  /* Create the accessible application server object */
 
-  bonobo_activate ();
+  this_app = spi_application_new (atk_get_root ());
+
+  DBG (1, g_message ("About to register application\n"));
 
-  Accessibility_Registry_registerApplication (registry,
-                                              CORBA_Object_duplicate (BONOBO_OBJREF (this_app), &ev),
+  spi_atk_bridge_register_application (spi_atk_bridge_get_registry ());
+  
+  g_atexit (spi_atk_bridge_exit_func);
+
+  DBG (1, g_message ("Application registered & listening\n"));
+
+}
+
+static void
+spi_atk_bridge_toplevel_added (AtkObject *object,
+                               guint     index,
+                               AtkObject *child)
+{
+  if (toplevels == 0)
+    {
+      spi_atk_bridge_do_registration ();
+      spi_atk_bridge_init_event_type_consts ();
+    }
+  toplevels++;
+}
+
+static void
+spi_atk_bridge_toplevel_removed (AtkObject *object,
+                                 guint     index,
+                                 AtkObject *child)
+{
+  BonoboObject *app = (BonoboObject *) this_app;
+
+  toplevels--;
+  if (toplevels == 0)
+    {
+      deregister_application (app);
+      spi_atk_deregister_event_listeners ();
+      reinit_register_vars ();
+    }
+  if (toplevels < 0)
+    {
+      g_warning ("More toplevels removed than added\n");
+      toplevels = 0;
+    }
+}
+
+static void
+spi_atk_bridge_register_application (Accessibility_Registry registry)
+{
+  Accessibility_Registry_registerApplication (spi_atk_bridge_get_registry (),
+                                              BONOBO_OBJREF (this_app),
                                               &ev);
+  spi_atk_register_event_listeners ();
+}
+
+static Accessibility_Registry
+spi_atk_bridge_get_registry (void)
+{
+  CORBA_Environment ev;
+
+  if (registry_died || (registry == CORBA_OBJECT_NIL)) {
+         CORBA_exception_init (&ev);
+         if (registry_died) 
+           DBG (1, g_warning ("registry died! restarting..."));
+         registry = bonobo_activation_activate_from_id (
+                 "OAFIID:Accessibility_Registry:1.0", 0, NULL, &ev);
+         
+         if (ev._major != CORBA_NO_EXCEPTION)
+         {
+                 g_error ("Accessibility app error: exception during "
+                          "registry activation from id: %s\n",
+                          CORBA_exception_id (&ev));
+                 CORBA_exception_free (&ev);
+         }
+         
+         if (registry_died && registry) {
+                 registry_died = FALSE;
+                 spi_atk_bridge_register_application (registry);
+         }
+  }
+  return registry;
+}
+
+static Accessibility_DeviceEventController
+spi_atk_bridget_get_dec (void)
+{
+  CORBA_Environment ev;
 
-  register_atk_event_listeners ();
+  if (device_event_controller != CORBA_OBJECT_NIL)
+    {
+      if (ORBit_small_get_connection_status (device_event_controller)
+         == ORBIT_CONNECTION_CONNECTED)
+        return device_event_controller;
+    }
+
+  CORBA_exception_init (&ev);
+
+  device_event_controller =
+    Accessibility_Registry_getDeviceEventController (
+           spi_atk_bridge_get_registry (), &ev);
+
+  if (BONOBO_EX (&ev))
+    {
+      g_warning ("failure: no deviceeventcontroller found\n");
+      registry_died = TRUE;
+      device_event_controller = CORBA_OBJECT_NIL;
+    }
 
-  return FALSE;
+  return device_event_controller;
+}
+
+int
+gtk_module_init (gint *argc, gchar **argv[])
+{
+       return atk_bridge_init (argc, argv);
 }
 
 static void
-register_atk_event_listeners ()
+add_signal_listener (const char *signal_name)
 {
-  GType t;
+  guint id;
+
+  id = atk_add_global_event_listener (
+    spi_atk_bridge_signal_listener, signal_name);
+
+  g_array_append_val (listener_ids, id);
+}
 
+static void
+spi_atk_register_event_listeners (void)
+{
   /*
    * kludge to make sure the Atk interface types are registered, otherwise
    * the AtkText signal handlers below won't get registered
    */
+  guint      id;
+  GObject   *ao = g_object_new (ATK_TYPE_OBJECT, NULL);
+  AtkObject *bo = atk_no_op_object_new (ao);
 
-  AtkNoOpObject *o = atk_no_op_object_new (g_object_new (ATK_TYPE_OBJECT, NULL));
+
+  if (atk_listeners_registered) return;
+
+  atk_listeners_registered = TRUE;
 
   /* Register for focus event notifications, and register app with central registry  */
 
-  g_type_class_ref (ATK_TYPE_TEXT);
-  g_type_class_ref (ATK_TYPE_SELECTION);
-  g_type_class_ref (ATK_TYPE_TABLE);
-
-  atk_add_focus_tracker (bridge_focus_tracker);
-  atk_add_global_event_listener (bridge_property_event_listener, "Gtk:AtkObject:property-change");
-  atk_add_global_event_listener (bridge_signal_listener, "Gtk:AtkObject:children-changed");
-  atk_add_global_event_listener (bridge_signal_listener, "Gtk:AtkObject:visible-data-changed");
-  atk_add_global_event_listener (bridge_signal_listener, "Gtk:AtkSelection:selection-changed");
-  atk_add_global_event_listener (bridge_signal_listener, "Gtk:AtkText:text-selection-changed");
-  atk_add_global_event_listener (bridge_signal_listener, "Gtk:AtkText:text-changed");
-  atk_add_global_event_listener (bridge_signal_listener, "Gtk:AtkText:text-caret-moved");
-  atk_add_global_event_listener (bridge_signal_listener, "Gtk:AtkTable:row-inserted");
-  atk_add_global_event_listener (bridge_signal_listener, "Gtk:AtkTable:row-reordered");
-  atk_add_global_event_listener (bridge_signal_listener, "Gtk:AtkTable:row-deleted");
-  atk_add_global_event_listener (bridge_signal_listener, "Gtk:AtkTable:column-inserted");
-  atk_add_global_event_listener (bridge_signal_listener, "Gtk:AtkTable:column-reordered");
-  atk_add_global_event_listener (bridge_signal_listener, "Gtk:AtkTable:column-deleted");
-  atk_add_global_event_listener (bridge_signal_listener, "Gtk:AtkTable:model-changed");
-  atk_add_key_event_listener    (bridge_key_listener, NULL);
+  listener_ids = g_array_sized_new (FALSE, TRUE, sizeof (guint), 16);
+
+  atk_bridge_focus_tracker_id = atk_add_focus_tracker (spi_atk_bridge_focus_tracker);
+
+  id = atk_add_global_event_listener (spi_atk_bridge_property_event_listener,
+                                     "Gtk:AtkObject:property-change");
+  g_array_append_val (listener_ids, id);
+  id = atk_add_global_event_listener (spi_atk_bridge_window_event_listener,
+                                     "window:create");
+  g_array_append_val (listener_ids, id);
+  id = atk_add_global_event_listener (spi_atk_bridge_window_event_listener,
+                                     "window:destroy");
+  g_array_append_val (listener_ids, id);
+  id = atk_add_global_event_listener (spi_atk_bridge_window_event_listener,
+                                     "window:minimize");
+  g_array_append_val (listener_ids, id);
+  id = atk_add_global_event_listener (spi_atk_bridge_window_event_listener,
+                                     "window:maximize");
+  g_array_append_val (listener_ids, id);
+  id = atk_add_global_event_listener (spi_atk_bridge_window_event_listener,
+                                     "window:restore");
+  g_array_append_val (listener_ids, id);
+  id = atk_add_global_event_listener (spi_atk_bridge_window_event_listener,
+                                     "window:activate");
+  g_array_append_val (listener_ids, id);
+  id = atk_add_global_event_listener (spi_atk_bridge_window_event_listener,
+                                     "window:deactivate");
+  g_array_append_val (listener_ids, id);
+  id = atk_add_global_event_listener (spi_atk_bridge_state_event_listener,
+                                     "Gtk:AtkObject:state-change");
+  g_array_append_val (listener_ids, id);
+
+  add_signal_listener ("Gtk:AtkObject:children-changed");
+  add_signal_listener ("Gtk:AtkObject:visible-data-changed");
+  add_signal_listener ("Gtk:AtkObject:active-descendant-changed");
+  add_signal_listener ("Gtk:AtkSelection:selection-changed");
+  add_signal_listener ("Gtk:AtkText:text-selection-changed");
+  add_signal_listener ("Gtk:AtkText:text-changed");
+  add_signal_listener ("Gtk:AtkText:text-caret-moved");
+  add_signal_listener ("Gtk:AtkTable:row-inserted");
+  add_signal_listener ("Gtk:AtkTable:row-reordered");
+  add_signal_listener ("Gtk:AtkTable:row-deleted");
+  add_signal_listener ("Gtk:AtkTable:column-inserted");
+  add_signal_listener ("Gtk:AtkTable:column-reordered");
+  add_signal_listener ("Gtk:AtkTable:column-deleted");
+  add_signal_listener ("Gtk:AtkTable:model-changed");
+  add_signal_listener ("Gtk:AtkHypertext:link-selected");
+/*
+ * May add the following listeners to implement preemptive key listening for GTK+
+ *
+ * atk_add_global_event_listener (spi_atk_bridge_widgetkey_listener, "Gtk:GtkWidget:key-press-event");
+ * atk_add_global_event_listener (spi_atk_bridge_widgetkey_listener, "Gtk:GtkWidget:key-release-event");
+ */
+  atk_bridge_key_event_listener_id = atk_add_key_event_listener (
+    spi_atk_bridge_key_listener, NULL);
+  
+  g_object_unref (G_OBJECT (bo));
+  g_object_unref (ao);
+}
+
+static void
+spi_atk_deregister_event_listeners (void)
+{
+  gint i;
+  guint id;
+
+  if (!atk_listeners_registered)
+    return;
+
+  atk_listeners_registered = FALSE;
+
+  for (i = 0; i < listener_ids->len; i++)
+    {
+      id = g_array_index (listener_ids, guint, i);
+      atk_remove_global_event_listener (id);   
+    }
+  g_array_free (listener_ids, TRUE);
+  listener_ids = NULL;
+
+  atk_remove_focus_tracker (atk_bridge_focus_tracker_id);
+  atk_bridge_focus_tracker_id = 0;
+
+  atk_remove_key_event_listener (atk_bridge_key_event_listener_id);
+  atk_bridge_key_event_listener_id = 0;
+}
+
+static void
+deregister_application (BonoboObject *app)
+{
+  Accessibility_Registry registry = spi_atk_bridge_get_registry ();    
+  Accessibility_Registry_deregisterApplication (registry, BONOBO_OBJREF (app), &ev);
+
+  device_event_controller = bonobo_object_release_unref (device_event_controller, &ev);
+  registry = bonobo_object_release_unref (registry, &ev);
+  
+  app = bonobo_object_unref (app);
+}
+
+static void
+spi_atk_bridge_exit_func (void)
+{
+  BonoboObject *app = (BonoboObject *) this_app;
+
+  DBG (1, g_message ("exiting bridge\n"));
+
+  if (!app)
+    {
+      return;
+    }
+  this_app = NULL;
+
+  /*
+   * Check whether we still have windows which have not been deleted.
+   */
+  spi_atk_tidy_windows ();
+  /*
+   *  FIXME: this may be incorrect for apps that do their own bonobo
+   *  shutdown, until we can explicitly shutdown to get the ordering
+   *  right.
+   */
+  if (!bonobo_is_initialized ())
+    {
+      DBG (1, g_warning ("Re-initializing bonobo\n"));
+      g_assert (bonobo_init (0, NULL));
+      g_assert (bonobo_activate ());
+    }
+  
+  deregister_application (app);
+
+  DBG (1, g_message ("bridge exit func complete.\n"));
+
+  if (g_getenv ("AT_BRIDGE_SHUTDOWN"))
+    {
+      g_assert (!bonobo_debug_shutdown ());
+    }
 }
 
-static void bridge_exit_func()
+void
+gnome_accessibility_module_init (void)
 {
-  fprintf (stderr, "exiting bridge\n");
-  Accessibility_Registry_deregisterApplication (registry,
-                                               CORBA_Object_duplicate (BONOBO_OBJREF (this_app), &ev),
-                                               &ev);
-  fprintf (stderr, "bridge exit func complete.\n");
+  atk_bridge_init (NULL, NULL);
+
+  g_print("Atk Accessibilty bridge initialized\n");
 }
 
-static void bridge_focus_tracker (AtkObject *object)
+void
+gnome_accessibility_module_shutdown (void)
 {
-  Accessibility_Event *e = Accessibility_Event__alloc();
-  e->type = CORBA_string_dup ("focus:");
-  e->source = CORBA_Object_duplicate (BONOBO_OBJREF (spi_accessible_new (object)), &ev);
-  e->detail1 = 0;
-  e->detail2 = 0;
-  Accessibility_Registry_notifyEvent (registry, e, &ev);
+  BonoboObject *app = (BonoboObject *) this_app;
+  int     i;
+  GArray *ids = listener_ids;
+  
+  if (!atk_bridge_initialized)
+    {
+      return;
+    }
+  atk_bridge_initialized = FALSE;
+  this_app = NULL;
+
+  g_print("Atk Accessibilty bridge shutdown\n");
+
+  listener_ids = NULL;
+  atk_remove_focus_tracker (atk_bridge_focus_tracker_id);
+  
+  for (i = 0; ids && i < ids->len; i++)
+  {
+          atk_remove_global_event_listener (g_array_index (ids, guint, i));
+  }
+  
+  atk_remove_key_event_listener (atk_bridge_key_event_listener_id);
+
+  deregister_application (app);
+}
+
+static void
+spi_atk_bridge_focus_tracker (AtkObject *object)
+{
+  SpiAccessible *source;
+  Accessibility_Event e;
+
+  source = spi_accessible_new (object);
+
+  e.type = "focus:";
+  e.source = BONOBO_OBJREF (source);
+  e.detail1 = 0;
+  e.detail2 = 0;
+  spi_init_any_nil (&e.any_data);
+
+  CORBA_exception_init (&ev);
+  Accessibility_Registry_notifyEvent (spi_atk_bridge_get_registry (), &e, &ev);
+  if (BONOBO_EX (&ev))
+    registry_died = TRUE;
+
+  bonobo_object_unref (source);
+  
+  CORBA_exception_free (&ev);
+}
+
+static void
+spi_atk_emit_eventv (const GObject         *gobject,
+                    long                   detail1,
+                    long                   detail2,
+                    CORBA_any             *any,
+                    const char            *format, ...)
+{
+  va_list             args;
+  Accessibility_Event e;
+  SpiAccessible      *source;
+  AtkObject          *aobject;
+#ifdef SPI_BRIDGE_DEBUG
+  CORBA_string s;
+#endif
+  
+  va_start (args, format);
+  
+  if (ATK_IS_IMPLEMENTOR (gobject))
+    {
+      aobject = atk_implementor_ref_accessible (ATK_IMPLEMENTOR (gobject));
+      source  = spi_accessible_new (aobject);
+      g_object_unref (G_OBJECT (aobject));
+    }
+  else if (ATK_IS_OBJECT (gobject))
+    {
+      aobject = ATK_OBJECT (gobject);
+      source  = spi_accessible_new (aobject);
+    }
+  else
+    {
+      aobject = NULL;
+      source  = NULL;
+      DBG (0, g_warning ("received property-change event from non-AtkImplementor"));
+    }
+
+  if (source) 
+    {
+      e.type = g_strdup_vprintf (format, args);
+      e.source = BONOBO_OBJREF (source);
+      e.detail1 = detail1;
+      e.detail2 = detail2;
+      if (any) e.any_data = *any;
+      else spi_init_any_nil (&e.any_data);
+
+#ifdef SPI_BRIDGE_DEBUG
+      s = Accessibility_Accessible__get_name (BONOBO_OBJREF (source), &ev);
+      g_warning ("Emitting event '%s' (%lu, %lu) on %s",
+                e.type, e.detail1, e.detail2, s);
+      CORBA_free (s);
+#endif
+      CORBA_exception_init (&ev);
+      Accessibility_Registry_notifyEvent (spi_atk_bridge_get_registry (), 
+                                         &e, &ev);
+#ifdef SPI_BRIDGE_DEBUG
+      if (ev._major != CORBA_NO_EXCEPTION)
+       g_warning ("error emitting event %s, (%d) %s",
+                  e.type,
+                  ev._major,
+                  CORBA_exception_id(&ev));
+#endif       
+      if (BONOBO_EX (&ev)) registry_died = TRUE;
+      Accessibility_Accessible_unref (e.source, &ev);
+      
+      CORBA_exception_free (&ev);
+      
+      g_free (e.type);
+    }
+
+  va_end (args);
+
 }
 
 static gboolean
-bridge_property_event_listener (GSignalInvocationHint *signal_hint,
-                               guint n_param_values,
-                               const GValue *param_values,
-                               gpointer data)
+spi_atk_bridge_property_event_listener (GSignalInvocationHint *signal_hint,
+                                       guint n_param_values,
+                                       const GValue *param_values,
+                                       gpointer data)
 {
-  Accessibility_Event *e = Accessibility_Event__alloc();
-  Bonobo_Unknown source = NULL;
-  AtkObject *aobject;
   AtkPropertyValues *values;
   GObject *gobject;
+  const gchar *prop_name;
+  CORBA_any any;
+  const gchar *sp = NULL;
+  AtkObject *ao;
+  SpiAccessible *s_ao = NULL;
+  CORBA_Object c_obj;
+  gint i;
+
+#ifdef SPI_BRIDGE_DEBUG
   GSignalQuery signal_query;
-  gchar *name;
-  char sbuf[APP_STATIC_BUFF_SZ];
+  const gchar *name;
+  const gchar *s, *s2;
   
   g_signal_query (signal_hint->signal_id, &signal_query);
   name = signal_query.signal_name;
-#ifdef SPI_BRIDGE_DEBUG
-  fprintf (stderr, "Received (property) signal %s:%s\n",
-          g_type_name (signal_query.itype), name);
+
+  s2 = g_type_name (G_OBJECT_TYPE (g_value_get_object (param_values + 0)));
+  s = atk_object_get_name (ATK_OBJECT (g_value_get_object (param_values + 0)));
+  values = (AtkPropertyValues*) g_value_get_pointer (param_values + 1);
+  DBG (2, g_message ("Received (property) signal %s:%s:%s from object %s (gail %s)\n",
+          g_type_name (signal_query.itype), name, values->property_name, s, s2));
+  
 #endif
+
   gobject = g_value_get_object (param_values + 0);
   values = (AtkPropertyValues*) g_value_get_pointer (param_values + 1);
 
-  /* notify the actual listeners */
-  if (ATK_IS_IMPLEMENTOR (gobject))
-  {
-    aobject = atk_implementor_ref_accessible (ATK_IMPLEMENTOR (gobject));
-    source = CORBA_Object_duplicate (BONOBO_OBJREF (spi_accessible_new (aobject)), &ev);
-    g_object_unref (G_OBJECT(aobject));
-  }
-  else if (ATK_IS_OBJECT (gobject))
-  {
-    aobject = ATK_OBJECT (gobject);
-    source = CORBA_Object_duplicate (BONOBO_OBJREF (spi_accessible_new (aobject)), &ev);
-  }
+  prop_name = values->property_name;
+  if (strcmp (prop_name, "accessible-name") == 0)
+    {
+      sp = atk_object_get_name (ATK_OBJECT (gobject));
+      spi_init_any_string (&any, (gchar **)&sp);
+    }
+  else if (strcmp (prop_name, "accessible-description") == 0)
+    {
+      sp = atk_object_get_description (ATK_OBJECT (gobject));
+      spi_init_any_string (&any, (gchar **)&sp);
+    }
+  else if (strcmp (prop_name, "accessible-parent") == 0)
+    {
+      ao = atk_object_get_parent (ATK_OBJECT (gobject));
+      if (ao) 
+        {
+          s_ao = spi_accessible_new (ao);
+          c_obj = BONOBO_OBJREF (s_ao);
+          spi_init_any_object (&any, &c_obj);
+       }
+      else
+        {
+          spi_init_any_nil (&any);
+        }
+    }
+  else if (strcmp (prop_name, "accessible-table-summary") == 0)
+    {
+      ao = atk_table_get_summary (ATK_TABLE (gobject));
+      if (ao) 
+        {
+          s_ao = spi_accessible_new (ao);
+          c_obj = BONOBO_OBJREF (s_ao);
+          spi_init_any_object (&any, &c_obj);
+       }
+      else
+        {
+          spi_init_any_nil (&any);
+        }
+    }
+  else if (strcmp (prop_name, "accessible-table-column-header") == 0)
+    {
+      i = g_value_get_int (&(values->new_value));
+      ao = atk_table_get_column_header (ATK_TABLE (gobject), i);
+      if (ao) 
+        {
+          s_ao = spi_accessible_new (ao);
+          c_obj = BONOBO_OBJREF (s_ao);
+          spi_init_any_object (&any, &c_obj);
+       }
+      else
+        {
+          spi_init_any_nil (&any);
+        }
+    }
+  else if (strcmp (prop_name, "accessible-table-row-header") == 0)
+    {
+      i = g_value_get_int (&(values->new_value));
+      ao = atk_table_get_row_header (ATK_TABLE (gobject), i);
+      if (ao) 
+        {
+          s_ao = spi_accessible_new (ao);
+          c_obj = BONOBO_OBJREF (s_ao);
+          spi_init_any_object (&any, &c_obj);
+       }
+      else
+        {
+          spi_init_any_nil (&any);
+        }
+    }
+  else if (strcmp (prop_name, "accessible-table-row-description") == 0)
+    {
+      i = g_value_get_int (&(values->new_value));
+      sp = atk_table_get_row_description (ATK_TABLE (gobject), i);
+      spi_init_any_string (&any, (gchar **)&sp);
+    }
+  else if (strcmp (prop_name, "accessible-table-column-description") == 0)
+    {
+      i = g_value_get_int (&(values->new_value));
+      sp = atk_table_get_column_description (ATK_TABLE (gobject), i);
+      spi_init_any_string (&any, (gchar **)&sp);
+    }
+  else if (strcmp (prop_name, "accessible-table-caption-object") == 0)
+    {
+      ao = atk_table_get_caption (ATK_TABLE (gobject));
+      sp = atk_object_get_name (ao);
+      spi_init_any_string (&any, (gchar **)&sp);
+    }
   else
-  {
-    g_error("received property-change event from non-AtkImplementor");
-  }
-  
-  snprintf(sbuf, APP_STATIC_BUFF_SZ, "object:property-change:%s", values->property_name);
-  e->type = CORBA_string_dup (sbuf);
-  e->source = source;
-  e->detail1 = 0;
-  e->detail2 = 0;
-  if (source)
-    Accessibility_Registry_notifyEvent (registry, e, &ev);
+    {
+      spi_init_any_nil (&any);
+    }
+
+  spi_atk_emit_eventv (gobject, 0, 0, &any,
+                      "object:property-change:%s", prop_name);
+
+
   return TRUE;
 }
 
 static gboolean
-bridge_state_event_listener (GSignalInvocationHint *signal_hint,
-                            guint n_param_values,
-                            const GValue *param_values,
-                            gpointer data)
+spi_atk_bridge_state_event_listener (GSignalInvocationHint *signal_hint,
+                                    guint n_param_values,
+                                    const GValue *param_values,
+                                    gpointer data)
 {
-  Accessibility_Event *e = Accessibility_Event__alloc();
-  Bonobo_Unknown source = NULL;
-  AtkObject *aobject;
-  AtkPropertyValues *values;
   GObject *gobject;
+  gchar *property_name;
+  gchar *type;
+  unsigned long detail1;
+#ifdef SPI_BRIDGE_DEBUG
   GSignalQuery signal_query;
-  gchar *name;
-  char sbuf[APP_STATIC_BUFF_SZ];
+  const gchar *name;
   
   g_signal_query (signal_hint->signal_id, &signal_query);
   name = signal_query.signal_name;
-#ifdef SPI_BRIDGE_DEBUG
   fprintf (stderr, "Received (state) signal %s:%s\n",
           g_type_name (signal_query.itype), name);
 #endif
+
   gobject = g_value_get_object (param_values + 0);
-  values = (AtkPropertyValues*) g_value_get_pointer (param_values + 1);
+  property_name = g_strdup (g_value_get_string (param_values + 1));
+  detail1 = (g_value_get_boolean (param_values + 2))
+    ? 1 : 0;
+  type = g_strdup_printf ("object:state-changed:%s", property_name);
+  spi_atk_emit_eventv (gobject, 
+                      detail1,
+                      0,
+                      NULL,
+                      type);
+  g_free (property_name);
+  g_free (type);
+  return TRUE;
+}
 
-  /* notify the actual listeners */
-  if (ATK_IS_IMPLEMENTOR (gobject))
-  {
-    aobject = atk_implementor_ref_accessible (ATK_IMPLEMENTOR (gobject));
-    source = CORBA_Object_duplicate (BONOBO_OBJREF (spi_accessible_new (aobject)), &ev);
-    g_object_unref (G_OBJECT(aobject));
-  }
-  else if (ATK_IS_OBJECT (gobject))
-  {
-    aobject = ATK_OBJECT (gobject);
-    source = CORBA_Object_duplicate (BONOBO_OBJREF (spi_accessible_new (aobject)), &ev);
-  }
+static void
+spi_init_keystroke_from_atk_key_event (Accessibility_DeviceEvent  *keystroke,
+                                      AtkKeyEventStruct          *event)
+{
+#ifdef SPI_DEBUG
+  if (event)
+    {
+      g_print ("event %c (%d)\n", (int) event->keyval, (int) event->keycode);
+    }
   else
-  {
-    g_error("received property-change event from non-AtkImplementor");
-  }
+#endif
+  if (!event)
+    {
+      g_print ("WARNING: NULL key event!");
+    }
   
-  snprintf(sbuf, APP_STATIC_BUFF_SZ, "object:%s:%s", values->property_name, "?");
-  e->type = CORBA_string_dup (sbuf);
-  e->source = source;
-  e->detail1 = (unsigned long) values->old_value.data[0].v_ulong;
-  e->detail2 = (unsigned long) values->new_value.data[0].v_ulong;
-  if (source)
-    Accessibility_Registry_notifyEvent (registry, e, &ev);
-  return TRUE;
+  keystroke->id        = (CORBA_long) event->keyval;
+  keystroke->hw_code   = (CORBA_short) event->keycode;
+  keystroke->timestamp = (CORBA_unsigned_long) event->timestamp;
+  keystroke->modifiers = (CORBA_unsigned_short) (event->state & 0xFFFF);
+  if (event->string)
+    {
+      gunichar c;
+
+      keystroke->event_string = CORBA_string_dup (event->string);
+      c = g_utf8_get_char_validated (event->string, -1);
+      if (c > 0 && g_unichar_isprint (c))
+        keystroke->is_text = CORBA_TRUE;
+      else
+        keystroke->is_text = CORBA_FALSE;
+    }
+  else
+    {
+      keystroke->event_string = CORBA_string_dup ("");
+      keystroke->is_text = CORBA_FALSE;
+    }
+  switch (event->type)
+    {
+    case (ATK_KEY_EVENT_PRESS):
+      keystroke->type = Accessibility_KEY_PRESSED_EVENT;
+      break;
+    case (ATK_KEY_EVENT_RELEASE):
+      keystroke->type = Accessibility_KEY_RELEASED_EVENT;
+      break;
+    default:
+      keystroke->type = 0;
+      break;
+    }
+#if 0  
+  g_print ("key_event type %d; val=%d code=%d modifiers=%x name=%s is_text=%d, time=%lx\n",
+          (int) keystroke->type, (int) keystroke->id, (int) keystroke->hw_code,
+          (int) keystroke->modifiers,
+          keystroke->event_string, (int) keystroke->is_text, (unsigned long) keystroke->timestamp);
+#endif
 }
 
 static gint
-bridge_key_listener (AtkImplementor *atk_impl, AtkKeyEventStruct *event, gpointer data)
+spi_atk_bridge_key_listener (AtkKeyEventStruct *event, gpointer data)
 {
-  Accessibility_KeyStroke *key_event;
-  static Accessibility_DeviceEventController controller = CORBA_OBJECT_NIL;
-  if (controller == CORBA_OBJECT_NIL)
-    {
-      controller = Accessibility_Registry_getDeviceEventController (registry, &ev);
-    }
-  g_print ("bridge key listener fired!\n");
-/* Accessibility_DeviceEventController_notifyListenersSync (controller, key_event, &ev); */
+  CORBA_boolean             result;
+  Accessibility_DeviceEvent key_event;
+
+  CORBA_exception_init (&ev);
+
+  spi_init_keystroke_from_atk_key_event (&key_event, event);
+
+  result = Accessibility_DeviceEventController_notifyListenersSync (
+         spi_atk_bridget_get_dec (), &key_event, &ev);
+
+  CORBA_exception_free (&ev);
+
+  return result;
 }
 
 static gboolean
-bridge_signal_listener (GSignalInvocationHint *signal_hint,
-                       guint n_param_values,
-                       const GValue *param_values,
-                       gpointer data)
+spi_atk_bridge_signal_listener (GSignalInvocationHint *signal_hint,
+                               guint n_param_values,
+                               const GValue *param_values,
+                               gpointer data)
 {
-  Accessibility_Event *e = g_new0(Accessibility_Event, 1);
-  AtkObject *aobject;
-  Bonobo_Unknown source;
-  AtkPropertyValues *values;
   GObject *gobject;
   GSignalQuery signal_query;
-  gchar *name;
-  char sbuf[APP_STATIC_BUFF_SZ];
+  const gchar *name;
+  const gchar *detail;
+  CORBA_any any;
+  CORBA_Object c_obj;
+  char *sp = NULL;
+  AtkObject *ao;
+  AtkText *text;
+  gint detail1 = 0, detail2 = 0;
+  SpiAccessible *s_ao = NULL;
+#ifdef SPI_BRIDGE_DEBUG
+  const gchar *s, *s2;
+#endif 
   
   g_signal_query (signal_hint->signal_id, &signal_query);
+
   name = signal_query.signal_name;
+  if (signal_hint->detail)
+    detail = g_quark_to_string (signal_hint->detail);
+  else
+    detail = NULL;
+
 #ifdef SPI_BRIDGE_DEBUG
-  fprintf (stderr, "Received signal %s:%s\n",
-          g_type_name (signal_query.itype), name);
+  s2 = g_type_name (G_OBJECT_TYPE (g_value_get_object (param_values + 0)));
+  s = atk_object_get_name (ATK_OBJECT (g_value_get_object (param_values + 0)));
+  fprintf (stderr, "Received signal %s:%s detail: %s from object %s (gail %s)\n",
+          g_type_name (signal_query.itype), name, 
+          detail ? detail : "<NULL>", s ? s : "<NULL>" , s2);
 #endif
+  
   gobject = g_value_get_object (param_values + 0);
 
-  /* notify the actual listeners */
-  if (ATK_IS_IMPLEMENTOR (gobject))
-  {
-    aobject = atk_implementor_ref_accessible (ATK_IMPLEMENTOR (gobject));
-  }
-  else if (ATK_IS_OBJECT (gobject))
-  {
-    aobject = ATK_OBJECT (gobject);
-    g_object_ref (aobject);
-  }
+  if (signal_query.signal_id == atk_signal_active_descendant_changed)
+    {
+      gpointer child = g_value_get_pointer (param_values + 1);
+
+      g_return_val_if_fail (ATK_IS_OBJECT (child), TRUE);
+
+      ao = ATK_OBJECT (child);
+
+      detail1 = atk_object_get_index_in_parent (ao);
+      s_ao = spi_accessible_new (ao);
+      c_obj = BONOBO_OBJREF (s_ao);
+      spi_init_any_object (&any, &c_obj);
+    }
+  else if (signal_query.signal_id == atk_signal_link_selected)
+    {
+      if (G_VALUE_TYPE (param_values + 1) == G_TYPE_INT)
+        detail1 = g_value_get_int (param_values + 1);
+      spi_init_any_nil (&any);
+    }
+  else if ((signal_query.signal_id == atk_signal_children_changed) && gobject)
+    {
+      ao = atk_object_ref_accessible_child (ATK_OBJECT (gobject), 
+                                           detail1);
+      if (ao) 
+        {
+          s_ao = spi_accessible_new (ao);
+          c_obj = BONOBO_OBJREF (s_ao);
+          spi_init_any_object (&any, &c_obj);
+         g_object_unref (ao);
+       }
+      else
+       {
+         spi_init_any_nil (&any);
+       }
+    }
   else
-  {
-    g_error("received property-change event from non-AtkImplementor");
-  }
+    {
+      if (n_param_values >= 2)
+        {
+          if (G_VALUE_TYPE (param_values + 1) == G_TYPE_INT)
+            detail1 = g_value_get_int (param_values + 1);
+          if (n_param_values >= 3)
+            {
+              if (G_VALUE_TYPE (param_values + 2) == G_TYPE_INT)
+                detail2 = g_value_get_int (param_values + 2);
+            }
+        }
+
+      if (signal_query.signal_id == atk_signal_text_changed)
+        {
+          sp = atk_text_get_text (ATK_TEXT (gobject),
+                                 detail1,
+                                 detail1+detail2);
+          spi_init_any_string (&any, &sp);
+        }
+      else if (signal_query.signal_id == atk_signal_text_selection_changed)
+        {
+          text = ATK_TEXT (gobject);
+          /* Return NULL as the selected string */
+         spi_init_any_nil (&any);
+        }
+      else
+        {
+         spi_init_any_nil (&any);
+        }
+    }
+
+  if (detail)
+    spi_atk_emit_eventv (gobject, detail1, detail2, &any,
+                        "object:%s:%s", name, detail);
+  else
+    spi_atk_emit_eventv (gobject, detail1, detail2, &any,
+                        "object:%s", name);
+
+  if (sp)
+    g_free (sp);
 
-  snprintf(sbuf, APP_STATIC_BUFF_SZ, "%s:%s", name, g_type_name (signal_query.itype));
-  source =  CORBA_Object_duplicate (BONOBO_OBJREF (spi_accessible_new (aobject)), &ev);
-  e->type = CORBA_string_dup (sbuf);
-  e->source = source;
-  e->detail1 = 0;
-  e->detail2 = 0;
-  Accessibility_Registry_notifyEvent (registry, e, &ev);
-  g_object_unref (aobject);
   return TRUE;
 }
 
-static Accessibility_Registry bridge_get_registry ()
+static gboolean
+spi_atk_bridge_window_event_listener (GSignalInvocationHint *signal_hint,
+                                     guint n_param_values,
+                                     const GValue *param_values,
+                                     gpointer data)
 {
-  return registry;
+  GObject *gobject;
+  GSignalQuery signal_query;
+  CORBA_any any;
+  const gchar *name, *s;
+#ifdef SPI_BRIDGE_DEBUG
+  const gchar *s2;
+#endif
+  
+  g_signal_query (signal_hint->signal_id, &signal_query);
+
+  name = signal_query.signal_name;
+
+#ifdef SPI_BRIDGE_DEBUG
+  s2 = g_type_name (G_OBJECT_TYPE (g_value_get_object (param_values + 0)));
+  s = atk_object_get_name (ATK_OBJECT (g_value_get_object (param_values + 0)));
+  fprintf (stderr, "Received signal %s:%s from object %s (gail %s)\n",
+          g_type_name (signal_query.itype), name, s ? s : "<NULL>" , s2);
+#endif
+  
+  gobject = g_value_get_object (param_values + 0);
+
+  s = atk_object_get_name (ATK_OBJECT (gobject));
+  spi_init_any_string (&any, (char **) &s);
+  
+  spi_atk_emit_eventv (gobject, 0, 0, &any,
+                      "window:%s", name);
+  return TRUE;
+}
+
+static void
+spi_atk_tidy_windows (void)
+{
+  AtkObject *root;
+  gint n_children;
+  gint i;
+
+  root = atk_get_root ();
+  n_children = atk_object_get_n_accessible_children (root);
+  for (i = 0; i < n_children; i++)
+    {
+      AtkObject *child;
+      AtkStateSet *stateset;
+      CORBA_any any;
+      const gchar *name;
+     
+      child = atk_object_ref_accessible_child (root, i);
+      stateset = atk_object_ref_state_set (child);
+      
+      name = atk_object_get_name (child);
+      spi_init_any_string (&any, (char**) &name);
+      if (atk_state_set_contains_state (stateset, ATK_STATE_ACTIVE))
+        {
+          spi_atk_emit_eventv (G_OBJECT (child), 0, 0, &any, "window:deactivate");
+        }
+      g_free (stateset);
+
+      spi_atk_emit_eventv (G_OBJECT (child), 0, 0, &any, "window:destroy");
+      g_object_unref (child);
+    }
 }
+
+static void
+reinit_register_vars (void)
+{
+  registry = CORBA_OBJECT_NIL;
+  device_event_controller = CORBA_OBJECT_NIL;
+  this_app = NULL;
+}
+