implemented recorder

1 files changed, 34 insertions, 0 deletions

diff --git a/src/flufigut.py b/src/flufigut.py
index 953fa35..6882299 100755
--- a/src/flufigut.py
+++ b/src/flufigut.py
@@ -275,10 +275,44 @@ 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 ########################################################