feat: add TestVector optional decoder parameters

adding the capability to include an optional decoder parameters set
for a specfic test vector in the test suite definition.
optional parameters are utilized in Decoder class decode function abstraction
and are applied in Gstreamer(Decoder) and Ffmpeg(Decoder) classes implementations.
It's child class responsibility to handle the optional parameters.

Author: msabiniok

fluster/decoder.py

@@ -47,6 +47,7 @@ def decode(
         timeout: int,
         verbose: bool,
         keep_files: bool,
+        optional_params: Optional[dict],
     ) -> str:
         """Decodes input_filepath in output_filepath"""
         raise Exception("Not implemented")

fluster/decoders/av1_aom.py

@@ -14,6 +14,7 @@
 #
 # You should have received a copy of the GNU Lesser General Public
 # License along with this library. If not, see <https://www.gnu.org/licenses/>.
+from typing import Optional
 
 from fluster.codec import Codec, OutputFormat
 from fluster.decoder import Decoder, register_decoder
@@ -38,6 +39,7 @@ def decode(
         timeout: int,
         verbose: bool,
         keep_files: bool,
+        optional_params: Optional[dict],
     ) -> str:
         """Decodes input_filepath in output_filepath"""
         fmt = "--rawvideo"

fluster/decoders/av1_dav1d.py

@@ -14,6 +14,7 @@
 #
 # You should have received a copy of the GNU Lesser General Public
 # License along with this library. If not, see <https://www.gnu.org/licenses/>.
+from typing import Optional
 
 from fluster.codec import Codec, OutputFormat
 from fluster.decoder import Decoder, register_decoder
@@ -37,6 +38,7 @@ def decode(
         timeout: int,
         verbose: bool,
         keep_files: bool,
+        optional_params: Optional[dict],
     ) -> str:
         """Decodes input_filepath in output_filepath"""
         fmt = "yuv"

fluster/decoders/chromium.py

@@ -16,6 +16,7 @@
 # License along with this library. If not, see <https://www.gnu.org/licenses/>.
 
 from functools import lru_cache
+from typing import Optional
 
 from fluster.codec import Codec, OutputFormat
 from fluster.decoder import Decoder, register_decoder
@@ -50,6 +51,7 @@ def decode(
         timeout: int,
         verbose: bool,
         keep_files: bool,
+        optional_params: Optional[dict],
     ) -> str:
         return str(main(input_filepath))
 

fluster/decoders/cros_codecs.py

@@ -14,6 +14,7 @@
 #
 # You should have received a copy of the GNU Lesser General Public
 # License along with this library. If not, see <https://www.gnu.org/licenses/>.
+from typing import Optional
 
 from fluster.codec import Codec, OutputFormat
 from fluster.decoder import Decoder, register_decoder
@@ -38,6 +39,7 @@ def decode(
         timeout: int,
         verbose: bool,
         keep_files: bool,
+        optional_params: Optional[dict],
     ) -> str:
         """Decodes input_filepath in output_filepath"""
 

fluster/decoders/dummy.py

@@ -14,6 +14,7 @@
 #
 # You should have received a copy of the GNU Lesser General Public
 # License along with this library. If not, see <https://www.gnu.org/licenses/>.
+from typing import Optional
 
 from fluster.codec import Codec, OutputFormat
 from fluster.decoder import Decoder, register_decoder
@@ -36,5 +37,6 @@ def decode(
         timeout: int,
         verbose: bool,
         keep_files: bool,
+        optional_params: Optional[dict],
     ) -> str:
         return file_checksum(input_filepath)

fluster/decoders/ffmpeg.py

@@ -70,6 +70,7 @@ def decode(
         timeout: int,
         verbose: bool,
         keep_files: bool,
+        optional_params: Optional[dict],
     ) -> str:
         """Decodes input_filepath in output_filepath"""
         command = [self.binary, "-hide_banner", "-nostdin"]
@@ -99,6 +100,11 @@ def decode(
         elif self.ffmpeg_codec:
             command.extend(["-codec", self.ffmpeg_codec])
 
+        # Optional decoder parameters
+        if optional_params:
+            for key, value in optional_params.items():
+                command.extend([key, str(value)])
+
         # Input file
         command.extend(["-i", input_filepath])
 

fluster/decoders/gstreamer.py

@@ -109,14 +109,21 @@ def gen_pipeline(
         input_filepath: str,
         output_filepath: Optional[str],
         output_format: OutputFormat,
+        optional_params: Optional[dict] = None,
     ) -> str:
         """Generate the GStreamer pipeline used to decode the test vector"""
         output = f"location={output_filepath}" if output_filepath else ""
+
+        decoder_params = ""
+        if optional_params:
+            for key, value in optional_params.items():
+                decoder_params += f" {key}={value} "
+
         return PIPELINE_TPL.format(
             self.cmd,
             input_filepath,
             self.parser if self.parser else "parsebin",
-            self.decoder_bin,
+            self.decoder_bin + decoder_params,
             self.caps,
             self.sink,
             output,
@@ -149,6 +156,7 @@ def decode(
         timeout: int,
         verbose: bool,
         keep_files: bool,
+        optional_params: Optional[dict],
     ) -> str:
         """Decode the test vector and do the checksum"""
         # When using videocodectestsink we can avoid writing files to disk
@@ -162,7 +170,7 @@ def decode(
             data = run_command_with_output(command, timeout=timeout, verbose=verbose).splitlines()
             return self.parse_videocodectestsink_md5sum(data)
 
-        pipeline = self.gen_pipeline(input_filepath, output_filepath, output_format)
+        pipeline = self.gen_pipeline(input_filepath, output_filepath, output_format, optional_params)
         run_command(shlex.split(pipeline), timeout=timeout, verbose=verbose)
         return file_checksum(output_filepath)
 
@@ -193,6 +201,7 @@ def gen_pipeline(
         input_filepath: str,
         output_filepath: Optional[str],
         output_format: OutputFormat,
+        optional_params: Optional[dict] = None,
     ) -> str:
         raw_caps = "video/x-raw"
         try:

fluster/decoders/h264_jct_vt.py

@@ -15,6 +15,7 @@
 #
 # You should have received a copy of the GNU Lesser General Public
 # License along with this library. If not, see <https://www.gnu.org/licenses/>.
+from typing import Optional
 
 from fluster.codec import Codec, OutputFormat
 from fluster.decoder import Decoder, register_decoder
@@ -38,6 +39,7 @@ def decode(
         timeout: int,
         verbose: bool,
         keep_files: bool,
+        optional_params: Optional[dict],
     ) -> str:
         """Decodes input_filepath in output_filepath"""
         run_command(

fluster/decoders/h265_jct_vt.py

@@ -15,6 +15,7 @@
 #
 # You should have received a copy of the GNU Lesser General Public
 # License along with this library. If not, see <https://www.gnu.org/licenses/>.
+from typing import Optional
 
 from fluster.codec import Codec, OutputFormat
 from fluster.decoder import Decoder, register_decoder
@@ -38,6 +39,7 @@ def decode(
         timeout: int,
         verbose: bool,
         keep_files: bool,
+        optional_params: Optional[dict],
     ) -> str:
         """Decodes input_filepath in output_filepath"""
         run_command(