X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=sfa%2Fmethods%2FUpdate.py;h=2cedf9bb36d6ad54cd7a8f5a73b9c8430175e42b;hb=c90201600fe2e94f432e81dec5a9b1817bc76ca5;hp=dcc5c70e40aac812a382c54fa044c739b5a4965c;hpb=680d4fc1af88ed631f820545216bee6e7a698f39;p=sfa.git diff --git a/sfa/methods/Update.py b/sfa/methods/Update.py index dcc5c70e..2cedf9bb 100644 --- a/sfa/methods/Update.py +++ b/sfa/methods/Update.py @@ -5,10 +5,9 @@ import time from sfa.util.faults import * from sfa.util.method import Method from sfa.util.parameter import Parameter, Mixed -from sfa.util.debug import log from sfa.trust.credential import Credential -class update(Method): +class Update(Method): """ Update an object in the registry. Currently, this only updates the PLC information associated with the record. The SFA fields (name, type, @@ -23,29 +22,25 @@ class update(Method): interfaces = ['registry'] accepts = [ - Parameter(str, "Credential string"), Parameter(dict, "Record dictionary to be updated"), - Mixed(Parameter(str, "Human readable name of the original caller"), - Parameter(None, "Origin hrn not specified")) + Parameter(str, "Credential string"), ] returns = Parameter(int, "1 if successful") - def call(self, cred, record_dict, origin_hrn=None): - user_cred = Credential(string=cred) - - #log the call - if not origin_hrn: - origin_hrn = user_cred.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, None, self.name)) - + def call(self, record_dict, creds): # validate the cred - self.api.auth.check(cred, "update") + valid_creds = self.api.auth.checkCredentials(creds, "update") - # 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]) + # verify permissions + hrn = record_dict.get('hrn', '') + api.auth.verify_object_permission(hrn) + + # log + 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)) + + manager = self.api.get_interface_manager() + return manager.update(self.api, record_dict)