Sha256: 2f335e8bf1bff872e7fb190f728a9ee05ab8f9b8651fa94d4369a3ab18e578d8
Contents?: true
Size: 1.84 KB
Versions: 8
Compression:
Stored size: 1.84 KB
Contents
require 'rest-client' module InsightsCloud module Async class InsightsRulesSync < ::Actions::EntryAction include ::ForemanRhCloud::CloudAuth def plan plan_self plan_resolutions end def plan_resolutions plan_action InsightsResolutionsSync end 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 def logger action_logger end private def query_insights_rules(offset) rules_response = execute_cloud_request( method: :get, url: InsightsCloud.rules_url(offset: offset) ) JSON.parse(rules_response) end def write_rules_page(rules) rules_attributes = rules.map { |rule| to_rule_hash(rule) } InsightsRule.create(rules_attributes) end 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 end end end
Version data entries
8 entries across 8 versions & 1 rubygems