mirror of
https://github.com/discourse/discourse.git
synced 2025-03-12 10:05:32 +08:00
30990006a9
This reduces chances of errors where consumers of strings mutate inputs and reduces memory usage of the app. Test suite passes now, but there may be some stuff left, so we will run a few sites on a branch prior to merging
139 lines
3.5 KiB
Ruby
139 lines
3.5 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
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 && post.topic
|
|
|
|
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.topic.blank?
|
|
return if post.topic.private_message?
|
|
return if SiteSetting.disable_edit_notifications && post_revision.user_id == Discourse::SYSTEM_USER_ID
|
|
|
|
user_ids = []
|
|
|
|
if post_revision.user_id != post.user_id
|
|
user_ids << post.user_id
|
|
end
|
|
|
|
if post.wiki && post.is_first_post?
|
|
user_ids.concat(
|
|
TopicUser.watching(post.topic_id)
|
|
.where.not(user_id: post_revision.user_id)
|
|
.where(topic: post.topic)
|
|
.pluck(:user_id)
|
|
)
|
|
end
|
|
|
|
if user_ids.present?
|
|
Jobs.enqueue(:notify_post_revision,
|
|
user_ids: user_ids,
|
|
post_revision_id: post_revision.id
|
|
)
|
|
end
|
|
end
|
|
|
|
def self.after_post_unhide(post, flaggers)
|
|
return if @disabled || post.last_editor.blank? || flaggers.blank?
|
|
|
|
flaggers.each do |flagger|
|
|
alerter.create_notification(
|
|
flagger,
|
|
Notification.types[:edited],
|
|
post,
|
|
display_username: post.last_editor.username,
|
|
acting_user_id: post.last_editor.id
|
|
)
|
|
end
|
|
end
|
|
end
|