summaryrefslogtreecommitdiffstats
path: root/newton/newton/requests/views/network.py
diff options
context:
space:
mode:
authorHuang Haibin <haibin.huang@intel.com>2018-03-15 18:21:43 +0800
committerHuang Haibin <haibin.huang@intel.com>2018-03-15 18:24:55 +0800
commitdaf87b3a503a6d3ff5e82abf31d5a667d6616b16 (patch)
tree3f2f0fe0b026564478733bed7aac17dea2435285 /newton/newton/requests/views/network.py
parent7b7d2abafd64f73d49906e2116fec43ccd930246 (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.py172
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