discourse/app/jobs/regular/process_sns_notification.rb

module Jobs

  class ProcessSnsNotification < Jobs::Base
    sidekiq_options retry: false

    def execute(args)
      return unless raw = args[:raw].presence
      return unless json = args[:json].presence
      return unless message = json["Message"].presence

      message = begin
        JSON.parse(message)
      rescue JSON::ParserError
        nil
      end

      return unless message && message["notificationType"] == "Bounce"
      return unless message_id = message.dig("mail", "messageId").presence
      return unless bounce_type = message.dig("bounce", "bounceType").presence

      require "aws-sdk-sns"
      return unless Aws::SNS::MessageVerifier.new.authentic?(raw)

      message.dig("bounce", "bouncedRecipients").each do |r|
        if email_log = EmailLog.find_by(message_id: message_id, to_address: r["emailAddress"])
          email_log.update_columns(bounced: true)

          if email_log.user&.email.present?
            if r["status"]&.start_with?["4."] || bounce_type == "Transient"
              Email::Receiver.update_bounce_score(email_log.user.email, SiteSetting.soft_bounce_score)
            else
              Email::Receiver.update_bounce_score(email_log.user.email, SiteSetting.hard_bounce_score)
            end
          end
        end
      end
    end

  end

end