from django.views.generic import View
from django.views.generic.base import TemplateView
from django.shortcuts import render
+from django.template.loader import render_to_string
+from django.core.mail import send_mail
from django.utils.decorators import method_decorator
from django.contrib.auth.decorators import login_required
from portal.forms import SliceRequestForm, ContactForm
from portal.util import RegistrationView, ActivationView
from portal.models import PendingUser, PendingSlice
+from portal.actions import authority_get_pi_emails, get_request_by_authority
from manifold.core.query import Query
from manifold.manifoldapi import execute_query
from unfold.page import Page
def get_context_data(self, **kwargs):
- page = Page(self.request)
+ #page = Page(self.request)
- #network_query = Query().get('local:platform').filter_by('disabled', '==', '0').select('platform','platform_longname','gateway_type')
- network_query = Query().get('local:user').select('user_id','email','config')
- page.enqueue_query(network_query)
+ user_query = Query().get('local:user').select('config','email')
+ user_details = execute_query(self.request, user_query)
+
+ # not always found in user_details...
+ config={}
+ for user_detail in user_details:
+ #email = user_detail['email']
+ if user_detail['config']:
+ config = json.loads(user_detail['config'])
+
+ platform_query = Query().get('local:platform').select('platform_id','platform')
+ account_query = Query().get('local:account').select('user_id','platform_id','auth_type','config')
+ platform_details = execute_query(self.request, platform_query)
+ account_details = execute_query(self.request, account_query)
+
+ # initial assignment needed for users having no account
+ platform_name = ''
+ account_type = ''
+ account_usr_hrn = ''
+ account_pub_key = ''
+ for account_detail in account_details:
+ for platform_detail in platform_details:
+ if platform_detail['platform_id'] == account_detail['platform_id']:
+ platform_name = platform_detail['platform']
+ account_type = account_detail['auth_type']
+ account_config = json.loads(account_detail['config'])
+
+ # a bit more pythonic
+ account_usr_hrn = account_config.get('user_hrn','N/A')
+ account_pub_key = account_config.get('user_public_key','N/A')
+
+ #page.enqueue_query(network_query)
- page.expose_js_metadata()
- page.expose_queries()
+ #page.expose_js_metadata()
+ #page.expose_queries()
- userlist = SimpleList(
- title = None,
- page = page,
- key = 'user_id',
- query = network_query,
- )
+ #userlist = SimpleList(
+ # title = None,
+ # page = page,
+ # key = 'user_id',
+ # query = network_query,
+ #)
context = super(AccountView, self).get_context_data(**kwargs)
+ context['platform_name'] = platform_name
+ context['account_type'] = account_type
+ context['account_usr_hrn'] = account_usr_hrn
+ context['account_pub_key'] = account_pub_key
context['person'] = self.request.user
- context['users'] = userlist.render(self.request)
+ context ['firstname'] = config.get('firstname',"?")
+ context ['lastname'] = config.get('lastname',"?")
+ context ['fullname'] = context['firstname'] +' '+ context['lastname']
+ context ['affiliation'] = config.get('affiliation',"Unknown Affiliation")
+ #context['users'] = userlist.render(self.request)
# XXX This is repeated in all pages
# more general variables expected in the template
context['topmenu_items'] = topmenu_items('My Account', self.request)
# so we can sho who is logged
context['username'] = the_user(self.request)
-
- context.update(page.prelude_env())
+# context ['firstname'] = config['firstname']
+ #context.update(page.prelude_env())
return context
authorities = execute_query(request, authorities_query)
if request.method == 'POST':
+ # We shall use a form here
+
#get_email = PendingUser.objects.get(email)
reg_fname = request.POST.get('firstname', '')
reg_lname = request.POST.get('lastname', '')
# email=reg_email, password=request.POST['password'], keypair=keypair)
#b.save()
if not errors:
- b = PendingUser(first_name=reg_fname, last_name=reg_lname, affiliation=reg_aff,
- authority_hrn=reg_auth,
- email=reg_email, password=request.POST['password'], keypair=keypair)
+ b = PendingUser(
+ first_name=reg_fname,
+ last_name=reg_lname,
+ affiliation=reg_aff,
+ authority_hrn=reg_auth,
+ email=reg_email,
+ password=request.POST['password'],
+ keypair=keypair
+ )
b.save()
+
+ # Send email
+ ctx = {
+ first_name : reg_fname,
+ last_name : reg_lname,
+ affiliation : reg_aff,
+ authority_hrn: reg_auth,
+ email : reg_email,
+ keypair : keypair,
+ cc_myself : True # form.cleaned_data['cc_myself']
+ }
+
+ recipients = authority_get_pi_emails(authority_hrn)
+ if ctx['cc_myself']:
+ recipients.append(ctx['email'])
+
+ msg = render_to_string('user_request_email.txt', ctx)
+ send_mail("Onelab New User request submitted", msg, email, recipients)
+
return render(request, 'user_register_complete.html')
return render(request, 'register_4m_f4f.html',{
email = form.cleaned_data['email'] # email of the sender
cc_myself = form.cleaned_data['cc_myself']
+ #recipients = authority_get_pi_emails(authority_hrn)
recipients = ['yasin.upmc@gmail.com']
if cc_myself:
recipients.append(email)
@login_required
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']
+ errors = []
+
+ authorities_query = Query.get('authority').filter_by('authority_hrn', 'included', ['ple.inria', 'ple.upmc']).select('name', 'authority_hrn')
+ #authorities_query = Query.get('authority').select('authority_hrn')
+ authorities = execute_query(request, authorities_query)
+
+ authority_hrn_tuple = []
+ for authority in authorities:
+ authority_hrn_tuple.append((authority['authority_hrn'], authority['name']))
+ authority_hrn_initial = {'authority_hrn': authority_hrn_tuple}
+
+ # request.POST or None ?
+ if request.method == 'POST':
+ # The form has been submitted
+ form = SliceRequestForm(request.POST, initial=authority_hrn_initial)
+
+ if form.is_valid():
+ slice_name = form.cleaned_data['slice_name']
+ authority_hrn = form.cleaned_data['authority_hrn']
number_of_nodes = form.cleaned_data['number_of_nodes']
- type_of_nodes = form.cleaned_data['type_of_nodes']
- purpose = form.cleaned_data['purpose']
+ type_of_nodes = form.cleaned_data['type_of_nodes']
+ purpose = form.cleaned_data['purpose']
+
+ s = PendingSlice(
+ slice_name = slice_name,
+ authority_hrn = authority_hrn,
+ number_of_nodes = number_of_nodes,
+ type_of_nodes = type_of_nodes,
+ purpose = purpose
+ )
+ s.save()
+
+ # All validation rules pass; process data in form.cleaned_data
+ # slice_name, number_of_nodes, type_of_nodes, 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']
+ # The recipients are the PI of the authority
+ recipients = authority_get_pi_emails(authority_hrn)
+ #recipients = ['yasin.upmc@gmail.com','jordan.auge@lip6.fr']
if cc_myself:
recipients.append(email)
+ msg = render_to_string('slice_request_email.txt', form.cleaned_data)
+ send_mail("Onelab New Slice request form submitted", msg, email, recipients)
- 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
+ form = SliceRequestForm(initial=authority_hrn_initial)
# template_env = {}
# template_env['form'] = form
queried_pending_authorities = pi_my_authorities | pi_delegation_authorities
print "----"
print "queried_pending_authorities = ", queried_pending_authorities
-
- # Pending requests + authorities
- #pending_users = PendingUser.objects.filter(authority_hrn__in = queried_pending_authorities).all()
- #pending_slices = PendingSlice.objects.filter(authority_hrn__in = queried_pending_authorities).all()
- pending_users = PendingUser.objects.all()
- pending_slices = PendingSlice.objects.all()
-
- # Dispatch requests and build the proper structure for the template:
- print "pending users =", pending_users
- print "pending slices =", pending_slices
-
- for user in pending_users:
- auth_hrn = user.authority_hrn
-
- request = {}
- request['type'] = 'user'
- request['id'] = 'TODO' # XXX in DB ?
- request['timestamp'] = 'TODO' # XXX in DB ?
- request['details'] = "%s %s <%s>" % (user.first_name, user.last_name, user.email)
+ 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
else:
continue
-
- if not auth_hrn in dest:
- dest[auth_hrn] = []
- print "auth_hrn [%s] was added %r" % (auth_hrn, request)
- dest[auth_hrn].append(request)
-
- for slice in pending_slices:
- auth_hrn = slice.authority_hrn
- if not auth_hrn:
- auth_hrn = "ple.upmc" # XXX HARDCODED
-
- request = {}
- request['type'] = 'slice'
- request['id'] = 'TODO' # XXX in DB ?
- request['timestamp'] = 'TODO' # XXX in DB ?
- request['details'] = "Number of nodes: %d -- Type of nodes: %s<br/>%s" % ('TODO', 'TODO', 'TODO') # XXX
- 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'
-
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