# Copyright (C) 2021 Wind River Systems, Inc. # # 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 __future__ import annotations import json from o2common.domain.base import AgRoot, Serializer # from dataclasses import dataclass # from datetime import date # from typing import Optional, List, Set from .resource_type import ResourceTypeEnum # from uuid import UUID class DeploymentManager(AgRoot, Serializer): def __init__(self, id: str, name: str, ocloudid: str, dmsendpoint: str, description: str = '', supportedLocations: str = '', capabilities: str = '', capacity: str = '', profile: str = '') -> None: super().__init__() self.deploymentManagerId = id self.version_number = 0 self.oCloudId = ocloudid self.name = name self.description = description self.deploymentManagementServiceEndpoint = dmsendpoint self.supportedLocations = supportedLocations self.capabilities = capabilities self.capacity = capacity self.profile = profile self.extensions = [] def serialize(self): d = Serializer.serialize(self) if 'profile' in d and d['profile'] != '': d['profile'] = json.loads(d['profile']) d['profileSupportList'] = ['default', 'sol0018'] return d class ResourcePool(AgRoot, Serializer): def __init__(self, id: str, name: str, location: str, ocloudid: str, gLocationId: str = '', description: str = '') -> None: super().__init__() self.resourcePoolId = id self.version_number = 0 self.oCloudId = ocloudid self.globalLocationId = gLocationId self.name = name self.location = location self.description = description self.extensions = [] class ResourceType(AgRoot, Serializer): def __init__(self, typeid: str, name: str, typeEnum: ResourceTypeEnum, ocloudid: str, vender: str = '', model: str = '', version: str = '', description: str = '') -> None: super().__init__() self.resourceTypeId = typeid self.version_number = 0 self.oCloudId = ocloudid self.resourceTypeEnum = typeEnum self.name = name self.vender = vender self.model = model self.version = version self.description = description self.extensions = [] class Resource(AgRoot, Serializer): def __init__(self, resourceId: str, resourceTypeId: str, resourcePoolId: str, name: str, parentId: str = '', gAssetId: str = '', elements: str = '', description: str = '') -> None: super().__init__() self.resourceId = resourceId self.version_number = 0 self.resourceTypeId = resourceTypeId self.resourcePoolId = resourcePoolId self.name = name self.globalAssetId = gAssetId self.parentId = parentId self.elements = elements self.description = description self.children = [] self.extensions = [] def set_children(self, children: list): self.children = children def set_resource_type_name(self, resource_type_name: str): self.resourceTypeName = resource_type_name def serialize(self): d = Serializer.serialize(self) if 'elements' in d and d['elements'] != '': d['elements'] = json.loads(d['elements']) if not hasattr(self, 'children') or len(self.children) == 0: return d else: d['children'] = [] for child in self.children: d['children'].append(child.serialize()) return d class Ocloud(AgRoot, Serializer): def __init__(self, ocloudid: str, name: str, imsendpoint: str, globalcloudId: str = '', description: str = '', version_number: int = 0) -> None: super().__init__() self.oCloudId = ocloudid self.globalcloudId = globalcloudId self.version_number = version_number self.name = name self.description = description self.infrastructureManagementServiceEndpoint = imsendpoint self.resourcePools = [] self.deploymentManagers = [] self.resourceTypes = [] self.extensions = [] # def addDeploymentManager(self, # deploymentManager: DeploymentManager): # deploymentManager.oCloudId = self.oCloudId # old = filter( # lambda x: x.deploymentManagerId == # deploymentManager.deploymentManagerId, # self.deploymentManagers) # for o in old or []: # self.deploymentManagers.remove(o) # self.deploymentManagers.append(deploymentManager)