From 33de02bc04595ec56fa8ef7c3200dba63c05297b Mon Sep 17 00:00:00 2001
From: Walter Bender <walter@walter-laptop.(none)>
Date: Thu, 12 Feb 2009 21:58:53 +0000
Subject: finishing up merge from TAPortfolio

---
(limited to 'tagplay.py')

diff --git a/tagplay.py b/tagplay.py
new file mode 100644
index 0000000..9caaea4
--- /dev/null
+++ b/tagplay.py
@@ -0,0 +1,171 @@
+import gtk
+import pygtk
+pygtk.require('2.0')
+# import sys
+import pygst
+pygst.require('0.10')
+import gst
+import gst.interfaces
+import gobject
+import time
+gobject.threads_init()
+
+from sugar.datastore import datastore
+from talogo import *
+
+class Gplay:
+
+	def __init__(self):
+		self.window = None
+		self.playing = False
+
+		self.player = gst.element_factory_make("playbin", "playbin")
+		xis = gst.element_factory_make("xvimagesink", "xvimagesink")
+		self.player.set_property("video-sink", xis)
+		bus = self.player.get_bus()
+		bus.enable_sync_message_emission()
+		bus.add_signal_watch()
+		self.SYNC_ID = bus.connect('sync-message::element', self._onSyncMessageCb)
+
+
+	def _onSyncMessageCb(self, bus, message):
+		if message.structure is None:
+			return True
+		if message.structure.get_name() == 'prepare-xwindow-id':
+			self.window.set_sink(message.src)
+			message.src.set_property('force-aspect-ratio', True)
+			return True
+
+
+	def setFile(self, path):
+		uri = "file://" + str( path )
+		if (self.player.get_property('uri') == uri):
+			self.seek(gst.SECOND*0)
+			return
+
+		self.player.set_state(gst.STATE_READY)
+		self.player.set_property('uri', uri)
+		ext = uri[len(uri)-3:]
+		if (ext == "jpg"):
+			self.pause()
+		else:
+			self.play()
+
+
+	def queryPosition(self):
+		#"Returns a (position, duration) tuple"
+		try:
+			position, format = self.player.query_position(gst.FORMAT_TIME)
+		except:
+			position = gst.CLOCK_TIME_NONE
+
+		try:
+			duration, format = self.player.query_duration(gst.FORMAT_TIME)
+		except:
+			duration = gst.CLOCK_TIME_NONE
+
+		return (position, duration)
+
+
+	def seek(self, time):
+		event = gst.event_new_seek(1.0, gst.FORMAT_TIME, gst.SEEK_FLAG_FLUSH | \
+                    gst.SEEK_FLAG_ACCURATE, gst.SEEK_TYPE_SET, time, gst.SEEK_TYPE_NONE, 0)
+		res = self.player.send_event(event)
+		if res:
+			self.player.set_new_stream_time(0L)
+
+
+	def pause(self):
+		self.playing = False
+		self.player.set_state(gst.STATE_PAUSED)
+
+
+	def play(self):
+		self.playing = True
+		self.player.set_state(gst.STATE_PLAYING)
+
+
+	def stop(self):
+		self.playing = False
+		self.player.set_state(gst.STATE_NULL)
+		# self.nextMovie()
+
+
+	def get_state(self, timeout=1):
+		return self.player.get_state(timeout=timeout)
+
+
+	def is_playing(self):
+		return self.playing
+
+
+class PlayVideoWindow(gtk.Window):
+	def __init__(self):
+		gtk.Window.__init__(self)
+		self.imagesink = None
+		self.unset_flags(gtk.DOUBLE_BUFFERED)
+		self.set_flags(gtk.APP_PAINTABLE)
+
+	def set_sink(self, sink):
+		if (self.imagesink != None):
+			assert self.window.xid
+			self.imagesink = None
+			del self.imagesink
+
+		self.imagesink = sink
+		self.imagesink.set_xwindow_id(self.window.xid)
+
+def play_audio(lc, audio):
+    print "loading audio id: " + str(audio)
+    if audio == "" or audio[6:] == "":
+        raise logoerror("#nomedia")
+    elif audio[6:] != "None":
+        try:
+            dsobject = datastore.get(audio[6:])
+            print dsobject.file_path
+        except:
+            print "Couldn't open id: " + str(audio[6:])
+        if lc.gplay == None:
+            lc.gplay = Gplay()
+        lc.gplay.setFile("file:///" + dsobject.file_path)
+
+def play_video(lc, media, x, y, w, h):
+    print "loading media id: " + str(media)
+    if media == "" or media[6:] == "":
+        raise logoerror("#nomedia")
+    elif media[6:] != "None":
+        try:
+            dsobject = datastore.get(media[6:])
+            print dsobject.file_path
+        except:
+            print "Couldn't open id: " + str(media[6:])
+    play_dsobject(lc, dsobject, x, y, w, h)
+
+def play_dsobject(lc, dsobject, x, y, w, h):
+    if lc.gplay == None:
+        lc.gplay = Gplay()
+    lc.gplay.setFile("file:///" + dsobject.file_path)
+    # if lc.gplay.window == None:
+    gplayWin = PlayVideoWindow()
+    lc.gplay.window = gplayWin
+    gplayWin.set_type_hint( gtk.gdk.WINDOW_TYPE_HINT_DIALOG )
+    gplayWin.set_decorated( False )
+    gplayWin.set_transient_for( lc.tw.activity )
+    # y position is too high for some reason (toolbox?) adding offset
+    gplayWin.move( x, y+108 )
+    gplayWin.resize( w, h )
+    gplayWin.show_all( )
+
+def stop_media(lc):
+    if lc.gplay == None:
+        return
+    lc.gplay.stop()
+    if lc.gplay.window != None:
+        # need to figure out how to destroy the video window
+#        lc.gplay.window.destroy()
+#        lc.gplay == None
+        # but meanwhile, just shrink it
+        lc.gplay.window.move( 0, 0 )
+        lc.gplay.window.resize( 1, 1 )
+
+
--
cgit v0.9.1