X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=portal%2Fviews.py;h=d454502e417c2e8a92076086300a2af5589b241d;hb=74a25f8b8d58726e9bda273a2fde04da83d5d913;hp=27455f2e4158e09d9e9af98d0621ea92d8db9226;hpb=d9fa97447cdfd1fc896d840f7b3bebbb3d2bd921;p=myslice.git
diff --git a/portal/views.py b/portal/views.py
index 27455f2e..d454502e 100644
--- a/portal/views.py
+++ b/portal/views.py
@@ -21,534 +21,383 @@
# 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 django.conf import settings
-from django.contrib.sites.models import Site, RequestSite
-from django.contrib import messages
-from django.views.generic import View
-from django.views.generic.base import TemplateView
-from django.shortcuts import render
-from plugins.lists.simplelist import SimpleList
-from portal import signals
-from portal.forms import UserRegisterForm, SliceRequestForm, ContactForm
-from portal.util import RegistrationView, ActivationView
-from portal.models import PendingUser, PendingSlice
-from manifold.core.query import Query
-from unfold.page import Page
-from myslice.viewutils import topmenu_items, the_user
-from django.http import HttpResponseRedirect
-
-class DashboardView(TemplateView):
- template_name = "dashboard.html"
+import json
- def get_context_data(self, **kwargs):
- user_hrn = 'ple.upmc.jordan_auge'
-
- #messages.info(self.request, 'You have logged in')
- page = Page(self.request)
-
- # Slow...
- #slice_query = Query().get('slice').filter_by('user.user_hrn', 'contains', user_hrn).select('slice_hrn')
- slice_query = Query().get('user').filter_by('user_hrn', '==', user_hrn).select('user_hrn', 'slice.slice_hrn')
- auth_query = Query().get('network').select('network_hrn')
- page.enqueue_query(slice_query)
- page.enqueue_query(auth_query)
-
- page.expose_queries()
-
- slicelist = SimpleList(
- title = None,
- page = page,
- key = 'slice.slice_hrn',
- query = slice_query,
- )
-
- authlist = SimpleList(
- title = None,
- page = page,
- key = 'network_hrn',
- query = auth_query,
- )
-
- context = super(DashboardView, self).get_context_data(**kwargs)
- context['person'] = self.request.user
- context['networks'] = authlist.render(self.request)
- context['slices'] = slicelist.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('Dashboard', self.request)
- # so we can sho who is logged
- context['username'] = the_user(self.request)
+from django.http import HttpResponseRedirect, HttpResponse
+from django.shortcuts import render
+from django.template.loader import render_to_string
- context.update(page.prelude_env())
+from unfold.loginrequired import FreeAccessView
+from ui.topmenu import topmenu_items, the_user
- return context
+from portal.event import Event
+# presview is put in observation for now
+#from plugins.pres_view import PresView
+from plugins.raw import Raw
-class UserRegisterView(RegistrationView):
- """
- A registration backend which follows a simple workflow:
-
- 1. User signs up, inactive account is created.
-
- 2. Email is sent to user with activation link.
-
- 3. User clicks activation link, account is now active.
-
- Using this backend requires that
-
- * ``registration`` be listed in the ``INSTALLED_APPS`` setting
- (since this backend makes use of models defined in this
- application).
-
- * The setting ``ACCOUNT_ACTIVATION_DAYS`` be supplied, specifying
- (as an integer) the number of days from registration during
- which a user may activate their account (after that period
- expires, activation will be disallowed).
-
- * The creation of the templates
- ``registration/activation_email_subject.txt`` and
- ``registration/activation_email.txt``, which will be used for
- the activation email. See the notes for this backends
- ``register`` method for details regarding these templates.
-
- Additionally, registration can be temporarily closed by adding the
- setting ``REGISTRATION_OPEN`` and setting it to
- ``False``. Omitting this setting, or setting it to ``True``, will
- be interpreted as meaning that registration is currently open and
- permitted.
-
- Internally, this is accomplished via storing an activation key in
- an instance of ``registration.models.RegistrationProfile``. See
- that model and its custom manager for full documentation of its
- fields and supported operations.
-
- """
- form_class = UserRegisterForm
-
- def register(self, request, **cleaned_data):
- """
- Given a username, email address and password, register a new
- user account, which will initially be inactive.
-
- Along with the new ``User`` object, a new
- ``registration.models.RegistrationProfile`` will be created,
- tied to that ``User``, containing the activation key which
- will be used for this account.
-
- An email will be sent to the supplied email address; this
- email should contain an activation link. The email will be
- rendered using two templates. See the documentation for
- ``RegistrationProfile.send_activation_email()`` for
- information about these templates and the contexts provided to
- them.
-
- After the ``User`` and ``RegistrationProfile`` are created and
- the activation email is sent, the signal
- ``registration.signals.user_registered`` will be sent, with
- the new ``User`` as the keyword argument ``user`` and the
- class of this backend as the sender.
-
- """
- first_name = cleaned_data['first_name']
- last_name = cleaned_data['last_name']
- affiliation= cleaned_data['affiliation']
- email = cleaned_data['email']
- password = cleaned_data['password1']
-
- #password2 = cleaned_data['password2']
- keypair = cleaned_data['keypair']
+# these seem totally unused for now
+#from portal.util import RegistrationView, ActivationView
- #if Site._meta.installed:
- # site = Site.objects.get_current()
- #else:
- # site = RequestSite(request)
- site = None
+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
- new_user = PendingUser.objects.create_inactive_user(first_name, last_name, email, password, site)
- signals.user_registered.send(sender=self.__class__,
- user=new_user,
- request=request)
- return new_user
+# 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(FreeAccessView):
+ template_name = "view-unfold1.html"
def get_context_data(self, **kwargs):
- context = super(UserRegisterView, self).get_context_data(**kwargs)
- context['topmenu_items'] = topmenu_items('Register', self.request)
- context['username'] = the_user (self.request)
- return context
- def registration_allowed(self, request):
- """
- Indicate whether account registration is currently permitted,
- based on the value of the setting ``REGISTRATION_OPEN``. This
- is determined as follows:
+ page = Page(self.request)
- * If ``REGISTRATION_OPEN`` is not specified in settings, or is
- set to ``True``, registration is permitted.
+# pres_view = PresView(page = page)
+ pres_view = Raw(page = page,html="
PresView needs to be integrated
")
- * If ``REGISTRATION_OPEN`` is both specified and set to
- ``False``, registration is not permitted.
-
- """
- return getattr(settings, 'REGISTRATION_OPEN', True)
+ context = super(PresViewView, self).get_context_data(**kwargs)
- def get_success_url(self, request, user):
- """
- Return the name of the URL to redirect to after successful
- user registration.
-
- """
- return ('user_register_complete', (), {})
+ #context['ALL_STATIC'] = "all_static"
+ context['unfold_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)
-class UserValidateView(ActivationView):
- def activate(self, request, activation_key):
- """
- Given an an activation key, look up and activate the user
- account corresponding to that key (if possible).
+ return context
- After successful activation, the signal
- ``registration.signals.user_activated`` will be sent, with the
- newly activated ``User`` as the keyword argument ``user`` and
- the class of this backend as the sender.
-
- """
- activated_user = RegistrationProfile.objects.activate_user(activation_key)
- if activated_user:
- signals.user_activated.send(sender=self.__class__,
- user=activated_user,
- request=request)
- return activated_user
-
- def get_success_url(self, request, user):
- return ('registration_activation_complete', (), {})
-
-
-# DEPRECATED #from portal.portalpage import PortalPage
-# DEPRECATED #from plugins.wizard import Wizard
-# DEPRECATED #from plugins.form import CreateForm
-# DEPRECATED #from plugins.raw.raw import Raw # XXX
-# DEPRECATED #
-# DEPRECATED #from myslice.viewutils import the_user
-# DEPRECATED #
-# DEPRECATED #from django.template.loader import render_to_string
-# DEPRECATED #from django.template import RequestContext
-# DEPRECATED #from django.views import generic
-# DEPRECATED #
-# DEPRECATED #from django.contrib.formtools.wizard.views import NamedUrlSessionWizardView
-# DEPRECATED ##from django.core.files.storage import FileSystemStorage
-# DEPRECATED #from django.core.files.storage import default_storage
-# DEPRECATED #
-# DEPRECATED ##class MerlinWizard(NamedUrlSessionWizardView):
-# DEPRECATED ##
-# DEPRECATED ## ...
-# DEPRECATED ## ...
-# DEPRECATED ##
-# DEPRECATED ## @classonlymethod
-# DEPRECATED ## def as_view(cls, *args, **kwargs):
-# DEPRECATED ## kwargs.update({
-# DEPRECATED ## 'form_list': [
-# DEPRECATED ## NameForm,
-# DEPRECATED ## QuestForm,
-# DEPRECATED ## ColorForm,
-# DEPRECATED ## ],
-# DEPRECATED ## 'url_name': 'merlin_wizard'
-# DEPRECATED ## })
-# DEPRECATED ## return super(MerlinWizard, cls).as_view(*args, **kwargs)
-# DEPRECATED #
-# DEPRECATED #class UserRegisterWizardView(NamedUrlSessionWizardView):
-# DEPRECATED ##class UserRegisterWizardView(LoginRequiredMixin, NamedUrlSessionWizardView):
-# DEPRECATED # # Notice that I specify a file storage instance. If you don't specify this,
-# DEPRECATED # # and you need to support FileField or ImageField in your forms, you'll get
-# DEPRECATED # # errors from Django. This is something else I think could be handled by
-# DEPRECATED # # the views better. Seems to me that it should just use whatever the
-# DEPRECATED # # default/specified storage is for the rest of your project/application.
-# DEPRECATED # file_storage = default_storage # FileSystemStorage()
-# DEPRECATED # template_name = "register_user_wizard.html"
-# DEPRECATED #
-# DEPRECATED # def done(self, form_list, **kwargs):
-# DEPRECATED # step1_form = form_list[0]
-# DEPRECATED # step2_form = form_list[1]
-# DEPRECATED #
-# DEPRECATED # productext = self.create_product(product_form)
-# DEPRECATED # shippings = self.create_shippings(productext, shipping_forms)
-# DEPRECATED # images = self.create_images(productext, image_forms)
-# DEPRECATED #
-# DEPRECATED # if all([productext, shippings, images]):
-# DEPRECATED # del self.request.session["wizard_product_wizard_view"]
-# DEPRECATED #
-# DEPRECATED # messages.success(self.request,
-# DEPRECATED # _("Your product has been created."))
-# DEPRECATED # return HttpResponseRedirect(self.get_success_url(productext))
-# DEPRECATED #
-# DEPRECATED # messages.error(self.request, _("Something went wrong creating your "
-# DEPRECATED # "product. Please try again or contact support."))
-# DEPRECATED # return HttpResponseRedirect(reverse("register_wizard"))
-# DEPRECATED #
-# DEPRECATED # #def get_form_kwargs(self, step):
-# DEPRECATED # # if step == "product":
-# DEPRECATED # # return {"user": self.request.user}
-# DEPRECATED # # return {}
-# DEPRECATED #
-# DEPRECATED ## The portal should hook the slice and user creation pages
-# DEPRECATED #
-# DEPRECATED #def register_user(request):
-# DEPRECATED #
-# DEPRECATED # if request.method == 'POST':
-# DEPRECATED # form = UserRegisterForm(request.POST) # Nous reprenons les données
-# DEPRECATED # if form.is_valid():
-# DEPRECATED # first_name = form.cleaned_data['first_name']
-# DEPRECATED # last_name = form.cleaned_data['last_name']
-# DEPRECATED # email = form.cleaned_data['email']
-# DEPRECATED # password = form.cleaned_data['password']
-# DEPRECATED # password2 = form.cleaned_data['password2']
-# DEPRECATED # keypair = form.cleaned_data['keypair']
-# DEPRECATED # ## Ici nous pouvons traiter les données du formulaire
-# DEPRECATED # #sujet = form.cleaned_data['sujet']
-# DEPRECATED # #message = form.cleaned_data['message']
-# DEPRECATED # #envoyeur = form.cleaned_data['envoyeur']
-# DEPRECATED # #renvoi = form.cleaned_data['renvoi']
-# DEPRECATED # ## Nous pourrions ici envoyer l'e-mail grâce aux données que nous venons de récupérer
-# DEPRECATED # #envoi = True
-# DEPRECATED # else:
-# DEPRECATED # form = UserRegisterForm()
-# DEPRECATED # return render(request, 'register_user.html', locals())
-# DEPRECATED #
-# DEPRECATED #def index(request):
-# DEPRECATED #
-# DEPRECATED # WIZARD_TITLE = 'User registration'
-# DEPRECATED # STEP1_TITLE = 'Enter your details'
-# DEPRECATED # STEP2_TITLE = 'Select your institution'
-# DEPRECATED # STEP3_TITLE = 'Authentication'
-# DEPRECATED # STEP4_TITLE = 'Request a slice (optional)'
-# DEPRECATED # STEP5_TITLE = 'Waiting for validation'
-# DEPRECATED # STEP6_TITLE = 'Account validated'
-# DEPRECATED #
-# DEPRECATED # STEP0 = render_to_string('account_validated.html', context_instance=RequestContext(request))
-# DEPRECATED # STEP2_HTML = """
-# DEPRECATED # coucou
-# DEPRECATED # """
-# DEPRECATED # STEP4 = """
-# DEPRECATED # mede
-# DEPRECATED # """
-# DEPRECATED # STEP5 = render_to_string('account_validated.html', context_instance=RequestContext(request))
-# DEPRECATED #
-# DEPRECATED # p = PortalPage(request)
-# DEPRECATED #
-# DEPRECATED # # This is redundant with the Wizard title
-# DEPRECATED # p << "User registration
"
-# DEPRECATED #
-# DEPRECATED # sons = []
-# DEPRECATED # start_step = 1
-# DEPRECATED #
-# DEPRECATED # # STEP 1
-# DEPRECATED # # If the user already exists (is logged), let's display a summary of his account details
-# DEPRECATED # # Otherwise propose a form to fill in
-# DEPRECATED # if the_user(request):
-# DEPRECATED # # Fill a disabled form with user info
-# DEPRECATED # # Please logout to register another user
-# DEPRECATED # sons.append(Raw(page=p, title=STEP1_TITLE, togglable=False, html=STEP0))
-# DEPRECATED # start_step += 1
-# DEPRECATED # else:
-# DEPRECATED # # We could pass a list of fields also, instead of retrieving them from metadata
-# DEPRECATED # # Otherwise we need some heuristics to display nice forms
-# DEPRECATED # # XXX Could we log the user in after the form is validated ?
-# DEPRECATED # # XXX Explain the password is for XXX
-# DEPRECATED # field_list = [{
-# DEPRECATED # 'name' : 'First name',
-# DEPRECATED # 'field' : 'firstname',
-# DEPRECATED # 'type' : 'text',
-# DEPRECATED # 'validate_rx' : '^[a-zA-Z -]+$',
-# DEPRECATED # 'validate_err': 'Your first name must be comprised of letters only',
-# DEPRECATED # 'description' : 'Enter your first name',
-# DEPRECATED # }, {
-# DEPRECATED # 'name' : 'Last name',
-# DEPRECATED # 'field' : 'lastname',
-# DEPRECATED # 'type' : 'text',
-# DEPRECATED # 'validate_rx' : '^[a-zA-Z -]+$',
-# DEPRECATED # 'validate_err': 'Your last name must be comprised of letters only',
-# DEPRECATED # 'description' : 'Enter your last name',
-# DEPRECATED # }, {
-# DEPRECATED # 'name' : 'Email',
-# DEPRECATED # 'field' : 'email',
-# DEPRECATED # 'type' : 'text',
-# DEPRECATED # 'description' : 'Enter your email address',
-# DEPRECATED # }, {
-# DEPRECATED # 'name' : 'Password',
-# DEPRECATED # 'field' : 'password',
-# DEPRECATED # 'type' : 'password',
-# DEPRECATED # 'description' : 'Enter your password',
-# DEPRECATED # }, {
-# DEPRECATED # 'name' : 'Confirm password',
-# DEPRECATED # 'field' : 'password2',
-# DEPRECATED # 'type' : 'password',
-# DEPRECATED # 'description' : 'Enter your password again',
-# DEPRECATED # }]
-# DEPRECATED # sons.append(CreateForm(page = p, title = STEP1_TITLE, togglable = False, object = 'local:user', fields = field_list))
-# DEPRECATED #
-# DEPRECATED # # STEP 2
-# DEPRECATED # # If the user already exists (is logged), let's display a summary of its institution
-# DEPRECATED # # Otherwise propose a form to fill in (we should base our selection on the email)
-# DEPRECATED # if the_user(request):
-# DEPRECATED # # Fill a disabled form with institution
-# DEPRECATED # # Please logout to register another user
-# DEPRECATED # sons.append(Raw(page=p, title=STEP2_TITLE, togglable=False, html="User created"))
-# DEPRECATED # start_step += 1
-# DEPRECATED # else:
-# DEPRECATED # sons.append(CreateForm(page = p, title = STEP2_TITLE, togglable = False, object = 'slice')) #institution'))
-# DEPRECATED #
-# DEPRECATED # # STEP3
-# DEPRECATED # # Please should your prefered authentication method
-# DEPRECATED # # This step should allow the user to either choose the user or managed mode in MySlice
-# DEPRECATED # sons.append(Raw(page = p, title = STEP3_TITLE, togglable = False, html = STEP2_HTML))
-# DEPRECATED #
-# DEPRECATED # # Step 4: Request a slice (optional)
-# DEPRECATED # sons.append(CreateForm(page = p, title = STEP4_TITLE, togglable = False, object = 'slice'))
-# DEPRECATED #
-# DEPRECATED # # Step 5: Your request is waiting for validation
-# DEPRECATED # # Periodic refresh
-# DEPRECATED # sons.append(Raw(page = p, title = STEP5_TITLE, togglable = False, html = STEP4))
-# DEPRECATED #
-# DEPRECATED # # Step 6: Account validation = welcome for newly validated users
-# DEPRECATED # # . delegation
-# DEPRECATED # # . platforms
-# DEPRECATED # # . slice
-# DEPRECATED # # . pointers
-# DEPRECATED # sons.append(Raw(page = p, title = STEP6_TITLE, togglable = False, html = STEP5))
-# DEPRECATED #
-# DEPRECATED # wizard = Wizard(
-# DEPRECATED # page = p,
-# DEPRECATED # title = WIZARD_TITLE,
-# DEPRECATED # togglable = False,
-# DEPRECATED # sons = sons,
-# DEPRECATED # start_step = start_step,
-# DEPRECATED # )
-# DEPRECATED #
-# DEPRECATED # p << wizard.render(request) # in portal page if possible
-# DEPRECATED #
-# DEPRECATED # return p.render()
-
-class MyAccountView(TemplateView):
- template_name = "my_account.html"
+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:
+ 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(FreeAccessView):
+ template_name = "validate_pending.html"
def get_context_data(self, **kwargs):
- #user_hrn = 'ple.upmc.jordan_auge'
+ # 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)
- # Slow...
- #slice_query = Query().get('slice').filter_by('user.user_hrn', 'contains', user_hrn).select('slice_hrn')
- #slice_query = Query().get('user').filter_by('user_hrn', '==', user_hrn).select('slice.slice_hrn')
- #auth_query = Query().get('network').select('network_hrn')
- #page.enqueue_query(slice_query)
- #page.enqueue_query(auth_query)
-
- #page.expose_queries()
-
- #slicelist = SimpleList(
- # title = None,
- # page = page,
- # key = 'slice.slice_hrn',
- # query = slice_query,
- #)
-
- #authlist = SimpleList(
- # title = None,
- # page = page,
- # key = 'network_hrn',
- # query = auth_query,
- #)
-
- context = super(MyAccountView, self).get_context_data(**kwargs)
- context['person'] = self.request.user
- #context['networks'] = authlist.render(self.request)
- #context['slices'] = slicelist.render(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'])
+
+ print "W: Hardcoding platform myslice"
+ # There has been a tweak on how new platforms are referencing a
+ # so-called 'myslice' platform for storing authentication tokens.
+ # XXX This has to be removed in final versions.
+ myslice_platforms_query = Query().get('local:platform').filter_by('platform', '==', 'myslice').select('platform_id')
+ myslice_platforms = execute_query(self.request, myslice_platforms_query)
+ if myslice_platforms:
+ myslice_platform, = myslice_platforms
+ platform_ids.append(myslice_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('auth_type', 'config')
+ user_accounts = execute_query(self.request, user_accounts_query)
+ #print "=" * 80
+ #print user_accounts
+ #print "=" * 80
+ for user_account in user_accounts:
+
+ print "USER ACCOUNT", user_account
+ if user_account['auth_type'] == 'reference':
+ continue # we hardcoded the myslice platform...
+
+ config = json.loads(user_account['config'])
+ creds = []
+ print "CONFIG KEYS", config.keys()
+ if 'authority_credentials' in config:
+ print "***", config['authority_credentials'].keys()
+ 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:
+ print "***", config['delegated_authority_credentials'].keys()
+ 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'] = 'User Profile Page'
+ context['title'] = 'Test view that combines various plugins'
# the menu items on the top
- context['topmenu_items'] = topmenu_items('my_account', self.request)
+ context['topmenu_items'] = topmenu_items('Validation', self.request)
# so we can sho who is logged
- context['username'] = the_user(self.request)
+ context['username'] = the_user(self.request)
- context.update(page.prelude_env())
+ # XXX We need to prepare the page for queries
+ #context.update(page.prelude_env())
return context
-
-
-
-
-
-
-
-# view for contact form
-def contact(request):
- if request.method == 'POST': # If the form has been submitted...
- form = ContactForm(request.POST) # A form bound to the POST data
- if form.is_valid(): # All validation rules pass
- # Process the data in form.cleaned_data
- first_name = form.cleaned_data['first_name']
- last_name = form.cleaned_data['last_name']
- affiliation = form.cleaned_data['affiliation']
- subject = form.cleaned_data['subject']
- message = form.cleaned_data['message']
- email = form.cleaned_data['email'] # email of the sender
- cc_myself = form.cleaned_data['cc_myself']
-
- recipients = ['yasin.upmc@gmail.com']
- if cc_myself:
- recipients.append(email)
-
- from django.core.mail import send_mail
- send_mail("Onelab user submitted a query ", [first_name,last_name,affiliation,subject,message], email, recipients)
- return render(request,'contact_sent.html') # Redirect after POST
- else:
- form = ContactForm() # An unbound form
-
- return render(request, 'contact.html', {
- 'form': form,
- })
-
-
-def slice_request(request):
- if request.method == 'POST': # If the form has been submitted...
- form = SliceRequestForm(request.POST) # A form bound to the POST data
- if form.is_valid(): # All validation rules pass
- # Process the data in form.cleaned_data
- slice_name = form.cleaned_data['slice_name']
- number_of_nodes = form.cleaned_data['number_of_nodes']
- type_of_nodes = form.cleaned_data['type_of_nodes']
- purpose = form.cleaned_data['purpose']
- email = form.cleaned_data['email'] # email of the sender
- cc_myself = form.cleaned_data['cc_myself']
-
- recipients = ['yasin.upmc@gmail.com','jordan.auge@lip6.fr']
- if cc_myself:
- recipients.append(email)
-
- from django.core.mail import send_mail
- send_mail("Onelab New Slice request form submitted", [slice_name,number_of_nodes,type_of_nodes,purpose], email, recipients)
- return render(request,'slicereq_recvd.html') # Redirect after POST
- else:
- form = SliceRequestForm() # An unbound form
-
-# template_env = {}
-# template_env['form'] = form
-# template_env['topmenu_items'] = topmenu_items('Request a slice', request)
-# template_env['unfold1_main'] = render(request, 'slice_request_.html', {
-# 'form': form,
-# })
-# from django.shortcuts import render_to_response
-# from django.template import RequestContext
-# return render_to_response ('view-unfold1.html',template_env,
-# context_instance=RequestContext(request))
-
- return render(request, 'slice_request.html', {
- 'form': form,
- 'topmenu_items': topmenu_items('Request a slice', request),
- 'username': the_user (request)
- })
-