X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=sfa%2Fmethods%2Fdelete_slice.py;h=78baafaca296a7b71e898e3af6ec974083caab3b;hb=11d02cbfd5e91784119bb9377fceb4fa6adae621;hp=02df39b2047b86718a62ad1563110c24a6c996be;hpb=a2e21bef1545bbb68c86ec1a84a611bde7f17a45;p=sfa.git diff --git a/sfa/methods/delete_slice.py b/sfa/methods/delete_slice.py index 02df39b2..78baafac 100644 --- a/sfa/methods/delete_slice.py +++ b/sfa/methods/delete_slice.py @@ -2,34 +2,60 @@ ### $URL$ from sfa.util.faults import * -from sfa.util.misc import * +from sfa.util.namespace import * from sfa.util.method import Method from sfa.util.parameter import Parameter, Mixed from sfa.trust.auth import Auth - -from sfa.util.slices import Slices +from sfa.trust.credential import Credential class delete_slice(Method): """ Remove the slice from all nodes. @param cred credential string specifying the rights of the caller - @param hrn human readable name specifying the slice to delete + @param xrn human readable name specifying the slice to delete (hrn or urn) @return 1 if successful, faults otherwise """ - interfaces = ['aggregate', 'slicemgr'] + interfaces = ['aggregate', 'slicemgr', 'component'] accepts = [ Parameter(str, "Credential string"), - Parameter(str, "Human readable name of slice to delete"), + Parameter(str, "Human readable name of slice to delete (hrn or urn)"), + Mixed(Parameter(str, "Human readable name of the original caller"), + Parameter(None, "Origin hrn not specified")) ] - returns = [Parameter(int, "1 if successful")] + returns = Parameter(int, "1 if successful") - def call(self, cred, hrn): - + def call(self, cred, xrn, origin_hrn=None): + hrn, type = urn_to_hrn(xrn) + 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, hrn, self.name)) + + # validate the credential self.api.auth.check(cred, 'deleteslice') - slices = Slices(self.api) - slices.delete_slice(hrn) + + # 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 = manager_base + ".component_manager_%s" % mgr_type + manager = __import__(manager_module, fromlist=[manager_base]) + manager.delete_slice(self.api, xrn) + elif self.api.interface in ['aggregate']: + mgr_type = self.api.config.SFA_AGGREGATE_TYPE + manager_module = manager_base + ".aggregate_manager_%s" % mgr_type + manager = __import__(manager_module, fromlist=[manager_base]) + manager.delete_slice(self.api, xrn) + elif self.api.interface in ['slicemgr']: + mgr_type = self.api.config.SFA_SM_TYPE + manager_module = manager_base + ".slice_manager_%s" % mgr_type + manager = __import__(manager_module, fromlist=[manager_base]) + manager.delete_slice(self.api, xrn, origin_hrn) + return 1