rygel r105 - in trunk: . src

[zeeshanak svn gnome org]

Author: zeeshanak
Date: Tue Oct 28 21:00:25 2008
New Revision: 105
URL: http://svn.gnome.org/viewvc/rygel?rev=105&view=rev

Log:
Add a gstreamer-based metadata extractor.

Added:
   trunk/src/gupnp-metadata-extractor.vala
Modified:
   trunk/ChangeLog
   trunk/src/Makefile.am

Modified: trunk/src/Makefile.am
==============================================================================
--- trunk/src/Makefile.am	(original)
+++ trunk/src/Makefile.am	Tue Oct 28 21:00:25 2008
@@ -41,7 +41,10 @@
 			     gupnp-media-receiver-registrar.vala \
 			     gupnp-media-tracker.h \
 			     gupnp-media-tracker.c \
-			     gupnp-media-tracker.vala
+			     gupnp-media-tracker.vala \
+			     gupnp-metadata-extractor.c \
+			     gupnp-metadata-extractor.h \
+			     gupnp-metadata-extractor.vala
 
 gupnp-media-server.stamp: $(filter %.vala,$(gupnp_media_server_SOURCES))
 	$(VALAC) -C --vapidir=$(srcdir) --pkg cstuff --pkg gupnp-1.0 \

Added: trunk/src/gupnp-metadata-extractor.vala
==============================================================================
--- (empty file)
+++ trunk/src/gupnp-metadata-extractor.vala	Tue Oct 28 21:00:25 2008
@@ -0,0 +1,168 @@
+/*
+ * Copyright (C) 2008 Zeeshan Ali <zeenix gmail com>.
+ *
+ * Author: Zeeshan Ali <zeenix gmail com>
+ *
+ * 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, write to the Free Software Foundation,
+ * Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Library General Public
+ * License as published by the Free Software Foundation; either
+ * version 2 of the License, or (at your option) any later version.
+ */
+
+using Gst;
+using GUPnP;
+
+public class GUPnP.MetadataExtractor: GLib.Object {
+
+    /* TODO: Use tagbin instead once it's ready */
+    private dynamic Gst.Element playbin;
+
+    /* Signals */
+    public signal void metadata_available (string uri,
+                                           string key,
+                                           ref GLib.Value value);
+    public signal void extraction_done (string uri);
+
+    public string uri {
+        get {
+            return playbin.uri;
+        }
+
+        set {
+            playbin.uri = value;
+
+            if (playbin.uri != null) {
+                /* Start the extaction when we get a new URI */
+                playbin.set_state (State.PAUSED);
+            }
+        }
+    }
+
+    /* A list of URIs to extract metadata from */
+    public List <string> _uris = null;
+    public List <string> uris {
+        get {
+            return _uris;
+        }
+
+        set {
+            _uris = value.copy ();
+
+            if (_uris != null) {
+                extraction_done += goto_next_uri;
+                uri = _uris.data;
+            } else {
+                extraction_done -= goto_next_uri;
+            }
+        }
+    }
+
+    private void goto_next_uri (MetadataExtractor extractor,
+                                string            uri) {
+        return_if_fail (_uris != null);
+
+        weak List <string> link = _uris.find_custom (uri, strcmp);
+        _uris.remove_link (link);
+
+        if (_uris != null) {
+            this.uri = _uris.data;
+        } else {
+            extraction_done -= goto_next_uri;
+        }
+    }
+
+    private void tag_cb (Gst.Bus     bus,
+                         Gst.Message message) {
+        TagList tag_list;
+
+        message.parse_tag (out tag_list);
+
+        tag_list.foreach (foreach_tag);
+    }
+
+    private void foreach_tag (TagList tag_list, string tag) {
+        GLib.Value value;
+
+        if (tag_list.copy_value (ref value, tag_list, tag)) {
+            /* signal the availability of new tag */
+            metadata_available (playbin.uri, tag, ref value);
+        }
+    }
+
+    private void state_changed_cb (Gst.Bus     bus,
+                                   Gst.Message message) {
+        if (message.src != playbin)
+            return;
+
+        State new_state;
+
+        message.parse_state_changed (null, out new_state, null);
+        if (new_state == State.PAUSED) {
+            int64 duration;
+
+            Format format = Format.TIME;
+            if (playbin.query_duration (ref format, out duration)) {
+                GLib.Value duration_val;
+
+                duration_val.init (typeof (int64));
+                duration_val.set_int64 (duration);
+
+                /* signal the availability of duration tag */
+                metadata_available (playbin.uri,
+                                    TAG_DURATION,
+                                    ref duration_val);
+            }
+
+            /* No hopes of getting any tags after this point */
+            playbin.set_state (State.NULL);
+            extraction_done (playbin.uri);
+        }
+    }
+
+    private void error_cb (Gst.Bus     bus,
+                           Gst.Message message) {
+
+        return_if_fail (uri != null);
+
+        Error error = null;
+        string debug;
+
+        message.parse_error (out error, out debug);
+        if (error != null) {
+            debug = error.message;
+        }
+
+        critical ("Failed to extract metadata from %s: %s\n", uri, debug);
+
+        if (_uris != null) {
+            /* We have a list of URIs to harvest, so lets jump to next one */
+            goto_next_uri (this, uri);
+        }
+    }
+
+    construct {
+        playbin = ElementFactory.make ("playbin", null);
+
+        var bus = playbin.get_bus ();
+
+        bus.add_signal_watch ();
+
+        bus.message["tag"] += tag_cb;
+        bus.message["state-changed"] += state_changed_cb;
+        bus.message["error"] += error_cb;
+    }
+}
+