-#-*- coding: utf-8 -*-
+# -*- coding: utf-8 -*-
+#
+# portal/views.py: views for the portal application
+# This file is part of the Manifold project.
+#
+# Authors:
+# Jordan Augé <jordan.auge@lip6.fr>
+# Mohammed Yasin Rahman <mohammed-yasin.rahman@lip6.fr>
+# Copyright 2013, UPMC Sorbonne Universités / LIP6
+#
+# This program is free software; you can redistribute it and/or modify it under
+# the terms of the GNU General Public License as published by the Free Software
+# Foundation; either version 3, or (at your option) any later version.
+#
+# This program is distributed in the hope that it will be useful, but WITHOUT
+# ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
+# FOR A PARTICULAR PURPOSE. See the GNU General Public License for more
+# details.
+#
+# You should have received a copy of the GNU General Public License along with
+# this program; see the file COPYING. If not, write to the Free Software
+# Foundation, 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
-from portal.portalpage import PortalPage
-from plugins.wizard import Wizard
-from plugins.form import CreateForm
-from plugins.raw.raw import Raw # XXX
+import json
-from myslice.viewutils import the_user
+from django.http import HttpResponseRedirect, HttpResponse
+from django.views.generic.base import TemplateView
+from django.shortcuts import render
+from django.template.loader import render_to_string
-from django.template.loader import render_to_string
-from django.template import RequestContext
-from django.views import generic
-from django.shortcuts import render
+from myslice.viewutils import topmenu_items, the_user
-from portal.forms import RegisterUserForm
+from plugins.pres_view import PresView
+from portal.event import Event
-from django.contrib.formtools.wizard.views import NamedUrlSessionWizardView
-#from django.core.files.storage import FileSystemStorage
-from django.core.files.storage import default_storage
+# these seem totally unused for now
+#from portal.util import RegistrationView, ActivationView
-#class MerlinWizard(NamedUrlSessionWizardView):
-#
-# ...
-# ...
-#
-# @classonlymethod
-# def as_view(cls, *args, **kwargs):
-# kwargs.update({
-# 'form_list': [
-# NameForm,
-# QuestForm,
-# ColorForm,
-# ],
-# 'url_name': 'merlin_wizard'
-# })
-# return super(MerlinWizard, cls).as_view(*args, **kwargs)
-
-class RegisterUserWizardView(NamedUrlSessionWizardView):
-#class RegisterUserWizardView(LoginRequiredMixin, NamedUrlSessionWizardView):
- # Notice that I specify a file storage instance. If you don't specify this,
- # and you need to support FileField or ImageField in your forms, you'll get
- # errors from Django. This is something else I think could be handled by
- # the views better. Seems to me that it should just use whatever the
- # default/specified storage is for the rest of your project/application.
- file_storage = default_storage # FileSystemStorage()
- template_name = "register_user_wizard.html"
-
- def done(self, form_list, **kwargs):
- step1_form = form_list[0]
- step2_form = form_list[1]
-
- productext = self.create_product(product_form)
- shippings = self.create_shippings(productext, shipping_forms)
- images = self.create_images(productext, image_forms)
-
- if all([productext, shippings, images]):
- del self.request.session["wizard_product_wizard_view"]
-
- messages.success(self.request,
- _("Your product has been created."))
- return HttpResponseRedirect(self.get_success_url(productext))
-
- messages.error(self.request, _("Something went wrong creating your "
- "product. Please try again or contact support."))
- return HttpResponseRedirect(reverse("register_wizard"))
-
- #def get_form_kwargs(self, step):
- # if step == "product":
- # return {"user": self.request.user}
- # return {}
-
-# The portal should hook the slice and user creation pages
-
-def register_user(request):
-
- if request.method == 'POST':
- form = RegisterUserForm(request.POST) # Nous reprenons les données
- if form.is_valid():
- first_name = form.cleaned_data['first_name']
- last_name = form.cleaned_data['last_name']
- email = form.cleaned_data['email']
- password = form.cleaned_data['password']
- password2 = form.cleaned_data['password2']
- keypair = form.cleaned_data['keypair']
- ## Ici nous pouvons traiter les données du formulaire
- #sujet = form.cleaned_data['sujet']
- #message = form.cleaned_data['message']
- #envoyeur = form.cleaned_data['envoyeur']
- #renvoi = form.cleaned_data['renvoi']
- ## Nous pourrions ici envoyer l'e-mail grâce aux données que nous venons de récupérer
- #envoi = True
- else:
- form = RegisterUserForm()
- return render(request, 'register_user.html', locals())
-
-def index(request):
-
- WIZARD_TITLE = 'User registration'
- STEP1_TITLE = 'Enter your details'
- STEP2_TITLE = 'Select your institution'
- STEP3_TITLE = 'Authentication'
- STEP4_TITLE = 'Request a slice (optional)'
- STEP5_TITLE = 'Waiting for validation'
- STEP6_TITLE = 'Account validated'
-
- STEP0 = render_to_string('account_validated.html', context_instance=RequestContext(request))
- STEP2_HTML = """
- coucou
- """
- STEP4 = """
- mede
- """
- STEP5 = render_to_string('account_validated.html', context_instance=RequestContext(request))
-
- p = PortalPage(request)
-
- # This is redundant with the Wizard title
- p << "<h3>User registration</h3>"
-
- sons = []
- start_step = 1
-
- # STEP 1
- # If the user already exists (is logged), let's display a summary of his account details
- # Otherwise propose a form to fill in
- if the_user(request):
- # Fill a disabled form with user info
- # Please logout to register another user
- sons.append(Raw(page=p, title=STEP1_TITLE, togglable=False, html=STEP0))
- start_step += 1
- else:
- # We could pass a list of fields also, instead of retrieving them from metadata
- # Otherwise we need some heuristics to display nice forms
- # XXX Could we log the user in after the form is validated ?
- # XXX Explain the password is for XXX
- field_list = [{
- 'name' : 'First name',
- 'field' : 'firstname',
- 'type' : 'text',
- 'validate_rx' : '^[a-zA-Z -]+$',
- 'validate_err': 'Your first name must be comprised of letters only',
- 'description' : 'Enter your first name',
- }, {
- 'name' : 'Last name',
- 'field' : 'lastname',
- 'type' : 'text',
- 'validate_rx' : '^[a-zA-Z -]+$',
- 'validate_err': 'Your last name must be comprised of letters only',
- 'description' : 'Enter your last name',
- }, {
- 'name' : 'Email',
- 'field' : 'email',
- 'type' : 'text',
- 'description' : 'Enter your email address',
- }, {
- 'name' : 'Password',
- 'field' : 'password',
- 'type' : 'password',
- 'description' : 'Enter your password',
- }, {
- 'name' : 'Confirm password',
- 'field' : 'password2',
- 'type' : 'password',
- 'description' : 'Enter your password again',
- }]
- sons.append(CreateForm(page = p, title = STEP1_TITLE, togglable = False, object = 'local:user', fields = field_list))
-
- # STEP 2
- # If the user already exists (is logged), let's display a summary of its institution
- # Otherwise propose a form to fill in (we should base our selection on the email)
- if the_user(request):
- # Fill a disabled form with institution
- # Please logout to register another user
- sons.append(Raw(page=p, title=STEP2_TITLE, togglable=False, html="User created"))
- start_step += 1
+from portal.models import PendingUser, PendingSlice
+from portal.actions import get_request_by_authority
+from manifold.manifoldapi import execute_query
+from manifold.core.query import Query
+from unfold.page import Page
+
+# NOTE
+# initially all the portal views were defined in this single file
+# all the other ones have now migrated into separate classes/files for more convenience
+# I'm leaving these ones here for now as I could not exactly figure what the purpose was
+# (i.e. what the correct name should be, as presviewview was a bit cryptic)
+class PresViewView(TemplateView):
+ template_name = "view-unfold1.html"
+
+ def get_context_data(self, **kwargs):
+
+ page = Page(self.request)
+
+ pres_view = PresView(page = page)
+
+ context = super(PresViewView, self).get_context_data(**kwargs)
+
+ #context['ALL_STATIC'] = "all_static"
+ context['unfold1_main'] = pres_view.render(self.request)
+
+ # XXX This is repeated in all pages
+ # more general variables expected in the template
+ context['title'] = 'Test view that combines various plugins'
+ # the menu items on the top
+ context['topmenu_items'] = topmenu_items('PresView', self.request)
+ # so we can sho who is logged
+ context['username'] = the_user(self.request)
+
+ prelude_env = page.prelude_env()
+ context.update(prelude_env)
+
+ return context
+
+def json_me(config_file,type):
+ json_answer = ''
+ for ligne in config_file:
+ if not ligne.startswith('#'):
+ args = ligne.split(';')
+ json_answer += str('{ "name": "' + args[0] + '" ,"id":"' + args[1] + '" ,"descriptif":"' + args[2]+'"')
+ if type!="dynamic":
+ json_answer += str(',"contraints":')
+ if args[3]=="":
+ json_answer += str('""')
+ else:
+ json_answer += str(args[3])
+ json_answer += str('},')
+ return json_answer[:-1]
+
+
+DIR = '/var/myslice/'
+STATIC = '%s/config_method_static' % DIR
+DYNAMIC = '%s/config_method_dynamic' % DIR
+ANIMATION = '%s/config_method_animation' % DIR
+
+def pres_view_methods(request, type):
+
+ if type ==None:
+ return 0
+ elif type =="static":
+ config = open(STATIC, "r")
+ json_answer = str('{ "options": [')
+ json_answer += str(json_me(config,"static"))
+ json_answer += str('] }')
+ config.close()
+ elif type =="dynamic":
+ config = open(DYNAMIC, "r")
+ json_answer = str('{ "options": [')
+ json_answer += str(json_me(config,"dynamic"))
+ json_answer += str('] }')
+ config.close()
+ elif type =="animation":
+ config = open(ANIMATION, "r")
+ json_answer = str('{ "options": [')
+ json_answer += str(json_me(config,"animation"))
+ json_answer += str('] }')
+ config.close()
+ elif type =="all":
+ config = open(STATIC, "r")
+ json_answer = str('{ "static": [')
+ json_answer += str(json_me(config,"static"))
+ json_answer += str('],')
+ json_answer += str('"dynamic": [')
+ config.close()
+ config = open(DYNAMIC, "r")
+ json_answer += str(json_me(config,"dynamic"))
+ json_answer += str('],')
+ json_answer += str('"animation": [')
+ config.close()
+ config = open(ANIMATION, "r")
+ json_answer += str(json_me(config,"animation"))
+ json_answer += str('] }')
+ config.close()
else:
- sons.append(CreateForm(page = p, title = STEP2_TITLE, togglable = False, object = 'slice')) #institution'))
-
- # STEP3
- # Please should your prefered authentication method
- # This step should allow the user to either choose the user or managed mode in MySlice
- sons.append(Raw(page = p, title = STEP3_TITLE, togglable = False, html = STEP2_HTML))
-
- # Step 4: Request a slice (optional)
- sons.append(CreateForm(page = p, title = STEP4_TITLE, togglable = False, object = 'slice'))
-
- # Step 5: Your request is waiting for validation
- # Periodic refresh
- sons.append(Raw(page = p, title = STEP5_TITLE, togglable = False, html = STEP4))
-
- # Step 6: Account validation = welcome for newly validated users
- # . delegation
- # . platforms
- # . slice
- # . pointers
- sons.append(Raw(page = p, title = STEP6_TITLE, togglable = False, html = STEP5))
-
- wizard = Wizard(
- page = p,
- title = WIZARD_TITLE,
- togglable = False,
- sons = sons,
- start_step = start_step,
- )
-
- p << wizard.render(request) # in portal page if possible
-
- return p.render()
+ return 0
+ return HttpResponse (json_answer, mimetype="application/json")
+
+def pres_view_animation(request, constraints, id):
+
+# sites crees depuis 2008
+# static.py?contraints=']date_created':1262325600&id='name_id"'
+
+ # method = request.getvalue('method') #ex : GetSites
+ #constraints = "']date_created':1262325600"
+ #id = "2"
+
+ if id == None:
+ return 0
+
+ # method = 'GetSites'#request.getvalue('method') #ex : GetSites
+ # constraints = {}#request.getvalue('constraints') // nul = {}
+ # response_field = "'site_id','name','date_created'"#request.getvalue('response_field')
+
+ config_file = open(ANIMATION, "r")
+ for ligne in config_file:
+ if not ligne.startswith('#'):
+ ligne = ligne.split('\n')
+ first = ligne[0].split(';')
+ if (str(first[1]) == str(id)):
+ save = first
+ config_file.close()
+
+ #Les print_method, print_option sont definis par le client (js)
+ #Les animations acceptent que les connexions anonymous
+ # args = "postmsg;animation;;;anonymous;https://www.planet-lab.eu/PLCAPI/;"
+ args = ";;"+str(save[8])+";"+str(save[9])+";anonymous;"+str(save[5])+";"+str(save[6])+";{"+str(constraints)+"};"+str(save[7])+";"
+
+
+ #Creation d'un objet event
+ event = Event(args)
+ cmd = [{"params": {
+ "data": {
+ "print_options": event.print_options,
+ "print_method": event.print_method,
+ "message": event.data
+ }
+ }
+ }]
+
+ json_answer = json.dumps(cmd)
+ return HttpResponse (json_answer, mimetype="application/json")
+
+def pres_view_static(request, constraints, id):
+ #constraints = "']date_created':1262325600"
+ #id = "2"
+
+ # method = 'GetSites'#request.getvalue('method') #ex : GetSites
+ # constraints = {}#request.getvalue('constraints') // nul = {}
+ # response_field = "'site_id','name','date_created'"#request.getvalue('response_field')
+
+ config_file = open(STATIC, "r")
+ for ligne in config_file:
+ if not ligne.startswith('#'):
+ ligne = ligne.split('\n')
+ first = ligne[0].split(';')
+ if (str(first[1]) == str(id)):
+ save = first
+ config_file.close()
+
+ #Les print_method, print_option sont definis par le client (js)
+ #Les animations acceptent que les connexions anonymous
+ # args = "postmsg;animation;;;anonymous;https://www.planet-lab.eu/PLCAPI/;"
+ args = ";;"+str(save[8])+";"+str(save[9])+";anonymous;"+str(save[5])+";"+str(save[6])+";{"+str(constraints)+"};"+str(save[7])+";"
+
+
+ #Creation d'un objet event
+ event = Event(args)
+ cmd = [{"params": {
+ "data": {
+ "print_options": event.print_options,
+ "print_method": event.print_method,
+ "message": event.data
+ }
+ }
+ }]
+
+ json_answer = json.dumps(cmd)
+ return HttpResponse (json_answer, mimetype="application/json")
+
+class ValidatePendingView(TemplateView):
+ template_name = "validate_pending.html"
+
+ def get_context_data(self, **kwargs):
+ # We might have slices on different registries with different user accounts
+ # We note that this portal could be specific to a given registry, to which we register users, but i'm not sure that simplifies things
+ # Different registries mean different identities, unless we identify via SFA HRN or have associated the user email to a single hrn
+
+ #messages.info(self.request, 'You have logged in')
+ page = Page(self.request)
+
+ ctx_my_authorities = {}
+ ctx_delegation_authorities = {}
+
+
+ # The user need to be logged in
+ if the_user(self.request):
+ # Who can a PI validate:
+ # His own authorities + those he has credentials for.
+ # In MySlice we need to look at credentials also.
+
+
+ # XXX This will have to be asynchroneous. Need to implement barriers,
+ # for now it will be sufficient to have it working statically
+
+ # get user_id to later on query accounts
+ # XXX Having real query plan on local tables would simplify all this
+ # XXX $user_email is still not available for local tables
+ #user_query = Query().get('local:user').filter_by('email', '==', '$user_email').select('user_id')
+ user_query = Query().get('local:user').filter_by('email', '==', the_user(self.request)).select('user_id')
+ user, = execute_query(self.request, user_query)
+ user_id = user['user_id']
+
+ # Query manifold to learn about available SFA platforms for more information
+ # In general we will at least have the portal
+ # For now we are considering all registries
+ all_authorities = []
+ platform_ids = []
+ sfa_platforms_query = Query().get('local:platform').filter_by('gateway_type', '==', 'sfa').select('platform_id', 'platform', 'auth_type')
+ sfa_platforms = execute_query(self.request, sfa_platforms_query)
+ for sfa_platform in sfa_platforms:
+ print "SFA PLATFORM > ", sfa_platform['platform']
+ if not 'auth_type' in sfa_platform:
+ continue
+ auth = sfa_platform['auth_type']
+ if not auth in all_authorities:
+ all_authorities.append(auth)
+ platform_ids.append(sfa_platform['platform_id'])
+
+ # We can check on which the user has authoritity credentials = PI rights
+ credential_authorities = set()
+ credential_authorities_expired = set()
+
+ # User account on these registries
+ user_accounts_query = Query.get('local:account').filter_by('user_id', '==', user_id).filter_by('platform_id', 'included', platform_ids).select('config')
+ user_accounts = execute_query(self.request, user_accounts_query)
+ #print "=" * 80
+ #print user_accounts
+ #print "=" * 80
+ for user_account in user_accounts:
+ config = json.loads(user_account['config'])
+ creds = []
+ if 'authority_credentials' in config:
+ for authority_hrn, credential in config['authority_credentials'].items():
+ #if credential is not expired:
+ credential_authorities.add(authority_hrn)
+ #else
+ # credential_authorities_expired.add(authority_hrn)
+ if 'delegated_authority_credentials' in config:
+ for authority_hrn, credential in config['delegated_authority_credentials'].items():
+ #if credential is not expired:
+ credential_authorities.add(authority_hrn)
+ #else
+ # credential_authorities_expired.add(authority_hrn)
+
+ print 'credential_authorities =', credential_authorities
+ print 'credential_authorities_expired =', credential_authorities_expired
+
+ # ** Where am I a PI **
+ # For this we need to ask SFA (of all authorities) = PI function
+ pi_authorities_query = Query.get('user').filter_by('user_hrn', '==', '$user_hrn').select('pi_authorities')
+ pi_authorities_tmp = execute_query(self.request, pi_authorities_query)
+ pi_authorities = set()
+ for pa in pi_authorities_tmp:
+ pi_authorities |= set(pa['pi_authorities'])
+
+ print "pi_authorities =", pi_authorities
+
+ # My authorities + I have a credential
+ pi_credential_authorities = pi_authorities & credential_authorities
+ pi_no_credential_authorities = pi_authorities - credential_authorities - credential_authorities_expired
+ pi_expired_credential_authorities = pi_authorities & credential_authorities_expired
+ # Authorities I've been delegated PI rights
+ pi_delegation_credential_authorities = credential_authorities - pi_authorities
+ pi_delegation_expired_authorities = credential_authorities_expired - pi_authorities
+
+ print "pi_credential_authorities =", pi_credential_authorities
+ print "pi_no_credential_authorities =", pi_no_credential_authorities
+ print "pi_expired_credential_authorities =", pi_expired_credential_authorities
+ print "pi_delegation_credential_authorities = ", pi_delegation_credential_authorities
+ print "pi_delegation_expired_authorities = ", pi_delegation_expired_authorities
+
+ # Summary intermediary
+ pi_my_authorities = pi_credential_authorities | pi_no_credential_authorities | pi_expired_credential_authorities
+ pi_delegation_authorities = pi_delegation_credential_authorities | pi_delegation_expired_authorities
+
+ print "--"
+ print "pi_my_authorities = ", pi_my_authorities
+ print "pi_delegation_authorities = ", pi_delegation_authorities
+
+ # Summary all
+ queried_pending_authorities = pi_my_authorities | pi_delegation_authorities
+ print "----"
+ print "queried_pending_authorities = ", queried_pending_authorities
+
+ requests = get_request_by_authority(queried_pending_authorities)
+ for request in requests:
+ auth_hrn = request['authority_hrn']
+
+ if auth_hrn in pi_my_authorities:
+ dest = ctx_my_authorities
+
+ # define the css class
+ if auth_hrn in pi_credential_authorities:
+ request['allowed'] = 'allowed'
+ elif auth_hrn in pi_expired_credential_authorities:
+ request['allowed'] = 'expired'
+ else: # pi_no_credential_authorities
+ request['allowed'] = 'denied'
+
+ elif auth_hrn in pi_delegation_authorities:
+ dest = ctx_delegation_authorities
+
+ if auth_hrn in pi_delegation_credential_authorities:
+ request['allowed'] = 'allowed'
+ else: # pi_delegation_expired_authorities
+ request['allowed'] = 'expired'
+
+ else:
+ continue
+
+ if not auth_hrn in dest:
+ dest[auth_hrn] = []
+ dest[auth_hrn].append(request)
+
+ context = super(ValidatePendingView, self).get_context_data(**kwargs)
+ context['my_authorities'] = ctx_my_authorities
+ context['delegation_authorities'] = ctx_delegation_authorities
+
+ # XXX This is repeated in all pages
+ # more general variables expected in the template
+ context['title'] = 'Test view that combines various plugins'
+ # the menu items on the top
+ context['topmenu_items'] = topmenu_items('Dashboard', self.request)
+ # so we can sho who is logged
+ context['username'] = the_user(self.request)
+
+ # XXX We need to prepare the page for queries
+ #context.update(page.prelude_env())
+
+ return context
git://git.onelab.eu / myslice.git / blobdiff