Add controll-server and control mixer

1 files changed, 47 insertions, 16 deletions

diff --git a/voctocore/lib/video/mix.py b/voctocore/lib/video/mix.py
index 8bb7036..a9e1513 100644
--- a/voctocore/lib/video/mix.py
+++ b/voctocore/lib/video/mix.py
@@ -1,19 +1,30 @@
 #!/usr/bin/python3
 import logging
 from gi.repository import Gst
+from enum import Enum
 
 from lib.config import Config
 
+class ComposteModes(Enum):
+	fullscreen = 0
+
 class VideoMix(object):
 	log = logging.getLogger('VideoMix')
 
 	mixingPipeline = None
 
+	caps = None
+	names = []
+
+	compositeMode = ComposteModes.fullscreen
+	sourceA = 0
+	sourceB = 1
+
 	def __init__(self):
-		caps = Config.get('mix', 'videocaps')
+		self.caps = Config.get('mix', 'videocaps')
 
-		names = Config.getlist('sources', 'video')
-		self.log.info('Configuring Mixer for %u Sources', len(names))
+		self.names = Config.getlist('sources', 'video')
+		self.log.info('Configuring Mixer for %u Sources', len(self.names))
 
 		pipeline = """
 			videomixer name=mix !
@@ -21,10 +32,10 @@ class VideoMix(object):
 			textoverlay text=mixer halignment=left valignment=top ypad=175 !
 			intervideosink channel=video_mix
 		""".format(
-			caps=caps
+			caps=self.caps
 		)
 
-		for idx, name in enumerate(names):
+		for idx, name in enumerate(self.names):
 			pipeline += """
 				intervideosrc channel=video_{name}_mixer !
 				{caps} !
@@ -33,22 +44,42 @@ class VideoMix(object):
 				mix.
 			""".format(
 				name=name,
-				caps=caps,
+				caps=self.caps,
 				idx=idx
 			)
 
-		self.log.debug('Launching Mixing-Pipeline:\n%s', pipeline)
+		self.log.debug('Creating Mixing-Pipeline:\n%s', pipeline)
 		self.mixingPipeline = Gst.parse_launch(pipeline)
+
+		self.log.debug('Initializing Mixer-State')
+		self.updateMixerState()
+
+		self.log.debug('Launching Mixing-Pipeline:\n%s', 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)
+	def updateMixerState(self):
+		if self.compositeMode == ComposteModes.fullscreen:
+			self.updateMixerStateFullscreen()
+
+	def updateMixerStateFullscreen(self):
+		self.log.info('Updating Mixer-State for Fullscreen-Composition')
+		for idx, name in enumerate(self.names):
+			alpha = int(idx == self.sourceA)
+
+			self.log.debug('Setting Mixerpad %u to x/y=0 and alpha=%u', idx, alpha)
+			mixerpad = self.mixingPipeline.get_by_name('mix').get_static_pad('sink_%u' % idx)
+			mixerpad.set_property('alpha', alpha )
+			mixerpad.set_property('xpos', 0)
+			mixerpad.set_property('ypos', 0)
+
+			self.log.debug('Resetting Scaler %u to non-scaling', idx)
+			capsfilter = self.mixingPipeline.get_by_name('caps_%u' % idx)
+			capsfilter.set_property('caps', Gst.Caps.from_string(self.caps))
 
-		mixerpad = self.mixingPipeline.get_by_name('mix').get_static_pad('sink_1')
-		mixerpad.set_property('alpha', 0.2)
+	def setVideoA(self, source):
+		self.sourceA = source
+		self.updateMixerState()
 
-		capsilter = self.mixingPipeline.get_by_name('caps_1')
-		capsilter.set_property('caps', Gst.Caps.from_string(
-			'video/x-raw,width=320,height=180'))
+	def setVideoB(self, source):
+		self.sourceN = source
+		self.updateMixerState()