From 271a1e3634435a00e2e77e6f1cc99f295c828ecc Mon Sep 17 00:00:00 2001
From: Christian Pointner <equinox@spreadspace.org>
Date: Sat, 27 Jan 2018 03:36:11 +0100
Subject: implemented recorder

---
 src/flufigut.py | 34 ++++++++++++++++++++++++++++++++++
 1 file changed, 34 insertions(+)

(limited to 'src/flufigut.py')

diff --git a/src/flufigut.py b/src/flufigut.py
index 953fa35..6882299 100755
--- a/src/flufigut.py
+++ b/src/flufigut.py
@@ -274,11 +274,45 @@ class Planet:
 
                     self.__generate_muxer(mux_name, format, profile, globals, audio_encoder, video_encoder)
 
+    #
+    # streams
+    def _generate_streams(self, streams, globals):
+        self.flow['repeaters'] = {}
+        self.flow['streamers'] = {}
+        pass
+
+    #
+    # records
+    def _generate_records(self, records, globals):
+        self.flow['recorders'] = {}
+
+        for _, record in records.items():
+            for mux in record['muxes']:
+                format = record['muxes'][mux]["format"]
+                profile = record['muxes'][mux]["profile"]
+                feeder = 'mux-%s-%s-%s' % (mux, format, profile)
+
+                comp_name = 'record-%s-%s-%s' % (mux, format, profile)
+                comp_desc = 'recorder for %s %s-%s' % (mux, format, profile),
+
+                self.flow['recorders'][comp_name] = {
+                    'type': "recorder",
+                    'desc': comp_desc,
+                    'worker': None,
+                    'feeder': feeder,
+                    'properties': {}
+                }
+                for prop in record:
+                    if prop != 'muxes':
+                        self.flow['recorders'][comp_name]['properties'][prop] = record[prop]
+
     #
     # all
     def generate(self, desc):
         self._generate_inputs(desc.inputs, desc.globals)
         self._generate_muxes(desc.muxes, desc.inputs, desc.globals)
+        self._generate_streams(desc.streams, desc.globals)
+        self._generate_records(desc.records, desc.globals)
 
 
 # Main ########################################################
-- 
cgit v1.2.3