discourse/app/models/user_email_observer.rb

89 lines
2.1 KiB
Ruby
Raw Normal View History

2013-02-05 14:16:51 -05:00
class UserEmailObserver < ActiveRecord::Observer
observe :notification
class EmailUser
attr_reader :notification
2013-07-21 12:50:01 -04:00
def initialize(notification)
@notification = notification
end
def group_mentioned
enqueue :group_mentioned
end
def mentioned
enqueue :user_mentioned
2013-02-05 14:16:51 -05:00
end
def posted
enqueue :user_posted
end
2013-02-05 14:16:51 -05:00
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
def enqueue(type, delay=default_delay)
return unless notification.user.email_direct? && (notification.user.active? || notification.user.staged?)
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? && (notification.user.active? || notification.user.staged?)
Jobs.enqueue_in(delay,
:user_email,
type: type,
user_id: notification.user_id,
notification_id: notification.id)
end
def default_delay
2013-08-26 21:52:09 -04:00
SiteSetting.email_time_window_mins.minutes
end
2013-02-05 14:16:51 -05:00
end
def after_commit(notification)
2014-02-17 11:44:28 -05:00
transaction_includes_action = notification.send(:transaction_include_any_action?, [:create])
delegate_to_email_user notification if transaction_includes_action
2013-02-05 14:16:51 -05:00
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
2013-02-05 14:16:51 -05:00
end
end