mirror of
https://github.com/codeninjasllc/discourse.git
synced 2024-11-23 23:58:31 -05:00
3829c78526
As it stands we load up user records quite frequently on the topic pages, this in turn pulls all the columns for the users being selected, just to discard them after they are loaded New structure keeps all options in a discrete table, this is better organised and allows us to easily add more column without worrying about bloating the user table
113 lines
2.7 KiB
Ruby
113 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 linked
|
|
enqueue :user_linked
|
|
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.user_option.email_direct?
|
|
perform_enqueue(type, delay)
|
|
end
|
|
|
|
def enqueue_private(type, delay=private_delay)
|
|
return unless notification.user.user_option.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
|