hrn, type = urn_to_hrn(xrn)
self.api.auth.check(cred, 'list')
aggregates = Aggregates(self.api)
- hrn_list = []
- if hrn:
- if isinstance(hrn, StringTypes):
- hrn_list = [hrn]
- elif isinstance(hrn, list):
- hrn_list = hrn
-
- if not hrn_list:
- interfaces = aggregates.interfaces.keys()
- else:
- interfaces = [interface for interface in aggregates.interfaces if interface in hrn_list]
-
- return interfaces
+ return aggregates.interfaces.values()
hrn, type = urn_to_hrn(xrn)
self.api.auth.check(cred, 'list')
registries = Registries(self.api)
- hrn_list = []
- if hrn:
- if isinstance(hrn, StringTypes):
- hrn_list = [hrn]
- elif isinstance(hrn, list):
- hrn_list = hrn
-
- if not hrn_list:
- interfaces = registries.interfaces.keys()
- else:
- interfaces = [interface for interface in registries.interfaces if interface in hrn_list]
-
- return interfaces
+ return registries.interfaces.values()
from sfa.util.server import SfaServer
from sfa.util.faults import *
+from sfa.util.namespace import hrn_to_urn
from sfa.server.interface import Interfaces
import sfa.util.xmlrpcprotocol as xmlrpcprotocol
import sfa.util.soapprotocol as soapprotocol
address = self.api.config.SFA_AGGREGATE_HOST
port = self.api.config.SFA_AGGREGATE_PORT
url = 'http://%(address)s:%(port)s' % locals()
- local_aggregate = {'hrn': self.api.hrn, 'addr': address, 'port': port}
+ local_aggregate = {'hrn': self.api.hrn,
+ 'urn': hrn_to_urn(self.api.hrn, 'authority'),
+ 'addr': address,
+ 'port': port,
+ 'url': url}
self.interfaces[self.api.hrn] = local_aggregate
# get connections
interfaces = self.interface_info.values()[0].values()[0]
if not isinstance(interfaces, list):
interfaces = [self.interfaces]
+ # set the url and urn
+ for interface in interfaces:
+ hrn, address, port = interface['hrn'], interface['addr'], interface['port']
+ url = 'http://%(address)s:%(port)s' % locals()
+ interface['url'] = url
+ interface['urn'] = hrn_to_urn(hrn, 'authority')
+
self.interfaces = {}
required_fields = self.default_fields.keys()
for interface in interfaces:
required_fields = self.default_fields.keys()
for interface in self.interfaces.values():
# make sure the required fields are present and not null
- if not all([interface.get(key) for key in required_fields]):
- continue
-
- hrn, address, port = interface['hrn'], interface['addr'], interface['port']
- url = 'http://%(address)s:%(port)s' % locals()
+ url = interface['url']
# check which client we should use
# sfa.util.xmlrpcprotocol is default
client_type = 'xmlrpcprotocol'
client_type = 'geniclientlight'
connections[hrn] = GeniClientLight(url, self.api.key_file, self.api.cert_file)
else:
- connections[hrn] = xmlrpcprotocol.get_server(url, self.api.key_file, self.api.cert_file)
+ connections[interface['hrn']] = xmlrpcprotocol.get_server(url, self.api.key_file, self.api.cert_file)
return connections
from sfa.util.server import SfaServer
from sfa.util.faults import *
+from sfa.util.namespace import hrn_to_urn
from sfa.server.interface import Interfaces
import sfa.util.xmlrpcprotocol as xmlrpcprotocol
import sfa.util.soapprotocol as soapprotocol
address = self.api.config.SFA_REGISTRY_HOST
port = self.api.config.SFA_REGISTRY_PORT
url = 'http://%(address)s:%(port)s' % locals()
- local_registry = {'hrn': self.api.hrn, 'addr': address, 'port': port}
+ local_registry = {'hrn': self.api.hrn,
+ 'urn': hrn_to_urn(self.api.hrn, 'authority'),
+ 'addr': address,
+ 'port': port,
+ 'url': url}
self.interfaces[self.api.hrn] = local_registry
# get connections
#
+from sfa.trust.certificate import Keypair, Certificate
from sfa.trust.credential import Credential
from sfa.trust.trustedroot import TrustedRootList
from sfa.util.faults import *