app/lib/actions/katello/repository/errata_mail.rb in katello-4.5.1 vs app/lib/actions/katello/repository/errata_mail.rb in katello-4.6.0.rc1

- old
+ new

@@ -3,18 +3,18 @@ module Repository class ErrataMail < Actions::EntryAction middleware.use Actions::Middleware::ExecuteIfContentsChanged def plan(repo, contents_changed = nil) - plan_self(:repo => repo.id, :contents_changed => contents_changed) + last_updated = repo.repository_errata.order('updated_at ASC').last.try(:updated_at) || Time.now + plan_self(:repo => repo.id, :contents_changed => contents_changed, :last_updated => last_updated.to_s) end def run ::User.current = ::User.anonymous_admin repo = ::Katello::Repository.find(input[:repo]) - last_updated = repo.repository_errata.order('updated_at ASC').last.try(:updated_at) || Time.now 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 => repo.repository_errata.where('katello_repository_errata.updated_at > ?', last_updated).pluck(:erratum_id)) + errata = ::Katello::Erratum.where(:id => repo.repository_errata.where('katello_repository_errata.updated_at > ?', input['last_updated'].to_datetime).pluck(:erratum_id)) 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})