Sha256: e372f4d4fd73002ce1ae01d449b8a9ffe71eceffdb02aa1443f7168b1bac342e
Contents?: true
Size: 1.24 KB
Versions: 16
Compression:
Stored size: 1.24 KB
Contents
require 'rest-client'
module InventorySync
module Async
class QueryInventoryJob < ::Actions::EntryAction
include ActiveSupport::Callbacks
include ::ForemanRhCloud::CloudAuth
define_callbacks :iteration, :step
def run
run_callbacks :iteration do
page = 1
loop do
api_response = query_inventory(page)
results = HostResult.new(api_response)
logger.debug("Downloaded cloud inventory data: #{results.percentage}%")
run_callbacks :step do
results
end
page += 1
break if results.last?
end
end
end
private
def query_inventory(page = 1)
hosts_inventory_response = execute_cloud_request(
method: :get,
url: request_url,
headers: {
params: {
per_page: 100,
page: page,
},
}
)
JSON.parse(hosts_inventory_response)
end
def logger
action_logger
end
def request_url
ForemanInventoryUpload.inventory_export_url
end
def rescue_strategy_for_self
Dynflow::Action::Rescue::Fail
end
end
end
end
Version data entries
16 entries across 16 versions & 1 rubygems