X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=sfa%2Fmethods%2FListResources.py;h=c05d697704f6814e8c60f389c8c1cb9887353e14;hb=db5e2034e15c72434fdf67ee40d32b980f971705;hp=38634de92ce8737a740fb4ff3b967f2666e636e2;hpb=6cb4717ad2a1ff4a08d73c7cc0dea759f12ab6d5;p=sfa.git diff --git a/sfa/methods/ListResources.py b/sfa/methods/ListResources.py index 38634de9..c05d6977 100644 --- a/sfa/methods/ListResources.py +++ b/sfa/methods/ListResources.py @@ -2,13 +2,15 @@ import zlib 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): """ - Returns information about available resources or resources allocated to this slice + Returns information about available resources @param credential list @param options dictionary @return string @@ -21,21 +23,24 @@ class ListResources(Method): ] returns = Parameter(str, "List of resources") - def call(self, creds, options={}): + def call(self, creds, options): self.api.logger.info("interface: %s\tmethod-name: %s" % (self.api.interface, self.name)) - - # get slice's hrn from options - xrn = options.get('geni_slice_urn', '') - (hrn, _) = urn_to_hrn(xrn) - + + # 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') + # Find the valid credentials - valid_creds = self.api.auth.checkCredentials(creds, 'listnodes', hrn) + valid_creds = self.api.auth.checkCredentials(creds, 'listnodes') # 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, options) + rspec = self.api.manager.ListResources(self.api, creds, options) # filter rspec through sfatables if self.api.interface in ['aggregate']: @@ -43,7 +48,7 @@ class ListResources(Method): elif self.api.interface in ['slicemgr']: chain_name = 'FORWARD-OUTGOING' self.api.logger.debug("ListResources: sfatables on chain %s"%chain_name) - filtered_rspec = run_sfatables(chain_name, hrn, origin_hrn, rspec) + filtered_rspec = run_sfatables(chain_name, '', origin_hrn, rspec) if options.has_key('geni_compressed') and options['geni_compressed'] == True: filtered_rspec = zlib.compress(filtered_rspec).encode('base64')