X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=sfa%2Fmethods%2FDescribe.py;h=b04b3a6e94013f6a28ccf26cd67b97baa8016c69;hb=fd395e1944dcd49f10a4d5b27ce4983ad389fb96;hp=546be22eb970543edecffeb34b672d34cc7a29c3;hpb=02e14469949f7c982cceccafabf796fbe914f492;p=sfa.git diff --git a/sfa/methods/Describe.py b/sfa/methods/Describe.py index 546be22e..b04b3a6e 100644 --- a/sfa/methods/Describe.py +++ b/sfa/methods/Describe.py @@ -4,58 +4,67 @@ from sfa.util.xrn import urn_to_hrn from sfa.util.method import Method from sfa.util.sfatablesRuntime import run_sfatables from sfa.util.faults import SfaInvalidArgument +from sfa.util.sfalogging import logger + from sfa.trust.credential import Credential from sfa.storage.parameter import Parameter, Mixed + class Describe(Method): """ - Retrieve a manifest RSpec describing the resources contained by the - named entities, e.g. a single slice or a set of the slivers in a - slice. This listing and description should be sufficiently - descriptive to allow experimenters to use the resources. + Retrieve a manifest RSpec describing the resources contained by the + named entities, e.g. a single slice or a set of the slivers in a + slice. This listing and description should be sufficiently + descriptive to allow experimenters to use the resources. @param credential list @param options dictionary @return dict """ interfaces = ['aggregate', 'slicemgr'] accepts = [ - Mixed(Parameter(str, "Credential string"), + Parameter(type([str]), "List of URNs"), + Mixed(Parameter(str, "Credential string"), Parameter(type([str]), "List of credentials")), Parameter(dict, "Options") - ] + ] returns = Parameter(str, "List of resources") - def call(self, creds, options): - self.api.logger.info("interface: %s\tmethod-name: %s" % (self.api.interface, self.name)) - + def call(self, urns, creds, options): + 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') - - # Find the valid credentials - valid_creds = self.api.auth.checkCredentials(creds, 'listnodes') + raise SfaInvalidArgument( + 'Must specify an rspec version option. geni_rspec_version cannot be null') + valid_creds = self.api.auth.checkCredentialsSpeaksFor( + creds, 'listnodes', urns, + check_sliver_callback=self.api.driver.check_sliver_credentials, + options=options) - # get hrn of the original caller + # 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() desc = self.api.manager.Describe(self.api, creds, urns, options) - # filter rspec through sfatables + # filter rspec through sfatables if self.api.interface in ['aggregate']: chain_name = 'OUTGOING' - elif self.api.interface in ['slicemgr']: + elif self.api.interface in ['slicemgr']: chain_name = 'FORWARD-OUTGOING' - self.api.logger.debug("ListResources: sfatables on chain %s"%chain_name) - desc['geni_rspec'] = run_sfatables(chain_name, '', origin_hrn, desc['geni_rspec']) - - if options.has_key('geni_compressed') and options['geni_compressed'] == True: - desc['geni_rspec'] = zlib.compress(desc['geni_rspec']).encode('base64') - - return desc - - + logger.debug( + "ListResources: sfatables on chain %s" % chain_name) + desc['geni_rspec'] = run_sfatables( + chain_name, '', origin_hrn, desc['geni_rspec']) + + if 'geni_compressed' in options and options['geni_compressed'] == True: + desc['geni_rspec'] = zlib.compress( + desc['geni_rspec']).encode('base64') + + return desc