X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=sfa%2Fmethods%2FRegister.py;h=619ed00bbaaf86b19ae315b3d945295f93e587c5;hb=57b6a99255d4a88be9c0f910f8524677e34ff4bc;hp=00560f77eed23d860d1a0992002877f0019788f0;hpb=680d4fc1af88ed631f820545216bee6e7a698f39;p=sfa.git diff --git a/sfa/methods/Register.py b/sfa/methods/Register.py index 00560f77..619ed00b 100644 --- a/sfa/methods/Register.py +++ b/sfa/methods/Register.py @@ -1,18 +1,8 @@ -### $Id: register.py 16477 2010-01-05 16:31:37Z thierry $ -### $URL: https://svn.planet-lab.org/svn/sfa/trunk/sfa/methods/register.py $ - -from sfa.trust.certificate import Keypair, convert_public_key -from sfa.trust.gid import * -from sfa.util.faults import * from sfa.util.method import Method from sfa.util.parameter import Parameter, Mixed -from sfa.util.record import SfaRecord -from sfa.util.debug import log -from sfa.trust.auth import Auth -from sfa.trust.gid import create_uuid from sfa.trust.credential import Credential -class register(Method): +class Register(Method): """ Register an object with the registry. In addition to being stored in the SFA database, the appropriate records will also be created in the @@ -27,29 +17,25 @@ class register(Method): interfaces = ['registry'] accepts = [ - Parameter(str, "Credential string"), - Parameter(dict, "Record dictionary containing record fields") + Parameter(dict, "Record dictionary containing record fields"), + Mixed(Parameter(str, "Credential string"), + Parameter(type([str]), "List of credentials")), ] returns = Parameter(int, "String representation of gid object") - def call(self, cred, record, origin_hrn=None): - user_cred = Credential(string=cred) + def call(self, record, creds): + # validate cred + valid_creds = self.api.auth.checkCredentials(creds, 'register') + + # verify permissions + hrn = record.get('hrn', '') + self.api.auth.verify_object_permission(hrn) #log the call - if not origin_hrn: - origin_hrn = user_cred.get_gid_caller().get_hrn() - hrn = None - if 'hrn' in record: - hrn = record['hrn'] + origin_hrn = Credential(string=valid_creds[0]).get_gid_caller().get_hrn() self.api.logger.info("interface: %s\tcaller-hrn: %s\ttarget-hrn: %s\tmethod-name: %s"%(self.api.interface, origin_hrn, hrn, self.name)) - # validate the cred - self.api.auth.check(cred, "register") + manager = self.api.get_interface_manager() - #send the call to the right manager - manager_base = 'sfa.managers' - mgr_type = self.api.config.SFA_REGISTRY_TYPE - manager_module = manager_base + ".registry_manager_%s" % mgr_type - manager = __import__(manager_module, fromlist=[manager_base]) return manager.register(self.api, record)