packagehandler/views.py

   1 #   Copyright 2018 EveryUP Srl
   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  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 import json
  16 import logging
  17
  18 import yaml
  19 from sf_t3d.decorators import login_required
  20 from django.http import HttpResponse
  21 from django.shortcuts import render, redirect
  22
  23
  24 from lib.util import Util
  25 from lib.osm.osmclient.clientv2 import Client
  26 from lib.osm.osm_rdcl_parser import OsmParser
  27 from lib.osm.osm_util import OsmUtil
  28 import authosm.utils as osmutils
  29
  30 logging.basicConfig(level=logging.DEBUG)
  31 log = logging.getLogger('packagehandler/view.py')
  32
  33
  34 @login_required
  35 def show_packages(request, package_type=None):
  36     user = osmutils.get_user(request)
  37     project_id = user.project_id
  38     client = Client()
  39     filter = request.GET.get('type')
  40     try:
  41         if package_type == 'ns':
  42             descriptors = client.nsd_list(user.get_token(),filter)
  43         elif package_type == 'vnf':
  44             descriptors = client.vnfd_list(user.get_token(),filter)
  45     except Exception as e:
  46         log.exception(e)
  47         descriptors = []
  48
  49     url = 'package_list.html'
  50     return __response_handler(request, {
  51         'descriptors': descriptors['data'] if descriptors and descriptors['error'] is False else [],
  52         'project_id': project_id,
  53         'project_type': 'osm',
  54         'package_type': package_type
  55     }, url)
  56
  57 @login_required
  58 def create_package_empty(request, package_type=None):
  59     user = osmutils.get_user(request)
  60     pkg_name = request.POST.get('name', '')
  61     try:
  62         client = Client()
  63         if package_type == 'ns':
  64             result = client.nsd_create_pkg_base(user.get_token(), pkg_name)
  65         elif package_type == 'vnf':
  66             result = client.vnfd_create_pkg_base(user.get_token(), pkg_name)
  67         else:
  68             log.debug('Update descriptor: Unknown data type')
  69             result = {'error': True, 'data': 'Update descriptor: Unknown data type'}
  70     except Exception as e:
  71         log.exception(e)
  72         result = {'error': True, 'data': str(e)}
  73
  74     if result['error'] == True:
  75         return __response_handler(request, result['data'], url=None,
  76                                   status=result['data']['status'] if 'status' in result['data'] else 500)
  77     else:
  78         result['data']['type'] = package_type
  79         return __response_handler(request, result, url=None, status=200)
  80
  81
  82 @login_required
  83 def delete_package(request, package_type=None, package_id=None):
  84     user = osmutils.get_user(request)
  85     project_id = user.project_id
  86     try:
  87         client = Client()
  88         if package_type == 'ns':
  89             result = client.nsd_delete(user.get_token(), package_id)
  90         elif package_type == 'vnf':
  91             result = client.vnfd_delete(user.get_token(), package_id)
  92     except Exception as e:
  93         log.exception(e)
  94         result = {'error': True, 'data': str(e)}
  95
  96     url = 'package_list.html'
  97     descriptors = {}
  98     try:
  99         if package_type == 'ns':
 100             descriptors = client.nsd_list(user.get_token())
 101         elif package_type == 'vnf':
 102             descriptors = client.vnfd_list(user.get_token())
 103     except Exception as e:
 104         log.exception(e)
 105
 106     return __response_handler(request, {
 107         'descriptors': descriptors['data'] if descriptors and descriptors['error'] is False else [],
 108         'project_id': project_id,
 109         'project_type': 'osm',
 110         'package_type': package_type,
 111         'alert_message': {
 112             'success': False if result['error'] is True else True,
 113             'message': 'An error occurred while processing your request.' if result and result['error'] is True else "Record deleted successfully"}
 114     }, url)
 115
 116 @login_required
 117 def clone_package(request, package_type=None, package_id=None):
 118     user = osmutils.get_user(request)
 119     try:
 120         client = Client()
 121         if package_type == 'ns':
 122             result = client.nsd_clone(user.get_token(), package_id)
 123         elif package_type == 'vnf':
 124             result = client.vnfd_clone(user.get_token(), package_id)
 125         else:
 126             log.debug('Update descriptor: Unknown data type')
 127             result = {'error': True, 'data': 'Update descriptor: Unknown data type'}
 128     except Exception as e:
 129         log.exception(e)
 130         result = {'error': True, 'data': str(e)}
 131     if result['error'] == True:
 132         return __response_handler(request, result['data'], url=None,
 133                                   status=result['data']['status'] if 'status' in result['data'] else 500)
 134     else:
 135         return __response_handler(request, {}, url=None, status=200)
 136
 137 @login_required
 138 def download_pkg(request, package_id, package_type):
 139     user = osmutils.get_user(request)
 140     file_name = "osm_export.tar.gz"
 141     tar_pkg = None
 142     try:
 143         client = Client()
 144         if package_type == 'ns':
 145             tar_pkg = client.get_nsd_pkg(user.get_token(), package_id)
 146         elif package_type == 'vnf':
 147             tar_pkg = client.get_vnfd_pkg(user.get_token(), package_id)
 148
 149     except Exception as e:
 150         log.exception(e)
 151
 152     response = HttpResponse(content_type="application/tgz")
 153     response["Content-Disposition"] = "attachment; filename="+ file_name
 154     response.write(tar_pkg.getvalue())
 155     return response
 156
 157 @login_required
 158 def onboard_package(request, package_type=None):
 159     user = osmutils.get_user(request)
 160     if request.method == 'POST':
 161         data_type = request.POST.get('type')
 162         if data_type == "file":
 163             file_uploaded = request.FILES['file']
 164
 165             try:
 166                 client = Client()
 167                 if package_type == 'ns':
 168                     result = client.nsd_onboard(user.get_token(), file_uploaded)
 169                 elif package_type == 'vnf':
 170                     result = client.vnfd_onboard(user.get_token(), file_uploaded)
 171                 else:
 172                     log.debug('Create descriptor: Unknown data type')
 173                     result = {'error': True, 'data': 'Create descriptor: Unknown data type'}
 174
 175             except Exception as e:
 176                 log.exception(e)
 177                 result = {'error': True, 'data': str(e)}
 178         else:
 179             result = {'error': True, 'data': 'Create descriptor: Unknown data type'}
 180
 181         if result['error']:
 182             return __response_handler(request, result['data'], url=None, status=result['data']['status'] if 'status' in result['data'] else 500)
 183         else:
 184             return __response_handler(request, {}, url=None, status=200)
 185
 186 @login_required
 187 def get_package_files_list(request, package_id, package_type):
 188     user = osmutils.get_user(request)
 189     try:
 190         client = Client()
 191         if package_type == 'ns':
 192             artifacts_res = client.nsd_artifacts(user.get_token(), package_id)
 193         elif package_type == 'vnf':
 194             artifacts_res = client.vnf_packages_artifacts(user.get_token(), package_id)
 195         else:
 196             return False
 197
 198         files_list = yaml.load(artifacts_res['data'] if artifacts_res and artifacts_res['error'] is False else [])
 199         result = {'files': files_list}
 200     except Exception as e:
 201         log.exception(e)
 202         result = {'error_msg': 'Unknown error.'}
 203     return __response_handler(request, result)
 204
 205 @login_required
 206 def custom_action(request, package_id=None, package_type=None, action_name=None):
 207     if request.method == 'GET':
 208         return globals()[action_name](request, package_id, package_type)
 209
 210 def __response_handler(request, data_res, url=None, to_redirect=None, *args, **kwargs):
 211     raw_content_types = request.META.get('HTTP_ACCEPT', '*/*').split(',')
 212     if 'application/json' in raw_content_types or url is None:
 213         return HttpResponse(json.dumps(data_res), content_type="application/json", *args, **kwargs)
 214     elif to_redirect:
 215         return redirect(url, *args, **kwargs)
 216     else:
 217         return render(request, url, data_res)