X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=sfa%2Fmethods%2Fget_slices.py;h=402bf0a7aeb8d2c0e2787db68d25f3053a9def83;hb=74f579cc69a3610c0a6a206c38f6a429d67e5822;hp=1c276b1c403df18678ab64b9f67c53d5d8b98ca1;hpb=4365941276ede6722e5ca7e82f81d489005311c5;p=sfa.git diff --git a/sfa/methods/get_slices.py b/sfa/methods/get_slices.py index 1c276b1c..402bf0a7 100644 --- a/sfa/methods/get_slices.py +++ b/sfa/methods/get_slices.py @@ -2,7 +2,6 @@ ### $URL$ from sfa.util.faults import * -from sfa.util.misc import * from sfa.util.method import Method from sfa.util.parameter import Parameter, Mixed from sfa.trust.auth import Auth @@ -21,38 +20,39 @@ class get_slices(Method): accepts = [ Parameter(str, "Credential string"), - Mixed(Parameter(str, "Request hash"), - Parameter(None, "Request hash not specified")), - Parameter(str, "Callers credential string") + Mixed(Parameter(str, "Human readable name of the original caller"), + Parameter(None, "Origin hrn not specified")) ] returns = [Parameter(str, "Human readable slice name (hrn)")] - def call(self, cred, request_hash=None, caller_cred=None): - self.api.auth.authenticateCred(cred, [cred], request_hash) - self.api.auth.check(cred, 'listslices') - if caller_cred==None: - caller_cred=cred - + def call(self, cred, origin_hrn=None): + user_cred = Credential(string=cred) #log the call - self.api.logger.info("interface: %s\tcaller-hrn: %s\ttarget-hrn: %s\tmethod-name: %s"%(self.api.interface, Credential(string=caller_cred).get_gid_caller().get_hrn(), None, self.name)) + 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)) + + # validate the cred + self.api.auth.check(cred, 'listslices') slices = [] # send the call to the right manager + manager_base = 'sfa.managers' if self.api.interface in ['component']: mgr_type = self.api.config.SFA_CM_TYPE - manager_module = manger_base + ".component_manager_%s" % mgr_type - manager = __import__(manager_module, manager_base) + manager_module = manager_base + ".component_manager_%s" % mgr_type + manager = __import__(manager_module, fromlist=[manager_base]) slices = manager.get_slices(self.api) elif self.api.interface in ['aggregate']: mgr_type = self.api.config.SFA_AGGREGATE_TYPE - manager_module = manger_base + ".agregate_manager_%s" % mgr_type - manager = __import__(manager_module, manager_base) + manager_module = manager_base + ".aggregate_manager_%s" % mgr_type + manager = __import__(manager_module, fromlist=[manager_base]) slices = manager.get_slices(self.api) - elif self.api.interface in ['slicemngr']: + elif self.api.interface in ['slicemgr']: mgr_type = self.api.config.SFA_SM_TYPE - manager_module = manger_base + ".slice_manager_%s" % mgr_type - manager = __import__(manager_module, manager_base) + manager_module = manager_base + ".slice_manager_%s" % mgr_type + manager = __import__(manager_module, fromlist=[manager_base]) slices = manager.get_slices(self.api) return slices