X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;ds=sidebyside;f=sfa%2Fmethods%2Flist.py;h=a1397040c1fc1bc9b819e3ff2eaf05ac5665454a;hb=07c8328ae960412c81ed60ddc49cb6800c530135;hp=75327f22446b69bad77ab22c1cded118b5b48293;hpb=eddcc8a722b907cd4b1df9fb3ee6964d15b94ea0;p=sfa.git diff --git a/sfa/methods/list.py b/sfa/methods/list.py index 75327f22..a1397040 100644 --- a/sfa/methods/list.py +++ b/sfa/methods/list.py @@ -24,19 +24,20 @@ class list(Method): accepts = [ Parameter(str, "Credential string"), Parameter(str, "Human readable name (hrn)"), - Parameter(str, "Request hash") + Mixed(Parameter(str, "Request hash"), + Parameter(None, "Request hash not specified")) ] returns = [GeniRecord] - def call(self, cred, hrn, request_hash, caller_cred=None): + def call(self, cred, hrn, request_hash=None, origin_hrn=None): self.api.auth.authenticateCred(cred, [cred, hrn], request_hash) self.api.auth.check(cred, 'list') - if caller_cred==None: - caller_cred=cred + if origin_hrn==None: + origin_hrn=Credential(string=cred).get_gid_caller().get_hrn() #log the call - self.api.logger.info("interface: %s\tcaller-hrn: %s\ttarget-hrn: %s\tmethod-name: %s"%(self.api.interface, Credential(string=caller_cred).get_gid_caller().get_hrn(), hrn, self.name)) + self.api.logger.info("interface: %s\tcaller-hrn: %s\ttarget-hrn: %s\tmethod-name: %s"%(self.api.interface, origin_hrn, hrn, self.name)) records = [] # load all know registry names into a prefix tree and attempt to find @@ -56,12 +57,17 @@ class list(Method): if registry_hrn != self.api.hrn: credential = self.api.getCredential() try: - record_list = registries[registry_hrn].list(credential, hrn, caller_cred=caller_cred) - records = [record.as_dict() for record in record_list] - if records: - return records + request_hash=None + record_list = registries[registry_hrn].list(credential, hrn, request_hash, origin_hrn) + records = [GeniRecord(dict=record).as_dict() for record in record_list] except: - pass + arg_list = [credential, hrn] + request_hash = self.api.key.compute_hash(arg_list) + record_list = registries[registry_hrn].list(credential, hrn, request_hash, origin_hrn) + records = [GeniRecord(dict=record).as_dict() for record in record_list] + + if records: + return records # if we still havnt found the record yet, try the local registry if not self.api.auth.hierarchy.auth_exists(hrn):