110 lines
2.7 KiB
Ruby
110 lines
2.7 KiB
Ruby
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)
|
|
end
|
|
|
|
def invited_to_private_message
|
|
enqueue(:user_invited_to_private_message, private_delay)
|
|
end
|
|
|
|
def invited_to_topic
|
|
enqueue(:user_invited_to_topic, private_delay)
|
|
end
|
|
|
|
def self.notification_params(notification, type)
|
|
post_id = (notification.data_hash[:original_post_id] || notification.post_id).to_i
|
|
|
|
hash = {
|
|
type: type,
|
|
user_id: notification.user_id,
|
|
notification_id: notification.id,
|
|
notification_data_hash: notification.data_hash,
|
|
notification_type: Notification.types[notification.notification_type],
|
|
}
|
|
|
|
hash[:post_id] = post_id if post_id > 0
|
|
hash
|
|
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?
|
|
perform_enqueue(type, delay)
|
|
end
|
|
|
|
def enqueue_private(type, delay=private_delay)
|
|
return unless notification.user.email_private_messages?
|
|
perform_enqueue(type, delay)
|
|
end
|
|
|
|
def perform_enqueue(type, delay)
|
|
return unless notification.user.active? || notification.user.staged?
|
|
return unless EMAILABLE_POST_TYPES.include?(post_type)
|
|
|
|
Jobs.enqueue_in(delay, :user_email, self.class.notification_params(notification, type))
|
|
end
|
|
|
|
def default_delay
|
|
SiteSetting.email_time_window_mins.minutes
|
|
end
|
|
|
|
def private_delay
|
|
SiteSetting.private_email_time_window_seconds
|
|
end
|
|
|
|
def post_type
|
|
@post_type ||= begin
|
|
type = notification.data_hash["original_post_type"] if notification.data_hash
|
|
type ||= notification.post.try(:post_type)
|
|
type
|
|
end
|
|
end
|
|
|
|
end
|
|
|
|
def after_commit(notification)
|
|
transaction_includes_action = notification.send(:transaction_include_any_action?, [:create])
|
|
self.class.process_notification(notification) if transaction_includes_action
|
|
end
|
|
|
|
def self.process_notification(notification)
|
|
email_user = EmailUser.new(notification)
|
|
email_method = Notification.types[notification.notification_type]
|
|
|
|
email_user.send(email_method) if email_user.respond_to? email_method
|
|
end
|
|
|
|
end
|