summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat
-rw-r--r--tests/dbus/self-handle.c160
1 files changed, 35 insertions, 125 deletions
diff --git a/tests/dbus/self-handle.c b/tests/dbus/self-handle.c
index 10c3f361e..464cd7423 100644
--- a/tests/dbus/self-handle.c
+++ b/tests/dbus/self-handle.c
@@ -16,7 +16,6 @@
#include <telepathy-glib/debug.h>
#include <telepathy-glib/gtypes.h>
#include <telepathy-glib/interfaces.h>
-#include <telepathy-glib/svc-generic.h>
#include "tests/lib/contacts-conn.h"
#include "tests/lib/debug.h"
@@ -24,126 +23,6 @@
#include "tests/lib/util.h"
typedef struct {
- TpTestsContactsConnection parent;
- gboolean change_self_handle_after_get_all;
-} MyConnection;
-
-typedef struct {
- TpTestsContactsConnectionClass parent_class;
-} MyConnectionClass;
-
-static GType my_connection_get_type (void);
-
-#define MY_CONNECTION(obj) \
- (G_TYPE_CHECK_INSTANCE_CAST((obj), my_connection_get_type (), MyConnection))
-
-static void props_iface_init (TpSvcDBusPropertiesClass *);
-
-G_DEFINE_TYPE_WITH_CODE (MyConnection, my_connection,
- TP_TESTS_TYPE_CONTACTS_CONNECTION,
- G_IMPLEMENT_INTERFACE (TP_TYPE_SVC_DBUS_PROPERTIES, props_iface_init))
-
-static void
-my_connection_init (MyConnection *self)
-{
-}
-
-static void
-my_connection_class_init (MyConnectionClass *cls)
-{
-}
-
-static void
-get (TpSvcDBusProperties *iface,
- const gchar *interface_name,
- const gchar *property_name,
- GDBusMethodInvocation *context)
-{
- GObject *self = G_OBJECT (iface);
- GValue value = { 0 };
- GError *error = NULL;
-
- if (tp_dbus_properties_mixin_get (self, interface_name, property_name,
- &value, &error))
- {
- tp_svc_dbus_properties_return_from_get (context, &value);
- g_value_unset (&value);
- }
- else
- {
- g_dbus_method_invocation_return_gerror (context, error);
- g_error_free (error);
- }
-}
-
-static void
-set (TpSvcDBusProperties *iface,
- const gchar *interface_name,
- const gchar *property_name,
- const GValue *value,
- GDBusMethodInvocation *context)
-{
- GObject *self = G_OBJECT (iface);
- GError *error = NULL;
-
- if (tp_dbus_properties_mixin_set (self, interface_name, property_name, value,
- &error))
- {
- tp_svc_dbus_properties_return_from_set (context);
- }
- else
- {
- g_dbus_method_invocation_return_gerror (context, error);
- g_error_free (error);
- }
-}
-
-static void
-get_all (TpSvcDBusProperties *iface,
- const gchar *interface_name,
- GDBusMethodInvocation *context)
-{
- MyConnection *self = MY_CONNECTION (iface);
- TpBaseConnection *base = TP_BASE_CONNECTION (iface);
- GHashTable *values = tp_dbus_properties_mixin_dup_all (G_OBJECT (iface),
- interface_name);
-
- tp_svc_dbus_properties_return_from_get_all (context, values);
- g_hash_table_unref (values);
-
- if (self->change_self_handle_after_get_all &&
- tp_base_connection_get_status (base) == TP_CONNECTION_STATUS_CONNECTED)
- {
- TpTestsSimpleConnection *simple = TP_TESTS_SIMPLE_CONNECTION (iface);
- TpHandleRepoIface *contact_repo = tp_base_connection_get_handles (base,
- TP_ENTITY_TYPE_CONTACT);
-
- DEBUG ("changing my own identifier to something else");
- self->change_self_handle_after_get_all = FALSE;
- tp_tests_simple_connection_set_identifier (simple, "myself@example.org");
- g_assert_cmpstr (tp_handle_inspect (contact_repo,
- tp_base_connection_get_self_handle (base)), ==,
- "myself@example.org");
- }
-}
-
-/* This relies on the assumption that every interface implemented by
- * TpTestsContactsConnection (or at least those exercised by this test)
- * is hooked up to TpDBusPropertiesMixin, which is true in practice. The
- * timing is quite subtle: to work as intended, test_change_inconveniently()
- * needs to change the self-handle *immediately* after the GetAll call. */
-static void
-props_iface_init (TpSvcDBusPropertiesClass *iface)
-{
-#define IMPLEMENT(x) \
- tp_svc_dbus_properties_implement_##x (iface, x)
- IMPLEMENT (get);
- IMPLEMENT (set);
- IMPLEMENT (get_all);
-#undef IMPLEMENT
-}
-
-typedef struct {
GDBusConnection *dbus;
TpTestsSimpleConnection *service_conn;
TpBaseConnection *service_conn_as_base;
@@ -164,7 +43,7 @@ setup (Fixture *f,
f->dbus = tp_tests_dbus_dup_or_die ();
f->service_conn = TP_TESTS_SIMPLE_CONNECTION (
- tp_tests_object_new_static_class (my_connection_get_type (),
+ tp_tests_object_new_static_class (TP_TESTS_TYPE_CONTACTS_CONNECTION,
"account", "me@example.com",
"protocol", "simple",
NULL));
@@ -218,6 +97,21 @@ swapped_counter_cb (gpointer user_data)
++*times;
}
+static GDBusMessage *
+got_all_counter_filter (GDBusConnection *connection,
+ GDBusMessage *message,
+ gboolean incoming,
+ gpointer user_data)
+{
+ guint *times = user_data;
+
+ if (incoming &&
+ !tp_strdiff (g_dbus_message_get_member (message), "GetAll"))
+ ++*times;
+
+ return message;
+}
+
static void
test_self_handle (Fixture *f,
gconstpointer unused G_GNUC_UNUSED)
@@ -329,11 +223,10 @@ test_change_inconveniently (Fixture *f,
gconstpointer arg)
{
TpContact *after;
- guint contact_times = 0;
+ guint contact_times = 0, got_all_times = 0;
gboolean ok;
GQuark features[] = { TP_CONNECTION_FEATURE_CONNECTED, 0 };
-
- MY_CONNECTION (f->service_conn)->change_self_handle_after_get_all = TRUE;
+ guint filter_id;
/* This test exercises what happens if the self-contact changes
* between obtaining its handle for the first time and having the
@@ -344,6 +237,9 @@ test_change_inconveniently (Fixture *f,
g_signal_connect_swapped (f->client_conn, "notify::self-contact",
G_CALLBACK (swapped_counter_cb), &contact_times);
+ filter_id = g_dbus_connection_add_filter (f->dbus,
+ got_all_counter_filter,
+ &got_all_times, NULL);
tp_proxy_prepare_async (f->client_conn, features, tp_tests_result_ready_cb,
&f->result);
@@ -362,6 +258,18 @@ test_change_inconveniently (Fixture *f,
TP_CONNECTION_STATUS_CONNECTED,
TP_CONNECTION_STATUS_REASON_REQUESTED);
+ /* run the main loop until just after GetAll(Connection)
+ * is processed, to make sure the client first saw the old self handle */
+ while (got_all_times == 0)
+ g_main_context_iteration (NULL, TRUE);
+
+ DEBUG ("changing my own identifier to something else");
+ tp_tests_simple_connection_set_identifier (f->service_conn,
+ "myself@example.org");
+ g_assert_cmpstr (tp_handle_inspect (f->contact_repo,
+ tp_base_connection_get_self_handle (f->service_conn_as_base)), ==,
+ "myself@example.org");
+
/* now run the main loop and let the client catch up */
tp_tests_run_until_result (&f->result);
ok = tp_proxy_prepare_finish (f->client_conn, f->result, &f->error);
@@ -383,6 +291,8 @@ test_change_inconveniently (Fixture *f,
g_assert_cmpstr (tp_contact_get_identifier (after), ==,
"myself@example.org");
+ g_dbus_connection_remove_filter (f->dbus, filter_id);
+
g_object_unref (after);
}
generated by cgit v1.2.3 (git 2.39.1) at 2024-12-11 23:56:17 +0000