Sha256: f4ba43a1656c2408d1b566223cdb5870a1b88da27eda8de2423cd37bd020613c
Contents?: true
Size: 1.82 KB
Versions: 77
Compression:
Stored size: 1.82 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, extra_headers = {})
logger.debug "Sending GET request to Candlepin: #{path}"
client = CandlepinResource.rest_client(Net::HTTP::Get, :get, path_with_cp_prefix(path))
client.get(extra_headers.merge!(default_request_headers))
rescue RestClient::NotModified => e
e.response
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
def self.default_request_headers
@default_request_headers ||= User.cp_oauth_header.merge(accept: :json)
end
end
end
end
end
Version data entries
77 entries across 77 versions & 1 rubygems