Contents

require 'set'
require 'pulp_file_client'

module Katello
  module Pulp3
    class PulpContentUnit
      # Any class that extends this class should define:
      # Class#update_model

      def self.content_api
        fail NotImplementedError
      end

      def update_model
        fail NotImplementedError
      end

      attr_accessor :uuid
      attr_writer :backend_data

      def initialize(uuid)
        self.uuid = uuid
      end

      def self.model_class
        Katello::RepositoryTypeManager.model_class(self)
      end

      def self.unit_identifier
        "_href"
      end

      def self.pulp_units_batch_for_repo(repository, options = {})
        fetch_identifiers = options.fetch(:fetch_identifiers, false)
        page_size = options.fetch(:page_size, SETTINGS[:katello][:pulp][:bulk_load_size])
        repository_version_href = repository.version_href
        page_opts = { "page" => 1, repository_version: repository_version_href, page_size: page_size}
        page_opts[:fields] = '_href' if fetch_identifiers
        response = {}
        Enumerator.new do |yielder|
          loop do
            page_opts = page_opts.with_indifferent_access
            break unless (response["next"] || page_opts["page"] == 1)
            response = fetch_content_list page_opts
            response = response.as_json.with_indifferent_access
            yielder.yield response[:results]
            page_opts[:page] += 1
          end
        end
      end

      def self.pulp_data(href)
        content_unit = self.class.content_api.read(href)
        content_unit.as_json
      end

      def self.content_unit_list(page_opts)
        self.content_api.list page_opts
      end

      def backend_data
        @backend_data ||= fetch_backend_data
        @backend_data.try(:with_indifferent_access)
      end

      def fetch_backend_data
        self.class.pulp_data(self.uuid)
      end

      def self.fetch_content_list(page_opts)
        content_unit_list page_opts
      end
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
katello-3.13.4	app/services/katello/pulp3/pulp_content_unit.rb
katello-3.13.3	app/services/katello/pulp3/pulp_content_unit.rb
katello-3.13.2	app/services/katello/pulp3/pulp_content_unit.rb
katello-3.13.1	app/services/katello/pulp3/pulp_content_unit.rb
katello-3.13.0	app/services/katello/pulp3/pulp_content_unit.rb
katello-3.13.0.rc2.1	app/services/katello/pulp3/pulp_content_unit.rb
katello-3.13.0.rc2	app/services/katello/pulp3/pulp_content_unit.rb
katello-3.13.0.rc1	app/services/katello/pulp3/pulp_content_unit.rb