diff options
Diffstat (limited to 'libmediaart/queue.c')
| -rw-r--r-- | libmediaart/queue.c | 228 |
1 files changed, 228 insertions, 0 deletions
diff --git a/libmediaart/queue.c b/libmediaart/queue.c new file mode 100644 index 0000000..97a889f --- /dev/null +++ b/libmediaart/queue.c @@ -0,0 +1,228 @@ +/* + * Copyright (C) 2008, Nokia <ivan.frade@nokia.com> + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License as published by the Free Software Foundation; either + * version 2.1 of the License, or (at your option) any later version. + * + * This library 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 + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this library; if not, write to the Free Software + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA + * 02110-1301 USA + */ + +#include "config.h" + +#include <string.h> + +#include <glib.h> +#include <glib/gstdio.h> + +#include <libtracker-sparql/tracker-sparql.h> + +/** + * SECTION:tracker-media-art + * @title: Media art management + * @short_description: Media art request and management. + * @include: libtracker-miner/tracker-media-art.h + * + * This is a convenience API using D-Bus to talk to the media management service. + **/ + +static gboolean had_any = FALSE; +static guint timer_id = 0; + +static void +on_query_finished (GObject *source_object, + GAsyncResult *res, + gpointer user_data) +{ + GError *error = NULL; + TrackerSparqlCursor *cursor = NULL; + GDir *dir = NULL; + GHashTable *table = NULL; + const gchar *name; + gchar *dirname = NULL; + GList *to_remove = NULL; + + cursor = tracker_sparql_connection_query_finish (TRACKER_SPARQL_CONNECTION (source_object), + res, + &error); + + if (error) { + goto on_error; + } + + dirname = g_build_filename (g_get_user_cache_dir (), + "media-art", + NULL); + + if (!g_file_test (dirname, G_FILE_TEST_EXISTS)) { + /* Ignore this and just quit the function */ + goto on_error; + } + + dir = g_dir_open (dirname, 0, &error); + + if (error) { + goto on_error; + } + + table = g_hash_table_new_full (g_str_hash, + g_str_equal, + (GDestroyNotify) g_free, + (GDestroyNotify) NULL); + + while (tracker_sparql_cursor_next (cursor, NULL, NULL)) { + gchar *target = NULL, *album_path = NULL; + const gchar *album, *artist; + + album = tracker_sparql_cursor_get_string (cursor, 0, NULL); + artist = tracker_sparql_cursor_get_value_type (cursor, 1) != TRACKER_SPARQL_VALUE_TYPE_UNBOUND ? tracker_sparql_cursor_get_string (cursor, 1, NULL) : NULL; + + /* The get_path API does stripping itself */ + tracker_media_art_get_path (artist, + album, + "album", NULL, + &target, NULL); + + g_hash_table_replace (table, target, target); + + /* Also add the file to which the symlinks are made */ + tracker_media_art_get_path (NULL, + album, + "album", NULL, + &album_path, NULL); + + + g_hash_table_replace (table, album_path, album_path); + } + + /* Perhaps we should have an internal list of media art files that we made, + * instead of going over all the media art (which could also have been made + * by other softwares) */ + + for (name = g_dir_read_name (dir); name != NULL; name = g_dir_read_name (dir)) { + gpointer value; + gchar *full; + + full = g_build_filename (dirname, name, NULL); + + value = g_hash_table_lookup (table, full); + + if (!value) { + g_message ("Removing media-art file %s: no album exists that has " + "any songs for this media-art cache", name); + to_remove = g_list_prepend (to_remove, (gpointer) full); + } else { + g_free (full); + } + } + + g_list_foreach (to_remove, (GFunc) g_unlink, NULL); + g_list_foreach (to_remove, (GFunc) g_free, NULL); + g_list_free (to_remove); + +on_error: + + g_free (dirname); + + if (table) { + g_hash_table_unref (table); + } + + if (cursor) { + g_object_unref (cursor); + } + + if (dir) { + g_dir_close (dir); + } + + if (error) { + g_critical ("Error running cleanup of media-art: %s", + error->message ? error->message : "No error given"); + g_error_free (error); + } +} +/** + * tracker_media_art_queue_remove: + * @uri: URI of the file + * @mime_type: mime-type of the file + * + * Adds a new request to tell the media art subsystem that @uri was removed. + * Stored requests can be processed with tracker_media_art_queue_empty(). + * + * Returns: #TRUE if successfully stored to be reported, #FALSE otherwise. + * + * Since: 0.10.4 + */ +gboolean +tracker_media_art_queue_remove (const gchar *uri, + const gchar *mime_type) +{ + /* mime_type can be NULL */ + + g_return_val_if_fail (uri != NULL, FALSE); + + if (mime_type && (g_str_has_prefix (mime_type, "video/") || g_str_has_prefix (mime_type, "audio/"))) { + had_any = TRUE; + } + + return TRUE; +} + +static gboolean +on_timer_callback (gpointer data) +{ + TrackerSparqlConnection *connection = data; + + tracker_sparql_connection_query_async (connection, + "SELECT ?title nmm:artistName (?artist) WHERE { " + " ?mpiece nmm:musicAlbum ?album . " + " ?album nmm:albumTitle ?title . " + " OPTIONAL { ?album nmm:albumArtist ?artist } " + "}", + NULL, + on_query_finished, + NULL); + + return FALSE; +} + +static void +on_timer_destroy (gpointer data) +{ + TrackerSparqlConnection *connection = data; + + g_object_unref (connection); + timer_id = 0; +} + +/** + * tracker_media_art_queue_execute: + * + * Process all stored media art requests. + * + * Since: 0.10.4 + */ +void +tracker_media_art_queue_empty (TrackerSparqlConnection *connection) +{ + if (had_any && timer_id == 0) { + + timer_id = g_timeout_add_seconds_full (G_PRIORITY_LOW, + 1800 /* Half an hour worth of seconds*/, + on_timer_callback, + g_object_ref (connection), + on_timer_destroy); + + had_any = FALSE; + } +} |