Contents

module InventorySync
  module Async
    class HostResult
      def initialize(result)
        @total = result['total']
        @count = result['count']
        @page = result['page']
        @per_page = result['per_page']
        @sub_ids = result["results"].map { |host| host['subscription_manager_id'] }
        @uuid_by_sub_id = Hash[result["results"].map { |host| [host['subscription_manager_id'], host['id']] }]
      end

      def status_hashes
        @sub_ids.map do |sub_id|
          host_id = host_id(sub_id)
          if host_id
            touched << host_id
            {
              host_id: host_id,
              status: InventorySync::InventoryStatus::SYNC,
              reported_at: DateTime.current,
            }
          end
        end.compact
      end

      def touched
        @touched ||= []
      end

      def host_id(sub_id)
        hosts[sub_id]
      end

      def hosts
        @hosts ||= Hash[
          Katello::Host::SubscriptionFacet.where(uuid: @sub_ids).pluck(:uuid, :host_id)
        ]
      end

      def host_uuids
        @host_uuids ||= Hash[@sub_ids.map { |sub_id| [host_id(sub_id), @uuid_by_sub_id[sub_id]] }].except(nil)
      end

      def percentage
        ratio = @per_page * @page * 1.0 / @total * 100
        ratio > 100 ? 100 : ratio.truncate(2)
      end

      def last?
        @total <= @per_page * @page
      end
    end
  end
end

Version data entries

9 entries across 9 versions & 1 rubygems

Version	Path
foreman_rh_cloud-3.0.23	lib/inventory_sync/async/host_result.rb
foreman_rh_cloud-4.0.23	lib/inventory_sync/async/host_result.rb
foreman_rh_cloud-3.0.22	lib/inventory_sync/async/host_result.rb
foreman_rh_cloud-4.0.22	lib/inventory_sync/async/host_result.rb
foreman_rh_cloud-4.0.21.1	lib/inventory_sync/async/host_result.rb
foreman_rh_cloud-3.0.21.1	lib/inventory_sync/async/host_result.rb
foreman_rh_cloud-3.0.21	lib/inventory_sync/async/host_result.rb
foreman_rh_cloud-3.0.20	lib/inventory_sync/async/host_result.rb
foreman_rh_cloud-3.0.19	lib/inventory_sync/async/host_result.rb