[CPS] Create CPS resources using data provider0.7.0

Create:
 - dataspace
 - anchor
 - schema set

Issue-ID: INT-2135
Signed-off-by: Michal Jagiello <michal.jagiello@t-mobile.pl>
Change-Id: I49fa9aa34bd4157372571275774c6a410d1bedcb

3 files changed, 279 insertions, 0 deletions

diff --git a/onap_data_provider/resources/cps_resource.py b/onap_data_provider/resources/cps_resource.py
new file mode 100644
index 0000000..c8e666f
--- /dev/null
+++ b/onap_data_provider/resources/cps_resource.py
@@ -0,0 +1,188 @@
+"""CPS resources module."""
+"""
+   Copyright 2022 Deutsche Telekom AG
+
+   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.
+"""
+
+import logging
+from abc import ABC
+from typing import Any, Dict
+
+from onapsdk.cps import Anchor, Dataspace, SchemaSet  # type: ignore
+from onapsdk.exceptions import APIError, ResourceNotFound  # type: ignore
+
+from onap_data_provider.resources.resource import Resource
+
+
+class DataspaceSubresource(Resource, ABC):
+    """Abstract dataspace subresource class."""
+
+    def __init__(self, data: Dict[str, Any]) -> None:
+        """Initialize dataspace subresource"""
+        super().__init__(data)
+
+        self._dataspace: Dataspace = None
+        self._schema_set: SchemaSet = None
+
+    @property
+    def dataspace(self) -> Dataspace:
+        """Dataspace property.
+
+        Return dataspace object by it name.
+
+        Returns:
+            Dataspace: Dataspace object.
+
+        """
+        return Dataspace(self.data["dataspace-name"])
+
+    @property
+    def schema_set(self) -> SchemaSet:
+        """Schema set property.
+
+        Raises:
+            ValueError: Dataspace which name was used to get schema-set object doesn't exist
+
+        Returns:
+            SchemaSet: Schema set object
+
+        """
+        if not self._schema_set:
+            try:
+                self._schema_set = self.dataspace.get_schema_set(self.data["schema-set-name"])
+            except APIError as api_error:
+                # Needs to be fixed when https://gitlab.com/Orange-OpenSource/lfn/onap/python-onapsdk/-/issues/181 is done
+                if "Dataspace not found" in str(api_error):
+                    logging.error("Dataspace %s does not exist, create it before", self.data["dataspace-name"])
+                    raise ValueError("Dataspace %s does not exist, create it before", self.data["dataspace-name"])
+                elif "Schema Set not found" in str(api_error):
+                    logging.info("Schema set %s not found", self.data["schema-set-name"])
+                    return None
+                else:
+                    raise
+        return self._schema_set
+
+
+class AnchorResource(DataspaceSubresource):
+    """Anchor resource class
+
+    Creates CPS anchor
+    """
+
+    def __init__(self, data: Dict[str, Any]) -> None:
+        """Initialize anchor resource"""
+        super().__init__(data)
+
+        self._anchor: Anchor = None
+
+    def create(self) -> None:
+        """Create anchor.
+
+        Raises:
+            ValueError: Schema set doesn't exist
+
+        """
+        if not self.schema_set:
+            raise ValueError("Schema set %s does not exist, create it first", self.data["schema-set-name"])
+        if not self.anchor:
+            self.dataspace.create_anchor(self.schema_set, self.data["anchor-name"])
+
+    @property
+    def anchor(self) -> Anchor:
+        """Anchor property.
+
+        Tries to get anchor from dataspace.
+
+        Returns:
+            Anchor: Anchor object, if anchor already exists. None otherwise.
+
+        """
+        if not self._anchor:
+            try:
+                self._anchor = self.dataspace.get_anchor(self.data["anchor-name"])
+            except APIError as api_error:
+                if "Anchor not found" in str(api_error):
+                    return None
+                else:
+                    raise
+        return self._anchor
+
+
+class SchemaSetResource(DataspaceSubresource):
+    """Schema set resource class
+
+    Creates CPS schema set and
+    """
+
+    def __init__(self, data: Dict[str, Any]) -> None:
+        """Initialize schema set resource"""
+        super().__init__(data)
+
+    def create(self) -> None:
+        """Create schema set resource."""
+        if not self.schema_set:
+            with open(self.data["schema-set-file"], "rb") as schema_set_file:
+                self.dataspace.create_schema_set(self.data["schema-set-name"], schema_set_file)
+
+
+class DataspaceResource(Resource):
+    """DataspaceResource resource class
+
+    Creates CPS dataspace and sub-resources
+    """
+
+    def __init__(self, data: Dict[str, Any]) -> None:
+        """Initialize dataspace resource"""
+        super().__init__(data)
+
+        self._dataspace: Dataspace = None
+
+    def create(self) -> None:
+        try:
+            self._dataspace = Dataspace.create(self.data["dataspace-name"])
+        except APIError as api_error:
+            # Needs to be fixed when https://gitlab.com/Orange-OpenSource/lfn/onap/python-onapsdk/-/issues/181 is done
+            if "409" in str(api_error):
+                logging.warning("Dataspace %s already exists", self.data["dataspace-name"])
+                self._dataspace = Dataspace(self.data["dataspace-name"])
+            else:
+                raise
+
+        for schema_set_data in self.data.get("schema-sets", []):
+            try:
+                self._dataspace.get_schema_set(schema_set_data["schema-set-name"])
+            except APIError:
+                # Needs to be fixed when https://gitlab.com/Orange-OpenSource/lfn/onap/python-onapsdk/-/issues/181 is done
+                with open(schema_set_data["schema-set-file"], "rb") as schema_set_file:
+                    self._dataspace.create_schema_set(
+                        schema_set_data["schema-set-name"],
+                        schema_set_file
+                    )
+            else:
+                logging.warning("Schema set %s already exists", schema_set_data["schema-set-name"])
+
+        for anchor_data in self.data.get("anchors", []):
+            try:
+                self._dataspace.get_anchor(anchor_data["anchor-name"])
+            except APIError:
+                try:
+                    schema_set: SchemaSet = self._dataspace.get_schema_set(anchor_data["schema-set-name"])
+                except APIError:
+                    logging.warning("Schema set %s does not exist, anchor won't be created",
+                                    anchor_data["schema-set-name"])
+                    continue
+                self._dataspace.create_anchor(schema_set,
+                                              anchor_data["anchor-name"])
+            else:
+                logging.warning("Anchor %s already exists", anchor_data["anchor-name"])
diff --git a/onap_data_provider/resources/resource_creator.py b/onap_data_provider/resources/resource_creator.py
index c6ed4d8..7bd61bc 100644
--- a/onap_data_provider/resources/resource_creator.py
+++ b/onap_data_provider/resources/resource_creator.py
@@ -28,6 +28,7 @@ from .cloud_region_resource import CloudRegionResource
 from .complex_resource import ComplexResource
 from .customer_resource import CustomerResource
 from .data_dictionary_resource import DataDictionarySetResource
+from .cps_resource import AnchorResource, DataspaceResource, SchemaSetResource
 from .line_of_business_resource import LineOfBusinessResource
 from .msb_k8s_definition import MsbK8SDefinitionResource
 from .owning_entity_resource import OwningEntityResource
@@ -141,6 +142,15 @@ class ResourceCreator(ABC):
         },
         "blueprint-resource-template": {
             VersionsEnum.V1_1: BlueprintResourceTemplateResource,
+        },
+        "cps-dataspace": {
+            VersionsEnum.V1_1: DataspaceResource
+        },
+        "cps-schema-set": {
+            VersionsEnum.V1_1: SchemaSetResource
+        },
+        "cps-anchor": {
+            VersionsEnum.V1_1: AnchorResource
         }
     }
 
@@ -174,6 +184,9 @@ class ResourceCreator(ABC):
          - data-dictionaries: DataDictionarySetResource
          - blueprints: BlueprintResource
          - blueprint-resource-template: BlueprintResourceTemplateResource
+         - cps-dataspace: DataspaceResource
+         - cps-schema-set: SchemaSetResource
+         - cps-anchor: AnchorResource
 
         Args:
             resource_type (str): Resource type to create
diff --git a/onap_data_provider/schemas/infra_1_1.schema b/onap_data_provider/schemas/infra_1_1.schema
index 9135569..d2480c6 100644
--- a/onap_data_provider/schemas/infra_1_1.schema
+++ b/onap_data_provider/schemas/infra_1_1.schema
@@ -677,3 +677,81 @@ properties:
                 - resource-type
                 - resource-id
                 - data-file
+  cps-dataspaces:
+    type: array
+    items:
+      - type: object
+        properties:
+          cps-dataspace:
+            type: object
+            properties:
+              dataspace-name:
+                type: string
+              schema-sets:
+                type: array
+                items:
+                  - type: object
+                    properties:
+                      schema-set-name:
+                        type: string
+                      schema-set-file:
+                        type: string
+                    required:
+                      - schema-set-name
+                      - schema-set-file
+              anchors:
+                type: array
+                items:
+                  - type: object
+                    properties:
+                      anchor-name:
+                        type: string
+                      schema-set-name:
+                        type: string
+                    required:
+                      - anchor-name
+                      - schema-set-name
+            required:
+              - dataspace-name
+        required:
+          - cps-dataspace
+  cps-schema-sets:
+    type: array
+    items:
+      - type: object
+        properties:
+          cps-schema-set:
+            type: object
+            properties:
+              schema-set-name:
+                type: string
+              schema-set-file:
+                type: string
+              dataspace-name:
+                type: string
+            required:
+              - schema-set-name
+              - schema-set-file
+              - dataspace-name
+        required:
+          - cps-schema-set
+  cps-anchors:
+    type: array
+    items:
+      - type: object
+        properties:
+          cps-anchor:
+            type: object
+            properties:
+              anchor-name:
+                type: string
+              dataspace-name:
+                type: string
+              schema-set-name:
+                type: string
+            required:
+              - anchor-name
+              - dataspace-name
+              - schema-set-name
+        required:
+          - cps-anchor