class InsightsCloud::Async::InsightsFullSync
Public Instance Methods
logger()
click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 50 def logger action_logger end
perform_hits_sync(organization)
click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 41 def perform_hits_sync(organization) hits = query_insights_hits(organization) uuids = hits.map { |hit| hit['uuid'] } setup_host_ids(uuids, organization) replace_hits_data(hits, organization) end
plan(organizations)
click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 8 def plan(organizations) organizations = organizations.select do |organization| if cert_auth_available?(organization) true else logger.debug("Certificate is not available for org: #{organization.name}, skipping insights sync") false end end sequence do # This can be turned off when we enable automatic status syncs # This step will query cloud inventory to retrieve inventory uuids for each host plan_hosts_sync(organizations) plan_self(organization_ids: organizations.map(&:id)) concurrence do plan_rules_sync(organizations) plan_notifications end end end
run()
click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 30 def run organizations.each do |organization| unless cert_auth_available?(organization) logger.debug("Certificate is not available for org: #{organization.name}, skipping insights sync") next end perform_hits_sync(organization) end end
Private Instance Methods
host_id(uuid)
click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 93 def host_id(uuid) @host_ids[uuid] end
organizations()
click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 138 def organizations @organizations ||= Organization.where(id: input[:organization_ids]) end
plan_hosts_sync(organizations)
click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 56 def plan_hosts_sync(organizations) plan_action(InventorySync::Async::InventoryHostsSync, organizations) end
plan_notifications()
click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 64 def plan_notifications plan_action InsightsGenerateNotifications end
plan_rules_sync(organizations)
click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 60 def plan_rules_sync(organizations) plan_action(InsightsRulesSync, organizations) end
query_insights_hits(organization)
click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 68 def query_insights_hits(organization) hits_response = execute_cloud_request( organization: organization, method: :get, url: InsightsCloud.hits_export_url ) JSON.parse(hits_response) end
query_insights_rules()
click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 78 def query_insights_rules rules_response = execute_cloud_request( method: :get, url: InsightsCloud.rules_url ) JSON.parse(rules_response) end
replace_hits_data(hits, organization)
click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 97 def replace_hits_data(hits, organization) InsightsHit.transaction do # Reset hit counters to 0, they will be recreated later InsightsFacet.for_organizations(organization.id).update_all(hits_count: 0) InsightsHit.for_organizations(organization.id).delete_all InsightsHit.create(hits.map { |hits_hash| to_model_hash(hits_hash) }.compact) end end
rescue_strategy_for_self()
click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 134 def rescue_strategy_for_self Dynflow::Action::Rescue::Fail end
safe_results_match(results_url)
click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 128 def safe_results_match(results_url) match = results_url.match(/\/(?<id>[^\/]*)\/[^\/]*\/\z/) match || { id: nil } end
setup_host_ids(uuids, organization)
click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 87 def setup_host_ids(uuids, organization) @host_ids = Hash[ InsightsFacet.for_organizations(organization.id).where(uuid: uuids).pluck(:uuid, :host_id) ] end
to_model_hash(hit_hash)
click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 106 def to_model_hash(hit_hash) hit_host_id = host_id(hit_hash['uuid']) return unless hit_host_id { host_id: hit_host_id, last_seen: DateTime.parse(hit_hash['last_seen']), publish_date: DateTime.parse(hit_hash['publish_date']), title: hit_hash['title'], solution_url: hit_hash['solution_url'], total_risk: hit_hash['total_risk'].to_i, likelihood: hit_hash['likelihood'].to_i, results_url: hit_hash['results_url'], rule_id: to_rule_id(hit_hash['results_url']), } end
to_rule_id(results_url)
click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 124 def to_rule_id(results_url) URI.decode(safe_results_match(results_url)[:id] || '') end