From 800e3caabcd9c85b0b2ae9299217ea31d0309545 Mon Sep 17 00:00:00 2001
From: Antoine van Gelder <antoine@g7.org.za>
Date: Sun, 28 Oct 2007 09:45:28 +0000
Subject: Initial import

---
(limited to 'util/audioplayer.py')

diff --git a/util/audioplayer.py b/util/audioplayer.py
new file mode 100644
index 0000000..911fa42
--- /dev/null
+++ b/util/audioplayer.py
@@ -0,0 +1,132 @@
+# 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 St, Fifth Floor, Boston, MA  02110-1301  USA
+#
+
+import os
+import gst
+import logging
+
+from globals import Globals
+
+from util.decorators import Property
+
+
+class AudioPlayer(object):
+  
+  def __init__(self):
+    pass
+  
+    
+  @Property
+  def uri():
+    def get(self): return self.__uri
+    def set(self, value): 
+      if value is None or not os.path.exists(value):
+	logging.error('AudioPlayer- Invalid URI: %r', value)
+	return
+      self.__uri = value
+      size = os.path.getsize(self.__uri)
+      self.pipeline.get_by_name('source').set_property('location', self.__uri)
+      self.pipeline.get_by_name('source').set_property('mmapsize', size)
+
+
+  @Property
+  def raw():
+    def get(self): 
+      if self.uri is None:
+	logging.error('AudioPlayer - No data')
+	return None
+      f = open(self.uri, 'r')
+      raw = f.read()
+      f.close()
+      return raw
+    def set(self, value): 
+      temp = Globals.temporary_filename()
+      f = open(temp, 'w')
+      f.write(value)
+      f.close()
+      #self.source.set_property('location', temp)
+      #self.source.set_property('mmapsize', len(value))
+      self.uri = temp
+      logging.debug('AudioPlayer - set_raw wrote %d bytes to %s', len(value), temp)
+
+
+  @Property
+  def pipeline():
+    def get(self):
+      if self.__pipeline is None:
+	self.__pipeline = self.__build_pipeline()
+      return self.__pipeline
+
+
+  def play(self):
+    logging.debug('AudioPlayer - started playing sound')
+    self.pipeline.set_state(gst.STATE_PLAYING)
+    logging.debug('AudioPlayer - finished playing sound')
+
+
+
+  def __build_pipeline(self):
+    # pipeline
+    pipeline = gst.Pipeline('pipeline')
+    
+    # add source
+    source = gst.element_factory_make('filesrc', 'source')
+    pipeline.add(source)
+    
+    # add decoder
+    decoder = gst.element_factory_make('decodebin', 'decoder')
+    decoder.connect("new-decoded-pad", self.__new_decoded_pad) #, converter)
+    pipeline.add(decoder)
+    source.link(decoder)
+
+    # add converter
+    converter = gst.element_factory_make("audioconvert", "converter")
+    pipeline.add(converter)
+    
+    # add output
+    sink = gst.element_factory_make('autoaudiosink', 'sink')
+    pipeline.add(sink)
+    converter.link(sink)
+    
+    bus = pipeline.get_bus()
+    bus.add_signal_watch()
+    bus.connect('message', self.__on_audio_message)	
+    
+    return pipeline
+
+  
+  
+  # callbacks ##################################################################
+  
+  def __new_decoded_pad(self, dbin, pad, islast):  #, converter)
+    converter = self.pipeline.get_by_name('converter') # TODO - pass by arg
+    pad.link(converter.get_pad("sink"))
+    
+  
+  def __on_audio_message(self, bus, message):
+    t = message.type
+    #logging.debug('message: %r' % t)
+    if t == gst.MESSAGE_EOS:
+      self.pipeline.set_state(gst.STATE_NULL)
+      logging.debug('AudioPlayer - EOS')
+    elif t == gst.MESSAGE_ERROR:
+      self.pipeline.set_state(gst.STATE_NULL)
+      err, debug = message.parse_error()
+      logging.debug('AudioPlayer - Error: %r %r', err, debug)
+
+
+  # Not used
+  def __on_source_handoff(self, source, buffer, pad):
+    logging.debug('on_source_handoff(%r, %r, %r)', source, buffer, pad)
--
cgit v0.9.1