[rhythmbox] grilo: use thumbnail key to provide album art

[Jonathan Matthew <jmatthew src gnome org>]

commit a72b43d4119c7ed6838625cc8ae2a13134514ba4
Author: Jonathan Matthew <jonathan d14n org>
Date:   Sat Sep 17 22:54:09 2011 +1000

    grilo: use thumbnail key to provide album art

 plugins/grilo/rb-grilo-plugin.c |  112 +++++++++++++++++++++++++++++++++++++++
 plugins/grilo/rb-grilo-source.c |   11 +----
 plugins/grilo/rb-grilo-source.h |   19 +++++++
 3 files changed, 132 insertions(+), 10 deletions(-)
---
diff --git a/plugins/grilo/rb-grilo-plugin.c b/plugins/grilo/rb-grilo-plugin.c
index 07e6ef0..49e3b69 100644
--- a/plugins/grilo/rb-grilo-plugin.c
+++ b/plugins/grilo/rb-grilo-plugin.c
@@ -38,6 +38,7 @@
 #include "rb-plugin-macros.h"
 #include "rb-debug.h"
 #include "rb-shell.h"
+#include "rb-shell-player.h"
 #include "rb-grilo-source.h"
 #include "rb-display-page-group.h"
 
@@ -65,6 +66,9 @@ typedef struct
 
 	GrlPluginRegistry *registry;
 	GHashTable *sources;
+	RhythmDB *db;
+	RBShellPlayer *shell_player;
+	gulong emit_cover_art_id;
 } RBGriloPlugin;
 
 typedef struct
@@ -128,11 +132,94 @@ grilo_source_added_cb (GrlPluginRegistry *registry, GrlMediaPlugin *grilo_plugin
 	g_object_unref (shell);
 }
 
+static const char *
+get_cover_art_uri (RhythmDBEntry *entry)
+{
+	RhythmDBEntryType *entry_type;
+	RBGriloEntryData *data;
+
+	entry_type = rhythmdb_entry_get_entry_type (entry);
+	if (RB_IS_GRILO_ENTRY_TYPE (entry_type) == FALSE) {
+		return NULL;
+	}
+
+	data = RHYTHMDB_ENTRY_GET_TYPE_DATA (entry, RBGriloEntryData);
+	return grl_data_get_string (data->grilo_data, GRL_METADATA_KEY_THUMBNAIL);
+}
+
+static GValue *
+cover_art_uri_request_cb (RhythmDB *db, RhythmDBEntry *entry, RBGriloPlugin *plugin)
+{
+	const char *uri;
+
+	uri = get_cover_art_uri (entry);
+	if (uri != NULL) {
+		GValue *value = g_new0 (GValue, 1);
+		g_value_init (value, G_TYPE_STRING);
+		rb_debug ("cover art uri: %s", uri);
+		g_value_set_string (value, uri);
+		return value;
+	} else {
+		return NULL;
+	}
+}
+
+static void
+extra_metadata_gather_cb (RhythmDB *db, RhythmDBEntry *entry, RBStringValueMap *map, RBGriloPlugin *plugin)
+{
+	const char *uri;
+
+	uri = get_cover_art_uri (entry);
+	if (uri != NULL) {
+		GValue v = {0,};
+		g_value_init (&v, G_TYPE_STRING);
+		rb_debug ("cover art uri: %s", uri);
+		rb_string_value_map_set (map, "rb:coverArt-uri", &v);
+		g_value_unset (&v);
+	}
+}
+
+static gboolean
+emit_cover_art_cb (RBGriloPlugin *plugin)
+{
+	const char *uri;
+	RhythmDBEntry *entry;
+	GValue v = {0,};
+
+	entry = rb_shell_player_get_playing_entry (plugin->shell_player);
+	uri = get_cover_art_uri (entry);
+	rb_debug ("emitting cover art uri: %s", uri);
+
+	g_value_init (&v, G_TYPE_STRING);
+	g_value_set_string (&v, uri);
+	rhythmdb_emit_entry_extra_metadata_notify (plugin->db, entry, "rb:coverArt-uri", &v);
+	g_value_unset (&v);
+
+	plugin->emit_cover_art_id = 0;
+	return FALSE;
+}
+
+static void
+playing_song_changed_cb (RBShellPlayer *player, RhythmDBEntry *entry, RBGriloPlugin *plugin)
+{
+	if (entry == NULL || get_cover_art_uri (entry) == NULL) {
+		if (plugin->emit_cover_art_id != 0) {
+			g_source_remove (plugin->emit_cover_art_id);
+			plugin->emit_cover_art_id = 0;
+		}
+	} else {
+		if (plugin->emit_cover_art_id == 0) {
+			plugin->emit_cover_art_id = g_idle_add ((GSourceFunc)emit_cover_art_cb, plugin);
+		}
+	}
+}
+
 static void
 impl_activate (PeasActivatable *plugin)
 {
 	RBGriloPlugin *pi = RB_GRILO_PLUGIN (plugin);
 	GError *error = NULL;
+	RBShell *shell;
 
 	pi->sources = g_hash_table_new_full (g_direct_hash,
 					     g_direct_equal,
@@ -146,6 +233,18 @@ impl_activate (PeasActivatable *plugin)
 		g_warning ("Failed to load Grilo plugins: %s", error->message);
 		g_clear_error (&error);
 	}
+
+	g_object_get (plugin, "object", &shell, NULL);
+	g_object_get (shell,
+		      "db", &pi->db,
+		      "shell-player", &pi->shell_player,
+		      NULL);
+	g_object_unref (shell);
+
+	g_signal_connect (pi->db, "entry-extra-metadata-request::" RHYTHMDB_PROP_COVER_ART_URI, G_CALLBACK (cover_art_uri_request_cb), pi);
+	g_signal_connect (pi->db, "entry-extra-metadata-gather" , G_CALLBACK (extra_metadata_gather_cb), pi);
+
+	g_signal_connect (pi->shell_player, "playing-song-changed", G_CALLBACK (playing_song_changed_cb), pi);
 }
 
 static void
@@ -171,6 +270,19 @@ impl_deactivate	(PeasActivatable *bplugin)
 
 	g_object_unref (plugin->registry);
 	plugin->registry = NULL;
+
+	g_signal_handlers_disconnect_by_func (plugin->db, G_CALLBACK (cover_art_uri_request_cb), plugin);
+	g_signal_handlers_disconnect_by_func (plugin->db, G_CALLBACK (extra_metadata_gather_cb), plugin);
+	g_object_unref (plugin->db);
+	plugin->db = NULL;
+
+	if (plugin->emit_cover_art_id != 0) {
+		g_source_remove (plugin->emit_cover_art_id);
+		plugin->emit_cover_art_id = 0;
+	}
+	g_signal_handlers_disconnect_by_func (plugin->shell_player, G_CALLBACK (playing_song_changed_cb), plugin);
+	g_object_unref (plugin->shell_player);
+	plugin->shell_player = NULL;
 }
 
 G_MODULE_EXPORT void
diff --git a/plugins/grilo/rb-grilo-source.c b/plugins/grilo/rb-grilo-source.c
index 61faea9..84b44ba 100644
--- a/plugins/grilo/rb-grilo-source.c
+++ b/plugins/grilo/rb-grilo-source.c
@@ -88,12 +88,6 @@ static void impl_selected (RBDisplayPage *page);
 
 static RBEntryView *impl_get_entry_view (RBSource *source);
 
-typedef struct
-{
-	GrlData *grilo_data;
-	GrlData *grilo_container;
-} RBGriloEntryData;
-
 struct _RBGriloSourcePrivate
 {
 	GrlMediaSource *grilo_source;
@@ -137,10 +131,6 @@ struct _RBGriloSourcePrivate
 G_DEFINE_DYNAMIC_TYPE (RBGriloSource, rb_grilo_source, RB_TYPE_SOURCE)
 
 /* entry type */
-typedef struct _RhythmDBEntryType RBGriloEntryType;
-typedef struct _RhythmDBEntryTypeClass RBGriloEntryTypeClass;
-
-GType rb_grilo_entry_type_get_type (void);
 
 G_DEFINE_DYNAMIC_TYPE (RBGriloEntryType, rb_grilo_entry_type, RHYTHMDB_TYPE_ENTRY_TYPE);
 
@@ -338,6 +328,7 @@ rb_grilo_source_constructed (GObject *object)
 
 	source->priv->grilo_keys = g_list_prepend (source->priv->grilo_keys, GRL_METADATA_KEY_CHILDCOUNT);
 	source->priv->grilo_keys = g_list_prepend (source->priv->grilo_keys, GRL_METADATA_KEY_URL);
+	source->priv->grilo_keys = g_list_prepend (source->priv->grilo_keys, GRL_METADATA_KEY_THUMBNAIL);
 
 	/* probably add an image column too? */
 	source->priv->browser_model = gtk_tree_store_new (4, GRL_TYPE_MEDIA, G_TYPE_STRING, G_TYPE_INT, G_TYPE_INT);
diff --git a/plugins/grilo/rb-grilo-source.h b/plugins/grilo/rb-grilo-source.h
index 78ddf07..0ba0f0a 100644
--- a/plugins/grilo/rb-grilo-source.h
+++ b/plugins/grilo/rb-grilo-source.h
@@ -42,6 +42,13 @@ G_BEGIN_DECLS
 #define RB_IS_GRILO_SOURCE_CLASS(k)  (G_TYPE_CHECK_CLASS_TYPE ((k), RB_TYPE_GRILO_SOURCE))
 #define RB_GRILO_SOURCE_GET_CLASS(o) (G_TYPE_INSTANCE_GET_CLASS ((o), RB_TYPE_GRILO_SOURCE, RBGriloSourceClass))
 
+#define RB_TYPE_GRILO_ENTRY_TYPE         (rb_grilo_entry_type_get_type ())
+#define RB_GRILO_ENTRY_TYPE(o)           (G_TYPE_CHECK_INSTANCE_CAST ((o), RB_TYPE_GRILO_ENTRY_TYPE, RBGriloEntryType))
+#define RB_GRILO_ENTRY_TYPE_CLASS(k)     (G_TYPE_CHECK_CLASS_CAST((k), RB_TYPE_GRILO_ENTRY_TYPE, RBGriloEntryTypeClass))
+#define RB_IS_GRILO_ENTRY_TYPE(o)        (G_TYPE_CHECK_INSTANCE_TYPE ((o), RB_TYPE_GRILO_ENTRY_TYPE))
+#define RB_IS_GRILO_ENTRY_TYPE_CLASS(k)  (G_TYPE_CHECK_CLASS_TYPE ((k), RB_TYPE_GRILO_ENTRY_TYPE))
+#define RB_GRILO_ENTRY_TYPE_GET_CLASS(o) (G_TYPE_INSTANCE_GET_CLASS ((o), RB_TYPE_GRILO_ENTRY_TYPE, RBGriloEntryTypeClass))
+
 typedef struct _RBGriloSourcePrivate RBGriloSourcePrivate;
 
 typedef struct
@@ -55,11 +62,23 @@ typedef struct
 	RBSourceClass parent;
 } RBGriloSourceClass;
 
+typedef struct _RhythmDBEntryType RBGriloEntryType;
+typedef struct _RhythmDBEntryTypeClass RBGriloEntryTypeClass;
+
+typedef struct
+{
+	GrlData *grilo_data;
+	GrlData *grilo_container;
+} RBGriloEntryData;
+
 RBSource *		rb_grilo_source_new	(GObject *plugin,
 						 GrlMediaSource *grilo_source);
 GType			rb_grilo_source_get_type (void);
 void			_rb_grilo_source_register_type	(GTypeModule *module);
 
+
+GType 			rb_grilo_entry_type_get_type (void);
+
 G_END_DECLS
 
 #endif /* __RB_GRILO_SOURCE_H */