/* * Copyright (C) 2005 Novell, Inc * * This program is free software; you can redistribute it and/or * modify it under the terms of the GNU General Public License as * published by the Free Software Foundation; either version 2 of the * License, or (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * General Public License for more details. * * You should have received a copy of the GNU General Public * License along with this program; if not, see . * * Author: Anders Carlsson */ #include "nautilus-search-directory.h" #include #include #include #include #include "nautilus-directory-private.h" #include "nautilus-file-private.h" #include "nautilus-file-utilities.h" #include "nautilus-file.h" #include "nautilus-query.h" #include "nautilus-scheme.h" #include "nautilus-search-directory-file.h" #include "nautilus-search-engine.h" #include "nautilus-search-hit.h" struct _NautilusSearchDirectory { NautilusDirectory parent_instance; NautilusQuery *query; NautilusSearchEngine *engine; gboolean search_running; /* When the search directory is stopped or cancelled, we might wait * until all data and signals from previous search are stopped and removed * from the search engine. While this situation happens we don't want to connect * clients to our signals, and we will wait until the search data and signals * are valid and ready. * The worst thing that can happens if we don't do this is that new clients * might get the information of old searches if they are waiting_for_file_list. * But that shouldn't be a big deal since old clients have the old information. * But anyway it's currently unused for this case since the only client is * nautilus-view and is not waiting_for_file_list :) . * * The other use case is for letting clients know if information of the directory * is outdated or not valid. This might happens for automatic * scheduled timeouts. */ gboolean search_ready_and_valid; GHashTable *files_hash; GList *monitor_list; GList *callback_list; GList *pending_callback_list; NautilusDirectory *base_model; }; typedef struct { gboolean monitor_hidden_files; NautilusAttributes monitor_attributes; gconstpointer client; } SearchMonitor; typedef struct { NautilusSearchDirectory *search_directory; NautilusDirectoryCallback callback; gpointer callback_data; NautilusAttributes wait_for_attributes; GList *file_list; GHashTable *non_ready_hash; } SearchCallback; enum { PROP_0, PROP_QUERY, NUM_PROPERTIES }; G_DEFINE_FINAL_TYPE_WITH_CODE (NautilusSearchDirectory, nautilus_search_directory, NAUTILUS_TYPE_DIRECTORY, nautilus_ensure_extension_points (); g_io_extension_point_implement (NAUTILUS_DIRECTORY_PROVIDER_EXTENSION_POINT_NAME, g_define_type_id, NAUTILUS_SEARCH_DIRECTORY_PROVIDER_NAME, 0)) static GParamSpec *properties[NUM_PROPERTIES] = { NULL, }; static void search_callback_file_ready_callback (NautilusFile *file, gpointer data); static void file_changed (NautilusFile *file, NautilusSearchDirectory *self); static void reset_file_list (NautilusSearchDirectory *self) { GHashTableIter hash_iter; NautilusFile *file; g_hash_table_iter_init (&hash_iter, self->files_hash); /* Remove file connections */ while (g_hash_table_iter_next (&hash_iter, (gpointer *) &file, NULL)) { /* Disconnect change handler */ g_signal_handlers_disconnect_by_func (file, file_changed, self); /* Remove monitors */ for (GList *monitor_list = self->monitor_list; monitor_list != NULL; monitor_list = monitor_list->next) { SearchMonitor *monitor = monitor_list->data; nautilus_file_monitor_remove (file, monitor); } } g_hash_table_remove_all (self->files_hash); } static gboolean is_monitoring_hidden_files (NautilusSearchDirectory *self) { for (GList *l = self->monitor_list; l != NULL; l = l->next) { SearchMonitor *monitor = l->data; if (monitor->monitor_hidden_files) { return TRUE; } } return FALSE; } static void start_search (NautilusSearchDirectory *self) { if (self->query == NULL || self->search_running || (self->monitor_list == NULL && self->pending_callback_list == NULL)) { return; } /* We need to start the search engine */ self->search_running = TRUE; self->search_ready_and_valid = FALSE; nautilus_query_set_show_hidden_files (self->query, is_monitoring_hidden_files (self)); reset_file_list (self); nautilus_search_engine_start (self->engine, self->query); } static void stop_search (NautilusSearchDirectory *self) { if (!self->search_running) { return; } self->search_running = FALSE; nautilus_search_engine_stop (self->engine); reset_file_list (self); } static void file_changed (NautilusFile *file, NautilusSearchDirectory *self) { nautilus_directory_emit_files_changed (NAUTILUS_DIRECTORY (self), &(NautilusFileList){ .data = file }); } static void search_monitor_add (NautilusDirectory *directory, gconstpointer client, gboolean monitor_hidden_files, NautilusAttributes attributes, NautilusDirectoryCallback callback, gpointer callback_data) { g_autoptr (GList) files_list = NULL; GList *list; SearchMonitor *monitor; NautilusSearchDirectory *self; NautilusFile *file; self = NAUTILUS_SEARCH_DIRECTORY (directory); monitor = g_new0 (SearchMonitor, 1); monitor->monitor_hidden_files = monitor_hidden_files; monitor->monitor_attributes = attributes; monitor->client = client; self->monitor_list = g_list_prepend (self->monitor_list, monitor); files_list = g_hash_table_get_keys (self->files_hash); if (callback != NULL) { (*callback)(directory, files_list, callback_data); } for (list = files_list; list != NULL; list = list->next) { file = list->data; /* Add monitors */ nautilus_file_monitor_add (file, monitor, attributes); } start_search (self); } static void search_monitor_remove_file_monitors (SearchMonitor *monitor, NautilusSearchDirectory *self) { g_autoptr (GList) files_list = g_hash_table_get_keys (self->files_hash); for (GList *list = files_list; list != NULL; list = list->next) { NautilusFile *file = list->data; nautilus_file_monitor_remove (file, monitor); } } static void search_monitor_destroy (SearchMonitor *monitor, NautilusSearchDirectory *self) { search_monitor_remove_file_monitors (monitor, self); g_free (monitor); } static void search_monitor_remove (NautilusDirectory *directory, gconstpointer client) { NautilusSearchDirectory *self; SearchMonitor *monitor; GList *list; self = NAUTILUS_SEARCH_DIRECTORY (directory); for (list = self->monitor_list; list != NULL; list = list->next) { monitor = list->data; if (monitor->client == client) { self->monitor_list = g_list_delete_link (self->monitor_list, list); search_monitor_destroy (monitor, self); break; } } if (!self->monitor_list) { stop_search (self); } } static void cancel_call_when_ready (gpointer key, gpointer value, gpointer user_data) { SearchCallback *search_callback; NautilusFile *file; file = key; search_callback = user_data; nautilus_file_cancel_call_when_ready (file, search_callback_file_ready_callback, search_callback); } static void search_callback_destroy (SearchCallback *search_callback) { if (search_callback->non_ready_hash) { g_hash_table_foreach (search_callback->non_ready_hash, cancel_call_when_ready, search_callback); g_hash_table_destroy (search_callback->non_ready_hash); } nautilus_file_list_free (search_callback->file_list); g_free (search_callback); } static void search_callback_invoke_and_destroy (SearchCallback *search_callback) { search_callback->callback (NAUTILUS_DIRECTORY (search_callback->search_directory), search_callback->file_list, search_callback->callback_data); search_callback->search_directory->callback_list = g_list_remove (search_callback->search_directory->callback_list, search_callback); search_callback_destroy (search_callback); } static void search_callback_file_ready_callback (NautilusFile *file, gpointer data) { SearchCallback *search_callback = data; g_hash_table_remove (search_callback->non_ready_hash, file); if (g_hash_table_size (search_callback->non_ready_hash) == 0) { search_callback_invoke_and_destroy (search_callback); } } static void search_callback_add_file_callbacks (SearchCallback *callback) { for (GList *l = callback->file_list; l != NULL; l = l->next) { NautilusFile *file = l->data; nautilus_file_call_when_ready (file, callback->wait_for_attributes, search_callback_file_ready_callback, callback); } } static SearchCallback * search_callback_find (NautilusSearchDirectory *self, NautilusDirectoryCallback callback, gpointer callback_data) { SearchCallback *search_callback; GList *list; for (list = self->callback_list; list != NULL; list = list->next) { search_callback = list->data; if (search_callback->callback == callback && search_callback->callback_data == callback_data) { return search_callback; } } return NULL; } static SearchCallback * search_callback_find_pending (NautilusSearchDirectory *self, NautilusDirectoryCallback callback, gpointer callback_data) { SearchCallback *search_callback; GList *list; for (list = self->pending_callback_list; list != NULL; list = list->next) { search_callback = list->data; if (search_callback->callback == callback && search_callback->callback_data == callback_data) { return search_callback; } } return NULL; } static GHashTable * file_list_to_hash_table (GList *file_list) { GList *list; GHashTable *table; if (!file_list) { return NULL; } table = g_hash_table_new (NULL, NULL); for (list = file_list; list != NULL; list = list->next) { g_hash_table_insert (table, list->data, list->data); } return table; } static void search_call_when_ready (NautilusDirectory *directory, NautilusAttributes attributes, NautilusDirectoryCallback callback, gpointer callback_data) { NautilusSearchDirectory *self; SearchCallback *search_callback; self = NAUTILUS_SEARCH_DIRECTORY (directory); search_callback = search_callback_find (self, callback, callback_data); if (search_callback == NULL) { search_callback = search_callback_find_pending (self, callback, callback_data); } if (search_callback) { g_warning ("tried to add a new callback while an old one was pending"); return; } search_callback = g_new0 (SearchCallback, 1); search_callback->search_directory = self; search_callback->callback = callback; search_callback->callback_data = callback_data; search_callback->wait_for_attributes = attributes; if (IS_ATTRIBUTE_SET (attributes, NAUTILUS_ATTRIBUTE_FILE_LIST) && !self->search_ready_and_valid) { /* Add it to the pending callback list, which will be * processed when the directory has valid data from the new * search and all data and signals from previous search is removed. */ self->pending_callback_list = g_list_prepend (self->pending_callback_list, search_callback); /* We might need to start the search engine */ start_search (self); } else { g_autoptr (GList) files_list = g_hash_table_get_keys (self->files_hash); search_callback->file_list = nautilus_file_list_copy (files_list); search_callback->non_ready_hash = file_list_to_hash_table (files_list); if (!search_callback->non_ready_hash) { /* If there are no ready files, we invoke the callback * with an empty list. */ search_callback_invoke_and_destroy (search_callback); } else { self->callback_list = g_list_prepend (self->callback_list, search_callback); search_callback_add_file_callbacks (search_callback); } } } static void search_cancel_callback (NautilusDirectory *directory, NautilusDirectoryCallback callback, gpointer callback_data) { NautilusSearchDirectory *self = NAUTILUS_SEARCH_DIRECTORY (directory); SearchCallback *search_callback; if ((search_callback = search_callback_find (self, callback, callback_data)) != NULL) { self->callback_list = g_list_remove (self->callback_list, search_callback); search_callback_destroy (search_callback); } /* Check for a pending callback */ else if ((search_callback = search_callback_find_pending (self, callback, callback_data)) != NULL) { self->pending_callback_list = g_list_remove (self->pending_callback_list, search_callback); search_callback_destroy (search_callback); } if (!self->callback_list && !self->pending_callback_list) { stop_search (self); } } static void search_callback_add_pending_file_callbacks (SearchCallback *callback) { g_autoptr (GList) files_list = g_hash_table_get_keys (callback->search_directory->files_hash); callback->file_list = nautilus_file_list_copy (files_list); callback->non_ready_hash = file_list_to_hash_table (files_list); search_callback_add_file_callbacks (callback); } static void search_directory_add_pending_files_callbacks (NautilusSearchDirectory *self) { /* Add all file callbacks */ g_list_foreach (self->pending_callback_list, (GFunc) search_callback_add_pending_file_callbacks, NULL); self->callback_list = g_list_concat (self->callback_list, self->pending_callback_list); g_list_free (self->pending_callback_list); self->pending_callback_list = NULL; } static void on_search_directory_search_ready_and_valid (NautilusSearchDirectory *self) { search_directory_add_pending_files_callbacks (self); self->search_ready_and_valid = TRUE; } static void search_engine_hits_added (NautilusSearchEngine *engine, GPtrArray *hits, NautilusSearchDirectory *self) { g_autoptr (GList) file_list = NULL; NautilusFile *file; g_autoptr (GDateTime) now = g_date_time_new_now_local (); SearchMonitor *monitor; GList *monitor_list; g_autoptr (GFile) query_location = nautilus_search_directory_get_search_location (self); for (guint i = 0; i < hits->len; i++) { NautilusSearchHit *hit = hits->pdata[i]; const char *uri = nautilus_search_hit_get_uri (hit); NautilusFile *hit_file = nautilus_file_get_by_uri (uri); nautilus_search_hit_compute_scores (hit, now, query_location); nautilus_file_set_search_relevance (hit_file, nautilus_search_hit_get_relevance (hit)); nautilus_file_set_search_fts_snippet (hit_file, nautilus_search_hit_get_fts_snippet (hit)); for (monitor_list = self->monitor_list; monitor_list; monitor_list = monitor_list->next) { monitor = monitor_list->data; /* Add monitors */ nautilus_file_monitor_add (hit_file, monitor, monitor->monitor_attributes); } g_signal_connect (hit_file, "changed", G_CALLBACK (file_changed), self), file_list = g_list_prepend (file_list, hit_file); g_hash_table_add (self->files_hash, g_steal_pointer (&hit_file)); } nautilus_directory_emit_files_added (NAUTILUS_DIRECTORY (self), file_list); file = nautilus_directory_get_corresponding_file (NAUTILUS_DIRECTORY (self)); nautilus_file_emit_changed (file); nautilus_file_unref (file); search_directory_add_pending_files_callbacks (self); } static void search_engine_finished (NautilusSearchDirectory *self) { /* This function does not get called when the search engine is restarted. */ on_search_directory_search_ready_and_valid (self); nautilus_directory_emit_done_loading (NAUTILUS_DIRECTORY (self)); } static NautilusFile * search_new_as_file (NautilusDirectory *directory) { return g_object_new (NAUTILUS_TYPE_SEARCH_DIRECTORY_FILE, "directory", directory, NULL); } static void search_force_reload (NautilusDirectory *directory) { NautilusSearchDirectory *self; NautilusFile *file; self = NAUTILUS_SEARCH_DIRECTORY (directory); if (!self->query) { return; } self->search_ready_and_valid = FALSE; /* Remove file monitors */ reset_file_list (self); stop_search (self); file = nautilus_directory_get_corresponding_file (directory); nautilus_file_invalidate_all_attributes (file); nautilus_file_unref (file); } static gboolean search_are_all_files_seen (NautilusDirectory *directory) { NautilusSearchDirectory *self; self = NAUTILUS_SEARCH_DIRECTORY (directory); return (!self->query || self->search_ready_and_valid); } static gboolean search_contains_file (NautilusDirectory *directory, NautilusFile *file) { NautilusSearchDirectory *self; self = NAUTILUS_SEARCH_DIRECTORY (directory); return (g_hash_table_lookup (self->files_hash, file) != NULL); } static GList * search_get_file_list (NautilusDirectory *directory) { NautilusSearchDirectory *self = NAUTILUS_SEARCH_DIRECTORY (directory); g_hash_table_foreach (self->files_hash, (GHFunc) nautilus_file_ref, NULL); return g_hash_table_get_keys (self->files_hash); } static gboolean search_is_editable (NautilusDirectory *directory) { return FALSE; } static gboolean real_handles_location (GFile *location) { return g_file_has_uri_scheme (location, SCHEME_SEARCH); } static void search_set_property (GObject *object, guint property_id, const GValue *value, GParamSpec *pspec) { NautilusSearchDirectory *self = NAUTILUS_SEARCH_DIRECTORY (object); switch (property_id) { case PROP_QUERY: { nautilus_search_directory_set_query (self, g_value_get_object (value)); } break; default: { G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec); } break; } } static void search_get_property (GObject *object, guint property_id, GValue *value, GParamSpec *pspec) { NautilusSearchDirectory *self = NAUTILUS_SEARCH_DIRECTORY (object); switch (property_id) { case PROP_QUERY: { g_value_set_object (value, nautilus_search_directory_get_query (self)); } break; default: { G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec); } break; } } static void clear_base_model (NautilusSearchDirectory *self) { if (self->base_model != NULL) { nautilus_directory_file_monitor_remove (self->base_model, &self->base_model); g_clear_object (&self->base_model); } } static void search_connect_engine (NautilusSearchDirectory *self) { g_signal_connect (self->engine, "hits-added", G_CALLBACK (search_engine_hits_added), self); g_signal_connect_swapped (self->engine, "search-finished", G_CALLBACK (search_engine_finished), self); } static void search_disconnect_engine (NautilusSearchDirectory *self) { g_signal_handlers_disconnect_by_func (self->engine, search_engine_hits_added, self); g_signal_handlers_disconnect_by_func (self->engine, search_engine_finished, self); } static void search_dispose (GObject *object) { NautilusSearchDirectory *self; GList *list; self = NAUTILUS_SEARCH_DIRECTORY (object); clear_base_model (self); /* Remove search monitors */ if (self->monitor_list) { for (list = self->monitor_list; list != NULL; list = list->next) { search_monitor_destroy ((SearchMonitor *) list->data, self); } g_list_free (self->monitor_list); self->monitor_list = NULL; } reset_file_list (self); if (self->callback_list) { /* Remove callbacks */ g_list_foreach (self->callback_list, (GFunc) search_callback_destroy, NULL); g_list_free (self->callback_list); self->callback_list = NULL; } if (self->pending_callback_list) { g_list_foreach (self->pending_callback_list, (GFunc) search_callback_destroy, NULL); g_list_free (self->pending_callback_list); self->pending_callback_list = NULL; } g_clear_object (&self->query); stop_search (self); search_disconnect_engine (self); g_clear_object (&self->engine); G_OBJECT_CLASS (nautilus_search_directory_parent_class)->dispose (object); } static void search_finalize (GObject *object) { NautilusSearchDirectory *self; self = NAUTILUS_SEARCH_DIRECTORY (object); g_hash_table_destroy (self->files_hash); G_OBJECT_CLASS (nautilus_search_directory_parent_class)->finalize (object); } static void nautilus_search_directory_init (NautilusSearchDirectory *self) { self->query = NULL; self->files_hash = g_hash_table_new_full (NULL, NULL, g_object_unref, NULL); self->engine = nautilus_search_engine_new (NAUTILUS_SEARCH_TYPE_FOLDER); search_connect_engine (self); } static void nautilus_search_directory_class_init (NautilusSearchDirectoryClass *class) { NautilusDirectoryClass *directory_class = NAUTILUS_DIRECTORY_CLASS (class); GObjectClass *oclass = G_OBJECT_CLASS (class); oclass->dispose = search_dispose; oclass->finalize = search_finalize; oclass->get_property = search_get_property; oclass->set_property = search_set_property; directory_class->new_as_file = search_new_as_file; directory_class->are_all_files_seen = search_are_all_files_seen; directory_class->contains_file = search_contains_file; directory_class->force_reload = search_force_reload; directory_class->call_when_ready = search_call_when_ready; directory_class->cancel_callback = search_cancel_callback; directory_class->file_monitor_add = search_monitor_add; directory_class->file_monitor_remove = search_monitor_remove; directory_class->get_file_list = search_get_file_list; directory_class->is_editable = search_is_editable; directory_class->handles_location = real_handles_location; properties[PROP_QUERY] = g_param_spec_object ("query", NULL, NULL, NAUTILUS_TYPE_QUERY, G_PARAM_READWRITE | G_PARAM_EXPLICIT_NOTIFY | G_PARAM_STATIC_STRINGS); g_object_class_install_properties (oclass, NUM_PROPERTIES, properties); } static void update_base_model (NautilusSearchDirectory *self) { g_autoptr (GFile) query_location = nautilus_search_directory_get_search_location (self); g_autoptr (NautilusDirectory) base_model = nautilus_directory_get (query_location); if (self->base_model != base_model) { clear_base_model (self); self->base_model = g_steal_pointer (&base_model); if (self->base_model != NULL) { nautilus_directory_file_monitor_add (self->base_model, &self->base_model, TRUE, NAUTILUS_ATTRIBUTE_INFO, NULL, NULL); } } NautilusSearchType search_type = (self->base_model != NULL) ? NAUTILUS_SEARCH_TYPE_FOLDER : NAUTILUS_SEARCH_TYPE_GLOBAL; nautilus_search_engine_set_search_type (self->engine, search_type); } char * nautilus_search_directory_generate_new_uri (void) { static int counter = 0; return g_strdup_printf (SCHEME_SEARCH "://%d/", counter++); } void nautilus_search_directory_set_query (NautilusSearchDirectory *self, NautilusQuery *query) { g_autoptr (NautilusFile) file = NULL; if (g_set_object (&self->query, query)) { g_object_notify_by_pspec (G_OBJECT (self), properties[PROP_QUERY]); } /* Even if the query is the same, its parameters might have changed, so we * ensure the base model and the display name are up-to-date. */ update_base_model (self); file = nautilus_directory_get_existing_corresponding_file (NAUTILUS_DIRECTORY (self)); if (file != NULL) { nautilus_search_directory_file_update_display_name (NAUTILUS_SEARCH_DIRECTORY_FILE (file)); } } NautilusQuery * nautilus_search_directory_get_query (NautilusSearchDirectory *self) { return self->query; } GFile * nautilus_search_directory_get_search_location (NautilusSearchDirectory *self) { if (self->query != NULL) { return nautilus_query_get_location (self->query); } else { return NULL; } }