portal/slicerequestview.py

   1 from django.shortcuts           import render
   2
   3 from unfold.page                import Page
   4
   5 from manifold.core.query        import Query
   6 from manifoldapi.manifoldapi    import execute_admin_query, execute_query
   7
   8 from portal.actions             import is_pi, create_slice, create_pending_slice
   9 from portal.forms               import SliceRequestForm
  10 from unfold.loginrequired       import LoginRequiredAutoLogoutView
  11 from ui.topmenu                 import topmenu_items_live, the_user
  12
  13 from myslice.theme import ThemeView
  14
  15 import json, time
  16
  17 class SliceRequestView (LoginRequiredAutoLogoutView, ThemeView):
  18     template_name = 'slicerequest_view.html'
  19
  20     # because we inherit LoginRequiredAutoLogoutView that is implemented by redefining 'dispatch'
  21     # we cannot redefine dispatch here, or we'd lose LoginRequired and AutoLogout behaviours
  22     def post (self, request):
  23         return self.get_or_post (request, 'POST')
  24
  25     def get (self, request):
  26         return self.get_or_post (request, 'GET')
  27
  28     def get_or_post  (self, wsgi_request, method):
  29         """
  30         """
  31         errors = []
  32
  33         # Retrieve the list of authorities
  34         authorities_query = Query.get('authority').select('name', 'authority_hrn')
  35         authorities = execute_admin_query(wsgi_request, authorities_query)
  36         if authorities is not None:
  37             authorities = sorted(authorities)
  38
  39         # Get user_hrn (XXX Would deserve to be simplified)
  40         user_query  = Query().get('local:user').select('email')
  41         user_emails = execute_query(wsgi_request, user_query)
  42         user_email = user_emails[0].get('email')
  43         #
  44         account_query  = Query().get('local:account').select('user_id','platform_id','auth_type','config')
  45         account_details = execute_query(wsgi_request, account_query)
  46         #
  47         platform_query  = Query().get('local:platform').select('platform_id','platform','gateway_type','disabled')
  48         platform_details = execute_query(wsgi_request, platform_query)
  49         user_hrn = None
  50         # getting user_hrn from local:account
  51         for account_detail in account_details:
  52             for platform_detail in platform_details:
  53                 if platform_detail['platform_id'] == account_detail['platform_id']:
  54                     # taking user_hrn only from myslice account
  55                     # NOTE: we should later handle accounts filter_by auth_type= managed OR user
  56                     if 'myslice' in platform_detail['platform']:
  57                         account_config = json.loads(account_detail['config'])
  58                         user_hrn = account_config.get('user_hrn','N/A')
  59
  60         # Page rendering
  61         page = Page(wsgi_request)
  62         page.add_css_files ( [ "http://code.jquery.com/ui/1.10.3/themes/smoothness/jquery-ui.css" ] )
  63
  64         if method == 'POST':
  65             # The form has been submitted
  66             slice_request = {
  67                 'type'              : 'slice',
  68                 'id'                : None,
  69                 'user_hrn'          : user_hrn,
  70                 'timestamp'         : time.time(),
  71                 'authority_hrn'     : wsgi_request.POST.get('authority_hrn', ''),
  72                 'slice_name'        : wsgi_request.POST.get('slice_name', ''),
  73                 'number_of_nodes'   : wsgi_request.POST.get('number_of_nodes', ''),
  74                 'type_of_nodes'     : wsgi_request.POST.get('type_of_nodes', ''),
  75                 'purpose'           : wsgi_request.POST.get('purpose', ''),
  76             }
  77
  78             authority_hrn = slice_request['authority_hrn']
  79             if (authority_hrn is None or authority_hrn == ''):
  80                 errors.append('Please, select an authority')
  81
  82             # What kind of slice name is valid?
  83             slice_name = slice_request['slice_name']
  84             if (slice_name is None or slice_name == ''):
  85                 errors.append('Slice Name is mandatory')
  86
  87             purpose = slice_request['purpose']
  88             if (purpose is None or purpose == ''):
  89                 errors.append('Purpose is mandatory')
  90
  91             if not errors:
  92                 if is_pi(wsgi_request, user_hrn, authority_hrn):
  93                     # PIs can directly create slices in their own authority...
  94                     create_slice(wsgi_request, slice_request)
  95                     self.template_name = 'slice-request-done-view.html'
  96                 else:
  97                     # Otherwise a wsgi_request is sent to the PI
  98                     create_pending_slice(wsgi_request, slice_request, user_email)
  99                     self.template_name = 'slice-request-ack-view.html'
 100
 101                 return render(wsgi_request, self.template, {'theme': self.theme}) # Redirect after POST
 102         else:
 103             slice_request = {}
 104
 105         template_env = {
 106             'username': wsgi_request.user.email,
 107             'topmenu_items': topmenu_items_live('Request a slice', page),
 108             'errors': errors,
 109             'email': user_email,
 110             'user_hrn': user_hrn,
 111             'cc_myself': True,
 112             'authorities': authorities,
 113             'theme': self.theme
 114         }
 115         template_env.update(slice_request)
 116         template_env.update(page.prelude_env())
 117         return render(wsgi_request, self.template, template_env)