o2ims/domain/ocloud.py

   1 # Copyright (C) 2021 Wind River Systems, Inc.
   2 #
   3 #  Licensed under the Apache License, Version 2.0 (the "License");
   4 #  you may not use this file except in compliance with the License.
   5 #  You may obtain a copy of the License at
   6 #
   7 #      http://www.apache.org/licenses/LICENSE-2.0
   8 #
   9 #  Unless required by applicable law or agreed to in writing, software
  10 #  distributed under the License is distributed on an "AS IS" BASIS,
  11 #  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  12 #  See the License for the specific language governing permissions and
  13 #  limitations under the License.
  14
  15 from __future__ import annotations
  16 import json
  17
  18 from o2common.domain.base import AgRoot, Serializer
  19 # from dataclasses import dataclass
  20 # from datetime import date
  21 # from typing import Optional, List, Set
  22 from .resource_type import ResourceTypeEnum
  23 # from uuid import UUID
  24
  25
  26 DeploymentManagerProfileDefault = 'default'
  27 DeploymentManagerProfileSOL018 = 'sol018'
  28 DeploymentManagerProfileSOL018HelmCLI = 'sol018_helmcli'
  29
  30
  31 class DeploymentManager(AgRoot, Serializer):
  32     def __init__(self, id: str, name: str, ocloudid: str,
  33                  dmsendpoint: str, description: str = '',
  34                  supportedLocations: str = '', capabilities: str = '',
  35                  capacity: str = '', profile: str = '') -> None:
  36         super().__init__()
  37         self.deploymentManagerId = id
  38         self.version_number = 0
  39         self.oCloudId = ocloudid
  40         self.name = name
  41         self.description = description
  42         self.deploymentManagementServiceEndpoint = dmsendpoint
  43         self.supportedLocations = supportedLocations
  44         self.capabilities = capabilities
  45         self.capacity = capacity
  46         self.profile = profile
  47         self.extensions = []
  48
  49     def serialize(self):
  50         print(self.__dict__)
  51         d = Serializer.serialize(self)
  52
  53         if 'profile' in d and d['profile'] != '':
  54             d['profile'] = json.loads(d['profile'])
  55         d['profileSupportList'] = [
  56             DeploymentManagerProfileDefault,
  57             DeploymentManagerProfileSOL018,
  58             DeploymentManagerProfileSOL018HelmCLI,
  59         ]
  60
  61         return d
  62
  63
  64 class ResourcePool(AgRoot, Serializer):
  65     def __init__(self, id: str, name: str, location: str,
  66                  ocloudid: str, gLocationId: str = '',
  67                  description: str = '') -> None:
  68         super().__init__()
  69         self.resourcePoolId = id
  70         self.version_number = 0
  71         self.oCloudId = ocloudid
  72         self.globalLocationId = gLocationId
  73         self.name = name
  74         self.location = location
  75         self.description = description
  76         self.extensions = []
  77
  78
  79 class ResourceType(AgRoot, Serializer):
  80     def __init__(self, typeid: str, name: str, typeEnum: ResourceTypeEnum,
  81                  ocloudid: str, vender: str = '', model: str = '',
  82                  version: str = '',
  83                  description: str = '') -> None:
  84         super().__init__()
  85         self.resourceTypeId = typeid
  86         self.version_number = 0
  87         self.oCloudId = ocloudid
  88         self.resourceTypeEnum = typeEnum
  89         self.name = name
  90         self.vender = vender
  91         self.model = model
  92         self.version = version
  93         self.description = description
  94         self.extensions = []
  95
  96
  97 class Resource(AgRoot, Serializer):
  98     def __init__(self, resourceId: str, resourceTypeId: str,
  99                  resourcePoolId: str, name: str, parentId: str = '',
 100                  gAssetId: str = '', elements: str = '',
 101                  description: str = '') -> None:
 102         super().__init__()
 103         self.resourceId = resourceId
 104         self.version_number = 0
 105         self.resourceTypeId = resourceTypeId
 106         self.resourcePoolId = resourcePoolId
 107         self.name = name
 108         self.globalAssetId = gAssetId
 109         self.parentId = parentId
 110         self.elements = elements
 111         self.description = description
 112         self.children = []
 113         self.extensions = []
 114
 115     def set_children(self, children: list):
 116         self.children = children
 117
 118     def set_resource_type_name(self, resource_type_name: str):
 119         self.resourceTypeName = resource_type_name
 120
 121     def serialize(self):
 122         d = Serializer.serialize(self)
 123
 124         if 'elements' in d and d['elements'] != '':
 125             d['elements'] = json.loads(d['elements'])
 126
 127         if not hasattr(self, 'children') or len(self.children) == 0:
 128             return d
 129         else:
 130             d['children'] = []
 131
 132         for child in self.children:
 133             d['children'].append(child.serialize())
 134         return d
 135
 136
 137 class Ocloud(AgRoot, Serializer):
 138     def __init__(self, ocloudid: str, name: str, imsendpoint: str,
 139                  globalcloudId: str = '',
 140                  description: str = '', version_number: int = 0) -> None:
 141         super().__init__()
 142         self.oCloudId = ocloudid
 143         self.globalcloudId = globalcloudId
 144         self.version_number = version_number
 145         self.name = name
 146         self.description = description
 147         self.serviceUri = imsendpoint
 148         self.resourcePools = []
 149         self.deploymentManagers = []
 150         self.resourceTypes = []
 151         self.extensions = []
 152
 153     # def addDeploymentManager(self,
 154     #                          deploymentManager: DeploymentManager):
 155
 156     #     deploymentManager.oCloudId = self.oCloudId
 157     #     old = filter(
 158     #         lambda x: x.deploymentManagerId ==
 159     #         deploymentManager.deploymentManagerId,
 160     #         self.deploymentManagers)
 161     #     for o in old or []:
 162     #         self.deploymentManagers.remove(o)
 163     #     self.deploymentManagers.append(deploymentManager)