[tracker/libtracker-bus: 3/44] libtracker-bus: Get queries working using original dbus methods

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

commit 974e807b686784bea938391b097e5e30046670e0
Author: Martyn Russell <martyn lanedo com>
Date:   Thu Jul 15 16:01:27 2010 +0100

    libtracker-bus: Get queries working using original dbus methods

 src/libtracker-bus/tracker-bus-cursor.c |   87 +++++++++++++++++++++++++++----
 src/libtracker-bus/tracker-bus.vala     |   30 +++++++++--
 2 files changed, 100 insertions(+), 17 deletions(-)
---
diff --git a/src/libtracker-bus/tracker-bus-cursor.c b/src/libtracker-bus/tracker-bus-cursor.c
index b48c9cc..849abcc 100644
--- a/src/libtracker-bus/tracker-bus-cursor.c
+++ b/src/libtracker-bus/tracker-bus-cursor.c
@@ -45,6 +45,7 @@ typedef struct TrackerBusCursorClass TrackerBusCursorClass;
 struct TrackerBusCursor {
 	TrackerSparqlCursor parent_instance;
 
+#ifdef HAVE_DBUS_FD_PASSING
 	char *buffer;
 	int buffer_index;
 	long buffer_size;
@@ -52,6 +53,12 @@ struct TrackerBusCursor {
 	guint n_columns;
 	int *offsets;
 	char *data;
+#else  /* HAVE_DBUS_FD_PASSING */
+	gint n_columns;
+	gint rows;
+	gint current_row;
+	gchar **results;
+#endif /* HAVE_DBUS_FD_PASSING */
 };
 
 struct TrackerBusCursorClass {
@@ -69,6 +76,8 @@ tracker_bus_cursor_rewind (TrackerBusCursor *cursor)
 	/* FIXME: Implement */
 }
 
+#ifdef HAVE_DBUS_FD_PASSING
+
 static inline int
 buffer_read_int (TrackerBusCursor *cursor)
 {
@@ -79,11 +88,14 @@ buffer_read_int (TrackerBusCursor *cursor)
 	return v;
 }
 
+#endif /* HAVE_DBUS_FD_PASSING */
+
 static gboolean
 tracker_bus_cursor_iter_next (TrackerBusCursor  *cursor,
               	              GCancellable      *cancellable,
               	              GError           **error)
 {
+#ifdef HAVE_DBUS_FD_PASSING
 	int last_offset;
 
 	if (cursor->buffer_index >= cursor->buffer_size) {
@@ -102,7 +114,13 @@ tracker_bus_cursor_iter_next (TrackerBusCursor  *cursor,
 	last_offset = buffer_read_int (cursor);
 	cursor->data = cursor->buffer + cursor->buffer_index;
 	cursor->buffer_index += last_offset + 1;
-	
+#else  /* HAVE_DBUS_FD_PASSING */
+	if (cursor->current_row >= (gint) cursor->rows - 1) {
+		return FALSE;
+	}
+
+	cursor->current_row++;
+#endif /* HAVE_DBUS_FD_PASSING */
 	return TRUE;
 }
 
@@ -160,13 +178,41 @@ tracker_bus_cursor_get_string (TrackerBusCursor *cursor,
 	                           guint             column,
 	                           gint             *length)
 {
+	const gchar *str = NULL;
+
+	if (length) {
+		*length = 0;
+	}
+	
+#ifdef HAVE_DBUS_FD_PASSING
 	g_return_val_if_fail (column < tracker_bus_cursor_get_n_columns (cursor), NULL);
 
 	if (column == 0) {
-		return cursor->data;
+		str = cursor->data;
 	} else {
-		return cursor->data + cursor->offsets[column - 1] + 1;
+		str = cursor->data + cursor->offsets[column - 1] + 1;
+	}
+#else  /* HAVE_DBUS_FD_PASSING */
+	gchar **row;
+
+	g_return_val_if_fail (column < tracker_bus_cursor_get_n_columns (cursor), NULL);
+
+	if (cursor->rows < 1) {
+		return NULL;
+	}
+
+	g_return_val_if_fail (cursor->current_row < (gint) cursor->rows, NULL);
+
+	row = cursor->results + cursor->current_row;
+
+	str = row[column];
+#endif /* HAVE_DBUS_FD_PASSING */
+
+	if (length) {
+		*length = strlen (str);
 	}
+
+	return str;
 }
 
 static void
@@ -197,28 +243,32 @@ tracker_bus_cursor_finalize (GObject *object)
 
 	cursor = TRACKER_BUS_CURSOR (object);
 
+#ifdef HAVE_DBUS_FD_PASSING
 	g_free (cursor->buffer);
+#else  /* HAVE_DBUS_FD_PASSING */
+	g_strfreev (cursor->results);
+#endif /* HAVE_DBUS_FD_PASSING */
 
 	G_OBJECT_CLASS (tracker_bus_cursor_parent_class)->finalize (object);
 }
 
-
 // Public API
 
 TrackerSparqlCursor *
 tracker_bus_query (DBusGConnection  *gconnection,
-                   const gchar     *query,
-                   GError         **error)
+                   const gchar      *query,
+                   GError          **error)
 {
 #ifdef HAVE_DBUS_FD_PASSING
-	TrackerBusCursor *cursor;
 	DBusConnection *connection;
 	DBusMessage *message;
 	DBusMessageIter iter;
-	int pipefd[2];
+	TrackerBusCursor *cursor;
 	GError *inner_error = NULL;
+	int pipefd[2];
 
-	g_return_val_if_fail (query, NULL);
+	g_return_val_if_fail (gconnection != NULL, NULL);
+	g_return_val_if_fail (query != NULL, NULL);
 
 	if (pipe (pipefd) < 0) {
 		/* FIXME: Use proper error domain/code */
@@ -254,10 +304,25 @@ tracker_bus_query (DBusGConnection  *gconnection,
 		g_object_unref (cursor);
 		cursor = NULL;
 	}
-
 	return TRACKER_SPARQL_CURSOR (cursor);
 #else  /* HAVE_DBUS_FD_PASSING */
-	return NULL;
+	return NULL;	
 #endif /* HAVE_DBUS_FD_PASSING */
 }
 
+TrackerSparqlCursor *
+tracker_bus_query_results_to_cursor (char **results, int rows, int cols)
+{
+	TrackerBusCursor *cursor;
+	
+	cursor = g_object_new (TRACKER_TYPE_BUS_CURSOR, NULL);
+	
+#ifndef HAVE_DBUS_FD_PASSING
+	cursor->rows = rows;
+	cursor->current_row = -1;
+	cursor->n_columns = cols;
+	cursor->results = results;
+#endif /* HAVE_DBUS_FD_PASSING */
+
+	return TRACKER_SPARQL_CURSOR (cursor);
+}
diff --git a/src/libtracker-bus/tracker-bus.vala b/src/libtracker-bus/tracker-bus.vala
index 6629ebf..140b2d5 100644
--- a/src/libtracker-bus/tracker-bus.vala
+++ b/src/libtracker-bus/tracker-bus.vala
@@ -24,12 +24,15 @@ private interface Tracker.Bus.Resources : GLib.Object {
 
 // Imported DBus FD API until we have support with Vala
 public extern Tracker.Sparql.Cursor tracker_bus_query (DBus.Connection connection, string query) throws GLib.Error;
+public extern Tracker.Sparql.Cursor tracker_bus_query_results_to_cursor (owned char **results, int rows, int cols);
 
 // Actual class definition
 public class Tracker.Bus.Connection : Tracker.Sparql.Connection {
 	static DBus.Connection connection;
+	static Resources resources;
 	static bool initialized;
-
+	static bool use_steroids;
+		
 	public Connection ()
 	requires (!initialized) {
 		initialized = true;
@@ -38,9 +41,11 @@ public class Tracker.Bus.Connection : Tracker.Sparql.Connection {
 			connection = DBus.Bus.get (DBus.BusType.SESSION);
 
 			// FIXME: Test for steroids and resources interfaces?			
-//			resources = (Resources) c.get_object (TRACKER_DBUS_SERVICE,
-//			                                      TRACKER_DBUS_OBJECT_RESOURCES,
-//			                                      TRACKER_DBUS_INTERFACE_RESOURCES);
+			use_steroids = false;
+
+			resources = (Resources) connection.get_object (TRACKER_DBUS_SERVICE,
+			                                               TRACKER_DBUS_OBJECT_RESOURCES,
+			                                               TRACKER_DBUS_INTERFACE_RESOURCES);
 		} catch (DBus.Error e) {
 			warning ("Could not connect to D-Bus service:'%s': %s", TRACKER_DBUS_INTERFACE_RESOURCES, e.message);
 			initialized = false;
@@ -49,13 +54,26 @@ public class Tracker.Bus.Connection : Tracker.Sparql.Connection {
 		
 		initialized = true;
 	}
-
+ 
 	~Connection () {
 		initialized = false;
 	}
 
 	public override Sparql.Cursor? query (string sparql, Cancellable? cancellable) throws GLib.Error {
-		return tracker_bus_query (connection, sparql);
+		// FIXME: Decide between FD passing and DBus-Glib, we need to do this
+		// here because otherwise we need to do the whole set up of their
+		// DBus interface again in the .c file, which is pointless when
+		// one call can do it here just fine.
+		//
+		// Really we need #ifdef here, unsupported in vala AFAIK
+
+		
+		if (use_steroids) {
+			return tracker_bus_query (connection, sparql);
+		} else {
+			string[,] results = resources.SparqlQuery (sparql);
+			return tracker_bus_query_results_to_cursor ((owned) results, results.length[0], results.length[1]);
+		}
 	}
 
 	public async override Sparql.Cursor? query_async (string sparql, Cancellable? cancellable = null) throws GLib.Error {