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     def __init__(self, on_playing_done = None):
  15         #Fields
  16         self.has_file = False
  17         self.playing = False
  18         self.__elapsed = 0
  19
  20         #Event callbacks
  21         self.on_playing_done = on_playing_done
  22
  23         #Set up GStreamer
  24         self.player = gst.element_factory_make("playbin2", "player")
  25         fakesink = gst.element_factory_make("fakesink", "fakesink")
  26         self.player.set_property("video-sink", fakesink)
  27         bus = self.player.get_bus()
  28         bus.add_signal_watch()
  29         bus.connect("message", self.on_message)
  30
  31         #Constants
  32         self.time_format = gst.Format(gst.FORMAT_TIME)
  33         self.seek_flag = gst.SEEK_FLAG_FLUSH
  34
  35     @gtk_toolbox.log_exception(_moduleLogger)
  36     def on_message(self, bus, message):
  37         t = message.type
  38         if t == gst.MESSAGE_EOS:        # End-Of-Stream
  39             self.player.set_state(gst.STATE_NULL)
  40             self.playing = False
  41             if self.on_playing_done is not None: # event callback
  42                 self.on_playing_done(self)
  43         elif t == gst.MESSAGE_ERROR:
  44             self.player.set_state(gst.STATE_NULL)
  45             err, debug = message.parse_error()
  46             #print "Error: %s" % err, debug
  47             _moduleLogger.error("Error: %s, (%s)" % (err, debug))
  48             self.playing = False
  49
  50     def set_file(self, file):
  51         _moduleLogger.info("set file: %s", file)
  52         if os.path.isfile(file):
  53             if self.playing:
  54                 self.stop()
  55
  56             file = os.path.abspath(file) # ensure absolute path
  57             _moduleLogger.debug("set file (absolute path): %s "%file)
  58             self.player.set_property("uri", "file://" + file)
  59             self.has_file = True
  60         else:
  61             _moduleLogger.error("File: %s not found" % file)
  62
  63     def play(self):
  64         _moduleLogger.info("Started playing")
  65         self.player.set_state(gst.STATE_PLAYING)
  66         self.playing = True
  67
  68     def stop(self):
  69         self.player.set_state(gst.STATE_NULL)
  70         self.playing = False
  71         _moduleLogger.info("Stopped playing")
  72
  73     def elapsed(self):
  74         try:
  75             self.__elapsed = self.player.query_position(self.time_format, None)[0]
  76         except:
  77             pass
  78         return self.__elapsed
  79
  80     def duration(self):
  81         try:
  82             return self.player.query_duration(self.time_format, None)[0]
  83         except:
  84             _moduleLogger.exception("Query failed")
  85             return 0
  86
  87     def seek_time(self, ns):
  88         _moduleLogger.debug("Seeking to: %s", ns)
  89         self.player.seek_simple(self.time_format, self.seek_flag, ns)
  90
  91     def __seek_percent(self, percent):
  92         format = gst.Format(gst.FORMAT_PERCENT)
  93         self.player.seek_simple(format, self.seek_flag, percent)