Sha256: 772905ca6f5a7da072d20ad53457fc0f2510ae2cfb6bb4cbe87622c9a08606ad
Contents?: true
Size: 1.6 KB
Versions: 119
Compression:
Stored size: 1.6 KB
Contents
module Katello
module Resources
module Candlepin
class Proxy
def self.logger
::Foreman::Logging.logger('katello/cp_proxy')
end
def self.post(path, body)
logger.debug "Sending POST request to Candlepin: #{path}"
client = CandlepinResource.rest_client(Net::HTTP::Post, :post, path_with_cp_prefix(path))
client.post body, {:accept => :json, :content_type => :json}.merge(User.cp_oauth_header)
end
def self.delete(path, body = nil)
logger.debug "Sending DELETE request to Candlepin: #{path}"
client = CandlepinResource.rest_client(Net::HTTP::Delete, :delete, path_with_cp_prefix(path))
# Some candlepin calls will set the body in DELETE requests.
client.options[:payload] = body unless body.nil?
client.delete({:accept => :json, :content_type => :json}.merge(User.cp_oauth_header))
end
def self.get(path)
logger.debug "Sending GET request to Candlepin: #{path}"
client = CandlepinResource.rest_client(Net::HTTP::Get, :get, path_with_cp_prefix(path))
client.get({:accept => :json}.merge(User.cp_oauth_header))
end
def self.put(path, body)
logger.debug "Sending PUT request to Candlepin: #{path}"
client = CandlepinResource.rest_client(Net::HTTP::Put, :put, path_with_cp_prefix(path))
client.put body, {:accept => :json, :content_type => :json}.merge(User.cp_oauth_header)
end
def self.path_with_cp_prefix(path)
CandlepinResource.prefix + path
end
end
end
end
end
Version data entries
119 entries across 119 versions & 1 rubygems