From 66e44262b8eb996c06670dcededd899dd1cbd7dc Mon Sep 17 00:00:00 2001
From: Michal Jagiello <michal.jagiello@t-mobile.pl>
Date: Tue, 30 Nov 2021 08:25:09 +0000
Subject: Data provider release

Change-Id: Ia041a07152e8dabd87de05992d3670cbdc1ddaae
Issue-ID: INT-2010
Signed-off-by: Michal Jagiello <michal.jagiello@t-mobile.pl>
---
 onap_data_provider/resources/service_resource.py | 100 +++++++++++++++++++++++
 1 file changed, 100 insertions(+)
 create mode 100644 onap_data_provider/resources/service_resource.py

(limited to 'onap_data_provider/resources/service_resource.py')

diff --git a/onap_data_provider/resources/service_resource.py b/onap_data_provider/resources/service_resource.py
new file mode 100644
index 0000000..8489982
--- /dev/null
+++ b/onap_data_provider/resources/service_resource.py
@@ -0,0 +1,100 @@
+"""Service resource module."""
+"""
+   Copyright 2021 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 Any, Dict, Mapping, Optional, Type
+
+from onapsdk.sdc.pnf import Pnf  # type: ignore
+from onapsdk.sdc.properties import Property  # type: ignore
+from onapsdk.sdc.sdc_resource import SdcResource  # type: ignore
+from onapsdk.sdc.service import Service, ServiceInstantiationType  # type: ignore
+from onapsdk.sdc.vf import Vf  # type: ignore
+from onapsdk.sdc.vl import Vl  # type: ignore
+
+from .resource import Resource
+
+
+class ServiceResource(Resource):
+    """Service resource class."""
+
+    RESOURCES: Mapping[str, Type[SdcResource]] = {
+        "PNF": Pnf,
+        "VF": Vf,
+        "VL": Vl,
+    }
+
+    def __init__(self, data: Dict[str, Any]) -> None:
+        """Initialize Service resource.
+
+        Args:
+            data (Dict[str, Any]): Data needed to create resource.
+
+        """
+        super().__init__(data)
+        self._service: Optional[Service] = None
+
+    def create(self) -> None:
+        """Create Service resource."""
+        if not self.exists:
+            service = Service(
+                name=self.data["name"],
+                instantiation_type=ServiceInstantiationType.MACRO,
+            )
+            service.create()
+            for resource_data in self.data.get("resources", []):
+                resource = self.RESOURCES[resource_data["type"].upper()](
+                    name=resource_data["name"]
+                )
+                service.add_resource(resource)
+                component = service.get_component(resource)
+                for prop_key, prop_value in resource_data.get("properties", {}).items():
+                    prop = component.get_property(prop_key)
+                    prop.value = prop_value
+            for property_data in self.data.get("properties", []):
+                service.add_property(
+                    Property(
+                        property_data["name"],
+                        property_data["type"],
+                        value=property_data.get("value"),
+                    )
+                )
+            service.checkin()
+            service.onboard()
+            self._service = service
+
+    @property
+    def exists(self) -> bool:
+        """Check if Service exists in SDC.
+
+        Returns:
+            bool: True if Service exists, False otherwise
+
+        """
+        return self.service is not None and self.service.distributed
+
+    @property
+    def service(self) -> Optional[Service]:
+        """Service property.
+
+        Returns:
+            Service: Service object which is describer by provided data. None if does not exist yet.
+
+        """
+        if not self._service:
+            service: Service = Service(name=self.data["name"])
+            if not service.created():
+                return None
+            self._service = service
+        return self._service
-- 
cgit 1.2.3-korg