implement mixer & test-output

1 files changed, 40 insertions, 1 deletions

diff --git a/voctocore/lib/video/mix.py b/voctocore/lib/video/mix.py
index 2d73d7b..8bb7036 100644
--- a/voctocore/lib/video/mix.py
+++ b/voctocore/lib/video/mix.py
@@ -7,9 +7,48 @@ from lib.config import Config
 class VideoMix(object):
 	log = logging.getLogger('VideoMix')
 
+	mixingPipeline = None
+
 	def __init__(self):
 		caps = Config.get('mix', 'videocaps')
 
 		names = Config.getlist('sources', 'video')
 		self.log.info('Configuring Mixer for %u Sources', len(names))
-		#for idx, name in enumerate():
+
+		pipeline = """
+			videomixer name=mix !
+			{caps} !
+			textoverlay text=mixer halignment=left valignment=top ypad=175 !
+			intervideosink channel=video_mix
+		""".format(
+			caps=caps
+		)
+
+		for idx, name in enumerate(names):
+			pipeline += """
+				intervideosrc channel=video_{name}_mixer !
+				{caps} !
+				videoscale !
+				capsfilter name=caps_{idx} !
+				mix.
+			""".format(
+				name=name,
+				caps=caps,
+				idx=idx
+			)
+
+		self.log.debug('Launching Mixing-Pipeline:\n%s', pipeline)
+		self.mixingPipeline = Gst.parse_launch(pipeline)
+		self.mixingPipeline.set_state(Gst.State.PLAYING)
+
+		mixerpad = self.mixingPipeline.get_by_name('mix').get_static_pad('sink_0')
+		mixerpad.set_property('alpha', 0.5)
+		mixerpad.set_property('xpos', 64)
+		mixerpad.set_property('ypos', 64)
+
+		mixerpad = self.mixingPipeline.get_by_name('mix').get_static_pad('sink_1')
+		mixerpad.set_property('alpha', 0.2)
+
+		capsilter = self.mixingPipeline.get_by_name('caps_1')
+		capsilter.set_property('caps', Gst.Caps.from_string(
+			'video/x-raw,width=320,height=180'))