Sha256: 1f84ff9ecc28fd23ce4ae421de6ec5479d47dba5faa0bb7e2c47b695e934486f
Contents?: true
Size: 1.5 KB
Versions: 10
Compression:
Stored size: 1.5 KB
Contents
require 'katello/util/data'
module Katello
module Resources
require 'rest_client'
module Registry
class Proxy
def self.logger
::Foreman::Logging.logger('katello/registry_proxy')
end
def self.get(path, headers = {:accept => :json}, options = {})
logger.debug "Sending GET request to Registry: #{path}"
resource = RegistryResource.load_class
joined_path = resource.prefix.chomp("/") + path
client = resource.rest_client(Net::HTTP::Get, :get, joined_path)
client.options.merge!(options)
client.get(headers)
end
end
class RegistryResource < HttpResource
class << self
def load_class
pulp_primary = ::SmartProxy.pulp_primary
content_app_url = pulp_primary.setting(SmartProxy::PULP3_FEATURE, 'content_app_url')
fail Errors::ContainerRegistryNotConfigured unless content_app_url
uri = URI.parse(content_app_url)
self.prefix = "/pulpcore_registry/"
self.site = "#{uri.scheme}://#{uri.host}:#{uri.port}"
self.ca_cert_file = Setting[:ssl_ca_file]
pulp_primary.pulp3_ssl_configuration(self)
self
end
def process_response(response)
debug_level = response.code >= 400 ? :error : :debug
logger.send(debug_level, "Registry request returned with code #{response.code}")
super
end
end
end
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems