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 86 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 = RestClient::Request.execute( method: :get, url: InsightsCloud.hits_export_url, verify_ssl: ForemanRhCloud.verify_ssl_method, proxy: ForemanRhCloud.transformed_http_proxy_string(logger: logger), headers: { Authorization: "Bearer #{rh_credentials}", } ) 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 = RestClient::Request.execute( method: :get, url: InsightsCloud.rules_url, verify_ssl: ForemanRhCloud.verify_ssl_method, proxy: ForemanRhCloud.transformed_http_proxy_string(logger: logger), headers: { Authorization: "Bearer #{rh_credentials}", } ) JSON.parse(rules_response) end
replace_hits_data(hits)
click to toggle source
# File lib/insights_cloud/async/insights_full_sync.rb, line 90 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 121 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 80 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 99 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 117 def to_rule_id(results_url) URI.decode(safe_results_match(results_url)[:id] || '') end