Sha256: ffd6493c9f3978d004f5fa4ac09dd0b2f5e7974d165a9bc3d527990e001d9607
Contents?: true
Size: 1012 Bytes
Versions: 13
Compression:
Stored size: 1012 Bytes
Contents
module Actions
module Pulp3
module Repository
class SaveDistributionReferences < Pulp3::Abstract
middleware.use Actions::Middleware::ExecuteIfContentsChanged
def plan(repository, smart_proxy, tasks, options = {})
plan_self(repository_id: repository.id, smart_proxy_id: smart_proxy.id, tasks: tasks, contents_changed: options[:contents_changed])
end
def run
if input[:tasks] && input[:tasks][:pulp_tasks] && input[:tasks][:pulp_tasks].first
distribution_hrefs = input[:tasks][:pulp_tasks].map { |task| task[:created_resources].first }
distribution_hrefs.compact!
repo = ::Katello::Repository.find(input[:repository_id])
if distribution_hrefs.any?
repo.backend_service(smart_proxy).save_distribution_references(distribution_hrefs)
else
repo.backend_service(smart_proxy).update_distribution
end
end
end
end
end
end
end
Version data entries
13 entries across 13 versions & 1 rubygems