diff options
Diffstat (limited to 'azure/azure/swagger/views/registry/views.py')
| -rw-r--r-- | azure/azure/swagger/views/registry/views.py | 167 |
1 files changed, 0 insertions, 167 deletions
diff --git a/azure/azure/swagger/views/registry/views.py b/azure/azure/swagger/views/registry/views.py deleted file mode 100644 index b5db805..0000000 --- a/azure/azure/swagger/views/registry/views.py +++ /dev/null @@ -1,167 +0,0 @@ -# Copyright (c) 2018 Amdocs -# -# 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. - - -import logging - -from rest_framework import status -from rest_framework.response import Response -from rest_framework.views import APIView - -from azure.pub.exceptions import VimDriverAzureException -from azure.pub.msapi import extsys -from azure.pub.utils.restcall import AAIClient - - -logger = logging.getLogger(__name__) - - -class Registry(APIView): - # def _get_tenants(self, auth_info): - # tenant_instance = OperateTenant.OperateTenant() - # try: - # projects = tenant_instance.get_projects(auth_info) - # except Exception as e: - # logger.exception("get tenants error %(e)s", {"e": e}) - # raise e - # - # rsp = {"tenants": []} - # for project in projects: - # rsp['tenants'].append(project.to_dict()) - # return rsp - # - # def _get_images(self, auth_info): - # image_instance = OperateImage.OperateImage(auth_info) - # try: - # images = image_instance.get_vim_images() - # except Exception as e: - # logger.exception("get images error %(e)s", {"e": e}) - # raise e - # - # rsp = {"images": []} - # for image in images: - # rsp['images'].append(image.to_dict()) - # return rsp - # - # def _get_flavors(self, auth_info): - # flavors_op = OperateFlavors.OperateFlavors() - # try: - # flavors = flavors_op.list_flavors( - # auth_info, auth_info['tenant']) - # except Exception as e: - # logger.exception("get flavors error %(e)s", {"e": e}) - # raise e - # - # rsp = {"flavors": []} - # for flavor in flavors: - # flavor_info = flavor[0].to_dict() - # flavor_info['extra_specs'] = flavor[1].extra_specs - # rsp['flavors'].append(flavor_info) - # return rsp - # - # def _get_networks(self, auth_info): - # net_op = OperateNetwork.OperateNetwork() - # try: - # resp = net_op.list_networks( - # auth_info['vimId'], auth_info['tenant']) - # except Exception as e: - # logger.exception("get networks error %(e)s", {"e": e}) - # raise e - # - # rsp = {'networks': resp['networks']} - # return rsp - # - # def _get_hypervisors(self, auth_info): - # hypervisor_op = OperateHypervisor.OperateHypervisor() - # try: - # hypervisors = hypervisor_op.list_hypervisors(auth_info) - # except Exception as e: - # logger.exception("get hypervisors error %(e)s", {"e": e}) - # raise e - # - # rsp = {"hypervisors": []} - # for hypervisor in hypervisors: - # rsp['hypervisors'].append(hypervisor.to_dict()) - # return rsp - - def _find_tenant_id(self, name, tenants): - for tenant in tenants['tenants']: - if tenant['name'] == name: - return tenant['id'] - - def post(self, request, vimid): - try: - vim_info = extsys.get_vim_by_id(vimid) - except VimDriverAzureException as e: - return Response(data={'error': str(e)}, status=e.status_code) - data = {} - data['vimId'] = vim_info['vimId'] - data['username'] = vim_info['userName'] - data['userName'] = vim_info['userName'] - data['password'] = vim_info['password'] - data['url'] = vim_info['url'] - data['project_name'] = vim_info['tenant'] - - rsp = {} - # get tenants - try: - logger.debug('Getting tenants') - tenants = self._get_tenants(data) - rsp.update(tenants) - data['tenant'] = self._find_tenant_id( - data['project_name'], tenants) - data['project_id'] = data['tenant'] - # set default tenant - # get images - logger.debug('Getting images') - images = self._get_images(data) - rsp.update(images) - # get flavors - logger.debug('Getting flavors') - flavors = self._get_flavors(data) - rsp.update(flavors) - # get networks - logger.debug('Getting networks') - networks = self._get_networks(data) - rsp.update(networks) - # get hypervisors - logger.debug('Getting hypervisors') - hypervisors = self._get_hypervisors(data) - rsp.update(hypervisors) - # update A&AI - logger.debug('Put data into A&AI') - cloud_owner, cloud_region = extsys.split_vim_to_owner_region( - vimid) - aai_adapter = AAIClient(cloud_owner, cloud_region) - aai_adapter.update_vim(rsp) - except Exception as e: - if hasattr(e, "http_status"): - return Response(data={'error': str(e)}, status=e.http_status) - else: - return Response(data={'error': str(e)}, - status=status.HTTP_500_INTERNAL_SERVER_ERROR) - - return Response(data="", status=status.HTTP_200_OK) - - -class UnRegistry(APIView): - - def delete(self, request, vimid): - try: - cloud_owner, cloud_region = extsys.split_vim_to_owner_region( - vimid) - aai_adapter = AAIClient(cloud_owner, cloud_region) - aai_adapter.delete_vim() - except Exception as e: - return Response(data=e.message, - status=status.HTTP_500_INTERNAL_SERVER_ERROR) - return Response(data="", status=status.HTTP_204_NO_CONTENT) |