IS-11: Test suites for Stream Compatibility Management

README.md

@@ -32,6 +32,7 @@ The following test suites are currently supported.
 | IS-09-01 | IS-09 System API | | (X) | | System Parameters Server |
 | IS-09-02 | IS-09 System API Discovery | X | | | |
 | IS-10-01 | IS-10 Authorization API | | | | Authorization Server |
+| IS-11-01 | IS-11 Stream Compatibility Management API | X | | | |
 | - | BCP-002-01 Natural Grouping | X | | | Included in IS-04 Node API suite |
 | - | BCP-002-02 Asset Distinguishing Information | X | | | Included in IS-04 Node API suite |
 | BCP-003-01 | BCP-003-01 Secure Communication | X | X | | See [Testing TLS](docs/2.2.%20Usage%20-%20Testing%20BCP-003-01%20TLS.md) |

nmostesting/Config.py

@@ -277,6 +277,17 @@
             }
         }
     },
+    "is-11": {
+        "repo": "is-11",
+        "versions": ["v1.0"],
+        "default_version": "v1.0",
+        "apis": {
+            "streamcompatibility": {
+                "name": "Stream Compatibility Management API",
+                "raml": "StreamCompatibilityManagementAPI.raml"
+            }
+        }
+    },
     "bcp-002-01": {
         "repo": "bcp-002-01",
         "versions": ["v1.0"],
@@ -313,6 +324,12 @@
             }
         }
     },
+    "bcp-005-01": {
+        "repo": "bcp-005-01",
+        "versions": ["v1.0"],
+        "default_version": "v1.0",
+        "apis": {}
+    },
     "nmos-parameter-registers": {
         "repo": "nmos-parameter-registers",
         "versions": ["main"],

nmostesting/IS04Utils.py

@@ -12,10 +12,11 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
+import re
+from copy import deepcopy
+from fractions import Fraction
 from . import TestHelper
-
 from .NMOSUtils import NMOSUtils
-from copy import deepcopy
 
 
 class IS04Utils(NMOSUtils):
@@ -71,6 +72,101 @@ def get_resources(self, resource, url=None):
         return toReturn
 
     @staticmethod
+    def comparable_parameter_constraint_value(value):
+        if isinstance(value, dict):
+            return Fraction(value["numerator"], value.get("denominator", 1))
+        return value
+
+    @staticmethod
+    def comparable_parameter_constraint(param_constraint):
+        result = deepcopy(param_constraint)
+        if "minimum" in result:
+            result["minimum"] = IS04Utils.comparable_parameter_constraint_value(
+                result["minimum"]
+            )
+        if "maximum" in result:
+            result["maximum"] = IS04Utils.comparable_parameter_constraint_value(
+                result["maximum"]
+            )
+        if "enum" in result:
+            for i, value in enumerate(result["enum"]):
+                result["enum"][i] = IS04Utils.comparable_parameter_constraint_value(
+                    value
+                )
+        return result
+
+    @staticmethod
+    def comparable_constraint_set(constraint_set):
+        result = {
+            k: IS04Utils.comparable_parameter_constraint(v)
+            if re.match("^urn:x-nmos:cap:(?!meta:)", k)
+            else v
+            for k, v in constraint_set.items()
+        }
+        # could also remove urn:x-nmos:cap:meta:label?
+        if "urn:x-nmos:cap:meta:preference" not in result:
+            result["urn:x-nmos:cap:meta:preference"] = 0
+        if "urn:x-nmos:cap:meta:enabled" not in result:
+            result["urn:x-nmos:cap:meta:enabled"] = True
+        return result
+
+    @staticmethod
+    def comparable_constraint_sets(constraint_sets):
+        return [IS04Utils.comparable_constraint_set(_) for _ in constraint_sets]
+
+    @staticmethod
+    def compare_constraint_sets(lhs, rhs):
+        """Check that two Constraint Sets arrays are closely equivalent"""
+        return TestHelper.compare_json(
+            IS04Utils.comparable_constraint_sets(lhs),
+            IS04Utils.comparable_constraint_sets(rhs),
+        )
+
+    @staticmethod
+    def make_sampling(flow_components):
+        samplers = {
+            # Red-Green-Blue-Alpha
+            "RGBA": {"R": (1, 1), "G": (1, 1), "B": (1, 1), "A": (1, 1)},
+            # Red-Green-Blue
+            "RGB": {"R": (1, 1), "G": (1, 1), "B": (1, 1)},
+            # Non-constant luminance YCbCr
+            "YCbCr-4:4:4": {"Y": (1, 1), "Cb": (1, 1), "Cr": (1, 1)},
+            "YCbCr-4:2:2": {"Y": (1, 1), "Cb": (2, 1), "Cr": (2, 1)},
+            "YCbCr-4:2:0": {"Y": (1, 1), "Cb": (2, 2), "Cr": (2, 2)},
+            "YCbCr-4:1:1": {"Y": (1, 1), "Cb": (4, 1), "Cr": (4, 1)},
+            # Constant luminance YCbCr
+            "CLYCbCr-4:4:4": {"Yc": (1, 1), "Cbc": (1, 1), "Crc": (1, 1)},
+            "CLYCbCr-4:2:2": {"Yc": (1, 1), "Cbc": (2, 1), "Crc": (2, 1)},
+            "CLYCbCr-4:2:0": {"Yc": (1, 1), "Cbc": (2, 2), "Crc": (2, 2)},
+            # Constant intensity ICtCp
+            "ICtCp-4:4:4": {"I": (1, 1), "Ct": (1, 1), "Cp": (1, 1)},
+            "ICtCp-4:2:2": {"I": (1, 1), "Ct": (2, 1), "Cp": (2, 1)},
+            "ICtCp-4:2:0": {"I": (1, 1), "Ct": (2, 2), "Cp": (2, 2)},
+            # XYZ
+            "XYZ": {"X": (1, 1), "Y": (1, 1), "Z": (1, 1)},
+            # Key signal represented as a single component
+            "KEY": {"Key": (1, 1)},
+            # Sampling signaled by the payload
+            "UNSPECIFIED": {},
+        }
+
+        max_w, max_h = 0, 0
+        for component in flow_components:
+            w, h = component["width"], component["height"]
+            if w > max_w:
+                max_w = w
+            if h > max_h:
+                max_h = h
+
+        components_sampler = {}
+        for component in flow_components:
+            w, h = component["width"], component["height"]
+            components_sampler[component["name"]] = (max_w / w, max_h / h)
+
+        for sampling, sampler in samplers.items():
+            if sampler == components_sampler:
+                return sampling
+
     def downgrade_resource(resource_type, resource_data, requested_version):
         """Downgrades given resource data to requested version"""
         version_major, version_minor = [int(x) for x in requested_version[1:].split(".")]

nmostesting/NMOSTesting.py

@@ -82,7 +82,9 @@
 from .suites import IS0901Test
 from .suites import IS0902Test
 # from .suites import IS1001Test
+from .suites import IS1101Test
 from .suites import BCP00301Test
+from .suites import BCP0050101Test
 from .suites import BCP0060101Test
 from .suites import BCP0060102Test
 
@@ -340,6 +342,20 @@
     #     }],
     #     "class": IS1001Test.IS1001Test
     # },
+    "IS-11-01": {
+        "name": "IS-11 Stream Compatibility Management API",
+        "specs": [{
+            "spec_key": "is-11",
+            "api_key": "streamcompatibility"
+        }, {
+            "spec_key": "is-04",
+            "api_key": "node"
+        }, {
+            "spec_key": "is-05",
+            "api_key": "connection"
+        }],
+        "class": IS1101Test.IS1101Test
+    },
     "BCP-003-01": {
         "name": "BCP-003-01 Secure Communication",
         "specs": [{
@@ -348,6 +364,14 @@
         }],
         "class": BCP00301Test.BCP00301Test
     },
+    "BCP-005-01-01": {
+        "name": "BCP-005-01 EDID to Receiver Capabilities Mapping",
+        "specs": [{
+            "spec_key": "is-04",
+            "api_key": "node"
+        }],
+        "class": BCP0050101Test.BCP0050101Test
+    },
     "BCP-006-01-01": {
         "name": "BCP-006-01 NMOS With JPEG XS",
         "specs": [{

nmostesting/suites/BCP0050101Test.py

@@ -0,0 +1,26 @@
+# Copyright (C) 2022 Advanced Media Workflow Association
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+from ..GenericTest import GenericTest
+
+NODE_API_KEY = "node"
+
+
+class BCP0050101Test(GenericTest):
+    """
+    Runs Node Tests covering BCP-005-01
+    """
+    def __init__(self, apis, **kwargs):
+        GenericTest.__init__(self, apis, **kwargs)
+        self.node_url = self.apis[NODE_API_KEY]["url"]