?  search:
summary | log | graphiclog1 | graphiclog2 | commit | commitdiff | tree | refs | edit | fork
blame | history | raw | HEAD
Add some more cases to the app-id unit tests
[glib.git] / gio / tests / gdbus-export.c
blob921ba40f769824df7e6ff53e7775d091f4188af2
1 /* GLib testing framework examples and tests
2 *
3 * Copyright (C) 2008-2010 Red Hat, Inc.
4 *
5 * This library is free software; you can redistribute it and/or
6 * modify it under the terms of the GNU Lesser General Public
7 * License as published by the Free Software Foundation; either
8 * version 2 of the License, or (at your option) any later version.
9 *
10 * This library is distributed in the hope that it will be useful,
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 * Lesser General Public License for more details.
14 *
15 * You should have received a copy of the GNU Lesser General
16 * Public License along with this library; if not, see <http://www.gnu.org/licenses/>.
17 *
18 * Author: David Zeuthen <davidz@redhat.com>
19 */
20
21 #include <gio/gio.h>
22 #include <unistd.h>
23 #include <string.h>
24
25 #include "gdbus-tests.h"
26
27 /* all tests rely on a shared mainloop */
28 static GMainLoop *loop = NULL;
29
30 static GDBusConnection *c = NULL;
31
32 /* ---------------------------------------------------------------------------------------------------- */
33 /* Test that we can export objects, the hierarchy is correct and the right handlers are invoked */
34 /* ---------------------------------------------------------------------------------------------------- */
35
36 static const GDBusArgInfo foo_method1_in_args =
37 {
38 -1,
39 "an_input_string",
40 "s",
41 NULL
42 };
43 static const GDBusArgInfo * const foo_method1_in_arg_pointers[] = {&foo_method1_in_args, NULL};
44
45 static const GDBusArgInfo foo_method1_out_args =
46 {
47 -1,
48 "an_output_string",
49 "s",
50 NULL
51 };
52 static const GDBusArgInfo * const foo_method1_out_arg_pointers[] = {&foo_method1_out_args, NULL};
53
54 static const GDBusMethodInfo foo_method_info_method1 =
55 {
56 -1,
57 "Method1",
58 (GDBusArgInfo **) &foo_method1_in_arg_pointers,
59 (GDBusArgInfo **) &foo_method1_out_arg_pointers,
60 NULL
61 };
62 static const GDBusMethodInfo foo_method_info_method2 =
63 {
64 -1,
65 "Method2",
66 NULL,
67 NULL,
68 NULL
69 };
70 static const GDBusMethodInfo * const foo_method_info_pointers[] = {&foo_method_info_method1, &foo_method_info_method2, NULL};
71
72 static const GDBusSignalInfo foo_signal_info =
73 {
74 -1,
75 "SignalAlpha",
76 NULL,
77 NULL
78 };
79 static const GDBusSignalInfo * const foo_signal_info_pointers[] = {&foo_signal_info, NULL};
80
81 static const GDBusPropertyInfo foo_property_info[] =
82 {
83 {
84 -1,
85 "PropertyUno",
86 "s",
87 G_DBUS_PROPERTY_INFO_FLAGS_READABLE | G_DBUS_PROPERTY_INFO_FLAGS_WRITABLE,
88 NULL
89 },
90 {
91 -1,
92 "NotWritable",
93 "s",
94 G_DBUS_PROPERTY_INFO_FLAGS_READABLE,
95 NULL
96 },
97 {
98 -1,
99 "NotReadable",
100 "s",
101 G_DBUS_PROPERTY_INFO_FLAGS_WRITABLE,
102 NULL
103 }
104 };
105 static const GDBusPropertyInfo * const foo_property_info_pointers[] =
106 {
107 &foo_property_info[0],
108 &foo_property_info[1],
109 &foo_property_info[2],
110 NULL
111 };
112
113 static const GDBusInterfaceInfo foo_interface_info =
114 {
115 -1,
116 "org.example.Foo",
117 (GDBusMethodInfo **) &foo_method_info_pointers,
118 (GDBusSignalInfo **) &foo_signal_info_pointers,
119 (GDBusPropertyInfo **)&foo_property_info_pointers,
120 NULL,
121 };
122
123 /* Foo2 is just Foo without the properties */
124 static const GDBusInterfaceInfo foo2_interface_info =
125 {
126 -1,
127 "org.example.Foo2",
128 (GDBusMethodInfo **) &foo_method_info_pointers,
129 (GDBusSignalInfo **) &foo_signal_info_pointers,
130 };
131
132 static void
133 foo_method_call (GDBusConnection *connection,
134 const gchar *sender,
135 const gchar *object_path,
136 const gchar *interface_name,
137 const gchar *method_name,
138 GVariant *parameters,
139 GDBusMethodInvocation *invocation,
140 gpointer user_data)
141 {
142 if (g_strcmp0 (method_name, "Method1") == 0)
143 {
144 const gchar *input;
145 gchar *output;
146 g_variant_get (parameters, "(&s)", &input);
147 output = g_strdup_printf ("You passed the string '%s'. Jolly good!", input);
148 g_dbus_method_invocation_return_value (invocation, g_variant_new ("(s)", output));
149 g_free (output);
150 }
151 else
152 {
153 g_dbus_method_invocation_return_dbus_error (invocation,
154 "org.example.SomeError",
155 "How do you like them apples, buddy!");
156 }
157 }
158
159 static GVariant *
160 foo_get_property (GDBusConnection *connection,
161 const gchar *sender,
162 const gchar *object_path,
163 const gchar *interface_name,
164 const gchar *property_name,
165 GError **error,
166 gpointer user_data)
167 {
168 GVariant *ret;
169 gchar *s;
170 s = g_strdup_printf ("Property '%s' Is What It Is!", property_name);
171 ret = g_variant_new_string (s);
172 g_free (s);
173 return ret;
174 }
175
176 static gboolean
177 foo_set_property (GDBusConnection *connection,
178 const gchar *sender,
179 const gchar *object_path,
180 const gchar *interface_name,
181 const gchar *property_name,
182 GVariant *value,
183 GError **error,
184 gpointer user_data)
185 {
186 gchar *s;
187 s = g_variant_print (value, TRUE);
188 g_set_error (error,
189 G_DBUS_ERROR,
190 G_DBUS_ERROR_SPAWN_FILE_INVALID,
191 "Returning some error instead of writing the value '%s' to the property '%s'",
192 property_name, s);
193 g_free (s);
194 return FALSE;
195 }
196
197 static const GDBusInterfaceVTable foo_vtable =
198 {
199 foo_method_call,
200 foo_get_property,
201 foo_set_property
202 };
203
204 /* -------------------- */
205
206 static const GDBusMethodInfo bar_method_info[] =
207 {
208 {
209 -1,
210 "MethodA",
211 NULL,
212 NULL,
213 NULL
214 },
215 {
216 -1,
217 "MethodB",
218 NULL,
219 NULL,
220 NULL
221 }
222 };
223 static const GDBusMethodInfo * const bar_method_info_pointers[] = {&bar_method_info[0], &bar_method_info[1], NULL};
224
225 static const GDBusSignalInfo bar_signal_info[] =
226 {
227 {
228 -1,
229 "SignalMars",
230 NULL,
231 NULL
232 }
233 };
234 static const GDBusSignalInfo * const bar_signal_info_pointers[] = {&bar_signal_info[0], NULL};
235
236 static const GDBusPropertyInfo bar_property_info[] =
237 {
238 {
239 -1,
240 "PropertyDuo",
241 "s",
242 G_DBUS_PROPERTY_INFO_FLAGS_READABLE,
243 NULL
244 }
245 };
246 static const GDBusPropertyInfo * const bar_property_info_pointers[] = {&bar_property_info[0], NULL};
247
248 static const GDBusInterfaceInfo bar_interface_info =
249 {
250 -1,
251 "org.example.Bar",
252 (GDBusMethodInfo **) bar_method_info_pointers,
253 (GDBusSignalInfo **) bar_signal_info_pointers,
254 (GDBusPropertyInfo **) bar_property_info_pointers,
255 NULL,
256 };
257
258 /* -------------------- */
259
260 static const GDBusMethodInfo dyna_method_info[] =
261 {
262 {
263 -1,
264 "DynaCyber",
265 NULL,
266 NULL,
267 NULL
268 }
269 };
270 static const GDBusMethodInfo * const dyna_method_info_pointers[] = {&dyna_method_info[0], NULL};
271
272 static const GDBusInterfaceInfo dyna_interface_info =
273 {
274 -1,
275 "org.example.Dyna",
276 (GDBusMethodInfo **) dyna_method_info_pointers,
277 NULL, /* no signals */
278 NULL, /* no properties */
279 NULL,
280 };
281
282 static void
283 dyna_cyber (GDBusConnection *connection,
284 const gchar *sender,
285 const gchar *object_path,
286 const gchar *interface_name,
287 const gchar *method_name,
288 GVariant *parameters,
289 GDBusMethodInvocation *invocation,
290 gpointer user_data)
291 {
292 GPtrArray *data = user_data;
293 gchar *node_name;
294 guint n;
295
296 node_name = strrchr (object_path, '/') + 1;
297
298 /* Add new node if it is not already known */
299 for (n = 0; n < data->len ; n++)
300 {
301 if (g_strcmp0 (g_ptr_array_index (data, n), node_name) == 0)
302 goto out;
303 }
304 g_ptr_array_add (data, g_strdup(node_name));
305
306 out:
307 g_dbus_method_invocation_return_value (invocation, NULL);
308 }
309
310 static const GDBusInterfaceVTable dyna_interface_vtable =
311 {
312 dyna_cyber,
313 NULL,
314 NULL
315 };
316
317 /* ---------------------------------------------------------------------------------------------------- */
318
319 static void
320 introspect_callback (GDBusProxy *proxy,
321 GAsyncResult *res,
322 gpointer user_data)
323 {
324 gchar **xml_data = user_data;
325 GVariant *result;
326 GError *error;
327
328 error = NULL;
329 result = g_dbus_proxy_call_finish (proxy,
330 res,
331 &error);
332 g_assert_no_error (error);
333 g_assert (result != NULL);
334 g_variant_get (result, "(s)", xml_data);
335 g_variant_unref (result);
336
337 g_main_loop_quit (loop);
338 }
339
340 static gchar **
341 get_nodes_at (GDBusConnection *c,
342 const gchar *object_path)
343 {
344 GError *error;
345 GDBusProxy *proxy;
346 gchar *xml_data;
347 GPtrArray *p;
348 GDBusNodeInfo *node_info;
349 guint n;
350
351 error = NULL;
352 proxy = g_dbus_proxy_new_sync (c,
353 G_DBUS_PROXY_FLAGS_DO_NOT_LOAD_PROPERTIES |
354 G_DBUS_PROXY_FLAGS_DO_NOT_CONNECT_SIGNALS,
355 NULL,
356 g_dbus_connection_get_unique_name (c),
357 object_path,
358 "org.freedesktop.DBus.Introspectable",
359 NULL,
360 &error);
361 g_assert_no_error (error);
362 g_assert (proxy != NULL);
363
364 /* do this async to avoid libdbus-1 deadlocks */
365 xml_data = NULL;
366 g_dbus_proxy_call (proxy,
367 "Introspect",
368 NULL,
369 G_DBUS_CALL_FLAGS_NONE,
370 -1,
371 NULL,
372 (GAsyncReadyCallback) introspect_callback,
373 &xml_data);
374 g_main_loop_run (loop);
375 g_assert (xml_data != NULL);
376
377 node_info = g_dbus_node_info_new_for_xml (xml_data, &error);
378 g_assert_no_error (error);
379 g_assert (node_info != NULL);
380
381 p = g_ptr_array_new ();
382 for (n = 0; node_info->nodes != NULL && node_info->nodes[n] != NULL; n++)
383 {
384 const GDBusNodeInfo *sub_node_info = node_info->nodes[n];
385 g_ptr_array_add (p, g_strdup (sub_node_info->path));
386 }
387 g_ptr_array_add (p, NULL);
388
389 g_object_unref (proxy);
390 g_free (xml_data);
391 g_dbus_node_info_unref (node_info);
392
393 return (gchar **) g_ptr_array_free (p, FALSE);
394 }
395
396 static gboolean
397 has_interface (GDBusConnection *c,
398 const gchar *object_path,
399 const gchar *interface_name)
400 {
401 GError *error;
402 GDBusProxy *proxy;
403 gchar *xml_data;
404 GDBusNodeInfo *node_info;
405 gboolean ret;
406
407 error = NULL;
408 proxy = g_dbus_proxy_new_sync (c,
409 G_DBUS_PROXY_FLAGS_DO_NOT_LOAD_PROPERTIES |
410 G_DBUS_PROXY_FLAGS_DO_NOT_CONNECT_SIGNALS,
411 NULL,
412 g_dbus_connection_get_unique_name (c),
413 object_path,
414 "org.freedesktop.DBus.Introspectable",
415 NULL,
416 &error);
417 g_assert_no_error (error);
418 g_assert (proxy != NULL);
419
420 /* do this async to avoid libdbus-1 deadlocks */
421 xml_data = NULL;
422 g_dbus_proxy_call (proxy,
423 "Introspect",
424 NULL,
425 G_DBUS_CALL_FLAGS_NONE,
426 -1,
427 NULL,
428 (GAsyncReadyCallback) introspect_callback,
429 &xml_data);
430 g_main_loop_run (loop);
431 g_assert (xml_data != NULL);
432
433 node_info = g_dbus_node_info_new_for_xml (xml_data, &error);
434 g_assert_no_error (error);
435 g_assert (node_info != NULL);
436
437 ret = (g_dbus_node_info_lookup_interface (node_info, interface_name) != NULL);
438
439 g_object_unref (proxy);
440 g_free (xml_data);
441 g_dbus_node_info_unref (node_info);
442
443 return ret;
444 }
445
446 static guint
447 count_interfaces (GDBusConnection *c,
448 const gchar *object_path)
449 {
450 GError *error;
451 GDBusProxy *proxy;
452 gchar *xml_data;
453 GDBusNodeInfo *node_info;
454 guint ret;
455
456 error = NULL;
457 proxy = g_dbus_proxy_new_sync (c,
458 G_DBUS_PROXY_FLAGS_DO_NOT_LOAD_PROPERTIES |
459 G_DBUS_PROXY_FLAGS_DO_NOT_CONNECT_SIGNALS,
460 NULL,
461 g_dbus_connection_get_unique_name (c),
462 object_path,
463 "org.freedesktop.DBus.Introspectable",
464 NULL,
465 &error);
466 g_assert_no_error (error);
467 g_assert (proxy != NULL);
468
469 /* do this async to avoid libdbus-1 deadlocks */
470 xml_data = NULL;
471 g_dbus_proxy_call (proxy,
472 "Introspect",
473 NULL,
474 G_DBUS_CALL_FLAGS_NONE,
475 -1,
476 NULL,
477 (GAsyncReadyCallback) introspect_callback,
478 &xml_data);
479 g_main_loop_run (loop);
480 g_assert (xml_data != NULL);
481
482 node_info = g_dbus_node_info_new_for_xml (xml_data, &error);
483 g_assert_no_error (error);
484 g_assert (node_info != NULL);
485
486 ret = 0;
487 while (node_info->interfaces != NULL && node_info->interfaces[ret] != NULL)
488 ret++;
489
490 g_object_unref (proxy);
491 g_free (xml_data);
492 g_dbus_node_info_unref (node_info);
493
494 return ret;
495 }
496
497 static void
498 dyna_create_callback (GDBusProxy *proxy,
499 GAsyncResult *res,
500 gpointer user_data)
501 {
502 GVariant *result;
503 GError *error;
504
505 error = NULL;
506 result = g_dbus_proxy_call_finish (proxy,
507 res,
508 &error);
509 g_assert_no_error (error);
510 g_assert (result != NULL);
511 g_variant_unref (result);
512
513 g_main_loop_quit (loop);
514 }
515
516 /* Dynamically create @object_name under /foo/dyna */
517 static void
518 dyna_create (GDBusConnection *c,
519 const gchar *object_name)
520 {
521 GError *error;
522 GDBusProxy *proxy;
523 gchar *object_path;
524
525 object_path = g_strconcat ("/foo/dyna/", object_name, NULL);
526
527 error = NULL;
528 proxy = g_dbus_proxy_new_sync (c,
529 G_DBUS_PROXY_FLAGS_DO_NOT_LOAD_PROPERTIES |
530 G_DBUS_PROXY_FLAGS_DO_NOT_CONNECT_SIGNALS,
531 NULL,
532 g_dbus_connection_get_unique_name (c),
533 object_path,
534 "org.example.Dyna",
535 NULL,
536 &error);
537 g_assert_no_error (error);
538 g_assert (proxy != NULL);
539
540 /* do this async to avoid libdbus-1 deadlocks */
541 g_dbus_proxy_call (proxy,
542 "DynaCyber",
543 g_variant_new ("()"),
544 G_DBUS_CALL_FLAGS_NONE,
545 -1,
546 NULL,
547 (GAsyncReadyCallback) dyna_create_callback,
548 NULL);
549 g_main_loop_run (loop);
550
551 g_assert_no_error (error);
552
553 g_object_unref (proxy);
554 g_free (object_path);
555
556 return;
557 }
558
559 typedef struct
560 {
561 guint num_unregistered_calls;
562 guint num_unregistered_subtree_calls;
563 guint num_subtree_nodes;
564 } ObjectRegistrationData;
565
566 static void
567 on_object_unregistered (gpointer user_data)
568 {
569 ObjectRegistrationData *data = user_data;
570
571 data->num_unregistered_calls++;
572 }
573
574 static void
575 on_subtree_unregistered (gpointer user_data)
576 {
577 ObjectRegistrationData *data = user_data;
578
579 data->num_unregistered_subtree_calls++;
580 }
581
582 static gboolean
583 _g_strv_has_string (const gchar* const * haystack,
584 const gchar *needle)
585 {
586 guint n;
587
588 for (n = 0; haystack != NULL && haystack[n] != NULL; n++)
589 {
590 if (g_strcmp0 (haystack[n], needle) == 0)
591 return TRUE;
592 }
593 return FALSE;
594 }
595
596 /* -------------------- */
597
598 static gchar **
599 subtree_enumerate (GDBusConnection *connection,
600 const gchar *sender,
601 const gchar *object_path,
602 gpointer user_data)
603 {
604 ObjectRegistrationData *data = user_data;
605 GPtrArray *p;
606 gchar **nodes;
607 guint n;
608
609 p = g_ptr_array_new ();
610
611 for (n = 0; n < data->num_subtree_nodes; n++)
612 {
613 g_ptr_array_add (p, g_strdup_printf ("vp%d", n));
614 g_ptr_array_add (p, g_strdup_printf ("evp%d", n));
615 }
616 g_ptr_array_add (p, NULL);
617
618 nodes = (gchar **) g_ptr_array_free (p, FALSE);
619
620 return nodes;
621 }
622
623 /* Only allows certain objects, and aborts on unknowns */
624 static GDBusInterfaceInfo **
625 subtree_introspect (GDBusConnection *connection,
626 const gchar *sender,
627 const gchar *object_path,
628 const gchar *node,
629 gpointer user_data)
630 {
631 const GDBusInterfaceInfo *interfaces[2] = {
632 NULL /* filled in below */, NULL
633 };
634
635 /* VPs implement the Foo interface, EVPs implement the Bar interface. The root
636 * does not implement any interfaces
637 */
638 if (node == NULL)
639 {
640 return NULL;
641 }
642 else if (g_str_has_prefix (node, "vp"))
643 {
644 interfaces[0] = &foo_interface_info;
645 }
646 else if (g_str_has_prefix (node, "evp"))
647 {
648 interfaces[0] = &bar_interface_info;
649 }
650 else
651 {
652 g_assert_not_reached ();
653 }
654
655 return g_memdup (interfaces, 2 * sizeof (void *));
656 }
657
658 static const GDBusInterfaceVTable *
659 subtree_dispatch (GDBusConnection *connection,
660 const gchar *sender,
661 const gchar *object_path,
662 const gchar *interface_name,
663 const gchar *node,
664 gpointer *out_user_data,
665 gpointer user_data)
666 {
667 if (g_strcmp0 (interface_name, "org.example.Foo") == 0)
668 return &foo_vtable;
669 else
670 return NULL;
671 }
672
673 static const GDBusSubtreeVTable subtree_vtable =
674 {
675 subtree_enumerate,
676 subtree_introspect,
677 subtree_dispatch
678 };
679
680 /* -------------------- */
681
682 static gchar **
683 dynamic_subtree_enumerate (GDBusConnection *connection,
684 const gchar *sender,
685 const gchar *object_path,
686 gpointer user_data)
687 {
688 GPtrArray *data = user_data;
689 gchar **nodes = g_new (gchar*, data->len + 1);
690 guint n;
691
692 for (n = 0; n < data->len; n++)
693 {
694 nodes[n] = g_strdup (g_ptr_array_index (data, n));
695 }
696 nodes[data->len] = NULL;
697
698 return nodes;
699 }
700
701 /* Allow all objects to be introspected */
702 static GDBusInterfaceInfo **
703 dynamic_subtree_introspect (GDBusConnection *connection,
704 const gchar *sender,
705 const gchar *object_path,
706 const gchar *node,
707 gpointer user_data)
708 {
709 const GDBusInterfaceInfo *interfaces[2] = { &dyna_interface_info, NULL };
710
711 return g_memdup (interfaces, 2 * sizeof (void *));
712 }
713
714 static const GDBusInterfaceVTable *
715 dynamic_subtree_dispatch (GDBusConnection *connection,
716 const gchar *sender,
717 const gchar *object_path,
718 const gchar *interface_name,
719 const gchar *node,
720 gpointer *out_user_data,
721 gpointer user_data)
722 {
723 *out_user_data = user_data;
724 return &dyna_interface_vtable;
725 }
726
727 static const GDBusSubtreeVTable dynamic_subtree_vtable =
728 {
729 dynamic_subtree_enumerate,
730 dynamic_subtree_introspect,
731 dynamic_subtree_dispatch
732 };
733
734 /* -------------------- */
735
736 typedef struct
737 {
738 const gchar *object_path;
739 gboolean check_remote_errors;
740 } TestDispatchThreadFuncArgs;
741
742 static gpointer
743 test_dispatch_thread_func (gpointer user_data)
744 {
745 TestDispatchThreadFuncArgs *args = user_data;
746 const gchar *object_path = args->object_path;
747 GDBusProxy *foo_proxy;
748 GVariant *value;
749 GVariant *inner;
750 GError *error;
751 gchar *s;
752 const gchar *value_str;
753
754 foo_proxy = g_dbus_proxy_new_sync (c,
755 G_DBUS_PROXY_FLAGS_DO_NOT_CONNECT_SIGNALS |
756 G_DBUS_PROXY_FLAGS_DO_NOT_LOAD_PROPERTIES,
757 NULL,
758 g_dbus_connection_get_unique_name (c),
759 object_path,
760 "org.example.Foo",
761 NULL,
762 &error);
763 g_assert (foo_proxy != NULL);
764
765 /* generic interfaces */
766 error = NULL;
767 value = g_dbus_proxy_call_sync (foo_proxy,
768 "org.freedesktop.DBus.Peer.Ping",
769 NULL,
770 G_DBUS_CALL_FLAGS_NONE,
771 -1,
772 NULL,
773 &error);
774 g_assert_no_error (error);
775 g_assert (value != NULL);
776 g_variant_unref (value);
777
778 /* user methods */
779 error = NULL;
780 value = g_dbus_proxy_call_sync (foo_proxy,
781 "Method1",
782 g_variant_new ("(s)", "winwinwin"),
783 G_DBUS_CALL_FLAGS_NONE,
784 -1,
785 NULL,
786 &error);
787 g_assert_no_error (error);
788 g_assert (value != NULL);
789 g_assert (g_variant_is_of_type (value, G_VARIANT_TYPE ("(s)")));
790 g_variant_get (value, "(&s)", &value_str);
791 g_assert_cmpstr (value_str, ==, "You passed the string 'winwinwin'. Jolly good!");
792 g_variant_unref (value);
793
794 error = NULL;
795 value = g_dbus_proxy_call_sync (foo_proxy,
796 "Method2",
797 NULL,
798 G_DBUS_CALL_FLAGS_NONE,
799 -1,
800 NULL,
801 &error);
802 g_assert_error (error, G_IO_ERROR, G_IO_ERROR_DBUS_ERROR);
803 g_assert_cmpstr (error->message, ==, "GDBus.Error:org.example.SomeError: How do you like them apples, buddy!");
804 g_error_free (error);
805 g_assert (value == NULL);
806
807 error = NULL;
808 value = g_dbus_proxy_call_sync (foo_proxy,
809 "Method2",
810 g_variant_new ("(s)", "failfailfail"),
811 G_DBUS_CALL_FLAGS_NONE,
812 -1,
813 NULL,
814 &error);
815 g_assert_error (error, G_DBUS_ERROR, G_DBUS_ERROR_INVALID_ARGS);
816 g_assert_cmpstr (error->message, ==, "GDBus.Error:org.freedesktop.DBus.Error.InvalidArgs: Type of message, '(s)', does not match expected type '()'");
817 g_error_free (error);
818 g_assert (value == NULL);
819
820 error = NULL;
821 value = g_dbus_proxy_call_sync (foo_proxy,
822 "NonExistantMethod",
823 NULL,
824 G_DBUS_CALL_FLAGS_NONE,
825 -1,
826 NULL,
827 &error);
828 g_assert_error (error, G_DBUS_ERROR, G_DBUS_ERROR_UNKNOWN_METHOD);
829 g_assert_cmpstr (error->message, ==, "GDBus.Error:org.freedesktop.DBus.Error.UnknownMethod: No such method 'NonExistantMethod'");
830 g_error_free (error);
831 g_assert (value == NULL);
832
833 error = NULL;
834 value = g_dbus_proxy_call_sync (foo_proxy,
835 "org.example.FooXYZ.NonExistant",
836 NULL,
837 G_DBUS_CALL_FLAGS_NONE,
838 -1,
839 NULL,
840 &error);
841 g_assert_error (error, G_DBUS_ERROR, G_DBUS_ERROR_UNKNOWN_METHOD);
842 g_error_free (error);
843 g_assert (value == NULL);
844
845 /* user properties */
846 error = NULL;
847 value = g_dbus_proxy_call_sync (foo_proxy,
848 "org.freedesktop.DBus.Properties.Get",
849 g_variant_new ("(ss)",
850 "org.example.Foo",
851 "PropertyUno"),
852 G_DBUS_CALL_FLAGS_NONE,
853 -1,
854 NULL,
855 &error);
856 g_assert_no_error (error);
857 g_assert (value != NULL);
858 g_assert (g_variant_is_of_type (value, G_VARIANT_TYPE ("(v)")));
859 g_variant_get (value, "(v)", &inner);
860 g_assert (g_variant_is_of_type (inner, G_VARIANT_TYPE_STRING));
861 g_assert_cmpstr (g_variant_get_string (inner, NULL), ==, "Property 'PropertyUno' Is What It Is!");
862 g_variant_unref (value);
863 g_variant_unref (inner);
864
865 error = NULL;
866 value = g_dbus_proxy_call_sync (foo_proxy,
867 "org.freedesktop.DBus.Properties.Get",
868 g_variant_new ("(ss)",
869 "org.example.Foo",
870 "ThisDoesntExist"),
871 G_DBUS_CALL_FLAGS_NONE,
872 -1,
873 NULL,
874 &error);
875 g_assert (value == NULL);
876 g_assert_error (error, G_DBUS_ERROR, G_DBUS_ERROR_INVALID_ARGS);
877 g_assert_cmpstr (error->message, ==, "GDBus.Error:org.freedesktop.DBus.Error.InvalidArgs: No such property 'ThisDoesntExist'");
878 g_error_free (error);
879
880 error = NULL;
881 value = g_dbus_proxy_call_sync (foo_proxy,
882 "org.freedesktop.DBus.Properties.Get",
883 g_variant_new ("(ss)",
884 "org.example.Foo",
885 "NotReadable"),
886 G_DBUS_CALL_FLAGS_NONE,
887 -1,
888 NULL,
889 &error);
890 g_assert (value == NULL);
891 g_assert_error (error, G_DBUS_ERROR, G_DBUS_ERROR_INVALID_ARGS);
892 g_assert_cmpstr (error->message, ==, "GDBus.Error:org.freedesktop.DBus.Error.InvalidArgs: Property 'NotReadable' is not readable");
893 g_error_free (error);
894
895 error = NULL;
896 value = g_dbus_proxy_call_sync (foo_proxy,
897 "org.freedesktop.DBus.Properties.Set",
898 g_variant_new ("(ssv)",
899 "org.example.Foo",
900 "NotReadable",
901 g_variant_new_string ("But Writable you are!")),
902 G_DBUS_CALL_FLAGS_NONE,
903 -1,
904 NULL,
905 &error);
906 g_assert (value == NULL);
907 if (args->check_remote_errors)
908 {
909 /* _with_closures variant doesn't support customizing error data. */
910 g_assert_error (error, G_DBUS_ERROR, G_DBUS_ERROR_SPAWN_FILE_INVALID);
911 g_assert_cmpstr (error->message, ==, "GDBus.Error:org.freedesktop.DBus.Error.Spawn.FileInvalid: Returning some error instead of writing the value 'NotReadable' to the property ''But Writable you are!''");
912 }
913 g_assert (error != NULL && error->domain == G_DBUS_ERROR);
914 g_error_free (error);
915
916 error = NULL;
917 value = g_dbus_proxy_call_sync (foo_proxy,
918 "org.freedesktop.DBus.Properties.Set",
919 g_variant_new ("(ssv)",
920 "org.example.Foo",
921 "NotWritable",
922 g_variant_new_uint32 (42)),
923 G_DBUS_CALL_FLAGS_NONE,
924 -1,
925 NULL,
926 &error);
927 g_assert (value == NULL);
928 g_assert_error (error, G_DBUS_ERROR, G_DBUS_ERROR_INVALID_ARGS);
929 g_assert_cmpstr (error->message, ==, "GDBus.Error:org.freedesktop.DBus.Error.InvalidArgs: Property 'NotWritable' is not writable");
930 g_error_free (error);
931
932 error = NULL;
933 value = g_dbus_proxy_call_sync (foo_proxy,
934 "org.freedesktop.DBus.Properties.GetAll",
935 g_variant_new ("(s)",
936 "org.example.Foo"),
937 G_DBUS_CALL_FLAGS_NONE,
938 -1,
939 NULL,
940 &error);
941 g_assert_no_error (error);
942 g_assert (value != NULL);
943 g_assert (g_variant_is_of_type (value, G_VARIANT_TYPE ("(a{sv})")));
944 s = g_variant_print (value, TRUE);
945 g_assert_cmpstr (s, ==, "({'PropertyUno': <\"Property 'PropertyUno' Is What It Is!\">, 'NotWritable': <\"Property 'NotWritable' Is What It Is!\">},)");
946 g_free (s);
947 g_variant_unref (value);
948
949 g_object_unref (foo_proxy);
950
951 g_main_loop_quit (loop);
952 return NULL;
953 }
954
955 static void
956 test_dispatch (const gchar *object_path,
957 gboolean check_remote_errors)
958 {
959 GThread *thread;
960
961 TestDispatchThreadFuncArgs args = {object_path, check_remote_errors};
962
963 /* run this in a thread to avoid deadlocks */
964 thread = g_thread_new ("test_dispatch",
965 test_dispatch_thread_func,
966 (gpointer) &args);
967 g_main_loop_run (loop);
968 g_thread_join (thread);
969 }
970
971 static void
972 test_object_registration (void)
973 {
974 GError *error;
975 ObjectRegistrationData data;
976 GPtrArray *dyna_data;
977 gchar **nodes;
978 guint boss_foo_reg_id;
979 guint boss_bar_reg_id;
980 guint worker1_foo_reg_id;
981 guint worker1p1_foo_reg_id;
982 guint worker2_bar_reg_id;
983 guint intern1_foo_reg_id;
984 guint intern2_bar_reg_id;
985 guint intern2_foo_reg_id;
986 guint intern3_bar_reg_id;
987 guint registration_id;
988 guint subtree_registration_id;
989 guint non_subtree_object_path_foo_reg_id;
990 guint non_subtree_object_path_bar_reg_id;
991 guint dyna_subtree_registration_id;
992 guint num_successful_registrations;
993
994 data.num_unregistered_calls = 0;
995 data.num_unregistered_subtree_calls = 0;
996 data.num_subtree_nodes = 0;
997
998 num_successful_registrations = 0;
999
1000 error = NULL;
1001 c = g_bus_get_sync (G_BUS_TYPE_SESSION, NULL, &error);
1002 g_assert_no_error (error);
1003 g_assert (c != NULL);
1004
1005 registration_id = g_dbus_connection_register_object (c,
1006 "/foo/boss",
1007 (GDBusInterfaceInfo *) &foo_interface_info,
1008 &foo_vtable,
1009 &data,
1010 on_object_unregistered,
1011 &error);
1012 g_assert_no_error (error);
1013 g_assert (registration_id > 0);
1014 boss_foo_reg_id = registration_id;
1015 num_successful_registrations++;
1016
1017 registration_id = g_dbus_connection_register_object (c,
1018 "/foo/boss",
1019 (GDBusInterfaceInfo *) &bar_interface_info,
1020 NULL,
1021 &data,
1022 on_object_unregistered,
1023 &error);
1024 g_assert_no_error (error);
1025 g_assert (registration_id > 0);
1026 boss_bar_reg_id = registration_id;
1027 num_successful_registrations++;
1028
1029 registration_id = g_dbus_connection_register_object (c,
1030 "/foo/boss/worker1",
1031 (GDBusInterfaceInfo *) &foo_interface_info,
1032 NULL,
1033 &data,
1034 on_object_unregistered,
1035 &error);
1036 g_assert_no_error (error);
1037 g_assert (registration_id > 0);
1038 worker1_foo_reg_id = registration_id;
1039 num_successful_registrations++;
1040
1041 registration_id = g_dbus_connection_register_object (c,
1042 "/foo/boss/worker1p1",
1043 (GDBusInterfaceInfo *) &foo_interface_info,
1044 NULL,
1045 &data,
1046 on_object_unregistered,
1047 &error);
1048 g_assert_no_error (error);
1049 g_assert (registration_id > 0);
1050 worker1p1_foo_reg_id = registration_id;
1051 num_successful_registrations++;
1052
1053 registration_id = g_dbus_connection_register_object (c,
1054 "/foo/boss/worker2",
1055 (GDBusInterfaceInfo *) &bar_interface_info,
1056 NULL,
1057 &data,
1058 on_object_unregistered,
1059 &error);
1060 g_assert_no_error (error);
1061 g_assert (registration_id > 0);
1062 worker2_bar_reg_id = registration_id;
1063 num_successful_registrations++;
1064
1065 registration_id = g_dbus_connection_register_object (c,
1066 "/foo/boss/interns/intern1",
1067 (GDBusInterfaceInfo *) &foo_interface_info,
1068 NULL,
1069 &data,
1070 on_object_unregistered,
1071 &error);
1072 g_assert_no_error (error);
1073 g_assert (registration_id > 0);
1074 intern1_foo_reg_id = registration_id;
1075 num_successful_registrations++;
1076
1077 /* ... and try again at another path */
1078 registration_id = g_dbus_connection_register_object (c,
1079 "/foo/boss/interns/intern2",
1080 (GDBusInterfaceInfo *) &bar_interface_info,
1081 NULL,
1082 &data,
1083 on_object_unregistered,
1084 &error);
1085 g_assert_no_error (error);
1086 g_assert (registration_id > 0);
1087 intern2_bar_reg_id = registration_id;
1088 num_successful_registrations++;
1089
1090 /* register at the same path/interface - this should fail */
1091 registration_id = g_dbus_connection_register_object (c,
1092 "/foo/boss/interns/intern2",
1093 (GDBusInterfaceInfo *) &bar_interface_info,
1094 NULL,
1095 &data,
1096 on_object_unregistered,
1097 &error);
1098 g_assert_error (error, G_IO_ERROR, G_IO_ERROR_EXISTS);
1099 g_assert (!g_dbus_error_is_remote_error (error));
1100 g_error_free (error);
1101 error = NULL;
1102 g_assert (registration_id == 0);
1103
1104 /* register at different interface - shouldn't fail */
1105 registration_id = g_dbus_connection_register_object (c,
1106 "/foo/boss/interns/intern2",
1107 (GDBusInterfaceInfo *) &foo_interface_info,
1108 NULL,
1109 &data,
1110 on_object_unregistered,
1111 &error);
1112 g_assert_no_error (error);
1113 g_assert (registration_id > 0);
1114 intern2_foo_reg_id = registration_id;
1115 num_successful_registrations++;
1116
1117 /* unregister it via the id */
1118 g_assert (g_dbus_connection_unregister_object (c, registration_id));
1119 g_main_context_iteration (NULL, FALSE);
1120 g_assert_cmpint (data.num_unregistered_calls, ==, 1);
1121 intern2_foo_reg_id = 0;
1122
1123 /* register it back */
1124 registration_id = g_dbus_connection_register_object (c,
1125 "/foo/boss/interns/intern2",
1126 (GDBusInterfaceInfo *) &foo_interface_info,
1127 NULL,
1128 &data,
1129 on_object_unregistered,
1130 &error);
1131 g_assert_no_error (error);
1132 g_assert (registration_id > 0);
1133 intern2_foo_reg_id = registration_id;
1134 num_successful_registrations++;
1135
1136 registration_id = g_dbus_connection_register_object (c,
1137 "/foo/boss/interns/intern3",
1138 (GDBusInterfaceInfo *) &bar_interface_info,
1139 NULL,
1140 &data,
1141 on_object_unregistered,
1142 &error);
1143 g_assert_no_error (error);
1144 g_assert (registration_id > 0);
1145 intern3_bar_reg_id = registration_id;
1146 num_successful_registrations++;
1147
1148 /* now register a whole subtree at /foo/boss/executives */
1149 subtree_registration_id = g_dbus_connection_register_subtree (c,
1150 "/foo/boss/executives",
1151 &subtree_vtable,
1152 G_DBUS_SUBTREE_FLAGS_NONE,
1153 &data,
1154 on_subtree_unregistered,
1155 &error);
1156 g_assert_no_error (error);
1157 g_assert (subtree_registration_id > 0);
1158 /* try registering it again.. this should fail */
1159 registration_id = g_dbus_connection_register_subtree (c,
1160 "/foo/boss/executives",
1161 &subtree_vtable,
1162 G_DBUS_SUBTREE_FLAGS_NONE,
1163 &data,
1164 on_subtree_unregistered,
1165 &error);
1166 g_assert_error (error, G_IO_ERROR, G_IO_ERROR_EXISTS);
1167 g_assert (!g_dbus_error_is_remote_error (error));
1168 g_error_free (error);
1169 error = NULL;
1170 g_assert (registration_id == 0);
1171
1172 /* unregister it, then register it again */
1173 g_assert_cmpint (data.num_unregistered_subtree_calls, ==, 0);
1174 g_assert (g_dbus_connection_unregister_subtree (c, subtree_registration_id));
1175 g_main_context_iteration (NULL, FALSE);
1176 g_assert_cmpint (data.num_unregistered_subtree_calls, ==, 1);
1177 subtree_registration_id = g_dbus_connection_register_subtree (c,
1178 "/foo/boss/executives",
1179 &subtree_vtable,
1180 G_DBUS_SUBTREE_FLAGS_NONE,
1181 &data,
1182 on_subtree_unregistered,
1183 &error);
1184 g_assert_no_error (error);
1185 g_assert (subtree_registration_id > 0);
1186
1187 /* try to register something under /foo/boss/executives - this should work
1188 * because registered subtrees and registered objects can coexist.
1189 *
1190 * Make the exported object implement *two* interfaces so we can check
1191 * that the right introspection handler is invoked.
1192 */
1193 registration_id = g_dbus_connection_register_object (c,
1194 "/foo/boss/executives/non_subtree_object",
1195 (GDBusInterfaceInfo *) &bar_interface_info,
1196 NULL,
1197 &data,
1198 on_object_unregistered,
1199 &error);
1200 g_assert_no_error (error);
1201 g_assert (registration_id > 0);
1202 non_subtree_object_path_bar_reg_id = registration_id;
1203 num_successful_registrations++;
1204 registration_id = g_dbus_connection_register_object (c,
1205 "/foo/boss/executives/non_subtree_object",
1206 (GDBusInterfaceInfo *) &foo_interface_info,
1207 NULL,
1208 &data,
1209 on_object_unregistered,
1210 &error);
1211 g_assert_no_error (error);
1212 g_assert (registration_id > 0);
1213 non_subtree_object_path_foo_reg_id = registration_id;
1214 num_successful_registrations++;
1215
1216 /* now register a dynamic subtree, spawning objects as they are called */
1217 dyna_data = g_ptr_array_new_with_free_func (g_free);
1218 dyna_subtree_registration_id = g_dbus_connection_register_subtree (c,
1219 "/foo/dyna",
1220 &dynamic_subtree_vtable,
1221 G_DBUS_SUBTREE_FLAGS_DISPATCH_TO_UNENUMERATED_NODES,
1222 dyna_data,
1223 (GDestroyNotify)g_ptr_array_unref,
1224 &error);
1225 g_assert_no_error (error);
1226 g_assert (dyna_subtree_registration_id > 0);
1227
1228 /* First assert that we have no nodes in the dynamic subtree */
1229 nodes = get_nodes_at (c, "/foo/dyna");
1230 g_assert (nodes != NULL);
1231 g_assert_cmpint (g_strv_length (nodes), ==, 0);
1232 g_strfreev (nodes);
1233 g_assert_cmpint (count_interfaces (c, "/foo/dyna"), ==, 4);
1234
1235 /* Install three nodes in the dynamic subtree via the dyna_data backdoor and
1236 * assert that they show up correctly in the introspection data */
1237 g_ptr_array_add (dyna_data, g_strdup ("lol"));
1238 g_ptr_array_add (dyna_data, g_strdup ("cat"));
1239 g_ptr_array_add (dyna_data, g_strdup ("cheezburger"));
1240 nodes = get_nodes_at (c, "/foo/dyna");
1241 g_assert (nodes != NULL);
1242 g_assert_cmpint (g_strv_length (nodes), ==, 3);
1243 g_assert_cmpstr (nodes[0], ==, "lol");
1244 g_assert_cmpstr (nodes[1], ==, "cat");
1245 g_assert_cmpstr (nodes[2], ==, "cheezburger");
1246 g_strfreev (nodes);
1247 g_assert_cmpint (count_interfaces (c, "/foo/dyna/lol"), ==, 4);
1248 g_assert_cmpint (count_interfaces (c, "/foo/dyna/cat"), ==, 4);
1249 g_assert_cmpint (count_interfaces (c, "/foo/dyna/cheezburger"), ==, 4);
1250
1251 /* Call a non-existing object path and assert that it has been created */
1252 dyna_create (c, "dynamicallycreated");
1253 nodes = get_nodes_at (c, "/foo/dyna");
1254 g_assert (nodes != NULL);
1255 g_assert_cmpint (g_strv_length (nodes), ==, 4);
1256 g_assert_cmpstr (nodes[0], ==, "lol");
1257 g_assert_cmpstr (nodes[1], ==, "cat");
1258 g_assert_cmpstr (nodes[2], ==, "cheezburger");
1259 g_assert_cmpstr (nodes[3], ==, "dynamicallycreated");
1260 g_strfreev (nodes);
1261 g_assert_cmpint (count_interfaces (c, "/foo/dyna/dynamicallycreated"), ==, 4);
1262
1263 /* now check that the object hierarachy is properly generated... yes, it's a bit
1264 * perverse that we round-trip to the bus to introspect ourselves ;-)
1265 */
1266 nodes = get_nodes_at (c, "/");
1267 g_assert (nodes != NULL);
1268 g_assert_cmpint (g_strv_length (nodes), ==, 1);
1269 g_assert_cmpstr (nodes[0], ==, "foo");
1270 g_strfreev (nodes);
1271 g_assert_cmpint (count_interfaces (c, "/"), ==, 0);
1272
1273 nodes = get_nodes_at (c, "/foo");
1274 g_assert (nodes != NULL);
1275 g_assert_cmpint (g_strv_length (nodes), ==, 2);
1276 g_assert_cmpstr (nodes[0], ==, "boss");
1277 g_assert_cmpstr (nodes[1], ==, "dyna");
1278 g_strfreev (nodes);
1279 g_assert_cmpint (count_interfaces (c, "/foo"), ==, 0);
1280
1281 nodes = get_nodes_at (c, "/foo/boss");
1282 g_assert (nodes != NULL);
1283 g_assert_cmpint (g_strv_length (nodes), ==, 5);
1284 g_assert (_g_strv_has_string ((const gchar* const *) nodes, "worker1"));
1285 g_assert (_g_strv_has_string ((const gchar* const *) nodes, "worker1p1"));
1286 g_assert (_g_strv_has_string ((const gchar* const *) nodes, "worker2"));
1287 g_assert (_g_strv_has_string ((const gchar* const *) nodes, "interns"));
1288 g_assert (_g_strv_has_string ((const gchar* const *) nodes, "executives"));
1289 g_strfreev (nodes);
1290 /* any registered object always implement org.freedesktop.DBus.[Peer,Introspectable,Properties] */
1291 g_assert_cmpint (count_interfaces (c, "/foo/boss"), ==, 5);
1292 g_assert (has_interface (c, "/foo/boss", foo_interface_info.name));
1293 g_assert (has_interface (c, "/foo/boss", bar_interface_info.name));
1294
1295 /* check subtree nodes - we should have only non_subtree_object in /foo/boss/executives
1296 * because data.num_subtree_nodes is 0
1297 */
1298 nodes = get_nodes_at (c, "/foo/boss/executives");
1299 g_assert (nodes != NULL);
1300 g_assert (_g_strv_has_string ((const gchar* const *) nodes, "non_subtree_object"));
1301 g_assert_cmpint (g_strv_length (nodes), ==, 1);
1302 g_strfreev (nodes);
1303 g_assert_cmpint (count_interfaces (c, "/foo/boss/executives"), ==, 0);
1304
1305 /* now change data.num_subtree_nodes and check */
1306 data.num_subtree_nodes = 2;
1307 nodes = get_nodes_at (c, "/foo/boss/executives");
1308 g_assert (nodes != NULL);
1309 g_assert_cmpint (g_strv_length (nodes), ==, 5);
1310 g_assert (_g_strv_has_string ((const gchar* const *) nodes, "non_subtree_object"));
1311 g_assert (_g_strv_has_string ((const gchar* const *) nodes, "vp0"));
1312 g_assert (_g_strv_has_string ((const gchar* const *) nodes, "vp1"));
1313 g_assert (_g_strv_has_string ((const gchar* const *) nodes, "evp0"));
1314 g_assert (_g_strv_has_string ((const gchar* const *) nodes, "evp1"));
1315 /* check that /foo/boss/executives/non_subtree_object is not handled by the
1316 * subtree handlers - we can do this because objects from subtree handlers
1317 * has exactly one interface and non_subtree_object has two
1318 */
1319 g_assert_cmpint (count_interfaces (c, "/foo/boss/executives/non_subtree_object"), ==, 5);
1320 g_assert (has_interface (c, "/foo/boss/executives/non_subtree_object", foo_interface_info.name));
1321 g_assert (has_interface (c, "/foo/boss/executives/non_subtree_object", bar_interface_info.name));
1322 /* check that the vp and evp objects are handled by the subtree handlers */
1323 g_assert_cmpint (count_interfaces (c, "/foo/boss/executives/vp0"), ==, 4);
1324 g_assert_cmpint (count_interfaces (c, "/foo/boss/executives/vp1"), ==, 4);
1325 g_assert_cmpint (count_interfaces (c, "/foo/boss/executives/evp0"), ==, 4);
1326 g_assert_cmpint (count_interfaces (c, "/foo/boss/executives/evp1"), ==, 4);
1327 g_assert (has_interface (c, "/foo/boss/executives/vp0", foo_interface_info.name));
1328 g_assert (has_interface (c, "/foo/boss/executives/vp1", foo_interface_info.name));
1329 g_assert (has_interface (c, "/foo/boss/executives/evp0", bar_interface_info.name));
1330 g_assert (has_interface (c, "/foo/boss/executives/evp1", bar_interface_info.name));
1331 g_strfreev (nodes);
1332 data.num_subtree_nodes = 3;
1333 nodes = get_nodes_at (c, "/foo/boss/executives");
1334 g_assert (nodes != NULL);
1335 g_assert_cmpint (g_strv_length (nodes), ==, 7);
1336 g_assert (_g_strv_has_string ((const gchar* const *) nodes, "non_subtree_object"));
1337 g_assert (_g_strv_has_string ((const gchar* const *) nodes, "vp0"));
1338 g_assert (_g_strv_has_string ((const gchar* const *) nodes, "vp1"));
1339 g_assert (_g_strv_has_string ((const gchar* const *) nodes, "vp2"));
1340 g_assert (_g_strv_has_string ((const gchar* const *) nodes, "evp0"));
1341 g_assert (_g_strv_has_string ((const gchar* const *) nodes, "evp1"));
1342 g_assert (_g_strv_has_string ((const gchar* const *) nodes, "evp2"));
1343 g_strfreev (nodes);
1344
1345 /* This is to check that a bug (rather, class of bugs) in gdbusconnection.c's
1346 *
1347 * g_dbus_connection_list_registered_unlocked()
1348 *
1349 * where /foo/boss/worker1 reported a child '1', is now fixed.
1350 */
1351 nodes = get_nodes_at (c, "/foo/boss/worker1");
1352 g_assert (nodes != NULL);
1353 g_assert_cmpint (g_strv_length (nodes), ==, 0);
1354 g_strfreev (nodes);
1355
1356 /* check that calls are properly dispatched to the functions in foo_vtable for objects
1357 * implementing the org.example.Foo interface
1358 *
1359 * We do this for both a regular registered object (/foo/boss) and also for an object
1360 * registered through the subtree mechanism.
1361 */
1362 test_dispatch ("/foo/boss", TRUE);
1363 test_dispatch ("/foo/boss/executives/vp0", TRUE);
1364
1365 /* To prevent from exiting and attaching a D-Bus tool like D-Feet; uncomment: */
1366 #if 0
1367 g_debug ("Point D-feet or other tool at: %s", g_test_dbus_get_temporary_address());
1368 g_main_loop_run (loop);
1369 #endif
1370
1371 /* check that unregistering the subtree handler works */
1372 g_assert_cmpint (data.num_unregistered_subtree_calls, ==, 1);
1373 g_assert (g_dbus_connection_unregister_subtree (c, subtree_registration_id));
1374 g_main_context_iteration (NULL, FALSE);
1375 g_assert_cmpint (data.num_unregistered_subtree_calls, ==, 2);
1376 nodes = get_nodes_at (c, "/foo/boss/executives");
1377 g_assert (nodes != NULL);
1378 g_assert_cmpint (g_strv_length (nodes), ==, 1);
1379 g_assert (_g_strv_has_string ((const gchar* const *) nodes, "non_subtree_object"));
1380 g_strfreev (nodes);
1381
1382 g_assert (g_dbus_connection_unregister_object (c, boss_foo_reg_id));
1383 g_assert (g_dbus_connection_unregister_object (c, boss_bar_reg_id));
1384 g_assert (g_dbus_connection_unregister_object (c, worker1_foo_reg_id));
1385 g_assert (g_dbus_connection_unregister_object (c, worker1p1_foo_reg_id));
1386 g_assert (g_dbus_connection_unregister_object (c, worker2_bar_reg_id));
1387 g_assert (g_dbus_connection_unregister_object (c, intern1_foo_reg_id));
1388 g_assert (g_dbus_connection_unregister_object (c, intern2_bar_reg_id));
1389 g_assert (g_dbus_connection_unregister_object (c, intern2_foo_reg_id));
1390 g_assert (g_dbus_connection_unregister_object (c, intern3_bar_reg_id));
1391 g_assert (g_dbus_connection_unregister_object (c, non_subtree_object_path_bar_reg_id));
1392 g_assert (g_dbus_connection_unregister_object (c, non_subtree_object_path_foo_reg_id));
1393
1394 g_main_context_iteration (NULL, FALSE);
1395 g_assert_cmpint (data.num_unregistered_calls, ==, num_successful_registrations);
1396
1397 /* check that we no longer export any objects - TODO: it looks like there's a bug in
1398 * libdbus-1 here: libdbus still reports the '/foo' object; so disable the test for now
1399 */
1400 #if 0
1401 nodes = get_nodes_at (c, "/");
1402 g_assert (nodes != NULL);
1403 g_assert_cmpint (g_strv_length (nodes), ==, 0);
1404 g_strfreev (nodes);
1405 #endif
1406
1407 g_object_unref (c);
1408 }
1409
1410 static void
1411 test_object_registration_with_closures (void)
1412 {
1413 GError *error;
1414 guint registration_id;
1415
1416 error = NULL;
1417 c = g_bus_get_sync (G_BUS_TYPE_SESSION, NULL, &error);
1418 g_assert_no_error (error);
1419 g_assert (c != NULL);
1420
1421 registration_id = g_dbus_connection_register_object_with_closures (c,
1422 "/foo/boss",
1423 (GDBusInterfaceInfo *) &foo_interface_info,
1424 g_cclosure_new (G_CALLBACK (foo_method_call), NULL, NULL),
1425 g_cclosure_new (G_CALLBACK (foo_get_property), NULL, NULL),
1426 g_cclosure_new (G_CALLBACK (foo_set_property), NULL, NULL),
1427 &error);
1428 g_assert_no_error (error);
1429 g_assert (registration_id > 0);
1430
1431 test_dispatch ("/foo/boss", FALSE);
1432
1433 g_assert (g_dbus_connection_unregister_object (c, registration_id));
1434
1435 g_object_unref (c);
1436 }
1437
1438 static const GDBusInterfaceInfo test_interface_info1 =
1439 {
1440 -1,
1441 "org.example.Foo",
1442 (GDBusMethodInfo **) NULL,
1443 (GDBusSignalInfo **) NULL,
1444 (GDBusPropertyInfo **) NULL,
1445 NULL,
1446 };
1447
1448 static const GDBusInterfaceInfo test_interface_info2 =
1449 {
1450 -1,
1451 "org.freedesktop.DBus.Properties",
1452 (GDBusMethodInfo **) NULL,
1453 (GDBusSignalInfo **) NULL,
1454 (GDBusPropertyInfo **) NULL,
1455 NULL,
1456 };
1457
1458 static void
1459 check_interfaces (GDBusConnection *c,
1460 const gchar *object_path,
1461 const gchar **interfaces)
1462 {
1463 GError *error;
1464 GDBusProxy *proxy;
1465 gchar *xml_data;
1466 GDBusNodeInfo *node_info;
1467 gint i, j;
1468
1469 error = NULL;
1470 proxy = g_dbus_proxy_new_sync (c,
1471 G_DBUS_PROXY_FLAGS_DO_NOT_LOAD_PROPERTIES |
1472 G_DBUS_PROXY_FLAGS_DO_NOT_CONNECT_SIGNALS,
1473 NULL,
1474 g_dbus_connection_get_unique_name (c),
1475 object_path,
1476 "org.freedesktop.DBus.Introspectable",
1477 NULL,
1478 &error);
1479 g_assert_no_error (error);
1480 g_assert (proxy != NULL);
1481
1482 /* do this async to avoid libdbus-1 deadlocks */
1483 xml_data = NULL;
1484 g_dbus_proxy_call (proxy,
1485 "Introspect",
1486 NULL,
1487 G_DBUS_CALL_FLAGS_NONE,
1488 -1,
1489 NULL,
1490 (GAsyncReadyCallback) introspect_callback,
1491 &xml_data);
1492 g_main_loop_run (loop);
1493 g_assert (xml_data != NULL);
1494
1495 node_info = g_dbus_node_info_new_for_xml (xml_data, &error);
1496 g_assert_no_error (error);
1497 g_assert (node_info != NULL);
1498
1499 g_assert (node_info->interfaces != NULL);
1500 for (i = 0; node_info->interfaces[i]; i++) ;
1501 #if 0
1502 if (g_strv_length ((gchar**)interfaces) != i - 1)
1503 {
1504 g_printerr ("expected ");
1505 for (i = 0; interfaces[i]; i++)
1506 g_printerr ("%s ", interfaces[i]);
1507 g_printerr ("\ngot ");
1508 for (i = 0; node_info->interfaces[i]; i++)
1509 g_printerr ("%s ", node_info->interfaces[i]->name);
1510 g_printerr ("\n");
1511 }
1512 #endif
1513 g_assert_cmpint (g_strv_length ((gchar**)interfaces), ==, i - 1);
1514
1515 for (i = 0; interfaces[i]; i++)
1516 {
1517 for (j = 0; node_info->interfaces[j]; j++)
1518 {
1519 if (strcmp (interfaces[i], node_info->interfaces[j]->name) == 0)
1520 goto found;
1521 }
1522
1523 g_assert_not_reached ();
1524
1525 found: ;
1526 }
1527
1528 g_object_unref (proxy);
1529 g_free (xml_data);
1530 g_dbus_node_info_unref (node_info);
1531 }
1532
1533 static void
1534 test_registered_interfaces (void)
1535 {
1536 GError *error;
1537 guint id1, id2;
1538 const gchar *interfaces[] = {
1539 "org.example.Foo",
1540 "org.freedesktop.DBus.Properties",
1541 "org.freedesktop.DBus.Introspectable",
1542 NULL,
1543 };
1544
1545 error = NULL;
1546 c = g_bus_get_sync (G_BUS_TYPE_SESSION, NULL, &error);
1547 g_assert_no_error (error);
1548 g_assert (c != NULL);
1549
1550 id1 = g_dbus_connection_register_object (c,
1551 "/test",
1552 (GDBusInterfaceInfo *) &test_interface_info1,
1553 NULL,
1554 NULL,
1555 NULL,
1556 &error);
1557 g_assert_no_error (error);
1558 g_assert (id1 > 0);
1559 id2 = g_dbus_connection_register_object (c,
1560 "/test",
1561 (GDBusInterfaceInfo *) &test_interface_info2,
1562 NULL,
1563 NULL,
1564 NULL,
1565 &error);
1566 g_assert_no_error (error);
1567 g_assert (id2 > 0);
1568
1569 check_interfaces (c, "/test", interfaces);
1570
1571 g_assert (g_dbus_connection_unregister_object (c, id1));
1572 g_assert (g_dbus_connection_unregister_object (c, id2));
1573 g_object_unref (c);
1574 }
1575
1576
1577 /* ---------------------------------------------------------------------------------------------------- */
1578
1579 static void
1580 test_async_method_call (GDBusConnection *connection,
1581 const gchar *sender,
1582 const gchar *object_path,
1583 const gchar *interface_name,
1584 const gchar *method_name,
1585 GVariant *parameters,
1586 GDBusMethodInvocation *invocation,
1587 gpointer user_data)
1588 {
1589 const GDBusPropertyInfo *property;
1590
1591 /* Strictly speaking, this function should also expect to receive
1592 * method calls not on the org.freedesktop.DBus.Properties interface,
1593 * but we don't do any during this testcase, so assert that.
1594 */
1595 g_assert_cmpstr (interface_name, ==, "org.freedesktop.DBus.Properties");
1596 g_assert (g_dbus_method_invocation_get_method_info (invocation) == NULL);
1597
1598 property = g_dbus_method_invocation_get_property_info (invocation);
1599
1600 /* We should never be seeing any property calls on the com.example.Bar
1601 * interface because it doesn't export any properties.
1602 *
1603 * In each case below make sure the interface is org.example.Foo.
1604 */
1605
1606 /* Do a whole lot of asserts to make sure that invalid calls are still
1607 * getting properly rejected by GDBusConnection and that our
1608 * environment is as we expect it to be.
1609 */
1610 if (g_str_equal (method_name, "Get"))
1611 {
1612 const gchar *iface_name, *prop_name;
1613
1614 g_variant_get (parameters, "(&s&s)", &iface_name, &prop_name);
1615 g_assert_cmpstr (iface_name, ==, "org.example.Foo");
1616 g_assert (property != NULL);
1617 g_assert_cmpstr (prop_name, ==, property->name);
1618 g_assert (property->flags & G_DBUS_PROPERTY_INFO_FLAGS_READABLE);
1619 g_dbus_method_invocation_return_value (invocation, g_variant_new ("(v)", g_variant_new_string (prop_name)));
1620 }
1621
1622 else if (g_str_equal (method_name, "Set"))
1623 {
1624 const gchar *iface_name, *prop_name;
1625 GVariant *value;
1626
1627 g_variant_get (parameters, "(&s&sv)", &iface_name, &prop_name, &value);
1628 g_assert_cmpstr (iface_name, ==, "org.example.Foo");
1629 g_assert (property != NULL);
1630 g_assert_cmpstr (prop_name, ==, property->name);
1631 g_assert (property->flags & G_DBUS_PROPERTY_INFO_FLAGS_WRITABLE);
1632 g_assert (g_variant_is_of_type (value, G_VARIANT_TYPE (property->signature)));
1633 g_dbus_method_invocation_return_value (invocation, g_variant_new ("()"));
1634 g_variant_unref (value);
1635 }
1636
1637 else if (g_str_equal (method_name, "GetAll"))
1638 {
1639 const gchar *iface_name;
1640
1641 g_variant_get (parameters, "(&s)", &iface_name);
1642 g_assert_cmpstr (iface_name, ==, "org.example.Foo");
1643 g_assert (property == NULL);
1644 g_dbus_method_invocation_return_value (invocation,
1645 g_variant_new_parsed ("({ 'PropertyUno': < 'uno' >,"
1646 " 'NotWritable': < 'notwrite' > },)"));
1647 }
1648
1649 else
1650 g_assert_not_reached ();
1651 }
1652
1653 static gint outstanding_cases;
1654
1655 static void
1656 ensure_result_cb (GObject *source,
1657 GAsyncResult *result,
1658 gpointer user_data)
1659 {
1660 GDBusConnection *connection = G_DBUS_CONNECTION (source);
1661 GVariant *reply;
1662
1663 reply = g_dbus_connection_call_finish (connection, result, NULL);
1664
1665 if (user_data == NULL)
1666 {
1667 /* Expected an error */
1668 g_assert (reply == NULL);
1669 }
1670 else
1671 {
1672 /* Expected a reply of a particular format. */
1673 gchar *str;
1674
1675 g_assert (reply != NULL);
1676 str = g_variant_print (reply, TRUE);
1677 g_assert_cmpstr (str, ==, (const gchar *) user_data);
1678 g_free (str);
1679
1680 g_variant_unref (reply);
1681 }
1682
1683 g_assert_cmpint (outstanding_cases, >, 0);
1684 outstanding_cases--;
1685 }
1686
1687 static void
1688 test_async_case (GDBusConnection *connection,
1689 const gchar *expected_reply,
1690 const gchar *method,
1691 const gchar *format_string,
1692 ...)
1693 {
1694 va_list ap;
1695
1696 va_start (ap, format_string);
1697
1698 g_dbus_connection_call (connection, g_dbus_connection_get_unique_name (connection), "/foo",
1699 "org.freedesktop.DBus.Properties", method, g_variant_new_va (format_string, NULL, &ap),
1700 NULL, G_DBUS_CALL_FLAGS_NONE, -1, NULL, ensure_result_cb, (gpointer) expected_reply);
1701
1702 va_end (ap);
1703
1704 outstanding_cases++;
1705 }
1706
1707 static void
1708 test_async_properties (void)
1709 {
1710 GError *error = NULL;
1711 guint registration_id, registration_id2;
1712 static const GDBusInterfaceVTable vtable = {
1713 test_async_method_call, NULL, NULL
1714 };
1715
1716 c = g_bus_get_sync (G_BUS_TYPE_SESSION, NULL, &error);
1717 g_assert_no_error (error);
1718 g_assert (c != NULL);
1719
1720 registration_id = g_dbus_connection_register_object (c,
1721 "/foo",
1722 (GDBusInterfaceInfo *) &foo_interface_info,
1723 &vtable, NULL, NULL, &error);
1724 g_assert_no_error (error);
1725 g_assert (registration_id);
1726 registration_id2 = g_dbus_connection_register_object (c,
1727 "/foo",
1728 (GDBusInterfaceInfo *) &foo2_interface_info,
1729 &vtable, NULL, NULL, &error);
1730 g_assert_no_error (error);
1731 g_assert (registration_id);
1732
1733 test_async_case (c, NULL, "random", "()");
1734
1735 /* Test a variety of error cases */
1736 test_async_case (c, NULL, "Get", "(si)", "wrong signature", 5);
1737 test_async_case (c, NULL, "Get", "(ss)", "org.example.WrongInterface", "zzz");
1738 test_async_case (c, NULL, "Get", "(ss)", "org.example.Foo", "NoSuchProperty");
1739 test_async_case (c, NULL, "Get", "(ss)", "org.example.Foo", "NotReadable");
1740
1741 test_async_case (c, NULL, "Set", "(si)", "wrong signature", 5);
1742 test_async_case (c, NULL, "Set", "(ssv)", "org.example.WrongInterface", "zzz", g_variant_new_string (""));
1743 test_async_case (c, NULL, "Set", "(ssv)", "org.example.Foo", "NoSuchProperty", g_variant_new_string (""));
1744 test_async_case (c, NULL, "Set", "(ssv)", "org.example.Foo", "NotWritable", g_variant_new_string (""));
1745 test_async_case (c, NULL, "Set", "(ssv)", "org.example.Foo", "PropertyUno", g_variant_new_object_path ("/wrong"));
1746
1747 test_async_case (c, NULL, "GetAll", "(si)", "wrong signature", 5);
1748 test_async_case (c, NULL, "GetAll", "(s)", "org.example.WrongInterface");
1749
1750 /* Make sure that we get no unexpected async property calls for com.example.Foo2 */
1751 test_async_case (c, NULL, "Get", "(ss)", "org.example.Foo2", "zzz");
1752 test_async_case (c, NULL, "Set", "(ssv)", "org.example.Foo2", "zzz", g_variant_new_string (""));
1753 test_async_case (c, "(@a{sv} {},)", "GetAll", "(s)", "org.example.Foo2");
1754
1755 /* Now do the proper things */
1756 test_async_case (c, "(<'PropertyUno'>,)", "Get", "(ss)", "org.example.Foo", "PropertyUno");
1757 test_async_case (c, "(<'NotWritable'>,)", "Get", "(ss)", "org.example.Foo", "NotWritable");
1758 test_async_case (c, "()", "Set", "(ssv)", "org.example.Foo", "PropertyUno", g_variant_new_string (""));
1759 test_async_case (c, "()", "Set", "(ssv)", "org.example.Foo", "NotReadable", g_variant_new_string (""));
1760 test_async_case (c, "({'PropertyUno': <'uno'>, 'NotWritable': <'notwrite'>},)", "GetAll", "(s)", "org.example.Foo");
1761
1762 while (outstanding_cases)
1763 g_main_context_iteration (NULL, TRUE);
1764
1765 g_dbus_connection_unregister_object (c, registration_id);
1766 g_dbus_connection_unregister_object (c, registration_id2);
1767 g_object_unref (c);
1768 }
1769
1770 /* ---------------------------------------------------------------------------------------------------- */
1771
1772 int
1773 main (int argc,
1774 char *argv[])
1775 {
1776 gint ret;
1777
1778 g_test_init (&argc, &argv, NULL);
1779
1780 /* all the tests rely on a shared main loop */
1781 loop = g_main_loop_new (NULL, FALSE);
1782
1783 g_test_add_func ("/gdbus/object-registration", test_object_registration);
1784 g_test_add_func ("/gdbus/object-registration-with-closures", test_object_registration_with_closures);
1785 g_test_add_func ("/gdbus/registered-interfaces", test_registered_interfaces);
1786 g_test_add_func ("/gdbus/async-properties", test_async_properties);
1787
1788 /* TODO: check that we spit out correct introspection data */
1789 /* TODO: check that registering a whole subtree works */
1790
1791 ret = session_bus_run ();
1792
1793 g_main_loop_unref (loop);
1794
1795 return ret;
1796 }
glib mirror