#!/usr/bin/env python
# -*- coding: utf-8 -*-

import sys, mplayer
from PyQt4.QtGui import * 
a = QApplication(sys.argv)
w = QWidget()

w.resize(320, 240)
w.setWindowTitle("Hello, World!")
w.show()
mp = mplayer.Mplayer(None)
mp.play("/media/storage/Music/zlt.mp3")
sys.exit(a.exec_())

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import sys, os, fcntl, gobject, time

STATUS_TIMEOUT = 1000

#
#  Provides simple piped I/O to an mplayer process.
#
class Mplayer:
	
	carplayer, mplayerIn, mplayerOut = None, None, None
	eofHandler, statusQuery = 0, 0
	paused = False
	
	#
	#  Initializes this Mplayer with the specified Pymp.
	#
	def __init__(self, carplayer):
		self.carplayer = carplayer
		
	#
	#   Plays the specified target.
	#
	def play(self, target):
		
		mpc = "mplayer -slave -quiet \"" + target + "\" 2>/dev/null"

                import subprocess
                PIPE = subprocess.PIPE
                p = subprocess.Popen(mpc, shell=isinstance(mpc, basestring),
                                 bufsize=-1, stdin=PIPE, stdout=PIPE,
                                 close_fds=True)
                self.mplayerIn, self.mplayerOut = p.stdin, p.stdout

		#self.mplayerIn, self.mplayerOut = os.popen2(mpc)  #open pipe
		fcntl.fcntl(self.mplayerOut, fcntl.F_SETFL, os.O_NONBLOCK)
		
		self.startEofHandler()
		self.startStatusQuery()
		
	#
	#  Issues command to mplayer.
	#
	def cmd(self, command):
		
		if not self.mplayerIn:
			return
		
		try:
			self.mplayerIn.write(command + "\n")
			self.mplayerIn.flush()  #flush pipe
		except StandardError:
			return
		
	#
	#  Toggles pausing of the current mplayer job and status query.
	#
	def pause(self):
		
		if not self.mplayerIn:
			return
			
		if self.paused:  #unpause
			self.startStatusQuery()
			self.paused = False
			
		else:  #pause
			self.stopStatusQuery()
			self.paused = True
			
		self.cmd("pause")
		
	#
	#  Seeks the amount using the specified mode.  See mplayer docs.
	#
	def seek(self, amount, mode=0):
		self.pymp.mplayer.cmd("seek " + str(amount) + " " + str(mode))
		self.pymp.mplayer.queryStatus()
	
	#
	#  Cleanly closes any IPC resources to mplayer.
	#
	def close(self):
		
		if self.paused:  #untoggle pause to cleanly quit
			self.pause()
		
		self.stopStatusQuery()  #cancel query
		self.stopEofHandler()  #cancel eof monitor
		
		self.cmd("quit")  #ask mplayer to quit
		
		try:			
			self.mplayerIn.close()	 #close pipes
			self.mplayerOut.close()
		except StandardError:
			pass
			
		self.mplayerIn, self.mplayerOut = None, None
		#self.pymp.control.setProgress(-1)  #reset bar
		
	#
	#  Triggered when mplayer's stdout reaches EOF.
	#
	def handleEof(self, source, condition):
		
		self.stopStatusQuery()  #cancel query
		
		self.mplayerIn, self.mplayerOut = None, None
		
#		if self.pymp.playlist.continuous:  #play next target
#			self.pymp.playlist.next(None, None)
#		else:  #reset progress bar
#			self.pymp.control.setProgress(-1)
			
		return False
		
	#
	#  Queries mplayer's playback status and upates the progress bar.
	#
	def queryStatus(self):
		
		self.cmd("get_percent_pos")  #submit status query
		self.cmd("get_time_pos")
		
		time.sleep(0.05)  #allow time for output
		
		line, percent, seconds = None, -1, -1
		
		while True:
			try:  #attempt to fetch last line of output
				line = self.mplayerOut.readline()
			except StandardError:
				break
				
			if not line: break
			
			if line.startswith("ANS_PERCENT_POSITION"):
				percent = int(line.replace("ANS_PERCENT_POSITION=", ""))
			
			if line.startswith("ANS_TIME_POSITION"):
				seconds = float(line.replace("ANS_TIME_POSITION=", ""))
		
		#self.pymp.control.setProgress(percent, seconds)
		return True
		
	#
	#  Inserts the status query monitor.
	#
	def startStatusQuery(self):
		self.statusQuery = gobject.timeout_add(STATUS_TIMEOUT, self.queryStatus)
		
	#
	#  Removes the status query monitor.
	#
	def stopStatusQuery(self):
		if self.eofHandler:
			gobject.source_remove(self.statusQuery)
		self.statusQuery = 0
		
	#
	#  Inserts the EOF monitor.
	#
	def startEofHandler(self):
		self.eofHandler = gobject.io_add_watch(self.mplayerOut, gobject.IO_HUP, self.handleEof)
	
	#
	#  Removes the EOF monitor.
	#
	def stopEofHandler(self):
		if self.eofHandler:
			gobject.source_remove(self.eofHandler)
		self.eofHandler = 0
		
#End of file