discourse/app/models/user_email_observer.rb

class UserEmailObserver < ActiveRecord::Observer
  observe :notification

  class EmailUser
    attr_reader :notification

    def initialize(notification)
      @notification = notification
    end

    def group_mentioned
      enqueue :group_mentioned
    end

    def mentioned
      enqueue :user_mentioned
    end

    def posted
      enqueue :user_posted
    end

    def quoted
      enqueue :user_quoted
    end

    def replied
      enqueue :user_replied
    end

    def private_message
      enqueue_private(:user_private_message, 0)
    end

    def invited_to_private_message
      enqueue(:user_invited_to_private_message, 0)
    end

    def invited_to_topic
      enqueue(:user_invited_to_topic, 0)
    end

    private

    EMAILABLE_POST_TYPES ||= Set.new [Post.types[:regular], Post.types[:whisper]]

    def enqueue(type, delay=default_delay)
      return unless notification.user.email_direct?
      return unless notification.user.active? || notification.user.staged?
      return unless EMAILABLE_POST_TYPES.include? notification.post.try(:post_type)

      Jobs.enqueue_in(delay,
                      :user_email,
                      type: type,
                      user_id: notification.user_id,
                      notification_id: notification.id)
    end

    def enqueue_private(type, delay=default_delay)
      return unless notification.user.email_private_messages?
      return unless notification.user.active? || notification.user.staged?
      return unless EMAILABLE_POST_TYPES.include? notification.post.try(:post_type)

      Jobs.enqueue_in(delay,
                      :user_email,
                      type: type,
                      user_id: notification.user_id,
                      notification_id: notification.id)
    end

    def default_delay
      SiteSetting.email_time_window_mins.minutes
    end
  end

  def after_commit(notification)
    transaction_includes_action = notification.send(:transaction_include_any_action?, [:create])
    delegate_to_email_user(notification) if transaction_includes_action
  end

  private


  def extract_notification_type(notification)
    Notification.types[notification.notification_type]
  end

  def delegate_to_email_user(notification)
    email_user   = EmailUser.new(notification)
    email_method = extract_notification_type(notification)

    email_user.send(email_method) if email_user.respond_to? email_method
  end
end