implement switchable preview source in mjpg coding for the GUI

1 files changed, 20 insertions, 4 deletions

diff --git a/voctocore/lib/pipeline.py b/voctocore/lib/pipeline.py
index 3aa8085..5a9ce3e 100644
--- a/voctocore/lib/pipeline.py
+++ b/voctocore/lib/pipeline.py
@@ -6,6 +6,7 @@ from gi.repository import Gst
 from lib.config import Config
 from lib.avsource import AVSource
 from lib.avrawoutput import AVRawOutput
+from lib.avpreviewoutput import AVPreviewOutput
 from lib.videomix import VideoMix
 from lib.audiomix import AudioMix
 
@@ -14,9 +15,12 @@ class Pipeline(object):
 	log = logging.getLogger('Pipeline')
 
 	sources = []
-	outputs = []
+	mirrors = []
+	previews = []
+
 	vmix = None
 	amix = None
+	mixout = None
 
 	def __init__(self):
 		self.log.info('Video-Caps configured to: %s', Config.get('mix', 'videocaps'))
@@ -39,7 +43,15 @@ class Pipeline(object):
 			self.log.info('Creating Mirror-Output for AVSource %s at tcp-port %u', name, port)
 
 			mirror = AVRawOutput('%s_mirror' % name, port)
-			self.outputs.append(mirror)
+			self.mirrors.append(mirror)
+
+
+			if Config.getboolean('previews', 'enabled'):
+				port = 14000 + idx
+				self.log.info('Creating Preview-Output for AVSource %s at tcp-port %u', name, port)
+
+				preview = AVPreviewOutput('%s_preview' % name, port)
+				self.previews.append(preview)
 
 
 		self.log.info('Creating Videmixer')
@@ -50,6 +62,10 @@ class Pipeline(object):
 
 		port = 11000
 		self.log.info('Creating Mixer-Output at tcp-port %u', port)
+		self.mixout = AVRawOutput('mix_out', port)
+
+		if Config.getboolean('previews', 'enabled'):
+			port = 12000
+			self.log.info('Creating Preview-Output for AVSource %s at tcp-port %u', name, port)
 
-		output = AVRawOutput('mix', port)
-		self.outputs.append(output)
+			self.mixpreview = AVPreviewOutput('mix_preview', port)