setting stuff up with a launch-string is far more easy

1 files changed, 20 insertions, 58 deletions

diff --git a/voctocore/videomix.py b/voctocore/videomix.py
index 895a25f..1426cb4 100644
--- a/voctocore/videomix.py
+++ b/voctocore/videomix.py
@@ -7,63 +7,25 @@ class Videomix:
 	mixerpads = []
 
 	def __init__(self):
-		self.pipeline = Gst.Pipeline()
-
-		self.videomixer = Gst.ElementFactory.make('videomixer', 'videomixer')
-		self.pipeline.add(self.videomixer)
-
-		for uri in ("http://video.blendertestbuilds.de/download.blender.org/ED/ED_1280.avi", "http://download.blender.org/durian/trailer/sintel_trailer-720p.mp4",):
-			decoder = Gst.ElementFactory.make('uridecodebin', 'uridecoder('+uri+')')
-			decoder.set_property("uri", uri)
-			decoder.connect("pad-added", self.OnDynamicPad)
-			self.pipeline.add(decoder)
-			self.decoder.append(decoder)
-
-		self.monitorvideosink = Gst.ElementFactory.make('autovideosink', 'monitorvideosink')
-		self.pipeline.add(self.monitorvideosink)
-		self.videomixer.link(self.monitorvideosink)
-
-		self.monitoraudiosink = Gst.ElementFactory.make('autoaudiosink', 'monitoraudiosink')
-		self.pipeline.add(self.monitoraudiosink)
+		self.pipeline = Gst.parse_launch("""
+			videomixer name=livevideo ! autovideosink
+			input-selector name=liveaudio ! autoaudiosink
+			
+			uridecodebin name=cam0 uri=file:///home/peter/122.mp4
+			uridecodebin name=cam1 uri=file:///home/peter/10025.mp4
+			
+			cam0. ! videoconvert ! videoscale ! videorate ! video/x-raw,width=1024,height=576,framerate=25/1 ! livevideo.
+			cam1. ! videoconvert ! videoscale ! videorate ! video/x-raw,width=1024,height=576,framerate=25/1 ! livevideo.
+			
+			cam0. ! audioconvert ! liveaudio.
+			cam1. ! audioconvert ! liveaudio.
+		""")
+		
+		liveaudio = self.pipeline.get_by_name('liveaudio')
+		liveaudio.set_property('active-pad', liveaudio.get_static_pad('sink_0'))
+
+		livevideo = self.pipeline.get_by_name('livevideo')
+		pad = livevideo.get_static_pad('sink_1')
+		pad.set_property('alpha', 0.5)
 
 		self.pipeline.set_state(Gst.State.PLAYING)
-
-		GLib.io_add_watch(sys.stdin, GLib.IO_IN, self.Input)
-
-	def Input(self, fd, condition):
-		if condition == GLib.IO_IN:
-			char = fd.readline()
-			try:
-				i = int(char.rstrip())
-				print("settinh pad {0} to alpha=1".format(i))
-				self.mixerpads[i].set_property('alpha', 1)
-				for idx, pad in enumerate(self.mixerpads):
-					if idx != i:
-						print("settinh pad {0} to alpha=0".format(idx))
-						pad.set_property('alpha', 0)
-			except:
-				pass
-
-			return True
-		else:
-			return False
-
-	def OnDynamicPad(self, uridecodebin, src_pad):
-		caps = src_pad.query_caps(None).to_string()
-		srcname = uridecodebin.get_name()
-		print("{0}-source of {1} online".format(caps.split(',')[0], srcname))
-
-		if caps.startswith('audio/'):
-			sinkpad = self.monitoraudiosink.get_static_pad("sink")
-
-			# link the first audio-stream and be done
-			if not sinkpad.is_linked():
-				src_pad.link(sinkpad)
-
-		else:
-			sinkpad = Gst.Element.get_request_pad(self.videomixer, "sink_%u")
-			src_pad.link(sinkpad)
-			self.mixerpads.append(sinkpad)
-			print('add', sinkpad)
-			sinkpad.set_property('alpha', 0.7)
-