Sha256: 1f5789eabce148d0ede8ad2789adcb6eed23ea4f9c2ea37e6f88d73aa53d919f
Contents?: true
Size: 1.83 KB
Versions: 7
Compression:
Stored size: 1.83 KB
Contents
module Actions module Katello module Organization class ManifestImport < Actions::AbstractAsyncTask middleware.use Actions::Middleware::PropagateCandlepinErrors include Helpers::Notifications def plan(organization, path, force) action_subject organization manifest_update = organization.products.redhat.any? sequence do plan_action(Candlepin::Owner::Import, :label => organization.label, :path => path, :force => force) plan_action(Candlepin::Owner::ImportProducts, :organization_id => organization.id) if manifest_update && SETTINGS[:katello][:use_pulp] repositories = ::Katello::Repository.in_default_view.in_product(::Katello::Product.redhat.in_org(organization)) repositories.each do |repo| plan_action(Katello::Repository::RefreshRepository, repo) end end plan_self end end def failure_notification(plan) ::Katello::UINotifications::Subscriptions::ManifestImportError.deliver!( :subject => subject_organization, :task => get_foreman_task(plan) ) end def success_notification(_plan) ::Katello::UINotifications::Subscriptions::ManifestImportSuccess.deliver!( subject_organization ) end def humanized_name _("Import Manifest") end def finalize subject_organization.clear_syspurpose_status if subject_organization.simple_content_access?(cached: false) subject_organization.clear_manifest_expired_notifications subject_organization.audit_manifest_action(_('Manifest imported')) end end end end end
Version data entries
7 entries across 7 versions & 1 rubygems