Sha256: e675e5fd162d63064194a2cc01960eb08ab889ba24f8f829f166eb7f98a2e318
Contents?: true
Size: 1.64 KB
Versions: 10
Compression:
Stored size: 1.64 KB
Contents
module Actions
module Pulp3
module Repository
class SaveVersion < Pulp3::Abstract
def plan(repository, options)
fail "Cannot accept tasks and repository_details into Save Version." if options[:tasks].present? && options[:repository_details].present?
plan_self(:repository_id => repository.id, :tasks => options[:tasks], :repository_details => options[:repository_details], :force_fetch_version => options.fetch(:force_fetch_version, false))
end
def run
repo = ::Katello::Repository.find(input[:repository_id])
if input[:force_fetch_version]
version_href = fetch_version_href(repo)
elsif input[:repository_details].present?
version_href = input[:repository_details][:latest_version_href]
elsif input[:tasks].present?
version_href = input[:tasks].last[:created_resources].first
else
version_href = fetch_version_href(repo)
end
if version_href
if repo.version_href != version_href || input[:force_fetch_version]
output[:contents_changed] = true
repo.update(:version_href => version_href)
end
else
output[:contents_changed] = false
end
end
def fetch_version_href(repo)
# Fetch latest Pulp 3 repo version
repo_backend_service = repo.backend_service(SmartProxy.pulp_primary)
repo_href = repo_backend_service.repository_reference.repository_href
repo_backend_service.api.repositories_api.read(repo_href).latest_version_href
end
end
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems