+# DEPRECATED ## view for my_account
+# DEPRECATED # class MyAccountView(TemplateView):
+# DEPRECATED # template_name = "my_account.html"
+# DEPRECATED #
+# DEPRECATED # def from_process(self, request, **cleaned_data):
+# DEPRECATED # #if request.method == 'POST':
+# DEPRECATED # # if request.POST['submit_name']:
+# DEPRECATED # if 'fname' in request.POST:
+# DEPRECATED # messsag= "Got Name"
+# DEPRECATED # #return render(request, 'portal/my_account.html')
+# DEPRECATED # #response = HttpResponse("Here's the text of the Web page.")
+# DEPRECATED # return HttpResponse(message)
+# DEPRECATED #
+# DEPRECATED # def get_context_data(self, **kwargs):
+# DEPRECATED # page = Page(self.request)
+# DEPRECATED # context = super(MyAccountView, self).get_context_data(**kwargs)
+# DEPRECATED # context['person'] = self.request.user
+# DEPRECATED # # XXX This is repeated in all pages
+# DEPRECATED # # more general variables expected in the template
+# DEPRECATED # context['title'] = 'User Profile Page'
+# DEPRECATED # # the menu items on the top
+# DEPRECATED # context['topmenu_items'] = topmenu_items('my_account', self.request)
+# DEPRECATED # # so we can sho who is logged
+# DEPRECATED # context['username'] = the_user(self.request)
+# DEPRECATED # context.update(page.prelude_env())
+# DEPRECATED # return context
+
+# View for platforms
+class PlatformsView(TemplateView):
+ template_name = "platforms.html"
+
+ def get_context_data(self, **kwargs):
+ 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:platform').select('platform','platform_longname','gateway_type')
+ page.enqueue_query(network_query)
+
+ page.expose_js_metadata()
+ page.expose_queries()
+ networklist = Hazelnut(
+ page = page,
+ title = 'List',
+ domid = 'checkboxes',
+ # this is the query at the core of the slice list
+ query = network_query,
+ query_all = network_query,
+ checkboxes = False,
+ datatables_options = {
+ # for now we turn off sorting on the checkboxes columns this way
+ # this of course should be automatic in hazelnut
+ 'aoColumns' : [None, None, None, None, {'bSortable': False}],
+ 'iDisplayLength' : 25,
+ 'bLengthChange' : True,
+ },
+ )
+#
+# networklist = SimpleList(
+# title = None,
+# page = page,
+# key = 'platform',
+# query = network_query,
+# )
+
+ context = super(PlatformsView, self).get_context_data(**kwargs)
+ context['person'] = self.request.user
+ context['networks'] = networklist.render(self.request)
+
+ # XXX This is repeated in all pages
+ # more general variables expected in the template
+ context['title'] = 'Platforms connected to MySlice'
+ # the menu items on the top
+ context['topmenu_items'] = topmenu_items('Platforms', self.request)
+ # so we can sho who is logged
+ context['username'] = the_user(self.request)
+
+ context.update(page.prelude_env())
+
+ return context
+
+
+
+# View for 1 platform and its details
+class PlatformView(TemplateView):
+ template_name = "platform.html"
+
+ def get_context_data(self, **kwargs):
+ page = Page(self.request)
+
+ for key, value in kwargs.iteritems():
+ print "%s = %s" % (key, value)
+ if key == "platformname":
+ platformname=value
+
+ network_query = Query().get('local:platform').filter_by('platform', '==', platformname).select('platform','platform_longname','gateway_type')
+ page.enqueue_query(network_query)
+
+ page.expose_js_metadata()
+ page.expose_queries()
+ networklist = Hazelnut(
+ page = page,
+ title = 'List',
+ domid = 'checkboxes',
+ # this is the query at the core of the slice list
+ query = network_query,
+ query_all = network_query,
+ checkboxes = False,
+ datatables_options = {
+ # for now we turn off sorting on the checkboxes columns this way
+ # this of course should be automatic in hazelnut
+ 'aoColumns' : [None, None, None, None, {'bSortable': False}],
+ 'iDisplayLength' : 25,
+ 'bLengthChange' : True,
+ },
+ )
+#
+# networklist = SimpleList(
+# title = None,
+# page = page,
+# key = 'platform',
+# query = network_query,
+# )
+
+ context = super(PlatformView, self).get_context_data(**kwargs)
+ context['person'] = self.request.user
+ context['networks'] = networklist.render(self.request)
+
+ # XXX This is repeated in all pages
+ # more general variables expected in the template
+ context['title'] = 'Platforms connected to MySlice'
+ # the menu items on the top
+ context['topmenu_items'] = topmenu_items('Platforms', self.request)
+ # so we can sho who is logged
+ context['username'] = the_user(self.request)
+
+ context.update(page.prelude_env())
+
+ return context
+
+
+
+#class for my_account
+class AccountView(TemplateView):
+ template_name = "my_account.html"
+
+ #This view requires login
+ @method_decorator(login_required)
+ def dispatch(self, *args, **kwargs):
+ return super(AccountView, self).dispatch(*args, **kwargs)
+
+
+ def get_context_data(self, **kwargs):
+ #page = Page(self.request)
+
+ user_query = Query().get('local:user').select('config','email')
+ user_details = execute_query(self.request, user_query)
+
+ 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 = ''
+ platform_name_list = []
+ account_type_list = []
+ usr_hrn_list = []
+ pub_key_list = []
+ 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'])
+
+ if 'user_hrn' in account_config:
+ account_usr_hrn = account_config['user_hrn']
+ else:
+ account_usr_hrn = 'N/A'
+ if 'user_public_key' in account_config:
+ account_pub_key = account_config['user_public_key']
+ else:
+ account_pub_key = 'N/A'
+ #print "THis is a test"
+ #print account_pub_key
+
+ platform_name_list.append(platform_name)
+ account_type_list.append(account_type)
+ usr_hrn_list.append(account_usr_hrn)
+ pub_key_list.append(account_pub_key)
+
+ # combining 4 lists into 1 [to render in the template]
+ lst = [{'platform_name': t[0], 'account_type': t[1], 'usr_hrn':t[2], 'usr_pubkey':t[3]} for t in zip(platform_name_list, account_type_list, usr_hrn_list, pub_key_list)]
+ #print "test"
+ #print lst
+
+ context = super(AccountView, self).get_context_data(**kwargs)
+ context['data'] = lst
+ context['person'] = self.request.user
+ context ['fullname'] = config['firstname'] +' '+ config['lastname']
+ context ['firstname'] = config['firstname']
+ context ['lastname'] = config['lastname']
+ context ['affiliation'] = config['affiliation']
+ #context['users'] = userlist.render(self.request)
+
+ # XXX This is repeated in all pages
+ # more general variables expected in the template
+ context['title'] = 'Platforms connected to MySlice'
+ # the menu items on the top
+ context['topmenu_items'] = topmenu_items('My Account', self.request)
+ # so we can sho who is logged
+ context['username'] = the_user(self.request)
+ context ['firstname'] = config['firstname']
+ #context.update(page.prelude_env())
+ return context
+
+
+
+
+
+
+@login_required
+# View for my_account form
+#def my_account(request):
+# return render(request, 'my_account.html', {
+# #'form': form,
+# 'topmenu_items': topmenu_items('My Account', request),
+# 'username': the_user (request)
+# })
+
+
+@login_required
+#my_acc form value processing
+def acc_process(request):
+ # getting the user_id from the session [now hardcoded]
+ get_user = PendingUser.objects.get(id='1') # here we will get the id/email from session e.g., person.email
+ # getting user info from manifold
+ if 'submit_name' in request.POST:
+ edited_first_name = request.POST['fname']
+ edited_last_name = request.POST['lname']
+ #email = 'test_email@gmail.com'
+ #password = 'test_pp'
+ #message = 'F_Name: %s L_name: %s dummy_pp: %s' % (first_name, last_name, password)
+ #site = None
+
+ # insert into DB [needed for registration page]
+ #approach borrowed from register view
+ #new_user = PendingUser.objects.create_inactive_user(edited_first_name, edited_last_name, email, password, site)
+ #conventional approach
+ #b = PendingUser(first_name=edited_first_name, last_name=edited_last_name)
+ #b.save()
+
+ # select and update [will be used throughout this view]
+ # select the logged in user [for the moment hard coded]
+ #get_user = PendingUser.objects.get(id='1') # here we will get the id/email from session e.g., person.email
+ # update first and last name
+ get_user.first_name = edited_first_name
+ get_user.last_name = edited_last_name
+ get_user.save()
+
+ return HttpResponse('Sucess: First Name and Last Name Updated!')
+ elif 'submit_pass' in request.POST:
+ edited_password = request.POST['password']
+ # select the logged in user [for the moment hard coded]
+ #get_user = PendingUser.objects.get(id='1') # here we will get the id/email from session e.g., person.email
+ # update password
+ get_user.password = edited_password
+ get_user.save()
+ return HttpResponse('Success: Password Changed!!')
+ elif 'generate' in request.POST:
+ # Generate public and private keys using SFA Library
+ from sfa.trust.certificate import Keypair
+ k = Keypair(create=True)
+ public_key = k.get_pubkey_string()
+ private_key = k.as_pem()
+
+# DEPRECATED
+# KEY_LENGTH = 2048
+#
+# def blank_callback():
+# "Replace the default dashes"
+# return
+#
+# # Random seed
+# Rand.rand_seed (os.urandom (KEY_LENGTH))
+# # Generate key pair
+# key = RSA.gen_key (KEY_LENGTH, 65537, blank_callback)
+# # Create memory buffers
+# pri_mem = BIO.MemoryBuffer()
+# pub_mem = BIO.MemoryBuffer()
+# # Save keys to buffers
+# key.save_key_bio(pri_mem, None)
+# key.save_pub_key_bio(pub_mem)
+#
+# # Get keys
+# public_key = pub_mem.getvalue()
+# private_key = pri_mem.getvalue()
+ private_key = ''.join(private_key.split())
+ public_key = "ssh-rsa " + public_key
+ # Saving to DB
+ keypair = '{"user_public_key":"'+ public_key + '", "user_private_key":"'+ private_key + '"}'
+# keypair = re.sub("\r", "", keypair)
+# keypair = re.sub("\n", "\\n", keypair)
+# #keypair = keypair.rstrip('\r\n')
+# keypair = ''.join(keypair.split())
+ get_user.keypair = keypair
+ get_user.save()
+ return HttpResponse('Success: New Keypair Generated! %s' % keypair)
+
+ elif 'upload_key' in request.POST:
+ up_file = request.FILES['pubkey']
+ file_content = up_file.read()
+ file_name = up_file.name
+ file_extension = os.path.splitext(file_name)[1]
+ allowed_extension = ['.pub','.txt']
+ if file_extension in allowed_extension and re.search(r'ssh-rsa',file_content):
+ file_content = '{"user_public_key":"'+ file_content +'"}'
+ file_content = re.sub("\r", "", file_content)
+ file_content = re.sub("\n", "\\n",file_content)
+ file_content = ''.join(file_content.split())
+ get_user.keypair = file_content
+ get_user.save()
+ return HttpResponse('Success: Publickey uploaded! Old records overwritten')
+ else:
+ return HttpResponse('Please upload a valid RSA public key [.txt or .pub].')
+
+ else:
+ message = 'You submitted an empty form.'
+ return HttpResponse(message)
+
+def register_4m_f4f(request):
+ 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)
+
+ 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', '')
+ reg_aff = request.POST.get('affiliation','')
+ reg_auth = request.POST.get('authority_hrn', '')
+ reg_email = request.POST.get('email','').lower()
+
+ #POST value validation
+ if (re.search(r'^[\w+\s.@+-]+$', reg_fname)==None):
+ errors.append('First Name may contain only letters, numbers, spaces and @/./+/-/_ characters.')
+ #return HttpResponse("Only Letters, Numbers, - and _ allowd in First Name")
+ #return render(request, 'register_4m_f4f.html')
+ if (re.search(r'^[\w+\s.@+-]+$', reg_lname) == None):
+ errors.append('Last Name may contain only letters, numbers, spaces and @/./+/-/_ characters.')
+ #return HttpResponse("Only Letters, Numbers, - and _ is allowed in Last name")
+ #return render(request, 'register_4m_f4f.html')
+ if (re.search(r'^[\w+\s.@+-]+$', reg_aff) == None):
+ errors.append('Affiliation may contain only letters, numbers, spaces and @/./+/-/_ characters.')
+ #return HttpResponse("Only Letters, Numbers and _ is allowed in Affiliation")
+ #return render(request, 'register_4m_f4f.html')
+ # XXX validate authority hrn !!
+ if PendingUser.objects.filter(email__iexact=reg_email):
+ errors.append('Email already registered.Please provide a new email address.')
+ #return HttpResponse("Email Already exists")
+ #return render(request, 'register_4m_f4f.html')
+ if 'generate' in request.POST['question']:
+ # Generate public and private keys using SFA Library
+ from sfa.trust.certificate import Keypair
+ k = Keypair(create=True)
+ public_key = k.get_pubkey_string()
+ private_key = k.as_pem()
+
+# DEPRECATED
+# #import os
+# #from M2Crypto import Rand, RSA, BIO
+#
+# KEY_LENGTH = 2048
+#
+# def blank_callback():
+# "Replace the default dashes"
+# return
+#
+# # Random seed
+# Rand.rand_seed (os.urandom (KEY_LENGTH))
+# # Generate key pair
+# key = RSA.gen_key (KEY_LENGTH, 65537, blank_callback)
+# # Create memory buffers
+# pri_mem = BIO.MemoryBuffer()
+# pub_mem = BIO.MemoryBuffer()
+# # Save keys to buffers
+# key.save_key_bio(pri_mem, None)
+# key.save_pub_key_bio(pub_mem)
+# # Get keys
+# public_key = pub_mem.getvalue()
+# private_key = pri_mem.getvalue()
+
+ private_key = ''.join(private_key.split())
+ public_key = "ssh-rsa " + public_key
+ # Saving to DB
+ keypair = '{"user_public_key":"'+ public_key + '", "user_private_key":"'+ private_key + '"}'
+# keypair = re.sub("\r", "", keypair)
+# keypair = re.sub("\n", "\\n", keypair)
+# #keypair = keypair.rstrip('\r\n')
+# keypair = ''.join(keypair.split())
+ else:
+ up_file = request.FILES['user_public_key']
+ file_content = up_file.read()
+ file_name = up_file.name
+ file_extension = os.path.splitext(file_name)[1]
+ allowed_extension = ['.pub','.txt']
+ if file_extension in allowed_extension and re.search(r'ssh-rsa',file_content):
+ keypair = '{"user_public_key":"'+ file_content +'"}'
+ keypair = re.sub("\r", "", keypair)
+ keypair = re.sub("\n", "\\n",keypair)
+ keypair = ''.join(keypair.split())
+ else:
+ errors.append('Please upload a valid RSA public key [.txt or .pub].')
+
+ #b = PendingUser(first_name=reg_fname, last_name=reg_lname, affiliation=reg_aff,
+ # 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.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',{
+ 'topmenu_items': topmenu_items('Register', request),
+ 'errors': errors,
+ 'firstname': request.POST.get('firstname', ''),
+ 'lastname': request.POST.get('lastname', ''),
+ 'affiliation': request.POST.get('affiliation', ''),
+ 'authority_hrn': request.POST.get('authority_hrn', ''),
+ 'email': request.POST.get('email', ''),
+ 'password': request.POST.get('password', ''),
+ 'authorities': authorities
+ })
+
+