Contents

module Actions
  module Pulp
    module Repository
      class CopyAllUnits < Pulp::AbstractAsyncTask
        def plan(source_repo, target_repo, options = {})
          filter_ids = options.fetch(:filters, nil)&.map(&:id)
          rpm_filenames = options.fetch(:rpm_filenames, nil)

          plan_self(source_repo_id: source_repo.id,
                    target_repo_id: target_repo.id,
                    filter_ids: filter_ids,
                    rpm_filenames: rpm_filenames)
        end

        def invoke_external_task
          source_repo = ::Katello::Repository.find(input[:source_repo_id])
          target_repo = ::Katello::Repository.find(input[:target_repo_id])
          filters = ::Katello::ContentViewFilter.where(:id => input[:filter_ids])

          source_repo.backend_service(SmartProxy.pulp_master).copy_contents(target_repo,
                                                                            filters: filters,
                                                                            rpm_filenames: input[:rpm_filenames])
        end
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
katello-3.11.2	app/lib/actions/pulp/repository/copy_all_units.rb
katello-3.11.1	app/lib/actions/pulp/repository/copy_all_units.rb
katello-3.11.0	app/lib/actions/pulp/repository/copy_all_units.rb
katello-3.11.0.rc2	app/lib/actions/pulp/repository/copy_all_units.rb
katello-3.11.0.rc1	app/lib/actions/pulp/repository/copy_all_units.rb