o2ims/views/ocloud_view.py

   1 # Copyright (C) 2021 Wind River Systems, Inc.\r
   2 #\r
   3 #  Licensed under the Apache License, Version 2.0 (the "License");\r
   4 #  you may not use this file except in compliance with the License.\r
   5 #  You may obtain a copy of the License at\r
   6 #\r
   7 #      http://www.apache.org/licenses/LICENSE-2.0\r
   8 #\r
   9 #  Unless required by applicable law or agreed to in writing, software\r
  10 #  distributed under the License is distributed on an "AS IS" BASIS,\r
  11 #  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
  12 #  See the License for the specific language governing permissions and\r
  13 #  limitations under the License.\r
  14 \r
  15 import uuid\r
  16 \r
  17 from o2common.service import unit_of_work\r
  18 from o2ims.views.ocloud_dto import SubscriptionDTO\r
  19 from o2ims.domain.subscription_obj import Subscription\r
  20 \r
  21 \r
  22 def oclouds(uow: unit_of_work.AbstractUnitOfWork):\r
  23     with uow:\r
  24         li = uow.oclouds.list()\r
  25     return [r.serialize() for r in li]\r
  26 \r
  27 \r
  28 def ocloud_one(ocloudid: str, uow: unit_of_work.AbstractUnitOfWork):\r
  29     with uow:\r
  30         first = uow.oclouds.get(ocloudid)\r
  31         return first.serialize() if first is not None else None\r
  32 \r
  33 \r
  34 def resource_types(uow: unit_of_work.AbstractUnitOfWork):\r
  35     with uow:\r
  36         li = uow.resource_types.list()\r
  37     return [r.serialize() for r in li]\r
  38 \r
  39 \r
  40 def resource_type_one(resourceTypeId: str,\r
  41                       uow: unit_of_work.AbstractUnitOfWork):\r
  42     with uow:\r
  43         first = uow.resource_types.get(resourceTypeId)\r
  44         return first.serialize() if first is not None else None\r
  45 \r
  46 \r
  47 def resource_pools(uow: unit_of_work.AbstractUnitOfWork):\r
  48     with uow:\r
  49         li = uow.resource_pools.list()\r
  50     return [r.serialize() for r in li]\r
  51 \r
  52 \r
  53 def resource_pool_one(resourcePoolId: str,\r
  54                       uow: unit_of_work.AbstractUnitOfWork):\r
  55     with uow:\r
  56         first = uow.resource_pools.get(resourcePoolId)\r
  57         return first.serialize() if first is not None else None\r
  58 \r
  59 \r
  60 def resources(resourcePoolId: str, uow: unit_of_work.AbstractUnitOfWork):\r
  61     with uow:\r
  62         li = uow.resources.list(resourcePoolId)\r
  63     return [r.serialize() for r in li]\r
  64 \r
  65 \r
  66 def resource_one(resourceId: str, uow: unit_of_work.AbstractUnitOfWork):\r
  67     with uow:\r
  68         first = uow.resources.get(resourceId)\r
  69         return first.serialize() if first is not None else None\r
  70 \r
  71 \r
  72 def deployment_managers(uow: unit_of_work.AbstractUnitOfWork):\r
  73     with uow:\r
  74         li = uow.deployment_managers.list()\r
  75     return [r.serialize() for r in li]\r
  76 \r
  77 \r
  78 def deployment_manager_one(deploymentManagerId: str,\r
  79                            uow: unit_of_work.AbstractUnitOfWork):\r
  80     with uow:\r
  81         first = uow.deployment_managers.get(deploymentManagerId)\r
  82         return first.serialize() if first is not None else None\r
  83 \r
  84 \r
  85 def subscriptions(uow: unit_of_work.AbstractUnitOfWork):\r
  86     with uow:\r
  87         li = uow.subscriptions.list()\r
  88     return [r.serialize() for r in li]\r
  89 \r
  90 \r
  91 def subscription_one(subscriptionId: str,\r
  92                      uow: unit_of_work.AbstractUnitOfWork):\r
  93     with uow:\r
  94         first = uow.subscriptions.get(subscriptionId)\r
  95         return first.serialize() if first is not None else None\r
  96 \r
  97 \r
  98 def subscription_create(subscriptionDto: SubscriptionDTO.subscription,\r
  99                         uow: unit_of_work.AbstractUnitOfWork):\r
 100 \r
 101     sub_uuid = str(uuid.uuid4())\r
 102     subscription = Subscription(\r
 103         sub_uuid, subscriptionDto['callback'],\r
 104         subscriptionDto['consumerSubscriptionId'],\r
 105         subscriptionDto['filter'])\r
 106     with uow:\r
 107         uow.subscriptions.add(subscription)\r
 108         uow.commit()\r
 109     return {"subscriptionId": sub_uuid}\r
 110 \r
 111 \r
 112 def subscription_delete(subscriptionId: str,\r
 113                         uow: unit_of_work.AbstractUnitOfWork):\r
 114     with uow:\r
 115         uow.subscriptions.delete(subscriptionId)\r
 116         uow.commit()\r
 117     return True\r