Merge "Custom YAML tag to get already existed ONAP resources properties"

6 files changed, 234 insertions, 1 deletions

diff --git a/onap_data_provider/config_loader.py b/onap_data_provider/config_loader.py
index 5757e1e..4507a14 100644
--- a/onap_data_provider/config_loader.py
+++ b/onap_data_provider/config_loader.py
@@ -17,11 +17,12 @@
 from pathlib import Path
 from typing import Any, Iterator, List
 import yaml
-from onap_data_provider.tag_handlers import join, generate_random_uuid
+from onap_data_provider.tag_handlers import join, generate_random_uuid, resource_property
 
 # register custom tag handlers in yaml.SafeLoader
 yaml.add_constructor("!join", join, yaml.SafeLoader)
 yaml.add_constructor("!uuid4", generate_random_uuid, yaml.SafeLoader)
+yaml.add_constructor("!onap_resource_property", resource_property, yaml.SafeLoader)
 
 
 class ConfigLoader:
diff --git a/onap_data_provider/property_tag/__init__.py b/onap_data_provider/property_tag/__init__.py
new file mode 100644
index 0000000..1e88be1
--- /dev/null
+++ b/onap_data_provider/property_tag/__init__.py
@@ -0,0 +1,21 @@
+"""Resource property tag package.
+
+There the package modules are going to be implemented.
+Each module represents one resource which can be used with "!onap_resource_property" tag.
+
+"""
+"""
+   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.
+"""
\ No newline at end of file
diff --git a/onap_data_provider/property_tag/base.py b/onap_data_provider/property_tag/base.py
new file mode 100644
index 0000000..7ae7102
--- /dev/null
+++ b/onap_data_provider/property_tag/base.py
@@ -0,0 +1,73 @@
+"""Base module for property tag classes."""
+"""
+   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.
+"""
+
+from abc import ABC
+from typing import Any, Type
+
+from onapsdk.onap_service import OnapService  # type: ignore
+
+
+class BasePropertyTagResource(ABC):
+    """Base property tag resource class.
+
+    Abstract class which all resource classes should inherit from.
+    Subclasses has to implement `resource` property to get the valid object
+        using Python ONAP SDK classes.
+
+    Subclass could also implement `__init__` method to get more attributes from
+        the user which uses the tag.
+
+    """
+
+    def __init__(self, property_name: str) -> None:
+        """Init property tag resource object.
+
+        Args:
+            property_name (str): Name of the property to get
+
+        """
+        self.property_name: str = property_name
+
+    @property
+    def resource(self) -> OnapService:
+        """Resource property abstract method.
+
+        Returns an object from which the property is going to be get.
+
+        Raises:
+            NotImplementedError: That method is an abstract one
+
+        Returns:
+            OnapService: Any OnapService subclass
+
+        """
+        raise NotImplementedError
+
+    @property
+    def resource_property(self) -> Any:
+        """Resource property.
+
+        Using `getattr` function get the property from resource.
+
+        Returns:
+            Any: Property value
+
+        Raises:
+            AttributeError: Resource has no property with given name.
+
+        """
+        return getattr(self.resource, self.property_name)
diff --git a/onap_data_provider/property_tag/properties_getter.py b/onap_data_provider/property_tag/properties_getter.py
new file mode 100644
index 0000000..df29314
--- /dev/null
+++ b/onap_data_provider/property_tag/properties_getter.py
@@ -0,0 +1,64 @@
+"""Properties getter 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 typing import Any, Mapping, Type, TYPE_CHECKING
+
+from .base import BasePropertyTagResource
+from .sdc_service import SdcServicePropertyTagResource
+
+if TYPE_CHECKING:
+    from typing import Any, Mapping
+
+
+class PropertiesGetter:
+    """Properties getter class.
+
+    Uses to get values of properties from already existing ONAP resources.
+
+    Contains a mapper to select right class to get the values from.
+    """
+
+    RESOURCES: Mapping[str, Type[BasePropertyTagResource]] = {
+        "service": SdcServicePropertyTagResource
+    }
+
+    @classmethod
+    def get_property(cls, resource_type: str, *args: str) -> Any:
+        """Get property class method.
+
+        Maps the input `resource_type` into `BasePropertyTagResource` class
+            and get it's `resource_property` property
+
+        Args:
+            resource_type (str): Type of the resource - uses by a mapper
+            *args (str): Args to be passed to the service class init
+
+        Raises:
+            ValueError: Given resource type is not supported
+
+        Returns:
+            Any: Resource property value
+
+        """
+        try:
+            return cls.RESOURCES[resource_type](*args).resource_property
+        except KeyError:
+            msg = f"Resource type \"{resource_type}\" is not supported"
+            logging.error(msg)
+            raise ValueError(msg)
+
diff --git a/onap_data_provider/property_tag/sdc_service.py b/onap_data_provider/property_tag/sdc_service.py
new file mode 100644
index 0000000..b8eca80
--- /dev/null
+++ b/onap_data_provider/property_tag/sdc_service.py
@@ -0,0 +1,52 @@
+"""SDC property module used by tag to get resource's property"""
+"""
+   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.
+"""
+
+from typing import Optional
+
+from onapsdk.onap_service import OnapService  # type: ignore
+from onapsdk.sdc.service import Service  # type: ignore
+
+from .base import BasePropertyTagResource
+
+
+class SdcServicePropertyTagResource(BasePropertyTagResource):
+    """Class to get property from SDC service module objects."""
+
+    def __init__(self, property_name: str, service_name: str, version: Optional[str] = None) -> None:
+        """Initialize object.
+
+        Get the name of the property to get, serivce name and optional version of the service.
+
+        Args:
+            property_name (str): Property name
+            service_name (str): Service name
+            version (Optional[str], optional): Optional version. If no version is given
+                the latest version of the service will be loaded. Defaults to None.
+        """
+        super().__init__(property_name)
+        self.service_name: str = service_name
+        self.version: Optional[str] = version
+
+    @property
+    def resource(self) -> Service:
+        """Service resource.
+
+        Returns:
+            Service: Service with the provided name and version.
+
+        """
+        return Service(self.service_name, version=self.version)
diff --git a/onap_data_provider/tag_handlers.py b/onap_data_provider/tag_handlers.py
index 1f8a21a..d8c9738 100644
--- a/onap_data_provider/tag_handlers.py
+++ b/onap_data_provider/tag_handlers.py
@@ -19,6 +19,8 @@ from typing import Any
 
 import yaml
 
+from .property_tag.properties_getter import PropertiesGetter
+
 
 def join(loader: yaml.SafeLoader, node: yaml.Node) -> str:
     """Concatinates the nodes fields for !join tag.
@@ -52,3 +54,23 @@ def generate_random_uuid(*_: Any) -> str:
         str: randomly generated UUID
     """
     return str(uuid.uuid4())
+
+
+def resource_property(loader: yaml.SafeLoader, node: yaml.Node) -> Any:
+    """Resource property tag method.
+
+    Constructs a scalar from the YAML node and uses `PropertiesGetter`
+        to get a property value from already existing ONAP resource.
+
+    Args:
+        loader (yaml.SafeLoader): YAML Safe Loader
+        node (yaml.Node): Node to get values from
+
+    Raises:
+        ValueError: Given property type from the node is not supported by a tag
+
+    Returns:
+        Any: Resource's property value
+    """
+    resource_type, *args = loader.construct_scalar(node).split(" ")  # type: ignore
+    return PropertiesGetter.get_property(resource_type, *args)