1 files changed, 155 insertions, 4 deletions

diff --git a/tests/test-dbus-qeventloop/test-dbus-qeventloop.cpp b/tests/test-dbus-qeventloop/test-dbus-qeventloop.cpp
index f0385af..f50f95a 100644
--- a/tests/test-dbus-qeventloop/test-dbus-qeventloop.cpp
+++ b/tests/test-dbus-qeventloop/test-dbus-qeventloop.cpp
@@ -5,14 +5,165 @@ class TestDbusQEventLoop: public QObject
 {
 	Q_OBJECT
 
+private:
+	DBusConnection* systemBus;
+	DBUSConnectionEventLoop* dbusEventLoop;
+
+	void resetValues()
+	{
+		wasInNotifyFnc = 0;
+		responseString = 0;
+		responseInt    = 0;
+		typeError      = false;
+		noResponse     = false;
+	}
+
+	void processQTEventLoop(DBusPendingCall* pending)
+	{
+		// Reset response values to zeros and reset errors
+		resetValues();
+
+		// Do we have something pending?
+		if( pending == NULL )
+		{
+			return;
+		}
+
+		// If we have some pending operation, let's get notification about result
+		dbus_pending_call_set_notify(pending, TestDbusQEventLoop::pendingNotify, this, NULL);
+
+		// Pump QT event loop, but only until pending operation is not finished
+		while( !wasInNotifyFnc )
+		{
+			QCoreApplication::processEvents(QEventLoop::AllEvents);
+		}
+	}
+
+public:
+	int 		wasInNotifyFnc;
+	const char* responseString;
+	uint32_t	responseInt;
+	bool		typeError;
+	bool		noResponse;
+
+	TestDbusQEventLoop()
+	{
+		resetValues();
+	}
+
+protected:
+	static void pendingNotify(DBusPendingCall *pending, void *user_data)
+	{
+		MYDEBUG();
+		TestDbusQEventLoop* pThis = reinterpret_cast<TestDbusQEventLoop*>(user_data);
+		DBusMessage* message = dbus_pending_call_steal_reply(pending);
+
+		DBusMessageIter args;
+		if( !dbus_message_iter_init(message, &args) )
+			MYDEBUGC("Reply message has no arguments!");
+		else
+		{
+			const char* error = dbus_message_get_error_name(message);
+
+			if( error != NULL )
+			{
+				pThis->noResponse = (strcmp(error, "org.freedesktop.DBus.Error.NoReply") == 0);
+			}
+
+			int argType = dbus_message_iter_get_arg_type(&args);
+			switch( argType )
+			{
+			case DBUS_TYPE_STRING:
+				dbus_message_iter_get_basic(&args, &pThis->responseString);
+				if( error != NULL )
+					MYDEBUGC("Got error [%s]: %s", error, pThis->responseString);
+				else
+					MYDEBUGC("Got Reply: %s", pThis->responseString);
+				break;
+			case DBUS_TYPE_BOOLEAN:
+			case DBUS_TYPE_UINT32:
+				dbus_message_iter_get_basic(&args, &pThis->responseInt);
+				MYDEBUGC("Got Reply: %d", pThis->responseInt);
+				break;
+			default:
+				MYDEBUGC("Reply message argument has unsupported type (%d)!", argType);
+				pThis->typeError = true;
+			}
+		}
+
+		if( message )
+			dbus_message_unref(message);
+
+		dbus_pending_call_unref(pending);
+
+		pThis->wasInNotifyFnc = 1;
+	}
+
 private slots:
-	void basicTest()
+	void initTestCase()
 	{
-		DBusConnection* systemBus = dbus_bus_get(DBUS_BUS_SYSTEM, NULL);
+		systemBus = dbus_bus_get(DBUS_BUS_SYSTEM, NULL);
 		QVERIFY(systemBus != NULL);
 
-		DBUSConnectionEventLoop d;
-		QVERIFY(d.initConnection(systemBus) == true);
+		dbusEventLoop = new DBUSConnectionEventLoop();
+		QVERIFY(dbusEventLoop != NULL);
+
+		QVERIFY(dbus_bus_name_has_owner(systemBus, "com.nokia.dbusqeventloop.test", NULL) == true);
+	}
+
+	void cleanupTestCase()
+	{
+		DBusMessage* message = dbus_message_new_method_call("com.nokia.dbusqeventloop.test", "/", NULL, "quit");
+		QVERIFY(message != NULL);
+		DBusPendingCall* pending;
+        dbus_connection_send_with_reply(systemBus, message, &pending, 3000);
+		dbus_message_unref(message);
+
+		processQTEventLoop(pending);
+		QVERIFY(responseInt == 12345);
+
+		QVERIFY(dbusEventLoop != NULL);
+		delete dbusEventLoop;
+		dbusEventLoop = NULL;
+	}
+
+	void initConnectionTest()
+	{
+		QVERIFY(dbusEventLoop->initConnection(systemBus) == true);
+	}
+
+	void pingTest()
+	{
+		DBusMessage* message = dbus_message_new_method_call("com.nokia.dbusqeventloop.test", "/", NULL, "ping");
+		QVERIFY(message != NULL);
+
+		const char* temp = "pekny kohutik co sa prechadza po svojom novom dvore a obzera si sliepocky";
+		dbus_message_append_args(message, DBUS_TYPE_STRING, &temp, DBUS_TYPE_INVALID);
+
+		DBusPendingCall* pending;
+        dbus_connection_send_with_reply(systemBus, message, &pending, 3000);
+
+		// Free the signal now we have finished with it
+		dbus_message_unref(message);
+
+		processQTEventLoop(pending);
+		QVERIFY(strcmp(temp, responseString) == 0);
+	}
+
+	void timeoutTest()
+	{
+		DBusMessage* message = dbus_message_new_method_call("com.nokia.dbusqeventloop.test", "/", NULL, "timeout");
+		QVERIFY(message != NULL);
+
+		DBusPendingCall* pending;
+        dbus_connection_send_with_reply(systemBus, message, &pending, 1000);
+
+		// Free the signal now we have finished with it
+		dbus_message_unref(message);
+
+		processQTEventLoop(pending);
+		QVERIFY(noResponse == true);
+		sleep(1);
 	}
 };