FM / novaclient

/usr/lib/python2.6/site-packages/novaclient/

/usr/lib/python2.6/site-packages/novaclient

Name	Size	Mode	Actions
openstack/	-	0755	rm
tests/	-	0755	rm
v1_1/	-	0755	rm
v2/	-	0755	rm
api_versions.py	13552	0644	edit dl rm
api_versions.pyc	13706	0644	edit dl rm
auth_plugin.py	4946	0644	edit dl rm
auth_plugin.pyc	5784	0644	edit dl rm
base.py	10869	0644	edit dl rm
base.pyc	9983	0644	edit dl rm
client.py	31586	0644	edit dl rm
client.pyc	25901	0644	edit dl rm
crypto.py	1293	0644	edit dl rm
crypto.pyc	1123	0644	edit dl rm
exceptions.py	7227	0644	edit dl rm
exceptions.pyc	11816	0644	edit dl rm
extension.py	1471	0644	edit dl rm
extension.pyc	1569	0644	edit dl rm
i18n.py	1144	0644	edit dl rm
i18n.pyc	561	0644	edit dl rm
service_catalog.py	3521	0644	edit dl rm
service_catalog.pyc	2697	0644	edit dl rm
shell.py	36007	0644	edit dl rm
shell.pyc	25914	0644	edit dl rm
utils.py	12205	0644	edit dl rm
utils.pyc	12505	0644	edit dl rm
__init__.py	839	0644	edit dl rm
__init__.pyc	467	0644	edit dl rm

Edit: /usr/lib/python2.6/site-packages/novaclient/service_catalog.py (3521B)

import novaclient.exceptions

class ServiceCatalog(object):
    """Helper methods for dealing with a Keystone Service Catalog."""

def __init__(self, resource_dict):
        self.catalog = resource_dict

def get_token(self):
        return self.catalog['access']['token']['id']

def get_tenant_id(self):
        return self.catalog['access']['token']['tenant']['id']

def url_for(self, attr=None, filter_value=None,
                service_type=None, endpoint_type='publicURL',
                service_name=None, volume_service_name=None):
        """Fetch the public URL from the Compute service for
        a particular endpoint attribute. If none given, return
        the first. See tests for sample service catalog.
        """
        matching_endpoints = []
        if 'endpoints' in self.catalog:
            # We have a bastardized service catalog. Treat it special. :/
            for endpoint in self.catalog['endpoints']:
                if not filter_value or endpoint[attr] == filter_value:
                    # Ignore 1.0 compute endpoints
                    if endpoint.get("type") == 'compute' and \
                            endpoint.get('versionId') in (None, '1.1', '2'):
                        matching_endpoints.append(endpoint)
            if not matching_endpoints:
                raise novaclient.exceptions.EndpointNotFound()

# We don't always get a service catalog back ...
        if 'serviceCatalog' not in self.catalog['access']:
            return None

# Full catalog ...
        catalog = self.catalog['access']['serviceCatalog']

for service in catalog:
            if service.get("type") != service_type:
                continue

if (service_name and service_type == 'compute' and
                    service.get('name') != service_name):
                continue

if (volume_service_name and service_type == 'volume' and
                    service.get('name') != volume_service_name):
                continue

endpoints = service['endpoints']
            for endpoint in endpoints:
                # Ignore 1.0 compute endpoints
                if (service.get("type") == 'compute' and
                        endpoint.get('versionId', '2') not in ('1.1', '2')):
                    continue
                if (not filter_value or
                        endpoint.get(attr).lower() == filter_value.lower()):
                    endpoint["serviceName"] = service.get("name")
                    matching_endpoints.append(endpoint)

if not matching_endpoints:
            raise novaclient.exceptions.EndpointNotFound()
        elif len(matching_endpoints) > 1:
            raise novaclient.exceptions.AmbiguousEndpoints(
                endpoints=matching_endpoints)
        else:
            return matching_endpoints[0][endpoint_type]

# Copyright 2011 OpenStack Foundation # Copyright 2011, Piston Cloud Computing, Inc. # # All Rights Reserved. # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. import novaclient.exceptions class ServiceCatalog(object): """Helper methods for dealing with a Keystone Service Catalog.""" def __init__(self, resource_dict): self.catalog = resource_dict def get_token(self): return self.catalog['access']['token']['id'] def get_tenant_id(self): return self.catalog['access']['token']['tenant']['id'] def url_for(self, attr=None, filter_value=None, service_type=None, endpoint_type='publicURL', service_name=None, volume_service_name=None): """Fetch the public URL from the Compute service for a particular endpoint attribute. If none given, return the first. See tests for sample service catalog. """ matching_endpoints = [] if 'endpoints' in self.catalog: # We have a bastardized service catalog. Treat it special. :/ for endpoint in self.catalog['endpoints']: if not filter_value or endpoint[attr] == filter_value: # Ignore 1.0 compute endpoints if endpoint.get("type") == 'compute' and \ endpoint.get('versionId') in (None, '1.1', '2'): matching_endpoints.append(endpoint) if not matching_endpoints: raise novaclient.exceptions.EndpointNotFound() # We don't always get a service catalog back ... if 'serviceCatalog' not in self.catalog['access']: return None # Full catalog ... catalog = self.catalog['access']['serviceCatalog'] for service in catalog: if service.get("type") != service_type: continue if (service_name and service_type == 'compute' and service.get('name') != service_name): continue if (volume_service_name and service_type == 'volume' and service.get('name') != volume_service_name): continue endpoints = service['endpoints'] for endpoint in endpoints: # Ignore 1.0 compute endpoints if (service.get("type") == 'compute' and endpoint.get('versionId', '2') not in ('1.1', '2')): continue if (not filter_value or endpoint.get(attr).lower() == filter_value.lower()): endpoint["serviceName"] = service.get("name") matching_endpoints.append(endpoint) if not matching_endpoints: raise novaclient.exceptions.EndpointNotFound() elif len(matching_endpoints) > 1: raise novaclient.exceptions.AmbiguousEndpoints( endpoints=matching_endpoints) else: return matching_endpoints[0][endpoint_type]