From dd7808acf7ef17356fa4d68708246c0bb944e46b Mon Sep 17 00:00:00 2001
From: "adrian.sampson" <none@none>
Date: Wed, 4 Feb 2009 04:54:40 +0000
Subject: [PATCH] created player directory and added GstPlayer

--HG--
rename : beets/bpd.py => beets/player/bpd.py
extra : convert_revision : svn%3A41726ec3-264d-0410-9c23-a9f1637257cc/trunk%4094
---
 beets/{ => player}/bpd.py |  0
 beets/player/gstplayer.py | 83 +++++++++++++++++++++++++++++++++++++++
 2 files changed, 83 insertions(+)
 rename beets/{ => player}/bpd.py (100%)
 create mode 100755 beets/player/gstplayer.py

diff --git a/beets/bpd.py b/beets/player/bpd.py
similarity index 100%
rename from beets/bpd.py
rename to beets/player/bpd.py
diff --git a/beets/player/gstplayer.py b/beets/player/gstplayer.py
new file mode 100755
index 000000000..1effe9d59
--- /dev/null
+++ b/beets/player/gstplayer.py
@@ -0,0 +1,83 @@
+#!/usr/bin/env python
+
+import gst
+import sys
+import time
+import gobject
+import thread
+import os
+
+class GstPlayer(object):
+    def __init__(self):
+        # set up the Gstreamer player
+        self.player = gst.element_factory_make("playbin", "player")
+        fakesink = gst.element_factory_make("fakesink", "fakesink")
+        self.player.set_property("video-sink", fakesink)
+        bus = self.player.get_bus()
+        bus.add_signal_watch()
+        bus.connect("message", self._handle_message)
+        
+        # set up our own stuff
+        self.playing = False
+        self.queue = []
+
+    def _get_state(self):
+        return self.player.get_state()[1]
+    
+    def _handle_message(self, bus, message):
+        if message.type == gst.MESSAGE_EOS:
+            # file finished playing
+            if self.queue:
+                self.play_file(self.queue.pop())
+            else:
+                self.playing = False
+
+        elif message.type == gst.MESSAGE_ERROR:
+            # error
+            self.player.set_state(gst.STATE_NULL)
+            err, debug = message.parse_error()
+            print "Error: " + err
+            self.playing = False
+
+    def play_file(self, path):
+        self.player.set_state(gst.STATE_NULL)
+        self.player.set_property("uri", "file://" + path)
+        self.player.set_state(gst.STATE_PLAYING)
+        self.playing = True
+
+    def play(self):
+        if self._get_state() == gst.STATE_PAUSED:
+            self.player.set_state(gst.STATE_PLAYING)
+            self.playing = True
+        else:
+            # presumably, nothing is playing
+            self.play_file(self.queue.pop())
+    
+    def pause(self):
+        self.player.set_state(gst.STATE_PAUSED)
+        self.playing = False
+
+    def enqueue(self, path):
+        self.queue[0:0] = [path] # push to front
+
+    def run(self):
+        gobject.threads_init()
+        def start():
+            loop = gobject.MainLoop()
+            loop.run()
+        thread.start_new_thread(start, ())
+
+    def block(self):
+        """Block until we stop playing."""
+        while self.playing:
+            time.sleep(1)
+
+if __name__ == '__main__':
+    path = sys.argv[1]
+    p = GstPlayer()
+    for path in sys.argv[1:]:
+        p.enqueue(os.path.abspath(os.path.expanduser(path)))
+    p.run()
+    p.play()
+    p.block()
+