|
class ReportImporter
|
|
delegate :logger, :to => :Rails
|
|
attr_reader :report
|
|
|
|
def self.import(raw, proxy_id = nil)
|
|
importer = new(raw, proxy_id)
|
|
importer.import
|
|
importer.report
|
|
end
|
|
|
|
def self.report_features
|
|
['Puppet', 'Chef Proxy']
|
|
end
|
|
|
|
def initialize(raw, proxy_id = nil)
|
|
raise ::Foreman::Exception.new(_('Invalid report')) unless raw.is_a?(Hash)
|
|
@raw = raw
|
|
@proxy_id = proxy_id
|
|
end
|
|
|
|
def import
|
|
start_time = Time.now
|
|
logger.info "processing report for #{name}"
|
|
logger.debug { "Report: #{raw.inspect}" }
|
|
|
|
if host.new_record? && !Setting[:create_new_host_when_report_is_uploaded]
|
|
logger.info("skipping report for #{name} as its an unknown host and create_new_host_when_report_is_uploaded setting is disabled")
|
|
return Report.new
|
|
end
|
|
|
|
# convert report status to bit field
|
|
st = ReportStatusCalculator.new(:counters => raw['status']).calculate
|
|
|
|
# we update our host record, so we won't need to lookup the report information just to display the host list / info
|
|
host.last_report = time if host.last_report.nil? or host.last_report.utc < time
|
|
|
|
# if proxy authentication is enabled and we have no puppet proxy set, use it.
|
|
host.puppet_proxy_id ||= proxy_id
|
|
|
|
# we save the host without validation for two reasons:
|
|
# 1. It might be auto imported, therefore might not be valid (e.g. missing partition table etc)
|
|
# 2. We want this to be fast and light on the db.
|
|
# at this point, the report is important, not the host
|
|
host.save(:validate => false)
|
|
|
|
# and save our report
|
|
@report = Report.new(:host => host, :reported_at => time, :status => st, :metrics => raw['metrics'])
|
|
return report unless report.save
|
|
# Store all Puppet message logs
|
|
import_log_messages
|
|
# Check for errors
|
|
inspect_report
|
|
logger.info("Imported report for #{name} in #{(Time.now - start_time).round(2)} seconds")
|
|
|
|
host.refresh_statuses
|
|
end
|
|
|
|
private
|
|
|
|
attr_reader :raw, :proxy_id
|
|
|
|
def name
|
|
@name ||= raw['host']
|
|
end
|
|
|
|
def host
|
|
@host ||= Host::Base.find_by_certname(name) ||
|
|
Host::Base.find_by_name(name) ||
|
|
Host::Managed.new(:name => name)
|
|
end
|
|
|
|
def time
|
|
@time ||= Time.parse(raw['reported_at']).utc
|
|
end
|
|
|
|
def logs
|
|
raw['logs'] || []
|
|
end
|
|
|
|
def import_log_messages
|
|
logs.each do |log|
|
|
# Parse the API format
|
|
level = log['log']['level']
|
|
msg = log['log']['messages']['message']
|
|
src = log['log']['sources']['source']
|
|
|
|
message = Message.find_or_create msg
|
|
source = Source.find_or_create src
|
|
|
|
# Symbols get turned into strings via the JSON API, so convert back here if it matches
|
|
# and expected log level. Log objects can't be created without one, so raise if not
|
|
raise(::Foreman::Exception.new(N_("Invalid log level: %s", level))) unless Report::LOG_LEVELS.include?(level)
|
|
|
|
Log.create(:message_id => message.id, :source_id => source.id, :report => report, :level => level.to_sym)
|
|
end
|
|
end
|
|
|
|
def inspect_report
|
|
if report.error?
|
|
# found a report with errors
|
|
# notify via email IF enabled is set to true
|
|
|
|
if host.disabled?
|
|
logger.warn "#{name} is disabled - skipping alert"
|
|
return
|
|
end
|
|
|
|
owners = host.owner.present? ? host.owner.recipients_for(:puppet_error_state) : []
|
|
if owners.present?
|
|
logger.debug "sending alert to #{owners.map(&:login).join(',')}"
|
|
MailNotification[:puppet_error_state].deliver(report, :users => owners)
|
|
else
|
|
logger.debug "no owner or recipients for alert on #{name}"
|
|
end
|
|
end
|
|
end
|
|
end
|
