X-Git-Url: http://git.onelab.eu/?p=myslice.git;a=blobdiff_plain;f=portal%2Factions.py;h=c373a30ccc671640ac5a2f76a4e5b90a0a6fe2fb;hp=97b8ac81d1fa2c07ff096cb79ddc103ff9fc7529;hb=caafec9916ce3ca86106a7bc8aa167b53309e072;hpb=4cff7691aba786e1e2e94c5a9c86a27f1be96b5b diff --git a/portal/actions.py b/portal/actions.py index 97b8ac81..c373a30c 100644 --- a/portal/actions.py +++ b/portal/actions.py @@ -42,6 +42,13 @@ def sfa_add_user(request, user_params): raise Exception, "Could not create %s. Already exists ?" % user_params['hrn'] return results +def sfa_update_user(request, user_hrn, user_params): + # user_params: keys [public_key] + query = Query.update('user').filter_by('user_hrn', '==', user_hrn).set(user_params).select('user_hrn') + results = execute_query(request,query) + return results + + def sfa_add_slice(request, slice_params): query = Query.create('slice').set(slice_params).select('slice_hrn') results = execute_query(request, query) @@ -60,10 +67,10 @@ def manifold_add_user(request, user_params): result, = results return result['email'] -def manifold_update_user(request, user_params): +def manifold_update_user(request, email, user_params): # user_params: password, config e.g., - query = Query.update('local:user').filter_by('email', '==', request.user.email).set(user_params).select('email') - results = execute_query(request,query) + query = Query.update('local:user').filter_by('email', '==', email).set(user_params).select('email') + results = execute_admin_query(request,query) # NOTE: results remains empty and goes to Exception. However, it updates the manifold DB. # That's why I commented the exception part. -- Yasin #if not results: @@ -189,7 +196,9 @@ def portal_validate_request(wsgi_request, request_ids): if request['type'] == 'user': try: - hrn = "%s.%s" % (request['authority_hrn'], request['login']) + # XXX tmp user_hrn inside the keypair column of pendiguser table + hrn = json.loads(request['keypair'])['user_hrn'] + #hrn = "%s.%s" % (request['authority_hrn'], request['login']) # XXX tmp sfa dependency from sfa.util.xrn import Xrn urn = Xrn(hrn, request['type']).get_urn()