[patch] Check for existing OpenShift Pipelines subscription (#23)

Co-authored-by: Harsh Tamakuwala <Harsh.Tamakuwala@ibm.com>
Co-authored-by: David Parker <parkerda@uk.ibm.com>

Author: 3 people

src/mas/devops/ocp.py

@@ -153,3 +153,13 @@ def getStorageClasses(dynClient: DynamicClient) -> list:
 
 def isSNO(dynClient: DynamicClient) -> bool:
     return len(getNodes(dynClient)) == 1
+
+def crdExists(dynClient: DynamicClient, crdName: str) -> bool:
+    crdAPI = dynClient.resources.get(api_version="apiextensions.k8s.io/v1", kind="CustomResourceDefinition")
+    try:
+        crd = crdAPI.get(name=crdName)
+        logger.debug(f"CRD does exist: {crdName}")
+        return True
+    except NotFoundError:
+        logger.debug(f"CRD does not exist: {crdName}")
+        return False

src/mas/devops/tekton.py

@@ -22,7 +22,7 @@
 
 from jinja2 import Environment, FileSystemLoader
 
-from .ocp import getConsoleURL, waitForCRD, waitForDeployment
+from .ocp import getConsoleURL, waitForCRD, waitForDeployment, crdExists
 
 logger = logging.getLogger(__name__)
 
@@ -36,25 +36,26 @@ def installOpenShiftPipelines(dynClient: DynamicClient) -> bool:
 
     # Create the Operator Subscription
     try:
-        manifest = packagemanifestAPI.get(name="openshift-pipelines-operator-rh", namespace="openshift-marketplace")
-        defaultChannel = manifest.status.defaultChannel
-        catalogSource = manifest.status.catalogSource
-        catalogSourceNamespace = manifest.status.catalogSourceNamespace
-
-        logger.info(f"OpenShift Pipelines Operator Details: {catalogSourceNamespace}/{catalogSource}@{defaultChannel}")
-
-        templateDir = path.join(path.abspath(path.dirname(__file__)), "templates")
-        env = Environment(
-            loader=FileSystemLoader(searchpath=templateDir)
-        )
-        template = env.get_template("subscription.yml.j2")
-        renderedTemplate = template.render(
-            pipelines_channel=defaultChannel,
-            pipelines_source=catalogSource,
-            pipelines_source_namespace=catalogSourceNamespace
-        )
-        subscription = yaml.safe_load(renderedTemplate)
-        subscriptionsAPI.apply(body=subscription, namespace="openshift-operators")
+        if not crdExists(dynClient, "pipelines.tekton.dev"):
+            manifest = packagemanifestAPI.get(name="openshift-pipelines-operator-rh", namespace="openshift-marketplace")
+            defaultChannel = manifest.status.defaultChannel
+            catalogSource = manifest.status.catalogSource
+            catalogSourceNamespace = manifest.status.catalogSourceNamespace
+
+            logger.info(f"OpenShift Pipelines Operator Details: {catalogSourceNamespace}/{catalogSource}@{defaultChannel}")
+
+            templateDir = path.join(path.abspath(path.dirname(__file__)), "templates")
+            env = Environment(
+                loader=FileSystemLoader(searchpath=templateDir)
+            )
+            template = env.get_template("subscription.yml.j2")
+            renderedTemplate = template.render(
+                pipelines_channel=defaultChannel,
+                pipelines_source=catalogSource,
+                pipelines_source_namespace=catalogSourceNamespace
+            )
+            subscription = yaml.safe_load(renderedTemplate)
+            subscriptionsAPI.apply(body=subscription, namespace="openshift-operators")
 
     except NotFoundError:
         logger.warning("Error: Couldn't find package manifest for Red Hat Openshift Pipelines Operator")