Sha256: 995c9cbd177cfb5ee490f860159240d4f4ba97cadba71bddbda17b67bb7fee3c
Contents?: true
Size: 1.83 KB
Versions: 35
Compression:
Stored size: 1.83 KB
Contents
module Fog
module OpenStack
module Auth
module Catalog
attr_reader :payload
class CatalogError < RuntimeError; end
class EndpointError < RuntimeError; end
class ServiceTypeError < RuntimeError; end
def initialize(payload)
@payload = payload
end
def get_endpoint_url(names, interfaces, region = nil)
# TODO: Inject OpenStack Service Types Authority
names_list = if names.kind_of?(String)
[names]
else
names
end
entries = get_by_type(names_list)
raise ServiceTypeError, 'No endpoint match' if entries.empty?
interfaces_list = if interfaces.kind_of?(String)
[interfaces]
else
interfaces
end
list = []
interfaces_list.each do |interface|
val = get_endpoint(entries, interface, region)
list << val if val
end
raise EndpointError, 'No endpoint found' if list.empty?
list[0]
end
private
def get_by_type(names)
raise CatalogError, 'Empty content' unless @payload
@payload.select do |e|
names.include?(e['type'])
end
end
def get_endpoint(entries, interface, region)
list = []
entries.each do |type|
next unless type.key?('endpoints')
type['endpoints'].each do |endpoint|
list << endpoint_url(endpoint, interface) if endpoint_match?(endpoint, interface, region)
end
end
raise EndpointError, 'Multiple endpoints found' if list.size > 1
list[0]
end
end
end
end
end
Version data entries
35 entries across 35 versions & 3 rubygems