Sha256: ab4ad19dd71602d00ed437f2bf0acdafbf7740493ca0945a0068f7a2feb8a9a1
Contents?: true
Size: 1.98 KB
Versions: 23
Compression:
Stored size: 1.98 KB
Contents
module Actions
module Katello
module Repository
class FilteredIndexContent < Actions::EntryAction
input_format do
param :id, Integer
param :filter
param :import_upload_task
param :content_type
param :upload_actions
end
def run
repo = ::Katello::Repository.find(input[:id])
if repo.puppet?
::Katello::PuppetModule.import_for_repository(repo)
elsif repo.docker?
::Katello::DockerManifest.import_for_repository(repo)
::Katello::DockerTag.import_for_repository(repo)
::Katello::DockerManifestList.import_for_repository(repo)
elsif repo.file?
::Katello::FileUnit.import_for_repository(repo)
elsif repo.deb?
unit_ids = search_units(repo)
::Katello::Deb.import_all(unit_ids, repo)
elsif repo.yum?
if input[:import_upload_task] && input[:import_upload_task][:content_unit_href]
unit_ids = [input[:import_upload_task][:content_unit_href]]
elsif input[:upload_actions]&.any? { |action| action.try(:[], "content_unit_href") }
uploaded_content_unit_hrefs = []
input[:upload_actions].each { |action| uploaded_content_unit_hrefs << action.try(:[], "content_unit_href") }
unit_ids = uploaded_content_unit_hrefs.compact
else
unit_ids = search_units(repo)
end
if input[:content_type] == ::Katello::Srpm::CONTENT_TYPE
::Katello::Srpm.import_all(unit_ids, repo)
else
::Katello::Rpm.import_all(unit_ids, repo)
end
end
end
private
def search_units(repo)
found = repo.unit_search(:type_ids => [input[:content_type]],
:filters => input[:filter])
found.map { |result| result.try(:[], :unit_id) }.compact
end
end
end
end
end
Version data entries
23 entries across 23 versions & 1 rubygems