mirror of
https://github.com/discourse/discourse.git
synced 2024-11-24 06:56:01 +08:00
c531f4ded5
Rails yanked out observers many many years ago, instead the functionality was yanked out to a gem that is very lightly maintained. For example: if we want to upgrade to rails 5 there is no published gem Internally the usage of observers had quite a few problem. The series of refactors renamed a bunch of classes to give us more clarity and removed some magic.
113 lines
2.8 KiB
Ruby
113 lines
2.8 KiB
Ruby
class PostActionNotifier
|
|
|
|
def self.disable
|
|
@disabled = true
|
|
end
|
|
|
|
def self.enable
|
|
@disabled = false
|
|
end
|
|
|
|
def self.alerter
|
|
@alerter ||= PostAlerter.new
|
|
end
|
|
|
|
def self.refresh_like_notification(post, read)
|
|
return unless post && post.user_id
|
|
|
|
usernames = post.post_actions.where(post_action_type_id: PostActionType.types[:like])
|
|
.joins(:user)
|
|
.order('post_actions.created_at desc')
|
|
.where('post_actions.created_at > ?', 1.day.ago)
|
|
.pluck(:username)
|
|
|
|
if usernames.length > 0
|
|
data = {
|
|
topic_title: post.topic.title,
|
|
username: usernames[0],
|
|
display_username: usernames[0],
|
|
username2: usernames[1],
|
|
count: usernames.length
|
|
}
|
|
Notification.create(
|
|
notification_type: Notification.types[:liked],
|
|
topic_id: post.topic_id,
|
|
post_number: post.post_number,
|
|
user_id: post.user_id,
|
|
read: read,
|
|
data: data.to_json
|
|
)
|
|
end
|
|
end
|
|
|
|
def self.post_action_deleted(post_action)
|
|
|
|
return if @disabled
|
|
|
|
# We only care about deleting post actions for now
|
|
return if post_action.deleted_at.blank?
|
|
|
|
if post_action.post_action_type_id == PostActionType.types[:like] && post_action.post
|
|
|
|
read = true
|
|
|
|
Notification.where(
|
|
topic_id: post_action.post.topic_id,
|
|
user_id: post_action.post.user_id,
|
|
post_number: post_action.post.post_number,
|
|
notification_type: Notification.types[:liked]
|
|
).each do |notification|
|
|
read = false unless notification.read
|
|
notification.destroy
|
|
end
|
|
|
|
refresh_like_notification(post_action.post, read)
|
|
else
|
|
# not using destroy_all cause we want stuff to trigger
|
|
Notification.where(post_action_id: post_action.id).each(&:destroy)
|
|
end
|
|
end
|
|
|
|
def self.post_action_created(post_action)
|
|
|
|
return if @disabled
|
|
|
|
# We only notify on likes for now
|
|
return unless post_action.is_like?
|
|
|
|
post = post_action.post
|
|
return if post_action.user.blank?
|
|
|
|
alerter.create_notification(
|
|
post.user,
|
|
Notification.types[:liked],
|
|
post,
|
|
display_username: post_action.user.username,
|
|
post_action_id: post_action.id,
|
|
user_id: post_action.user_id
|
|
)
|
|
end
|
|
|
|
def self.after_create_post_revision(post_revision)
|
|
|
|
return if @disabled
|
|
|
|
post = post_revision.post
|
|
|
|
return unless post
|
|
return if post_revision.user.blank?
|
|
return if post_revision.user_id == post.user_id
|
|
return if post.topic.private_message?
|
|
return if SiteSetting.disable_edit_notifications && post_revision.user_id == Discourse::SYSTEM_USER_ID
|
|
|
|
alerter.create_notification(
|
|
post.user,
|
|
Notification.types[:edited],
|
|
post,
|
|
display_username: post_revision.user.username,
|
|
acting_user_id: post_revision.try(:user_id)
|
|
)
|
|
end
|
|
|
|
end
|