X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=sfa%2Fmethods%2FListResources.py;h=41676e698381f99659296b60a9db78c0632db12b;hb=02a4a59a4a49183ec8c631cc03243b97f4602d50;hp=a12447f628851e337231b7d056362899bef570e9;hpb=89d0fa4efde57cb62445af75c16bdc42bc03693a;p=sfa.git diff --git a/sfa/methods/ListResources.py b/sfa/methods/ListResources.py index a12447f6..41676e69 100644 --- a/sfa/methods/ListResources.py +++ b/sfa/methods/ListResources.py @@ -1,10 +1,12 @@ import zlib - +import sys from sfa.util.xrn import urn_to_hrn from sfa.util.method import Method -from sfa.util.parameter import Parameter, Mixed -from sfa.trust.credential import Credential from sfa.util.sfatablesRuntime import run_sfatables +from sfa.util.faults import SfaInvalidArgument +from sfa.trust.credential import Credential + +from sfa.storage.parameter import Parameter, Mixed class ListResources(Method): """ @@ -17,14 +19,20 @@ class ListResources(Method): accepts = [ Mixed(Parameter(str, "Credential string"), Parameter(type([str]), "List of credentials")), - Parameter(dict, "Options"), - Parameter(str, "call_id"), + Parameter(dict, "Options") ] returns = Parameter(str, "List of resources") - def call(self, creds, options, call_id=""): + def call(self, creds, options): self.api.logger.info("interface: %s\tmethod-name: %s" % (self.api.interface, self.name)) - + + # client must specify a version + if not options.get('geni_rspec_version'): + if options.get('rspec_version'): + options['geni_rspec_version'] = options['rspec_version'] + else: + raise SfaInvalidArgument('Must specify an rspec version option. geni_rspec_version cannot be null') + # get slice's hrn from options xrn = options.get('geni_slice_urn', '') (hrn, _) = urn_to_hrn(xrn) @@ -34,16 +42,19 @@ class ListResources(Method): # get hrn of the original caller origin_hrn = options.get('origin_hrn', None) + if not origin_hrn: origin_hrn = Credential(string=valid_creds[0]).get_gid_caller().get_hrn() - rspec = self.api.manager.ListResources(self.api, creds, options, call_id) + print >>sys.stderr, " \r\n \r\n \t Lsitresources.py call :self.api.interface %s origin_hrn %s options %s \r\n \t creds %s " %(self.api.interface,origin_hrn,options, creds) + rspec = self.api.manager.ListResources(self.api, creds, options) # filter rspec through sfatables if self.api.interface in ['aggregate']: chain_name = 'OUTGOING' elif self.api.interface in ['slicemgr']: chain_name = 'FORWARD-OUTGOING' - self.api.logger.debug("ListResources: sfatables on chain %s"%chain_name) + self.api.logger.debug("ListResources: sfatables on chain %s"%chain_name) + print >>sys.stderr, " \r\n \r\n \t Listresources.py call : chain_name %s hrn %s origine_hrn %s " %(chain_name, hrn, origin_hrn) filtered_rspec = run_sfatables(chain_name, hrn, origin_hrn, rspec) if options.has_key('geni_compressed') and options['geni_compressed'] == True: