[nautilus/sam/tracker-3: 22/23] tag-manager: Track files rather than contents
- From: Sam Thursfield <sthursfield src gnome org>
- To: commits-list gnome org
- Cc:
- Subject: [nautilus/sam/tracker-3: 22/23] tag-manager: Track files rather than contents
- Date: Sat, 29 Aug 2020 14:23:43 +0000 (UTC)
commit e6319c7f7d0ab16bed8e2559cb73d4f6202abbf3
Author: Sam Thursfield <sam afuera me uk>
Date: Sat Aug 29 15:58:58 2020 +0200
tag-manager: Track files rather than contents
Nautilus is a file manager, so we should star files.
Previously we starred the content resources extracted by Tracker Miner
FS, instead. This had the advantage that the stars would follow file
renames. It had the downside of being more complex and limited in
which files can be starred. In Tracker 2.x, the feature only worked
in folders indexed by Tracker Miner FS. With Tracker 3.x, it was
additionally limited to files where Tracker had extracted metadata
-- mainly just documents and media files.
This commit takes the simpler approach of storing the star against
the file URL. All files can now be starred, and stars will no longer
persist when a file is moved or renamed.
Fixes https://gitlab.gnome.org/GNOME/nautilus/-/issues/160
data/ontology/nautilus.ontology | 11 +-
src/nautilus-tag-manager.c | 539 ++++++++--------------------------------
src/nautilus-tag-manager.h | 4 +-
3 files changed, 114 insertions(+), 440 deletions(-)
---
diff --git a/data/ontology/nautilus.ontology b/data/ontology/nautilus.ontology
index b87dddc25..ff2b1977d 100644
--- a/data/ontology/nautilus.ontology
+++ b/data/ontology/nautilus.ontology
@@ -8,11 +8,12 @@ nautilus: a nrl:Namespace, nrl:Ontology ;
nrl:prefix "nautilus" ;
nrl:lastModified "2020-05-01T10:00:00Z" .
-nautilus:FileReference a rdfs:Class ;
- rdfs:comment "A unique ID for a file, corresponding with the nie:InformationElement created by
tracker-miner-fs. We use a unique ID rather than the file URL so the star will follow renames." ;
- rdfs:subClassOf rdfs:Resource .
+nautilus:File a rdfs:Class ;
+ rdfs:comment "Represents a file on disk by its URL. Equivalent to
http://tracker.api.gnome.org/ontology/v3/nfo#FileDataObject"; ;
+ rdfs:subClassOf rdfs:Resource ;
+ nrl:notify true .
nautilus:starred a rdf:Property ;
- rdfs:comment "Marks resources that are starred in Nautilus." ;
- rdfs:domain nautilus:FileReference ;
+ rdfs:comment "Marks files that are starred in Nautilus." ;
+ rdfs:domain nautilus:File ;
rdfs:range xsd:boolean .
diff --git a/src/nautilus-tag-manager.c b/src/nautilus-tag-manager.c
index e21749a10..e668f7217 100644
--- a/src/nautilus-tag-manager.c
+++ b/src/nautilus-tag-manager.c
@@ -33,19 +33,14 @@ struct _NautilusTagManager
{
GObject object;
- gboolean tracker_ok;
- TrackerSparqlConnection *local;
- TrackerSparqlConnection *miner_fs;
- const gchar *miner_fs_busname;
+ gboolean database_ok;
+ TrackerSparqlConnection *db;
TrackerNotifier *notifier;
TrackerSparqlStatement *query_starred_files;
- TrackerSparqlStatement *query_updated_file_url;
+ TrackerSparqlStatement *query_file_is_starred;
- /* Map of URI -> tracker ID */
GHashTable *starred_file_uris;
- /* Map of tracker ID -> URI */
- GHashTable *starred_file_ids;
GCancellable *cancellable;
};
@@ -58,23 +53,12 @@ typedef enum
GET_IDS_FOR_URLS
} OperationType;
-typedef struct
-{
- GTask *task;
- GList *selection;
- GHashTable *ids;
- GObject *object;
- GAsyncReadyCallback callback;
- GCancellable *cancellable;
-} InsertTaskData;
-
typedef struct
{
NautilusTagManager *tag_manager;
GTask *task;
GList *selection;
gboolean star;
- GHashTable *ids;
} UpdateData;
enum
@@ -84,71 +68,23 @@ enum
};
#define QUERY_STARRED_FILES \
- "SELECT ?file_url ?content_id " \
+ "SELECT ?file " \
"{ " \
- " ?content_urn a nautilus:FileReference ; " \
+ " ?file a nautilus:File ; " \
" nautilus:starred true . " \
- " SERVICE <dbus:%s> { " \
- " ?content_urn nie:isStoredAs ?file_url . " \
- " BIND (tracker:id (?content_urn) AS ?content_id) " \
- " } " \
"}"
-#define QUERY_UPDATED_FILE_URL \
- "SELECT ?file_url EXISTS { ?content_urn nautilus:starred true } AS ?starred" \
+#define QUERY_FILE_IS_STARRED \
+ "ASK " \
"{ " \
- " SERVICE <dbus:%s> { " \
- " ?content_urn nie:isStoredAs ?file_url . " \
- " FILTER (tracker:id(?content_urn) = ~id) " \
- " }" \
+ " ~file a nautilus:File ; " \
+ " nautilus:starred true . " \
"}"
-
static guint signals[LAST_SIGNAL];
static void
-destroy_insert_task_data (gpointer data)
-{
- InsertTaskData *task_data;
-
- task_data = data;
-
- nautilus_file_list_free (task_data->selection);
- g_free (data);
-}
-
-static GString *
-add_selection_filter (GList *selection,
- GString *query)
-{
- NautilusFile *file;
- GList *l;
-
- g_string_append (query, " FILTER(?file_url IN (");
-
- for (l = selection; l != NULL; l = l->next)
- {
- g_autofree gchar *uri = NULL;
- g_autofree gchar *escaped_uri = NULL;
-
- file = l->data;
-
- uri = nautilus_file_get_uri (file);
- g_string_append_printf (query, "<%s>", uri);
-
- if (l->next != NULL)
- {
- g_string_append (query, ", ");
- }
- }
-
- g_string_append (query, "))");
-
- return query;
-}
-
-static void
-start_query_or_update (TrackerSparqlConnection *local,
+start_query_or_update (TrackerSparqlConnection *db,
GString *query,
GAsyncReadyCallback callback,
gpointer user_data,
@@ -157,7 +93,7 @@ start_query_or_update (TrackerSparqlConnection *local,
{
g_autoptr (GError) error = NULL;
- if (!local)
+ if (!db)
{
g_message ("nautilus-tag-manager: No Tracker connection");
return;
@@ -165,7 +101,7 @@ start_query_or_update (TrackerSparqlConnection *local,
if (is_query)
{
- tracker_sparql_connection_query_async (local,
+ tracker_sparql_connection_query_async (db,
query->str,
cancellable,
callback,
@@ -173,7 +109,7 @@ start_query_or_update (TrackerSparqlConnection *local,
}
else
{
- tracker_sparql_connection_update_async (local,
+ tracker_sparql_connection_update_async (db,
query->str,
cancellable,
callback,
@@ -186,58 +122,21 @@ on_update_callback (GObject *object,
GAsyncResult *result,
gpointer user_data)
{
- TrackerSparqlConnection *local;
+ TrackerSparqlConnection *db;
GError *error;
UpdateData *data;
- gint64 *new_id;
- GList *l;
- gchar *uri;
data = user_data;
error = NULL;
- local = TRACKER_SPARQL_CONNECTION (object);
+ db = TRACKER_SPARQL_CONNECTION (object);
- tracker_sparql_connection_update_finish (local, result, &error);
+ tracker_sparql_connection_update_finish (db, result, &error);
if (error == NULL)
{
- for (l = data->selection; l != NULL; l = l->next)
- {
- uri = nautilus_file_get_uri (NAUTILUS_FILE (l->data));
-
- if (data->star)
- {
- if (g_hash_table_contains (data->ids, uri))
- {
- new_id = g_new0 (gint64, 1);
-
- *new_id = GPOINTER_TO_INT (g_hash_table_lookup (data->ids, uri));
- g_hash_table_insert (data->tag_manager->starred_file_uris,
- nautilus_file_get_uri (NAUTILUS_FILE (l->data)),
- new_id);
- g_hash_table_insert (data->tag_manager->starred_file_ids,
- new_id,
- nautilus_file_get_uri (NAUTILUS_FILE (l->data)));
- }
- else
- {
- g_message ("Ignoring star request for %s as we didn't get the resource ID from
Tracker.", uri);
- }
- }
- else
- {
- new_id = g_hash_table_lookup (data->tag_manager->starred_file_uris, uri);
- if (new_id)
- {
- g_hash_table_remove (data->tag_manager->starred_file_uris, uri);
- g_hash_table_remove (data->tag_manager->starred_file_ids, new_id);
- }
- }
-
- g_free (uri);
- }
+ /* FIXME: make sure data->tag_manager->starred_file_uris is up to date */
if (!nautilus_file_undo_manager_is_operating ())
{
@@ -265,10 +164,6 @@ on_update_callback (GObject *object,
g_object_unref (data->task);
}
- if (data->ids)
- {
- g_hash_table_destroy (data->ids);
- }
nautilus_file_list_free (data->selection);
g_free (data);
}
@@ -329,7 +224,6 @@ on_get_starred_files_cursor_callback (GObject *object,
{
TrackerSparqlCursor *cursor;
const gchar *url;
- gint64 *id;
gboolean success;
NautilusTagManager *self;
GList *changed_files;
@@ -345,13 +239,9 @@ on_get_starred_files_cursor_callback (GObject *object,
return;
}
- id = g_new0 (gint64, 1);
-
url = tracker_sparql_cursor_get_string (cursor, 0, NULL);
- *id = tracker_sparql_cursor_get_integer (cursor, 1);
- g_hash_table_insert (self->starred_file_uris, g_strdup (url), id);
- g_hash_table_insert (self->starred_file_ids, id, g_strdup (url));
+ g_hash_table_add (self->starred_file_uris, g_strdup (url));
file = nautilus_file_get_by_uri (url);
changed_files = g_list_prepend (NULL, file);
@@ -403,7 +293,7 @@ static void
nautilus_tag_manager_query_starred_files (NautilusTagManager *self,
GCancellable *cancellable)
{
- if (!self->tracker_ok)
+ if (!self->database_ok)
{
g_message ("nautilus-tag-manager: No Tracker connection");
return;
@@ -417,259 +307,103 @@ nautilus_tag_manager_query_starred_files (NautilusTagManager *self,
self);
}
-static gpointer
-nautilus_tag_manager_gpointer_task_finish (GObject *source_object,
- GAsyncResult *res,
- GError **error)
-{
- g_return_val_if_fail (g_task_is_valid (res, source_object), FALSE);
-
- return g_task_propagate_pointer (G_TASK (res), error);
-}
-
static GString *
nautilus_tag_manager_delete_tag (NautilusTagManager *self,
- GList *selection,
- GString *query)
+ GList *selection)
{
- g_string_append_printf (query,
- "DELETE { "
- " ?content_urn a nautilus:FileReference ; "
- " nautilus:starred true . "
- "} "
- "WHERE { "
- " SERVICE <dbus:%s> { "
- " ?content_urn nie:isStoredAs ?file_url . ",
- self->miner_fs_busname);
-
- query = add_selection_filter (selection, query);
+ GString *query;
+ NautilusFile *file;
+ GList *l;
- g_string_append (query, " } }\n");
+ query = g_string_new ("DELETE DATA {");
- return query;
-}
+ for (l = selection; l != NULL; l = l->next)
+ {
+ g_autofree gchar *uri = NULL;
-static GString *
-nautilus_tag_manager_insert_tag (NautilusTagManager *self,
- GList *selection,
- GString *query)
-{
- g_string_append_printf (query,
- "INSERT { "
- " ?content_urn a nautilus:FileReference . "
- " ?content_urn nautilus:starred true . "
- "} WHERE { "
- " SERVICE <dbus:%s> { "
- " ?content_urn nie:isStoredAs ?file_url . ",
- self->miner_fs_busname);
+ file = l->data;
- query = add_selection_filter (selection, query);
+ uri = nautilus_file_get_uri (file);
+ g_string_append_printf (query,
+ " <%s> a nautilus:File ; "
+ " nautilus:starred true . ",
+ uri);
+ }
- g_string_append (query, "} }\n");
+ g_string_append (query, "}");
return query;
}
-gboolean
-nautilus_tag_manager_file_is_starred (NautilusTagManager *self,
- const gchar *file_name)
-{
- return g_hash_table_contains (self->starred_file_uris, file_name);
-}
-
-static void
-on_get_file_ids_for_urls_cursor_callback (GObject *object,
- GAsyncResult *result,
- gpointer user_data)
+static GString *
+nautilus_tag_manager_insert_tag (NautilusTagManager *self,
+ GList *selection)
{
- TrackerSparqlCursor *cursor;
- GTask *task;
- gint64 *id;
- const gchar *url;
- gboolean success;
+ GString *query;
+ NautilusFile *file;
GList *l;
- gchar *file_url;
- InsertTaskData *data;
-
- task = user_data;
- data = g_task_get_task_data (task);
-
- cursor = TRACKER_SPARQL_CURSOR (object);
-
- success = get_query_status (cursor, result, GET_IDS_FOR_URLS, task);
- if (!success)
- {
- return;
- }
-
- id = g_new0 (gint64, 1);
- url = tracker_sparql_cursor_get_string (cursor, 0, NULL);
- *id = tracker_sparql_cursor_get_integer (cursor, 1);
+ query = g_string_new ("INSERT DATA {");
- for (l = data->selection; l != NULL; l = l->next)
+ for (l = selection; l != NULL; l = l->next)
{
- file_url = nautilus_file_get_uri (NAUTILUS_FILE (l->data));
-
- if (g_strcmp0 (file_url, url) == 0)
- {
- g_hash_table_insert (data->ids,
- g_strdup (url),
- id);
-
- g_free (file_url);
+ g_autofree gchar *uri = NULL;
- break;
- }
+ file = l->data;
- g_free (file_url);
+ uri = nautilus_file_get_uri (file);
+ g_string_append_printf (query,
+ " <%s> a nautilus:File ; "
+ " nautilus:starred true . ",
+ uri);
}
- tracker_sparql_cursor_next_async (cursor,
- g_task_get_cancellable (task),
- on_get_file_ids_for_urls_cursor_callback,
- task);
-}
-
-
-static void
-on_get_file_ids_for_urls_query_callback (GObject *object,
- GAsyncResult *result,
- gpointer user_data)
-{
- TrackerSparqlCursor *cursor;
- g_autoptr (GError) error = NULL;
- TrackerSparqlConnection *local;
- GTask *task;
-
- local = TRACKER_SPARQL_CONNECTION (object);
- task = user_data;
-
- cursor = tracker_sparql_connection_query_finish (local, result, &error);
+ g_string_append (query, "}");
- if (error != NULL)
- {
- if (error->code != G_IO_ERROR_CANCELLED)
- {
- g_warning ("Error on getting id for url: %s", error->message);
- g_task_return_pointer (task, g_task_get_task_data (task), NULL);
- g_object_unref (task);
- }
- }
- else
- {
- tracker_sparql_cursor_next_async (cursor,
- g_task_get_cancellable (task),
- on_get_file_ids_for_urls_cursor_callback,
- user_data);
- }
+ return query;
}
-static void
-nautilus_tag_manager_get_file_ids_for_urls (NautilusTagManager *self,
- GList *selection,
- GTask *task)
+gboolean
+nautilus_tag_manager_file_is_starred (NautilusTagManager *self,
+ const gchar *file_uri)
{
- GString *query;
-
- query = g_string_new ("");
- g_string_append_printf (query, "SELECT ?file_url ?content_id "
- "WHERE { "
- " SERVICE <dbus:%s> { "
- " ?content_urn nie:isStoredAs ?file_url . "
- " BIND (tracker:id (?content_urn) AS ?content_id) ",
- self->miner_fs_busname);
-
- query = add_selection_filter (selection, query);
-
- g_string_append (query, "} }\n");
-
- start_query_or_update (self->local,
- query,
- on_get_file_ids_for_urls_query_callback,
- task,
- TRUE,
- g_task_get_cancellable (task));
-
- g_string_free (query, TRUE);
+ return g_hash_table_contains (self->starred_file_uris, file_uri);
}
-static void
-on_star_files_callback (GObject *object,
- GAsyncResult *res,
- gpointer user_data)
+void
+nautilus_tag_manager_star_files (NautilusTagManager *self,
+ GObject *object,
+ GList *selection,
+ GAsyncReadyCallback callback,
+ GCancellable *cancellable)
{
- NautilusTagManager *self;
GString *query;
- InsertTaskData *data;
g_autoptr (GError) error = NULL;
GTask *task;
UpdateData *update_data;
- self = NAUTILUS_TAG_MANAGER (object);
-
- data = nautilus_tag_manager_gpointer_task_finish (object, res, &error);
-
- task = g_task_new (data->object, data->cancellable, data->callback, NULL);
+ DEBUG ("Starring %i files", g_list_length (selection));
- query = g_string_new ("");
+ task = g_task_new (object, cancellable, callback, NULL);
- query = nautilus_tag_manager_insert_tag (self,
- data->selection,
- query);
+ query = nautilus_tag_manager_insert_tag (self, selection);
update_data = g_new0 (UpdateData, 1);
update_data->task = task;
update_data->tag_manager = self;
- update_data->selection = nautilus_file_list_copy (data->selection);
+ update_data->selection = nautilus_file_list_copy (selection);
update_data->star = TRUE;
- update_data->ids = data->ids;
- /* the ids hash table is now owned by the update_data,
- * so it will be freed by it.
- */
- destroy_insert_task_data (data);
-
- start_query_or_update (self->local,
+ start_query_or_update (self->db,
query,
on_update_callback,
update_data,
FALSE,
- g_task_get_cancellable (task));
+ cancellable);
g_string_free (query, TRUE);
}
-void
-nautilus_tag_manager_star_files (NautilusTagManager *self,
- GObject *object,
- GList *selection,
- GAsyncReadyCallback callback,
- GCancellable *cancellable)
-{
- GTask *task;
- InsertTaskData *data;
-
- data = g_new0 (InsertTaskData, 1);
- data->selection = nautilus_file_list_copy (selection);
- data->ids = g_hash_table_new_full (g_str_hash,
- g_str_equal,
- (GDestroyNotify) g_free,
- (GDestroyNotify) g_free);
- data->callback = callback;
- data->object = object;
- data->cancellable = cancellable;
-
- DEBUG ("Starring %i files", g_list_length (selection));
-
- task = g_task_new (self, cancellable, on_star_files_callback, NULL);
- g_task_set_task_data (task,
- data,
- NULL);
-
- nautilus_tag_manager_get_file_ids_for_urls (self, selection, task);
-}
-
void
nautilus_tag_manager_unstar_files (NautilusTagManager *self,
GObject *object,
@@ -685,11 +419,7 @@ nautilus_tag_manager_unstar_files (NautilusTagManager *self,
task = g_task_new (object, cancellable, callback, NULL);
- query = g_string_new ("");
-
- query = nautilus_tag_manager_delete_tag (self,
- selection,
- query);
+ query = nautilus_tag_manager_delete_tag (self, selection);
update_data = g_new0 (UpdateData, 1);
update_data->task = task;
@@ -697,7 +427,7 @@ nautilus_tag_manager_unstar_files (NautilusTagManager *self,
update_data->selection = nautilus_file_list_copy (selection);
update_data->star = FALSE;
- start_query_or_update (self->local,
+ start_query_or_update (self->db,
query,
on_update_callback,
update_data,
@@ -718,12 +448,10 @@ on_tracker_notifier_events (TrackerNotifier *notifier,
NautilusTagManager *self;
int i;
const gchar *file_url;
- const gchar *new_file_url;
GError *error = NULL;
TrackerSparqlCursor *cursor;
gboolean query_has_results = FALSE;
- gboolean is_starred;
- gint64 id, *new_id;
+ gboolean starred;
GList *changed_files;
NautilusFile *changed_file;
@@ -733,14 +461,13 @@ on_tracker_notifier_events (TrackerNotifier *notifier,
{
event = g_ptr_array_index (events, i);
- id = tracker_notifier_event_get_id (event);
- file_url = g_hash_table_lookup (self->starred_file_ids, &id);
+ file_url = tracker_notifier_event_get_urn (event);
changed_file = NULL;
- DEBUG ("Got event for tracker resource id %" G_GINT64_FORMAT, id);
+ DEBUG ("Got event for file %s", file_url);
- tracker_sparql_statement_bind_int (self->query_updated_file_url, "id", tracker_notifier_event_get_id
(event));
- cursor = tracker_sparql_statement_execute (self->query_updated_file_url,
+ tracker_sparql_statement_bind_string (self->query_file_is_starred, "file", file_url);
+ cursor = tracker_sparql_statement_execute (self->query_file_is_starred,
NULL,
&error);
@@ -749,66 +476,32 @@ on_tracker_notifier_events (TrackerNotifier *notifier,
query_has_results = tracker_sparql_cursor_next (cursor, NULL, &error);
}
- if (error || !cursor)
+ if (error || !cursor || !query_has_results)
{
- g_warning ("Couldn't query the Tracker Store: '%s'", error ? error->message : "(null error)");
+ g_warning ("Couldn't query the starred files database: '%s'", error ? error->message : "(null
error)");
g_clear_error (&error);
return;
}
- if (!query_has_results)
+ starred = tracker_sparql_cursor_get_boolean (cursor, 0);
+ if (starred)
{
- if (g_hash_table_contains (self->starred_file_ids, &id))
- {
- /* The file was deleted from the filesystem or is no longer indexed by Tracker. */
- file_url = g_hash_table_lookup (self->starred_file_ids, &id);
- DEBUG ("Removing %s from starred files list, as id %" G_GINT64_FORMAT " no longer present in
Tracker index. ", file_url, id);
+ gboolean inserted = g_hash_table_add (self->starred_file_uris, g_strdup (file_url));
+ if (inserted)
+ {
+ DEBUG ("Added %s to starred files list", file_url);
changed_file = nautilus_file_get_by_uri (file_url);
-
- g_hash_table_remove (self->starred_file_ids, &id);
- g_hash_table_remove (self->starred_file_uris, file_url);
}
}
else
{
- new_file_url = tracker_sparql_cursor_get_string (cursor, 0, NULL);
- is_starred = tracker_sparql_cursor_get_boolean (cursor, 1);
+ gboolean removed = g_hash_table_remove (self->starred_file_uris, file_url);
- if (g_hash_table_contains (self->starred_file_ids, &id))
- {
- if (is_starred && strcmp (file_url, new_file_url) != 0)
- {
- new_id = g_new0 (gint64, 1);
- *new_id = id;
-
- DEBUG ("Starred file changed URI from %s to %s.", file_url, new_file_url);
- g_hash_table_remove (self->starred_file_uris, file_url);
-
- g_hash_table_insert (self->starred_file_ids, new_id, g_strdup (new_file_url));
- g_hash_table_insert (self->starred_file_uris, g_strdup (new_file_url), new_id);
-
- changed_file = nautilus_file_get_by_uri (new_file_url);
- }
- else if (!is_starred)
- {
- DEBUG ("File is no longer starred: %s", file_url);
- g_hash_table_remove (self->starred_file_uris, file_url);
- g_hash_table_remove (self->starred_file_ids, &id);
-
- changed_file = nautilus_file_get_by_uri (new_file_url);
- }
- }
- else if (is_starred)
+ if (removed)
{
- DEBUG ("File is now starred: %s", new_file_url);
- new_id = g_new0 (gint64, 1);
- *new_id = id;
-
- g_hash_table_insert (self->starred_file_ids, new_id, g_strdup (new_file_url));
- g_hash_table_insert (self->starred_file_uris, g_strdup (new_file_url), new_id);
-
- changed_file = nautilus_file_get_by_uri (new_file_url);
+ DEBUG ("Removed %s from starred files list", file_url);
+ changed_file = nautilus_file_get_by_uri (file_url);
}
}
@@ -840,12 +533,10 @@ nautilus_tag_manager_finalize (GObject *object)
}
g_clear_object (&self->notifier);
- g_clear_object (&self->local);
- g_clear_object (&self->miner_fs);
- g_clear_object (&self->query_updated_file_url);
+ g_clear_object (&self->db);
+ g_clear_object (&self->query_file_is_starred);
g_clear_object (&self->query_starred_files);
- g_hash_table_destroy (self->starred_file_ids);
g_hash_table_destroy (self->starred_file_uris);
G_OBJECT_CLASS (nautilus_tag_manager_parent_class)->finalize (object);
@@ -889,18 +580,17 @@ nautilus_tag_manager_get (void)
}
static gboolean
-setup_tracker_connections (NautilusTagManager *self,
- GCancellable *cancellable,
- GError **error)
+setup_database (NautilusTagManager *self,
+ GCancellable *cancellable,
+ GError **error)
{
const gchar *datadir;
- gchar *query_with_busname;
g_autofree gchar *store_path = NULL;
g_autofree gchar *ontology_path = NULL;
g_autoptr (GFile) store = NULL;
g_autoptr (GFile) ontology = NULL;
- /* Connect to private database to store nautilus:starred property. */
+ /* Open private database to store nautilus:starred property. */
datadir = NAUTILUS_DATADIR;
@@ -910,44 +600,32 @@ setup_tracker_connections (NautilusTagManager *self,
store = g_file_new_for_path (store_path);
ontology = g_file_new_for_path (ontology_path);
- self->local = tracker_sparql_connection_new (TRACKER_SPARQL_CONNECTION_FLAGS_NONE,
- store,
- ontology,
- cancellable,
- error);
-
- if (*error)
- {
- return FALSE;
- }
+ self->db = tracker_sparql_connection_new (TRACKER_SPARQL_CONNECTION_FLAGS_NONE,
+ store,
+ ontology,
+ cancellable,
+ error);
- /* Connect to Tracker filesystem index to follow file renames. */
- self->miner_fs = nautilus_tracker_get_miner_fs_connection (error);
if (*error)
{
return FALSE;
}
- self->miner_fs_busname = nautilus_tracker_get_miner_fs_busname (NULL);
/* Prepare reusable queries. */
- query_with_busname = g_strdup_printf (QUERY_UPDATED_FILE_URL, self->miner_fs_busname);
- self->query_updated_file_url = tracker_sparql_connection_query_statement (self->local,
- query_with_busname,
- cancellable,
- error);
- g_free (query_with_busname);
+ self->query_file_is_starred = tracker_sparql_connection_query_statement (self->db,
+ QUERY_FILE_IS_STARRED,
+ cancellable,
+ error);
if (*error)
{
return FALSE;
}
- query_with_busname = g_strdup_printf (QUERY_STARRED_FILES, self->miner_fs_busname);
- self->query_starred_files = tracker_sparql_connection_query_statement (self->local,
- query_with_busname,
+ self->query_starred_files = tracker_sparql_connection_query_statement (self->db,
+ QUERY_STARRED_FILES,
cancellable,
error);
- g_free (query_with_busname);
if (*error)
{
@@ -964,7 +642,7 @@ nautilus_tag_manager_set_cancellable (NautilusTagManager *self,
{
g_autoptr (GError) error = NULL;
- self->tracker_ok = setup_tracker_connections (self, cancellable, &error);
+ self->database_ok = setup_database (self, cancellable, &error);
if (error)
{
@@ -972,7 +650,7 @@ nautilus_tag_manager_set_cancellable (NautilusTagManager *self,
return;
}
- self->notifier = tracker_sparql_connection_create_notifier (self->miner_fs);
+ self->notifier = tracker_sparql_connection_create_notifier (self->db);
nautilus_tag_manager_query_starred_files (self, cancellable);
@@ -988,11 +666,6 @@ nautilus_tag_manager_init (NautilusTagManager *self)
self->starred_file_uris = g_hash_table_new_full (g_str_hash,
g_str_equal,
(GDestroyNotify) g_free,
- /* values are keys in the other hash table
- * and are freed there */
+ /* values are keys */
NULL);
- self->starred_file_ids = g_hash_table_new_full (g_int_hash,
- g_int_equal,
- (GDestroyNotify) g_free,
- (GDestroyNotify) g_free);
}
diff --git a/src/nautilus-tag-manager.h b/src/nautilus-tag-manager.h
index 7c91bf987..acac9301a 100644
--- a/src/nautilus-tag-manager.h
+++ b/src/nautilus-tag-manager.h
@@ -49,6 +49,6 @@ void nautilus_tag_manager_unstar_files (NautilusTagManager
gboolean nautilus_tag_manager_file_is_starred (NautilusTagManager *self,
- const gchar *file_name);
+ const gchar *file_uri);
-G_END_DECLS
\ No newline at end of file
+G_END_DECLS
[
Date Prev][
Date Next] [
Thread Prev][
Thread Next]
[
Thread Index]
[
Date Index]
[
Author Index]
