class InsightsCloud::Async::InsightsRulesSync
Public Instance Methods
logger()
click to toggle source
# File lib/insights_cloud/async/insights_rules_sync.rb, line 42 def logger action_logger end
plan()
click to toggle source
# File lib/insights_cloud/async/insights_rules_sync.rb, line 8 def plan unless cloud_auth_available? logger.debug('Cloud authentication is not available, skipping rules sync') return end # since the tasks are not connected, we need to force sequence execution here # to make sure we don't run resolutions until we synced all our rules sequence do plan_self plan_resolutions end end
plan_resolutions()
click to toggle source
# File lib/insights_cloud/async/insights_rules_sync.rb, line 22 def plan_resolutions plan_action InsightsResolutionsSync end
run()
click to toggle source
# File lib/insights_cloud/async/insights_rules_sync.rb, line 26 def run offset = 0 InsightsRule.transaction do InsightsRule.delete_all loop do api_response = query_insights_rules(offset) results = RulesResult.new(api_response) logger.debug("Downloaded #{offset + results.count} of #{results.total}") write_rules_page(results.rules) offset += results.count output[:rules_count] = results.total break if offset >= results.total end end end
Private Instance Methods
query_insights_rules(offset)
click to toggle source
# File lib/insights_cloud/async/insights_rules_sync.rb, line 48 def query_insights_rules(offset) rules_response = execute_cloud_request( method: :get, url: InsightsCloud.rules_url(offset: offset) ) JSON.parse(rules_response) end
rescue_strategy_for_self()
click to toggle source
# File lib/insights_cloud/async/insights_rules_sync.rb, line 79 def rescue_strategy_for_self Dynflow::Action::Rescue::Fail end
to_rule_hash(rule_hash)
click to toggle source
# File lib/insights_cloud/async/insights_rules_sync.rb, line 63 def to_rule_hash(rule_hash) { rule_id: rule_hash['rule_id'], description: rule_hash['description'], category_name: rule_hash.dig('category', 'name'), impact_name: rule_hash.dig('impact', 'name'), summary: rule_hash['summary'], generic: rule_hash['generic'], reason: rule_hash['reason'], total_risk: rule_hash['total_risk'], reboot_required: rule_hash['reboot_required'], more_info: rule_hash['more_info'], rating: rule_hash['rating'], } end
write_rules_page(rules)
click to toggle source
# File lib/insights_cloud/async/insights_rules_sync.rb, line 57 def write_rules_page(rules) rules_attributes = rules.map { |rule| to_rule_hash(rule) } InsightsRule.create(rules_attributes) end