Generate single-host reports without shell commands or rake task

Author: jeremylenz

app/controllers/concerns/insights_cloud/package_profile_upload_extensions.rb

@@ -15,11 +15,10 @@ def generate_host_report
       logger.debug("Generating host-specific report for host #{@host.name}")
 
       ForemanTasks.async_task(
-        ForemanInventoryUpload::Async::GenerateReportJob,
+        ForemanInventoryUpload::Async::SingleHostReportJob,
         ForemanInventoryUpload.generated_reports_folder,
         @host.organization_id,
-        false,
-        "id=#{@host.id}"
+        @host.id
       )
 
       # in IoP case, the hosts are identified by the sub-man ID, and we can assume they already

lib/foreman_inventory_upload/async/generate_single_host_report.rb

@@ -0,0 +1,20 @@
+module ForemanInventoryUpload
+  module Async
+    class GenerateSingleHostReport < ::Actions::EntryAction
+      def plan(base_folder, organization_id, filter)
+        plan_self(
+          base_folder: base_folder,
+          organization_id: organization_id,
+          filter: filter,
+        )
+        input[:target] = File.join(base_folder, ForemanInventoryUpload.facts_archive_name(input[:organization_id], input[:filter]))
+        archived_report_generator = ForemanInventoryUpload::Generators::ArchivedReport.new(input[:target])
+        archived_report_generator.render(organization: input[:organization_id], filter: input[:filter])
+      end
+      
+      def finalize
+        output[:result] = "Generated #{input[:target]} for organization id #{input[:organization_id]}"
+      end
+    end
+  end
+end

lib/foreman_inventory_upload/async/single_host_report_job.rb

@@ -0,0 +1,42 @@
+module ForemanInventoryUpload
+  module Async
+    class SingleHostReportJob < ::Actions::EntryAction
+      def plan(base_folder, organization_id, host_id)
+        input[:host_id] = host_id
+        sequence do
+          plan_action(
+            GenerateSingleHostReport,
+            base_folder,
+            organization_id,
+            hosts_filter,
+          )
+
+          plan_action(
+            QueueForUploadJob,
+            base_folder,
+            ForemanInventoryUpload.facts_archive_name(organization_id, hosts_filter),
+            organization_id
+          )
+        end
+      end
+
+      def hostname(host_id)
+        host = ::Host.find_by(id: host_id)
+        host&.name
+      end
+
+      def humanized_name
+        hostname_result = hostname(input[:host_id])
+        hostname_result.present? ? _("Single-host report job for host %s" % hostname_result) : _("Single-host report job")
+      end
+
+      def organization_id
+        input[:organization_id]
+      end
+
+      def hosts_filter
+        "id=#{input[:host_id]}"
+      end
+    end
+  end
+end

lib/foreman_inventory_upload/generators/slice.rb

@@ -256,7 +256,7 @@ def report_yum_repos(host)
 
         @stream.array_field('yum_repos') do
           host.content_facet.bound_repositories.each_with_index do |repo, index|
-            report_yum_repo(host.content_source.load_balancer_pulp_content_url, repo)
+            report_yum_repo(host.content_source&.load_balancer_pulp_content_url || ::SmartProxy.pulp_primary.pulp_content_url, repo)
             @stream.comma unless index == host.content_facet.bound_repositories.count - 1
           end
         end