Sha256: f9b936c796712c8d2ab9412bb4538ad35d8263adc5939da51d451887c4273c2a
Contents?: true
Size: 1.98 KB
Versions: 16
Compression:
Stored size: 1.98 KB
Contents
module Katello
module Pulp3
class AnsibleCollection < PulpContentUnit
include LazyAccessor
def self.content_api
PulpAnsibleClient::ContentCollectionVersionsApi.new(Katello::Pulp3::Api::AnsibleCollection.new(SmartProxy.pulp_primary!).api_client)
end
def self.ids_for_repository(repo_id)
repo = Katello::Pulp3::Repository::AnsibleCollection.new(Katello::Repository.find(repo_id), SmartProxy.pulp_primary)
repo_content_list = repo.content_list
repo_content_list.map { |content| content.try(:pulp_href) }
end
def self.pulp_data(_pulp_href)
#No content read method
fail NotImplementedError
end
def self.generate_model_row(unit)
{
pulp_id: unit['pulp_href'],
checksum: unit['sha256'],
namespace: unit['namespace'],
version: unit['version'],
name: unit['name'],
description: unit['description']
}
end
def self.insert_child_associations(units, pulp_id_to_id)
tag_names = units.map { |unit| unit['tags'].map { |tag| tag[:name] } }.flatten
tag_rows = tag_names.map { |name| {name: name } }
Katello::AnsibleTag.insert_all(tag_rows, unique_by: [:name]) if tag_rows.any?
collection_tag_rows = []
units.each do |unit|
katello_id = pulp_id_to_id[unit['pulp_href']]
#delete old tags
unit_tags = unit['tags'].map { |tag| tag[:name] }
Katello::AnsibleCollectionTag.where(:ansible_collection_id => katello_id).where.not(:ansible_tag_id => Katello::AnsibleTag.where(:name => unit_tags)).delete_all
collection_tag_rows += Katello::AnsibleTag.where(:name => unit_tags).pluck(:id).map { |tag_id| {ansible_collection_id: katello_id, ansible_tag_id: tag_id} }
end
collection_tag_rows.flatten!
Katello::AnsibleCollectionTag.insert_all(collection_tag_rows, unique_by: [:ansible_collection_id, :ansible_tag_id])
end
end
end
end
Version data entries
16 entries across 16 versions & 1 rubygems