1 files changed, 116 insertions, 0 deletions
diff --git a/test/security/check_versions/versions/k8s_bin_versions_inspector_test_case.py b/test/security/check_versions/versions/k8s_bin_versions_inspector_test_case.py
new file mode 100644
index 000000000..87516cb60
--- /dev/null
+++ b/test/security/check_versions/versions/k8s_bin_versions_inspector_test_case.py
@@ -0,0 +1,116 @@
+#!/usr/bin/env python3
+
+#   COPYRIGHT NOTICE STARTS HERE
+#
+#   Copyright 2020 Samsung Electronics Co., Ltd.
+#
+#   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.
+#
+#   COPYRIGHT NOTICE ENDS HERE
+
+import logging
+import pathlib
+import time
+import os
+import wget
+from kubernetes import client, config
+from xtesting.core import testcase  # pylint: disable=import-error
+
+import versions.reporting as Reporting
+from versions.k8s_bin_versions_inspector import (
+    gather_containers_informations,
+    generate_and_handle_output,
+    verify_versions_acceptability,
+)
+
+RECOMMENDED_VERSIONS_FILE = "/tmp/recommended_versions.yaml"
+WAIVER_LIST_FILE = "/tmp/versions_xfail.txt"
+
+# Logger
+logging.basicConfig()
+LOGGER = logging.getLogger("onap-versions-status-inspector")
+LOGGER.setLevel("INFO")
+
+
+class Inspector(testcase.TestCase):
+    """Inspector CLass."""
+
+    def __init__(self, **kwargs):
+        """Init the testcase."""
+        if "case_name" not in kwargs:
+            kwargs["case_name"] = "check_versions"
+        super().__init__(**kwargs)
+
+        version = os.getenv("ONAP_VERSION", "master")
+        base_url = "https://git.onap.org/integration/seccom/plain"
+
+        self.namespace = "onap"
+        # if no Recommended file found, download it
+        if pathlib.Path(RECOMMENDED_VERSIONS_FILE).is_file():
+            self.acceptable = pathlib.Path(RECOMMENDED_VERSIONS_FILE)
+        else:
+            self.acceptable = wget.download(
+                base_url + "/recommended_versions.yaml?h=" + version,
+                out=RECOMMENDED_VERSIONS_FILE,
+            )
+        self.output_file = "/tmp/versions.json"
+        # if no waiver file found, download it
+        if pathlib.Path(WAIVER_LIST_FILE).is_file():
+            self.waiver = pathlib.Path(WAIVER_LIST_FILE)
+        else:
+            self.waiver = wget.download(
+                base_url + "/waivers/versions/versions_xfail.txt?h=" + version,
+                out=WAIVER_LIST_FILE,
+            )
+        self.result = 0
+        self.start_time = None
+        self.stop_time = None
+
+    def run(self):
+        """Execute the version Inspector."""
+        self.start_time = time.time()
+        config.load_kube_config()
+        api = client.CoreV1Api()
+
+        field_selector = "metadata.namespace==onap"
+
+        containers = gather_containers_informations(api, field_selector, True)
+        LOGGER.info("gather_containers_informations")
+        LOGGER.info(containers)
+        LOGGER.info("---------------------------------")
+
+        generate_and_handle_output(
+            containers, "json", pathlib.Path(self.output_file), True
+        )
+        LOGGER.info("generate_and_handle_output in %s", self.output_file)
+        LOGGER.info("---------------------------------")
+
+        code = verify_versions_acceptability(containers, self.acceptable, True)
+        LOGGER.info("verify_versions_acceptability")
+        LOGGER.info(code)
+        LOGGER.info("---------------------------------")
+
+        # Generate reporting
+        test = Reporting.OnapVersionsReporting(result_file=self.output_file)
+        LOGGER.info("Prepare reporting")
+        self.result = test.generate_reporting(self.output_file)
+        LOGGER.info("Reporting generated")
+
+        self.stop_time = time.time()
+        if self.result >= 90:
+            return testcase.TestCase.EX_OK
+        return testcase.TestCase.EX_TESTCASE_FAILED
+
+    def set_namespace(self, namespace):
+        """Set namespace."""
+        self.namespace = namespace