2 * AT-SPI - Assistive Technology Service Provider Interface
3 * (Gnome Accessibility Project; http://developer.gnome.org/projects/gap)
5 * Copyright 2008 Novell, Inc.
6 * Copyright 2008 Codethink Ltd.
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.
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.
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.
29 #include "droute-pairhash.h"
31 #define CHUNKS_DEFAULT (512)
33 #define oom() g_error ("D-Bus out of memory, this message will fail anyway")
35 #if defined DROUTE_DEBUG
36 #define _DROUTE_DEBUG(format, args...) g_print (format , ## args)
38 #define _DROUTE_DEBUG(format, args...)
43 GPtrArray *registered_paths;
45 gchar *introspect_string;
54 GPtrArray *interfaces;
55 GPtrArray *introspection;
57 GHashTable *properties;
59 DRouteIntrospectChildrenFunction introspect_children_cb;
60 void *introspect_children_data;
62 DRouteGetDatumFunction get_datum;
65 /*---------------------------------------------------------------------------*/
67 typedef struct PropertyPair
69 DRoutePropertyFunction get;
70 DRoutePropertyFunction set;
73 /*---------------------------------------------------------------------------*/
75 static DBusHandlerResult
76 handle_message (DBusConnection *bus, DBusMessage *message, void *user_data);
79 droute_object_does_not_exist_error (DBusMessage *message);
81 /*---------------------------------------------------------------------------*/
84 path_new (DRouteContext *cnx,
88 DRouteIntrospectChildrenFunction introspect_children_cb,
89 void *introspect_children_data,
90 DRouteGetDatumFunction get_datum)
94 new_path = g_new0 (DRoutePath, 1);
96 new_path->path = g_strdup (path);
97 new_path->prefix = prefix;
98 new_path->chunks = g_string_chunk_new (CHUNKS_DEFAULT);
99 new_path->interfaces = g_ptr_array_new ();
100 new_path->introspection = g_ptr_array_new ();
102 new_path->methods = g_hash_table_new_full ((GHashFunc)str_pair_hash,
107 new_path->properties = g_hash_table_new_full ((GHashFunc)str_pair_hash,
112 new_path->introspect_children_cb = introspect_children_cb;
113 new_path->introspect_children_data = introspect_children_data;
114 new_path->user_data = user_data;
115 new_path->get_datum = get_datum;
121 path_free (DRoutePath *path, gpointer user_data)
124 g_string_chunk_free (path->chunks);
125 g_ptr_array_free (path->interfaces, TRUE);
126 g_free(g_ptr_array_free (path->introspection, FALSE));
127 g_hash_table_destroy (path->methods);
128 g_hash_table_destroy (path->properties);
133 path_get_datum (DRoutePath *path, const gchar *pathstr)
135 if (path->get_datum != NULL)
136 return (path->get_datum) (pathstr, path->user_data);
138 return path->user_data;
141 /*---------------------------------------------------------------------------*/
148 cnx = g_new0 (DRouteContext, 1);
149 cnx->registered_paths = g_ptr_array_new ();
155 droute_free (DRouteContext *cnx)
157 g_ptr_array_foreach (cnx->registered_paths, (GFunc) path_free, NULL);
158 g_ptr_array_free (cnx->registered_paths, TRUE);
162 /*---------------------------------------------------------------------------*/
164 /*---------------------------------------------------------------------------*/
166 static DBusObjectPathVTable droute_vtable =
170 NULL, NULL, NULL, NULL
174 droute_add_one (DRouteContext *cnx,
178 DRoutePath *new_path;
180 new_path = path_new (cnx, path, FALSE, (void *)data, NULL, NULL, NULL);
182 g_ptr_array_add (cnx->registered_paths, new_path);
187 droute_add_many (DRouteContext *cnx,
190 DRouteIntrospectChildrenFunction introspect_children_cb,
191 void *introspect_children_data,
192 const DRouteGetDatumFunction get_datum)
194 DRoutePath *new_path;
196 new_path = path_new (cnx, path, TRUE, (void *) data,
197 introspect_children_cb, introspect_children_data,
200 g_ptr_array_add (cnx->registered_paths, new_path);
204 /*---------------------------------------------------------------------------*/
207 droute_path_add_interface(DRoutePath *path,
209 const char *introspect,
210 const DRouteMethod *methods,
211 const DRouteProperty *properties)
215 g_return_if_fail (name != NULL);
217 itf = g_string_chunk_insert (path->chunks, name);
218 g_ptr_array_add (path->interfaces, itf);
219 g_ptr_array_add (path->introspection, (gpointer) introspect);
221 for (; methods != NULL && methods->name != NULL; methods++)
225 meth = g_string_chunk_insert (path->chunks, methods->name);
226 g_hash_table_insert (path->methods, str_pair_new (itf, meth), methods->func);
229 for (; properties != NULL && properties->name != NULL; properties++)
234 prop = g_string_chunk_insert (path->chunks, properties->name);
235 pair = g_new (PropertyPair, 1);
236 pair->get = properties->get;
237 pair->set = properties->set;
238 g_hash_table_insert (path->properties, str_pair_new (itf, prop), pair);
242 /*---------------------------------------------------------------------------*/
244 /* The data structures don't support an efficient implementation of GetAll
245 * and I don't really care.
248 impl_prop_GetAll (DBusMessage *message,
252 DBusMessageIter iter, iter_dict, iter_dict_entry;
255 GHashTableIter prop_iter;
261 void *datum = path_get_datum (path, pathstr);
263 return droute_object_does_not_exist_error (message);
265 dbus_error_init (&error);
266 if (!dbus_message_get_args
267 (message, &error, DBUS_TYPE_STRING, &iface, DBUS_TYPE_INVALID))
270 ret = dbus_message_new_error (message, DBUS_ERROR_FAILED, error.message);
271 dbus_error_free (&error);
275 reply = dbus_message_new_method_return (message);
279 dbus_message_iter_init_append (reply, &iter);
280 if (!dbus_message_iter_open_container
281 (&iter, DBUS_TYPE_ARRAY, "{sv}", &iter_dict))
284 g_hash_table_iter_init (&prop_iter, path->properties);
285 while (g_hash_table_iter_next (&prop_iter, (gpointer*)&key, (gpointer*)&value))
287 if (!g_strcmp0 (key->one, iface))
291 if (!dbus_message_iter_open_container
292 (&iter_dict, DBUS_TYPE_DICT_ENTRY, NULL, &iter_dict_entry))
294 dbus_message_iter_append_basic (&iter_dict_entry, DBUS_TYPE_STRING,
296 (value->get) (&iter_dict_entry, datum);
297 if (!dbus_message_iter_close_container (&iter_dict, &iter_dict_entry))
302 if (!dbus_message_iter_close_container (&iter, &iter_dict))
308 impl_prop_GetSet (DBusMessage *message,
313 DBusMessage *reply = NULL;
317 PropertyPair *prop_funcs = NULL;
321 dbus_error_init (&error);
322 if (!dbus_message_get_args (message,
331 ret = dbus_message_new_error (message, DBUS_ERROR_FAILED, error.message);
332 dbus_error_free (&error);
335 _DROUTE_DEBUG ("DRoute (handle prop): %s|%s on %s\n", pair.one, pair.two, pathstr);
337 prop_funcs = (PropertyPair *) g_hash_table_lookup (path->properties, &pair);
341 #ifdef DBUS_ERROR_UNKNOWN_PROPERTY
342 ret = dbus_message_new_error (message, DBUS_ERROR_UNKNOWN_PROPERTY, "Property unavailable");
344 ret = dbus_message_new_error (message, DBUS_ERROR_FAILED, "Property unavailable");
346 dbus_error_free (&error);
350 datum = path_get_datum (path, pathstr);
352 return droute_object_does_not_exist_error (message);
354 if (get && prop_funcs->get)
357 DBusMessageIter iter;
359 _DROUTE_DEBUG ("DRoute (handle prop Get): %s|%s on %s\n", pair.one, pair.two, pathstr);
361 reply = dbus_message_new_method_return (message);
362 dbus_message_iter_init_append (reply, &iter);
363 if (!(prop_funcs->get) (&iter, datum))
365 dbus_message_unref (reply);
366 reply = dbus_message_new_error (message, DBUS_ERROR_FAILED, "Get failed");
369 else if (!get && prop_funcs->set)
371 DBusMessageIter iter;
373 _DROUTE_DEBUG ("DRoute (handle prop Get): %s|%s on %s\n", pair.one, pair.two, pathstr);
375 dbus_message_iter_init (message, &iter);
376 /* Skip the interface and property name */
377 dbus_message_iter_next(&iter);
378 dbus_message_iter_next(&iter);
379 (prop_funcs->set) (&iter, datum);
381 reply = dbus_message_new_method_return (message);
383 #ifdef DBUS_ERROR_PROPERTY_READ_ONLY
386 reply = dbus_message_new_error (message, DBUS_ERROR_PROPERTY_READ_ONLY, "Property is read-only");
391 reply = dbus_message_new_error (message, DBUS_ERROR_FAILED, "Getter or setter unavailable");
397 static DBusHandlerResult
398 handle_dbus (DBusConnection *bus,
399 DBusMessage *message,
402 const gchar *pathstr)
405 char *id_str = (char *) g_malloc(40);
408 if (strcmp (iface, DBUS_INTERFACE_DBUS) != 0 ||
409 strcmp (member, "Hello") != 0)
412 return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
415 /* TODO: Fix this hack (we don't handle wrap-around, for instance) */
416 sprintf (id_str, ":1.%d", id++);
417 reply = dbus_message_new_method_return (message);
418 dbus_message_append_args (reply, DBUS_TYPE_STRING, &id_str, DBUS_TYPE_INVALID);
419 dbus_connection_send (bus, reply, NULL);
420 dbus_connection_flush (bus);
421 dbus_message_unref (reply);
423 return DBUS_HANDLER_RESULT_HANDLED;
426 static DBusHandlerResult
427 handle_properties (DBusConnection *bus,
428 DBusMessage *message,
432 const gchar *pathstr)
434 DBusMessage *reply = NULL;
435 DBusHandlerResult result = DBUS_HANDLER_RESULT_HANDLED;
437 if (!g_strcmp0(member, "GetAll"))
438 reply = impl_prop_GetAll (message, path, pathstr);
439 else if (!g_strcmp0 (member, "Get"))
440 reply = impl_prop_GetSet (message, path, pathstr, TRUE);
441 else if (!g_strcmp0 (member, "Set"))
442 reply = impl_prop_GetSet (message, path, pathstr, FALSE);
444 result = DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
448 dbus_connection_send (bus, reply, NULL);
449 dbus_message_unref (reply);
455 /*---------------------------------------------------------------------------*/
457 static const char *introspection_header =
458 "<?xml version=\"1.0\"?>\n";
460 static const char *introspection_node_element =
461 "<node name=\"%s\">\n";
463 static const char *introspection_footer =
466 static DBusHandlerResult
467 handle_introspection (DBusConnection *bus,
468 DBusMessage *message,
472 const gchar *pathstr)
480 _DROUTE_DEBUG ("DRoute (handle introspection): %s\n", pathstr);
482 if (g_strcmp0 (member, "Introspect"))
483 return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
485 output = g_string_new(introspection_header);
487 g_string_append_printf(output, introspection_node_element, pathstr);
489 if (!path->get_datum || path_get_datum (path, pathstr))
491 for (i=0; i < path->introspection->len; i++)
493 gchar *introspect = (gchar *) g_ptr_array_index (path->introspection, i);
494 g_string_append (output, introspect);
498 if (path->introspect_children_cb)
500 gchar *children = (*path->introspect_children_cb) (pathstr, path->introspect_children_data);
503 g_string_append (output, children);
508 g_string_append(output, introspection_footer);
509 final = g_string_free(output, FALSE);
511 reply = dbus_message_new_method_return (message);
514 dbus_message_append_args(reply, DBUS_TYPE_STRING, &final,
516 dbus_connection_send (bus, reply, NULL);
518 dbus_message_unref (reply);
520 return DBUS_HANDLER_RESULT_HANDLED;
523 /*---------------------------------------------------------------------------*/
525 static DBusHandlerResult
526 handle_other (DBusConnection *bus,
527 DBusMessage *message,
531 const gchar *pathstr)
533 gint result = DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
537 DBusMessage *reply = NULL;
544 _DROUTE_DEBUG ("DRoute (handle other): %s|%s on %s\n", member, iface, pathstr);
546 func = (DRouteFunction) g_hash_table_lookup (path->methods, &pair);
549 datum = path_get_datum (path, pathstr);
551 reply = droute_object_does_not_exist_error (message);
553 reply = (func) (bus, message, datum);
555 /* All D-Bus method calls must have a reply.
556 * If one is not provided presume that the caller has already
561 dbus_connection_send (bus, reply, NULL);
562 dbus_message_unref (reply);
564 result = DBUS_HANDLER_RESULT_HANDLED;
567 _DROUTE_DEBUG ("DRoute (handle other) (reply): type %d\n",
568 dbus_message_get_type(reply));
572 /*---------------------------------------------------------------------------*/
574 static DBusHandlerResult
575 handle_message (DBusConnection *bus, DBusMessage *message, void *user_data)
577 DRoutePath *path = (DRoutePath *) user_data;
578 const gchar *iface = dbus_message_get_interface (message);
579 const gchar *member = dbus_message_get_member (message);
580 const gint type = dbus_message_get_type (message);
581 const gchar *pathstr = dbus_message_get_path (message);
583 DBusHandlerResult result = DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
585 _DROUTE_DEBUG ("DRoute (handle message): %s|%s of type %d on %s\n", member, iface, type, pathstr);
587 /* Check for basic reasons not to handle */
588 if (type != DBUS_MESSAGE_TYPE_METHOD_CALL ||
593 if (!strcmp (pathstr, DBUS_PATH_DBUS))
594 result = handle_dbus (bus, message, iface, member, pathstr);
595 else if (!strcmp (iface, "org.freedesktop.DBus.Properties"))
596 result = handle_properties (bus, message, path, iface, member, pathstr);
597 else if (!strcmp (iface, "org.freedesktop.DBus.Introspectable"))
598 result = handle_introspection (bus, message, path, iface, member, pathstr);
600 result = handle_other (bus, message, path, iface, member, pathstr);
602 if (result == DBUS_HANDLER_RESULT_NOT_YET_HANDLED)
603 g_print ("DRoute | Unhandled message: %s|%s of type %d on %s\n", member, iface, type, pathstr);
609 /*---------------------------------------------------------------------------*/
612 droute_object_does_not_exist_error (DBusMessage *message)
617 errmsg= g_strdup_printf (
618 "Method \"%s\" with signature \"%s\" on interface \"%s\" could not be processed as object %s does not exist\n",
619 dbus_message_get_member (message),
620 dbus_message_get_signature (message),
621 dbus_message_get_interface (message),
622 dbus_message_get_path (message));
623 #ifdef DBUS_ERROR_UNKNOWN_OBJECT
624 reply = dbus_message_new_error (message,
625 DBUS_ERROR_UNKNOWN_OBJECT,
628 reply = dbus_message_new_error (message,
636 /*---------------------------------------------------------------------------*/
639 droute_not_yet_handled_error (DBusMessage *message)
644 errmsg= g_strdup_printf (
645 "Method \"%s\" with signature \"%s\" on interface \"%s\" doesn't exist\n",
646 dbus_message_get_member (message),
647 dbus_message_get_signature (message),
648 dbus_message_get_interface (message));
649 reply = dbus_message_new_error (message,
650 DBUS_ERROR_UNKNOWN_METHOD,
657 droute_out_of_memory_error (DBusMessage *message)
662 errmsg= g_strdup_printf (
663 "Method \"%s\" with signature \"%s\" on interface \"%s\" could not be processed due to lack of memory\n",
664 dbus_message_get_member (message),
665 dbus_message_get_signature (message),
666 dbus_message_get_interface (message));
667 reply = dbus_message_new_error (message,
668 DBUS_ERROR_NO_MEMORY,
675 droute_invalid_arguments_error (DBusMessage *message)
680 errmsg= g_strdup_printf (
681 "Method \"%s\" with signature \"%s\" on interface \"%s\" was supplied with invalid arguments\n",
682 dbus_message_get_member (message),
683 dbus_message_get_signature (message),
684 dbus_message_get_interface (message));
685 reply = dbus_message_new_error (message,
686 DBUS_ERROR_INVALID_ARGS,
693 droute_path_register (DRoutePath *path, DBusConnection *bus)
696 dbus_connection_register_fallback (bus, path->path, &droute_vtable, path);
698 dbus_connection_register_object_path (bus, path->path,
699 &droute_vtable, path);
703 droute_path_unregister (DRoutePath *path, DBusConnection *bus)
705 dbus_connection_unregister_object_path (bus, path->path);
709 droute_context_register (DRouteContext *cnx, DBusConnection *bus)
711 g_ptr_array_foreach (cnx->registered_paths, (GFunc) droute_path_register,
716 droute_context_unregister (DRouteContext *cnx, DBusConnection *bus)
718 g_ptr_array_foreach (cnx->registered_paths, (GFunc) droute_path_unregister,
723 droute_context_deregister (DRouteContext *cnx, DBusConnection *bus)
725 g_ptr_array_foreach (cnx->registered_paths, (GFunc) droute_path_unregister,
730 droute_intercept_dbus (DBusConnection *bus)
732 dbus_connection_register_object_path (bus, DBUS_PATH_DBUS,
733 &droute_vtable, NULL);
737 droute_unintercept_dbus (DBusConnection *bus)
739 dbus_connection_unregister_object_path (bus, DBUS_PATH_DBUS);
742 /*END------------------------------------------------------------------------*/