[tracker/libtracker-bus: 36/51] tests/functional-tests: Refactoring the query test

[Jürg Billeter <juergbi src gnome org>]

commit 0db69b2ff73bfbd2a2d71c11d8dbc8bbf0209940
Author: Philip Van Hoof <philip codeminded be>
Date:   Thu Jul 22 12:56:01 2010 +0200

    tests/functional-tests: Refactoring the query test

 tests/functional-tests/shared-query-test.vala |   68 ++++++++++++++++++++++---
 1 files changed, 60 insertions(+), 8 deletions(-)
---
diff --git a/tests/functional-tests/shared-query-test.vala b/tests/functional-tests/shared-query-test.vala
index b11cdce..2f0eba9 100644
--- a/tests/functional-tests/shared-query-test.vala
+++ b/tests/functional-tests/shared-query-test.vala
@@ -2,7 +2,9 @@ using Tracker;
 using Tracker.Sparql;
 
 public class TestApp : GLib.Object {
+	MainLoop loop;
 	Sparql.Connection con;
+	int res = 0;
 
 	public TestApp (Sparql.Connection connection) {
 		con = connection;
@@ -27,28 +29,78 @@ public class TestApp : GLib.Object {
 		return (0);
 	}
 
-	public int run () {
+	private void test_query () {
 		Cursor cursor;
-		int a;
 
 		try {
 			cursor = con.query ("SELECT ?u WHERE { ?u a rdfs:Class }");
 		} catch (GLib.Error e) {
 			warning ("Couldn't perform query: %s", e.message);
-			return -1;
+			res = -1;
+			return;
 		}
 
-		a = iter_cursor (cursor);
+		res = iter_cursor (cursor);
 
-		if (a == -1)
-			return a;
+		if (res == -1)
+			return;
 
 		print ("\nRewinding\n");
 		cursor.rewind ();
 
 		print ("\nSecond run\n");
-		a = iter_cursor (cursor);
+		res = iter_cursor (cursor);
+	}
+
+	private async void test_query_async () {
+		Cursor cursor;
+
+		try {
+			cursor = yield con.query_async ("SELECT ?u WHERE { ?u a rdfs:Class }");
+		} catch (GLib.Error e) {
+			warning ("Couldn't perform query: %s", e.message);
+			res = -1;
+			return;
+		}
+
+		res = iter_cursor (cursor);
+
+		if (res == -1)
+			return;
+
+		print ("\nRewinding\n");
+		cursor.rewind ();
+
+		print ("\nSecond run\n");
+		res = iter_cursor (cursor);
+	}
+
+	void do_sync_tests () {
+		test_query ();
+	}
+
+	async void do_async_tests () {
+		yield test_query_async ();
+
+		print ("Async tests done, now I can quit the mainloop\n");
+		loop.quit ();
+	}
+
+	bool in_mainloop () {
+
+		do_sync_tests ();
+		do_async_tests ();
+
+		return false;
+	}
+
+	public int run () {
+		loop = new MainLoop (null, false);
+
+		Idle.add (in_mainloop);
+
+		loop.run ();
 
-		return a;
+		return res;
 	}
 }