Sha256: aa07945aed3f89111e5f8a54500c55d76a4346460f2c601fb78be8869a7afb07
Contents?: true
Size: 1.62 KB
Versions: 9
Compression:
Stored size: 1.62 KB
Contents
module Actions
module Katello
module CapsuleContent
class Sync < ::Actions::EntryAction
def humanized_name
_("Sychronize capsule content")
end
def plan(capsule_content, options = {})
environment = options.fetch(:environment, nil)
repository = options.fetch(:repository, nil)
content_view = options.fetch(:content_view, nil)
fail _("Action not allowed for the default capsule.") if capsule_content.default_capsule?
repository_ids = get_repository_ids(capsule_content, environment, content_view, repository)
unless repository_ids.blank?
sequence do
plan_action(ConfigureCapsule, capsule_content)
plan_action(Pulp::Consumer::SyncNode,
consumer_uuid: capsule_content.consumer_uuid,
repo_ids: repository_ids)
end
end
end
def get_repository_ids(capsule, environment, content_view, repository)
if environment
repository_ids = capsule.pulp_repos([environment], content_view).map(&:pulp_id)
elsif repository
repository_ids = [repository.pulp_id]
environment = repository.environment
else
repository_ids = capsule.pulp_repos.map(&:pulp_id)
end
if environment && !capsule.lifecycle_environments.include?(environment)
fail _("Lifecycle environment '%{environment}' is not attached to this capsule.") % { :environment => environment.name }
end
repository_ids
end
end
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems