vcs.maemo.org Git - nqaap/blob - src/opt/Nqa-Audiobook-player/SimpleGStreamer.py

   1 import os
   2 import logging
   3
   4 import gst
   5
   6 import gtk_toolbox
   7
   8
   9 _moduleLogger = logging.getLogger(__name__)
  10
  11
  12 class SimplePlayer(object):
  13
  14     # @todo Add pitch/speed control
  15     # http://github.com/jwagner/playitslowly/blob/master/playitslowly/pipeline.py
  16
  17     def __init__(self, on_playing_done = None):
  18         #Fields
  19         self.playing = False
  20         self.__filename = ""
  21         self.__elapsed = 0
  22         self.__duration = 0
  23
  24         #Event callbacks
  25         self.on_playing_done = on_playing_done
  26
  27         #Set up GStreamer
  28         self.player = gst.element_factory_make("playbin2", "player")
  29         fakesink = gst.element_factory_make("fakesink", "fakesink")
  30         self.player.set_property("video-sink", fakesink)
  31         bus = self.player.get_bus()
  32         bus.add_signal_watch()
  33         bus.connect("message", self.on_message)
  34
  35         #Constants
  36         self.time_format = gst.Format(gst.FORMAT_TIME)
  37         self.seek_flag = gst.SEEK_FLAG_FLUSH
  38
  39     @property
  40     def has_file(self):
  41         return 0 < len(self.__filename)
  42
  43     @gtk_toolbox.log_exception(_moduleLogger)
  44     def on_message(self, bus, message):
  45         t = message.type
  46         if t == gst.MESSAGE_EOS:        # End-Of-Stream
  47             self.player.set_state(gst.STATE_NULL)
  48             self.playing = False
  49             if self.on_playing_done is not None: # event callback
  50                 self.on_playing_done(self)
  51         elif t == gst.MESSAGE_ERROR:
  52             self.player.set_state(gst.STATE_NULL)
  53             err, debug = message.parse_error()
  54             #print "Error: %s" % err, debug
  55             _moduleLogger.error("Error: %s, (%s)" % (err, debug))
  56             self.playing = False
  57
  58     def set_file(self, file):
  59         _moduleLogger.info("set file: %s", file)
  60         if os.path.isfile(file):
  61             if self.__filename != file:
  62                 self._invalidate_cache()
  63             if self.playing:
  64                 self.stop()
  65
  66             file = os.path.abspath(file) # ensure absolute path
  67             _moduleLogger.debug("set file (absolute path): %s "%file)
  68             self.player.set_property("uri", "file://" + file)
  69             self.__filename = file
  70         else:
  71             _moduleLogger.error("File: %s not found" % file)
  72
  73     def play(self):
  74         _moduleLogger.info("Started playing")
  75         self.player.set_state(gst.STATE_PLAYING)
  76         self.playing = True
  77
  78     def stop(self):
  79         self.player.set_state(gst.STATE_NULL)
  80         self.playing = False
  81         _moduleLogger.info("Stopped playing")
  82
  83     def elapsed(self):
  84         try:
  85             self.__elapsed = self.player.query_position(self.time_format, None)[0]
  86         except:
  87             pass
  88         return self.__elapsed
  89
  90     def duration(self):
  91         try:
  92             self.__duration = self.player.query_duration(self.time_format, None)[0]
  93         except:
  94             _moduleLogger.exception("Query failed")
  95             pass
  96         return self.__duration
  97
  98     def seek_time(self, ns):
  99         _moduleLogger.debug("Seeking to: %s", ns)
 100         self.player.seek_simple(self.time_format, self.seek_flag, ns)
 101
 102     def _invalidate_cache(self):
 103         self.__elapsed = 0
 104         self.__duration = 0
 105
 106     def __seek_percent(self, percent):
 107         format = gst.Format(gst.FORMAT_PERCENT)
 108         self.player.seek_simple(format, self.seek_flag, percent)