class InsightsCloud::Async::InsightsFullSync
Public Instance Methods
logger()
click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 34 def logger action_logger end
perform_hits_sync()
click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 25 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 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 21 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 76 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 40 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 48 def plan_notifications plan_action InsightsGenerateNotifications end
plan_rules_sync()
click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 44 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 52 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 61 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 80 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
safe_results_match(results_url)
click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 111 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 70 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 89 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 107 def to_rule_id(results_url) URI.decode(safe_results_match(results_url)[:id] || '') end