-
-"""
-Create a new plauth object that the Aggregate Manager can use to execute
-plshell commands as the authenticated user.
-"""
-def __get_user_plauth(api, registry, credential, creds, operation, hrn):
- plauth = None
-
- user_creds = api.auth.checkCredentials(creds, operation, hrn)
- user_cred_obj = Credential(string=user_creds[0])
-
- # If user cred has a parent then the caller is the parent's cred.
- # This is true for delegated creds.
- if user_cred_obj.parent:
- user_hrn = user_cred_obj.parent.get_gid_caller().get_hrn()
- else:
- user_hrn = user_cred_obj.get_gid_caller().get_hrn()
-
- user_record = registry.Resolve(user_hrn, [credential])[0]
- email = user_record['email']
-
- person = api.plshell.GetPersons(api.plauth, email)
- if person:
- person_id = person[0]['person_id']
- # Get the user's session if one exists, create one otherwise
- session = api.plshell.GetSessions(api.plauth, {'person_id': person_id})
- if not session:
- session = api.plshell.AddSession(api.plauth, person_id)
- else:
- session = session[0]['session_id']
-
- # Create new authentication token
- plauth = {'Username':email, 'AuthMethod':'session', 'session':session}
-
- return plauth
-
+from sfa.util.version import version_core
+from sfa.rspecs.rspec_version import RSpecVersion
+from sfa.rspecs.sfa_rspec import sfa_rspec_version
+from sfa.rspecs.pg_rspec import pg_rspec_ad_version, pg_rspec_request_version
+from sfa.rspecs.rspec_parser import parse_rspec
+from sfa.util.sfatime import utcparse
+from sfa.util.callids import Callids
+
+def GetVersion(api):
+ xrn=Xrn(api.hrn)
+ request_rspec_versions = [dict(pg_rspec_request_version), dict(sfa_rspec_version)]
+ ad_rspec_versions = [dict(pg_rspec_ad_version), dict(sfa_rspec_version)]
+ version_more = {'interface':'aggregate',
+ 'testbed':'myplc',
+ 'hrn':xrn.get_hrn(),
+ 'request_rspec_versions': request_rspec_versions,
+ 'ad_rspec_versions': ad_rspec_versions,
+ 'default_ad_rspec': dict(sfa_rspec_version)
+ }
+ return version_core(version_more)