class InsightsCloud::Async::InsightsFullSync

Public Instance Methods

logger() click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 39
def logger
  action_logger
end
perform_hits_sync() click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 30
def perform_hits_sync
  hits = query_insights_hits

  uuids = hits.map { |hit| hit['uuid'] }
  setup_host_ids(uuids)

  replace_hits_data(hits)
end
plan() click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 8
def plan
  unless cloud_auth_available?
    logger.debug('Cloud authentication is not available, skipping insights sync')
    return
  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
    plan_self
    concurrence do
      plan_rules_sync
      plan_notifications
    end
  end
end
run() click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 26
def run
  perform_hits_sync
end

Private Instance Methods

host_id(uuid) click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 81
def host_id(uuid)
  @host_ids[uuid]
end
plan_hosts_sync() click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 45
def plan_hosts_sync
  plan_action InventorySync::Async::InventoryHostsSync
end
plan_notifications() click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 53
def plan_notifications
  plan_action InsightsGenerateNotifications
end
plan_rules_sync() click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 49
def plan_rules_sync
  plan_action InsightsRulesSync
end
query_insights_hits() click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 57
def query_insights_hits
  hits_response = execute_cloud_request(
    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 66
def query_insights_rules
  rules_response = execute_cloud_request(
    method: :get,
    url: InsightsCloud.rules_url
  )

  JSON.parse(rules_response)
end
replace_hits_data(hits) click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 85
def replace_hits_data(hits)
  InsightsHit.transaction do
    # Reset hit counters to 0, they will be recreated later
    InsightsFacet.unscoped.update_all(hits_count: 0)
    InsightsHit.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 122
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 116
def safe_results_match(results_url)
  match = results_url.match(/\/(?<id>[^\/]*)\/[^\/]*\/\z/)

  match || { id: nil }
end
setup_host_ids(uuids) click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 75
def setup_host_ids(uuids)
  @host_ids = Hash[
    InsightsFacet.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 94
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 112
def to_rule_id(results_url)
  URI.decode(safe_results_match(results_url)[:id] || '')
end