diff options
author | 2018-03-15 18:21:43 +0800 | |
---|---|---|
committer | 2018-03-15 18:24:55 +0800 | |
commit | daf87b3a503a6d3ff5e82abf31d5a667d6616b16 (patch) | |
tree | 3f2f0fe0b026564478733bed7aac17dea2435285 /newton/newton/requests/views/network.py | |
parent | 7b7d2abafd64f73d49906e2116fec43ccd930246 (diff) |
Delete repeat file with share directory
Change-Id: I93ecf179670216cb0b82803048daf22d0cd3b915
Issue-ID: MULTICLOUD-138
Signed-off-by: Huang Haibin <haibin.huang@intel.com>
Diffstat (limited to 'newton/newton/requests/views/network.py')
-rw-r--r-- | newton/newton/requests/views/network.py | 172 |
1 files changed, 0 insertions, 172 deletions
diff --git a/newton/newton/requests/views/network.py b/newton/newton/requests/views/network.py deleted file mode 100644 index b4cdbdf9..00000000 --- a/newton/newton/requests/views/network.py +++ /dev/null @@ -1,172 +0,0 @@ -# Copyright (c) 2017-2018 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. - -import logging -import json -import traceback -from keystoneauth1.exceptions import HttpError -from rest_framework import status -from rest_framework.response import Response -from rest_framework.views import APIView - -from newton.pub.exceptions import VimDriverNewtonException - -from newton.requests.views.util import VimDriverUtils - -logger = logging.getLogger(__name__) - - -class Networks(APIView): - service = {'service_type': 'network', - 'interface': 'public'} - keys_mapping = [ - ("provider:segmentation_id", "segmentationId"), - ("provider:physical_network", "physicalNetwork"), - ("router:external", "routerExternal"), - ("provider:network_type", "networkType"), - ("vlan_transparent", "vlanTransparent"), - ("project_id", "tenantId"), - ] - - def get(self, request, vimid="", tenantid="", networkid=""): - logger.debug("Networks--get::> %s" % request.data) - try: - query = VimDriverUtils.get_query_part(request) - content, status_code = self.get_networks(query, vimid, tenantid, networkid) - return Response(data=content, status=status_code) - - except VimDriverNewtonException as e: - return Response(data={'error': e.content}, status=e.status_code) - except HttpError as e: - logger.error("HttpError: status:%s, response:%s" % (e.http_status, e.response.json())) - return Response(data=e.response.json(), status=e.http_status) - except Exception as e: - logger.error(traceback.format_exc()) - return Response(data={'error': str(e)}, - status=status.HTTP_500_INTERNAL_SERVER_ERROR) - - def get_networks(self, query, vimid="", tenantid="", networkid=""): - logger.debug("Networks--get_networks::> %s" % networkid) - - # prepare request resource to vim instance - req_resouce = "v2.0/networks" - if networkid: - req_resouce += "/%s" % networkid - - if query: - req_resouce += "?%s" % query - - vim = VimDriverUtils.get_vim_info(vimid) - sess = VimDriverUtils.get_session(vim, tenantid) - resp = sess.get(req_resouce, endpoint_filter=self.service) - content = resp.json() - vim_dict = { - "vimName": vim["name"], - "vimId": vim["vimId"], - "tenantId": tenantid, - } - content.update(vim_dict) - - if not networkid: - # convert the key naming in networks - for network in content["networks"]: - VimDriverUtils.replace_key_by_mapping(network, - self.keys_mapping) - else: - # convert the key naming in the network specified by id - network = content.pop("network", None) - VimDriverUtils.replace_key_by_mapping(network, - self.keys_mapping) - content.update(network) - - return content, resp.status_code - - def post(self, request, vimid="", tenantid="", networkid=""): - logger.debug("Networks--post::> %s" % request.data) - try: - #check if created already: check name - query = "name=%s" % request.data["name"] - content, status_code = self.get_networks(query, vimid, tenantid) - existed = False - if status_code == 200: - for network in content["networks"]: - if network["name"] == request.data["name"]: - existed = True - break - if existed == True: - vim_dict = { - "returnCode": 0, - } - network.update(vim_dict) - return Response(data=network, status=status_code) - - # prepare request resource to vim instance - req_resouce = "v2.0/networks" - - vim = VimDriverUtils.get_vim_info(vimid) - sess = VimDriverUtils.get_session(vim, tenantid) - network = request.data - VimDriverUtils.replace_key_by_mapping(network, - self.keys_mapping, True) - req_body = json.JSONEncoder().encode({"network": network}) - resp = sess.post(req_resouce, data=req_body, - endpoint_filter=self.service) - resp_body = resp.json()["network"] - VimDriverUtils.replace_key_by_mapping(resp_body, self.keys_mapping) - vim_dict = { - "vimName": vim["name"], - "vimId": vim["vimId"], - "tenantId": tenantid, - "returnCode": 1, - } - resp_body.update(vim_dict) - return Response(data=resp_body, status=resp.status_code) - except VimDriverNewtonException as e: - return Response(data={'error': e.content}, status=e.status_code) - except HttpError as e: - logger.error("HttpError: status:%s, response:%s" % (e.http_status, e.response.json())) - return Response(data=e.response.json(), status=e.http_status) - except Exception as e: - logger.error(traceback.format_exc()) - return Response(data={'error': str(e)}, - status=status.HTTP_500_INTERNAL_SERVER_ERROR) - - def delete(self, request, vimid="", tenantid="", networkid=""): - logger.debug("Networks--delete::> %s" % request.data) - try: - # prepare request resource to vim instance - req_resouce = "v2.0/networks" - if networkid: - req_resouce += "/%s" % networkid - query = VimDriverUtils.get_query_part(request) - if query: - req_resouce += "?%s" % query - - vim = VimDriverUtils.get_vim_info(vimid) - sess = VimDriverUtils.get_session(vim, tenantid) - resp = sess.delete(req_resouce, endpoint_filter=self.service) - return Response(status=resp.status_code) - except VimDriverNewtonException as e: - return Response(data={'error': e.content}, status=e.status_code) - except HttpError as e: - logger.error("HttpError: status:%s, response:%s" % (e.http_status, e.response.json())) - return Response(data=e.response.json(), status=e.http_status) - except Exception as e: - logger.error(traceback.format_exc()) - return Response(data={'error': str(e)}, - status=status.HTTP_500_INTERNAL_SERVER_ERROR) - - -class Subnets(APIView): - pass |