Sha256: ccf484e352afb3606b1d15cc71d1fbfc552909910749a5583bc5700e230a428c
Contents?: true
Size: 1.6 KB
Versions: 76
Compression:
Stored size: 1.6 KB
Contents
require 'puppet/indirector/rest'
require 'semantic_puppet'
class Puppet::Transaction::Report::Rest < Puppet::Indirector::REST
desc "Get server report over HTTP via REST."
use_server_setting(:report_server)
use_port_setting(:report_port)
use_srv_service(:report)
def save(request)
return super unless use_http_client?
session = Puppet.lookup(:http_session)
api = session.route_to(:report)
response = api.put_report(
request.key,
request.instance,
environment: request.environment.to_s
)
content_type, body = parse_response(response)
deserialize_save(content_type, body)
rescue Puppet::HTTP::ResponseError => e
return nil if e.response.code == 404
raise convert_to_http_error(e.response.nethttp)
end
# This is called by the superclass when not using our httpclient.
def handle_response(request, response)
if !response.is_a?(Net::HTTPSuccess)
server_version = response[Puppet::Network::HTTP::HEADER_PUPPET_VERSION]
if server_version &&
SemanticPuppet::Version.parse(server_version).major < Puppet::Indirector::REST::MAJOR_VERSION_JSON_DEFAULT &&
Puppet[:preferred_serialization_format] != 'pson'
format = Puppet[:preferred_serialization_format]
raise Puppet::Error.new(_("Server version %{version} does not accept reports in '%{format}', use `preferred_serialization_format=pson`") % {version: server_version, format: format})
end
end
end
private
def deserialize_save(content_type, body)
format = Puppet::Network::FormatHandler.format_for(content_type)
format.intern(Array, body)
end
end
Version data entries
76 entries across 76 versions & 1 rubygems