From da67213a5f998e8013e7db5f15374de75088f1f6 Mon Sep 17 00:00:00 2001
From: Johannes Knutsen <johannes@knutseninfo.no>
Date: Mon, 9 Aug 2010 09:53:46 +0200
Subject: [PATCH] initial prototype to have libspotify backend to use gstreamer

---
 mopidy/backends/libspotify.py | 38 ++++++++++++++++++++++++++++++-----
 1 file changed, 33 insertions(+), 5 deletions(-)

diff --git a/mopidy/backends/libspotify.py b/mopidy/backends/libspotify.py
index 4f1b2049..32444612 100644
--- a/mopidy/backends/libspotify.py
+++ b/mopidy/backends/libspotify.py
@@ -14,8 +14,7 @@ from mopidy.backends import (BaseBackend, BaseCurrentPlaylistController,
     BaseStoredPlaylistsController)
 from mopidy.models import Artist, Album, Track, Playlist
 
-import alsaaudio
-
+import gst
 logger = logging.getLogger('mopidy.backends.libspotify')
 
 ENCODING = 'utf-8'
@@ -200,9 +199,29 @@ class LibspotifySessionManager(SpotifySessionManager, threading.Thread):
         threading.Thread.__init__(self)
         self.core_queue = core_queue
         self.connected = threading.Event()
-        self.audio = audio_controller_class(alsaaudio.PCM_NORMAL)
         self.session = None
 
+        cap_string = """audio/x-raw-int,
+                endianness=(int)1234,
+                channels=(int)2,
+                width=(int)16,
+                depth=(int)16,
+                signed=True,
+                rate=(int)44100"""
+        caps = gst.caps_from_string(cap_string)
+
+        self.gsrc = gst.element_factory_make("appsrc", "app-source")
+        self.gsrc.set_property('caps', caps)
+
+        self.gsink = gst.element_factory_make("autoaudiosink", "autosink")
+
+        self.pipeline = gst.Pipeline("spotify_pipeline")
+        self.pipeline.add(self.gsrc, self.gsink)
+
+        gst.element_link_many(self.gsrc, self.gsink)
+
+        self.pipeline.set_state(gst.STATE_PLAYING)
+
     def run(self):
         self.connect()
 
@@ -243,8 +262,17 @@ class LibspotifySessionManager(SpotifySessionManager, threading.Thread):
     def music_delivery(self, session, frames, frame_size, num_frames,
             sample_type, sample_rate, channels):
         """Callback used by pyspotify"""
-        self.audio.music_delivery(session, frames, frame_size, num_frames,
-            sample_type, sample_rate, channels)
+        cap_string = """audio/x-raw-int,
+                endianness=(int)1234,
+                channels=(int)2,
+                width=(int)16,
+                depth=(int)16,
+                signed=True,
+                rate=(int)44100"""
+        caps = gst.caps_from_string(cap_string)
+        b = gst.Buffer(frames)
+        b.set_caps(caps)
+        self.gsrc.emit('push-buffer', b)
 
     def play_token_lost(self, session):
         """Callback used by pyspotify"""