# HG changeset patch
# User Josef "Jeff" Sipek <jeffpc@josefsipek.net>
# Date 1162806655 18000
# Node ID d3ac3a46a294d0205a6416de6c000526c73a2491
# Parent  bc6db55448e100901ebdd59c572cb6cc8962db36
Abuse the Rhythmbox dbus messages to announce what is being played

diff -r bc6db55448e1 -r d3ac3a46a294 vixm/player.py
--- a/vixm/player.py	Sun Nov 05 19:25:30 2006 -0500
+++ b/vixm/player.py	Mon Nov 06 04:50:55 2006 -0500
@@ -3,7 +3,7 @@
 
 import mad, ao
 
-import playlist, stats
+import playlist, stats, rb_dbus
 
 class playerThread(Thread):
 	def __init__(self):
@@ -20,6 +20,9 @@
 
 		self.stats    = stats.statsengine("stats")
 
+		self.rb       = rb_dbus.RhythmboxDbusThread(self)
+		self.rb.start()
+
 	def play_next(self, lists):
 		try:
 			# pop song off the PRIO queue
@@ -43,9 +46,16 @@
 
 	def run(self):
 		while not self.shutdown:
-			if self.current and self.playing:
+			c = self.current
+
+			if c and self.playing:
+				# notify everyone
+
+				self.rb.notify("file://" + c["file"], \
+						c["title"], c["artist"])
+
 				# play the file
-				mf = mad.MadFile(self.current["file"])
+				mf = mad.MadFile(c["file"])
 		
 				while True:
 					buf = mf.read(self.blksize)
diff -r bc6db55448e1 -r d3ac3a46a294 vixm/rb_dbus.py
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/vixm/rb_dbus.py	Mon Nov 06 04:50:55 2006 -0500
@@ -0,0 +1,99 @@
+import time
+from threading import Thread
+
+import gobject
+import dbus
+import dbus.service
+if getattr(dbus, 'version', (0,0,0)) >= (0,41,0):
+	import dbus.glib
+
+class PlayerObject(dbus.service.Object):
+	def __init__(self, bus_name,
+			object_path='/org/gnome/Rhythmbox/Player'):
+		dbus.service.Object.__init__(self, bus_name, object_path)
+
+	@dbus.service.signal('org.gnome.Rhythmbox.Player')
+	def playingChanged(self, yesno):
+		pass
+
+	@dbus.service.signal('org.gnome.Rhythmbox.Player')
+	def playingUriChanged(self, uri):
+		pass
+	
+class RhythmboxObject(dbus.service.Object):
+	def __init__(self, bus_name,
+			object_path='/org/gnome/Rhythmbox'):
+		dbus.service.Object.__init__(self, bus_name, object_path)
+
+class ShellObject(dbus.service.Object):
+	def __init__(self, bus_name,
+			object_path='/org/gnome/Rhythmbox/Shell'):
+		dbus.service.Object.__init__(self, bus_name, object_path)
+
+		self.title	= ""
+		self.artist	= ""
+
+	@dbus.service.method('org.gnome.Rhythmbox.Shell')
+	def getSongProperties(self, uri):
+		return dbus.Dictionary({"title": dbus.Variant(self.title), \
+			"artist": dbus.Variant(self.artist)},\
+			    key_type=dbus.String, value_type=dbus.Variant)
+
+	@dbus.service.signal('org.gnome.Rhythmbox.Shell')
+	def visibilityChanged(self, yesno):
+		pass
+
+class RhythmboxDbusThread(Thread):
+	def __init__(self, play):
+		Thread.__init__(self)
+
+		NAMESPACE = 'org.gnome.Rhythmbox'
+		PLAYER_NS = NAMESPACE + ".Player"
+		SHELL_NS  = NAMESPACE + ".Shell"
+
+		session_bus = dbus.SessionBus()
+
+		rb_bus = dbus.service.BusName(NAMESPACE, bus=session_bus)
+		rb_object = RhythmboxObject(rb_bus)
+		
+		player_bus = dbus.service.BusName(PLAYER_NS, bus=session_bus)
+		player_object = PlayerObject(player_bus)
+		
+		shell_bus = dbus.service.BusName(SHELL_NS, bus=session_bus)
+		shell_object = ShellObject(shell_bus)
+		
+		self.__rb_obj = rb_object
+		self.__player_obj = player_object
+		self.__shell_obj = shell_object
+
+		shell_object.visibilityChanged(True)
+		player_object.playingChanged(False)
+
+		self.__title  = ""
+		self.__artist = ""
+		self.__uri    = ""
+
+		self.__main   = gobject.MainLoop()
+
+		self.__play = play
+
+	def notify(self, uri, title, artist):
+		self.__uri    = uri
+		self.__title  = title
+		self.__artist = artist
+
+	def run(self):
+		while not self.__play.shutdown:
+			if self.__title != self.__shell_obj.title:
+				self.__shell_obj.title = self.__title
+				self.__shell_obj.artist = self.__artist
+
+				self.__player_obj.playingUriChanged(self.__uri)
+				self.__player_obj.playingChanged(True)
+
+			# if there is something to process, do so
+			c = self.__main.get_context()
+			if c.pending():
+				c.iteration()
+
+			time.sleep(0.2)