projecthandler/views.py

   1 #
   2 #   Copyright 2017 CNIT - Consorzio Nazionale Interuniversitario per le Telecomunicazioni
   3 #
   4 #   Licensed under the Apache License, Version 2.0 (the "License");
   5 #   you may not use this file except in compliance with the License.
   6 #   You may obtain a copy of the License at
   7 #
   8 #       http://www.apache.org/licenses/LICENSE-2.0
   9 #
  10 #   Unless required by applicable law or agreed to in writing, software
  11 #   distributed under the License is distributed on an  BASIS,
  12 #   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13 #   See the License for the specific language governing permissions and
  14 #   limitations under the License.
  15 #
  16
  17 import json
  18 import logging
  19
  20 import yaml
  21 from django.contrib.auth.decorators import login_required
  22 from django.http import HttpResponse, JsonResponse
  23 from django.middleware.csrf import get_token
  24 from django.shortcuts import render, redirect
  25 from lib.util import Util
  26 from projecthandler.osm_model import OsmProject
  27 from lib.osm.osmclient.clientv2 import Client
  28
  29
  30 logging.basicConfig(level=logging.DEBUG)
  31 log = logging.getLogger('projecthandler/view.py')
  32
  33
  34 @login_required
  35 def home(request):
  36     return render(request, 'home.html', {})
  37
  38
  39 @login_required
  40 def create_new_project(request):
  41     return render(request, 'home.html', {})
  42
  43
  44 @login_required
  45 def user_projects(request):
  46     csrf_token_value = get_token(request)
  47     user = request.user
  48     projects = user.get_projects()
  49
  50     return render(request, 'projectlist.html', {
  51         'projects': list(projects),
  52         'csrf_token': csrf_token_value
  53     })
  54
  55
  56 @login_required
  57 def open_project(request, project_id=None):
  58     try:
  59         user = request.user
  60         client = Client()
  61         ##TODO change with adhoc api call
  62         nsd = client.nsd_list(request.session['token'])
  63         vnfd = client.vnfd_list(request.session['token'])
  64         ns = client.ns_list(request.session['token'])
  65         vnf = client.vnf_list(request.session['token'])
  66         project_overview = {
  67             'owner': user.username,
  68             'name': project_id,
  69             'updated_date': '-',
  70             'created_date': '-',
  71             'info': '-',
  72             'type': 'osm',
  73             'nsd': len(nsd['data']) if nsd and nsd['error'] is False else 0,
  74             'vnfd': len(vnfd['data']) if vnfd and vnfd['error'] is False else 0,
  75             'ns': len(ns['data']) if ns and ns['error'] is False else 0,
  76             'vnf': len(vnf['data']) if vnf and vnf['error'] is False else 0,
  77         }
  78         return render(request, 'osm/osm_project_details.html',
  79                       {'project_overview': project_overview, 'project_id': project_id})
  80
  81     except Exception as e:
  82         print e
  83         return render(request, 'error.html', {'error_msg': 'Error open project! Please retry.'})
  84
  85
  86 @login_required
  87 def delete_project(request, project_id=None):
  88     if request.method == 'POST':
  89
  90         try:
  91             ##TODO delete project
  92             return redirect('projects:projects_list')
  93         except Exception as e:
  94             print e
  95             return render(request, 'error.html', {'error_msg': 'Error deleting Project.'})
  96
  97     elif request.method == 'GET':
  98         try:
  99             return render(request, 'osm/osm_project_delete.html',
 100                           {'project_id': project_id, 'project_name': project_id})
 101
 102         except Exception as e:
 103             print e
 104             return render(request, 'error.html', {'error_msg': 'Project not found.'})
 105
 106
 107 @login_required
 108 def show_descriptors(request, project_id=None, descriptor_type=None):
 109     client = Client()
 110     print request.GET.dict()
 111     try:
 112         if descriptor_type == 'nsd':
 113             descriptors = client.nsd_list(request.session['token'])
 114         elif descriptor_type == 'vnfd':
 115             descriptors = client.vnfd_list(request.session['token'])
 116     except Exception as e:
 117         log.exception(e)
 118         descriptors = []
 119
 120     url = 'osm/osm_project_descriptors.html'
 121     return __response_handler(request, {
 122         'descriptors': descriptors['data'] if descriptors and descriptors['error'] is False else [],
 123         'project_id': project_id,
 124         'project_type': 'osm',
 125         'descriptor_type': descriptor_type
 126     },url)
 127
 128
 129 @login_required
 130 def delete_descriptor(request, project_id=None, descriptor_type=None, descriptor_id=None):
 131
 132     try:
 133         client = Client()
 134         if descriptor_type == 'nsd':
 135             result = client.nsd_delete(request.session['token'], descriptor_id)
 136         elif descriptor_type == 'vnfd':
 137             result = client.vnfd_delete(request.session['token'], descriptor_id)
 138     except Exception as e:
 139         log.exception(e)
 140         result = {'error': True, 'data': str(e)}
 141
 142     url = 'osm/osm_project_descriptors.html'
 143     descriptors = {}
 144     try:
 145         if descriptor_type == 'nsd':
 146             descriptors = client.nsd_list(request.session['token'])
 147         elif descriptor_type == 'vnfd':
 148             descriptors = client.vnfd_list(request.session['token'])
 149     except Exception as e:
 150         log.exception(e)
 151
 152     return __response_handler(request, {
 153         'descriptors': descriptors['data'] if descriptors and descriptors['error'] is False else [],
 154         'project_id': project_id,
 155         'project_type': 'osm',
 156         'descriptor_type': descriptor_type,
 157         'alert_message': {
 158             'success': False if result['error'] is True else True,
 159             'message': 'An error occurred while processing your request.' if result and result['error'] is True else "Record deleted successfully"}
 160     }, url)
 161
 162
 163
 164 @login_required
 165 def new_descriptor(request, project_id=None, descriptor_type=None):
 166
 167     page = 'osm/descriptor/descriptor_new.html'
 168     if request.method == 'GET':
 169         request_id = request.GET.get('id', '')
 170
 171         return __response_handler(request,  {
 172             'project_id': project_id,
 173             'descriptor_type': descriptor_type,
 174             'descriptor_id': request_id,
 175         }, page)
 176     elif request.method == 'POST':
 177         data_type = request.POST.get('type')
 178         print "TYPE", data_type
 179         if data_type == "file":
 180             file_uploaded = request.FILES['file']
 181
 182             try:
 183                 client = Client()
 184                 if descriptor_type == 'nsd':
 185                     result = client.nsd_onboard(request.session['token'], file_uploaded)
 186                 elif descriptor_type == 'vnfd':
 187                     result = client.vnfd_onboard(request.session['token'], file_uploaded)
 188                 else:
 189                     log.debug('Create descriptor: Unknown data type')
 190                     result = {'error': True, 'data': 'Create descriptor: Unknown data type'}
 191
 192             except Exception as e:
 193                 log.exception(e)
 194                 result = {'error': True, 'data': str(e)}
 195         else:
 196             result = {'error': True, 'data': 'Create descriptor: Unknown data type'}
 197
 198         if result['error']:
 199             print result
 200             return __response_handler(request, result['data'], url=None, status=result['data']['status'] if 'status' in result['data'] else 500)
 201
 202         else:
 203             return __response_handler(request, {}, url=None, status=200)
 204
 205
 206 @login_required
 207 def edit_descriptor(request, project_id=None, descriptor_id=None, descriptor_type=None):
 208     if request.method == 'POST':
 209         print "edit_descriptor"
 210         new_data = request.POST.get('text'),
 211         data_type = request.POST.get('type')
 212         #print new_data
 213         try:
 214             client = Client()
 215             if descriptor_type == 'nsd':
 216                 if data_type == 'yaml':
 217                     new_data = yaml.load(request.POST.get('text'))
 218                 elif data_type == 'json':
 219                     new_data = json.loads(request.POST.get('text'))
 220                 print new_data
 221                 result = client.nsd_update(request.session['token'], descriptor_id, new_data)
 222             elif descriptor_type == 'vnfd':
 223                 if data_type == 'yaml':
 224                     new_data = yaml.load(request.POST.get('text'))
 225                 elif data_type == 'json':
 226                     new_data = json.loads(request.POST.get('text'))
 227                 print new_data
 228                 result = client.vnfd_update(request.session['token'], descriptor_id, new_data)
 229
 230             else:
 231                 log.debug('Update descriptor: Unknown data type')
 232                 result = {'error': True, 'data': 'Update descriptor: Unknown data type'}
 233         except Exception as e:
 234             log.exception(e)
 235             result = {'error': True, 'data': str(e)}
 236         print result
 237         if result['error'] == True:
 238             return __response_handler(request, result['data'], url=None, status=result['data']['status'] if 'status' in result['data'] else 500)
 239
 240         else:
 241             return __response_handler(request, {}, url=None, status=200)
 242
 243     elif request.method == 'GET':
 244
 245         page = 'osm/descriptor/descriptor_view.html'
 246         try:
 247             client = Client()
 248             if descriptor_type == 'nsd':
 249                 result = client.nsd_get(request.session['token'], descriptor_id)
 250                 print result
 251             elif descriptor_type == 'vnfd':
 252                 result = client.vnfd_get(request.session['token'], descriptor_id)
 253
 254                 print result
 255         except Exception as e:
 256             log.exception(e)
 257             result = {'error': True, 'data': str(e)}
 258
 259         if isinstance(result, dict) and 'error' in result and result['error']:
 260             return render(request, 'error.html')
 261
 262         descriptor_string_json = json.dumps(result, indent=2)
 263         descriptor_string_yaml = Util.json2yaml(result)
 264         # print descriptor
 265         return render(request, page, {
 266             'project_id': project_id,
 267             'descriptor_id': descriptor_id,
 268             'descriptor_type': descriptor_type,
 269             'descriptor_strings': {'descriptor_string_yaml': descriptor_string_yaml,
 270                                    'descriptor_string_json': descriptor_string_json}})
 271
 272
 273 @login_required
 274 def get_package_files_list(request, project_id, descriptor_id, descriptor_type):
 275     files_list = []
 276     try:
 277         client = Client()
 278         if descriptor_type == 'nsd':
 279             artifacts_res = client.nsd_artifacts(request.session['token'], descriptor_id)
 280         elif descriptor_type == 'vnfd':
 281             artifacts_res = client.vnf_packages_artifacts(request.session['token'], descriptor_id)
 282         else:
 283             return False
 284
 285         files_list = yaml.load(artifacts_res['data'] if artifacts_res and artifacts_res['error'] is False else [])
 286         result = {'files': files_list}
 287     except Exception as e:
 288         log.exception(e)
 289         url = 'error.html'
 290         result = {'error_msg': 'Unknown error.'}
 291     return __response_handler(request, result)
 292
 293 @login_required
 294 def download_pkg(request, project_id, descriptor_id, descriptor_type):
 295     file_name = "osm_export.tar.gz"
 296     tar_pkg = None
 297     try:
 298         client = Client()
 299         if descriptor_type == 'nsd':
 300             tar_pkg = client.get_nsd_pkg(request.session['token'], descriptor_id)
 301         elif descriptor_type == 'vnfd':
 302             tar_pkg = client.get_vnfd_pkg(request.session['token'], descriptor_id)
 303
 304     except Exception as e:
 305         log.exception(e)
 306
 307     response = HttpResponse(content_type="application/tgz")
 308     response["Content-Disposition"] = "attachment; filename="+ file_name
 309     response.write(tar_pkg.getvalue())
 310     return response
 311
 312
 313 @login_required
 314 def custom_action(request, project_id=None, descriptor_id=None, descriptor_type=None, action_name=None):
 315     if request.method == 'GET':
 316         print "Custom action: " + action_name
 317         return globals()[action_name](request, project_id, descriptor_id, descriptor_type)
 318
 319
 320 def __response_handler(request, data_res, url=None, to_redirect=None, *args, **kwargs):
 321     raw_content_types = request.META.get('HTTP_ACCEPT', '*/*').split(',')
 322     if 'application/json' in raw_content_types or url is None:
 323         return HttpResponse(json.dumps(data_res), content_type="application/json", *args, **kwargs)
 324     elif to_redirect:
 325         return redirect(url, *args, **kwargs)
 326     else:
 327         return render(request, url, data_res)