X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=sfa%2Fmethods%2FListResources.py;h=b7ac0b72c1e53e5ce80e6ac60c4e9c59243463c2;hb=f9ca4f5241efee10e93801df459e0b764cc0d912;hp=6b1e785048c63ce09bddddd954866551bbe26816;hpb=bb57cb30c7cfdddcf8e55fd7084e3cdaf67eaac4;p=sfa.git diff --git a/sfa/methods/ListResources.py b/sfa/methods/ListResources.py index 6b1e7850..b7ac0b72 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,20 +23,23 @@ 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() + origin_hrn = Credential(cred=valid_creds[0]).get_gid_caller().get_hrn() rspec = self.api.manager.ListResources(self.api, creds, options) # filter rspec through sfatables @@ -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')