Sha256: 53a79889517cf0c275ddba9b60415f04a06c26d323d52296cfa3c984f20e53a0
Contents?: true
Size: 1.72 KB
Versions: 46
Compression:
Stored size: 1.72 KB
Contents
module Actions
module Katello
module Repository
class ErrataMail < Actions::EntryAction
def plan(repo)
plan_self(:repo => repo.id, :associated_errata_before_syncing => repo.repository_errata.pluck(:erratum_id).uniq.sort.reverse, :new_associated_errata => [])
end
def run
::User.current = ::User.anonymous_admin
repo = ::Katello::Repository.find(input[:repo])
input[:new_associated_errata] = repo.repository_errata.pluck(:erratum_id).uniq.sort.reverse - input[:associated_errata_before_syncing]
users = ::User.select { |user| user.receives?(:sync_errata) && user.organization_ids.include?(repo.organization.id) && user.can?(:view_products, repo.product) }.compact
errata = ::Katello::Erratum.where(:id => input[:new_associated_errata])
[:associated_errata_before_syncing, :new_associated_errata].each do |key|
input[key] = "Trimmed list... (#{input[key].length} #{key.to_s.gsub('_', ' ')})" if input[key].length > 3
end
begin
MailNotification[:sync_errata].deliver(:users => users, :repo => repo, :errata => errata) unless (users.blank? || errata.blank?)
rescue => e
message = _('Unable to send errata e-mail notification: %{error}' % {:error => e})
Rails.logger.error(message)
output[:result] = message
end
end
def finalize
::User.current = nil
end
def rescue_strategy_for_self
# If sending mail fails do not cause any calling tasks to fail
# but mark the task in a WARNING state with the error message.
Dynflow::Action::Rescue::Skip
end
end
end
end
end
Version data entries
46 entries across 46 versions & 1 rubygems