mirror of
https://github.com/discourse/discourse.git
synced 2024-12-13 09:53:44 +08:00
bc23dcd30b
When a user archives a personal message, they are redirected back to the
inbox and will refresh the list of the topics for the given filter.
Publishing an event to the user results in an incorrect incoming message
because the list of topics has already been refreshed.
This does mean that if a user has two tabs opened, the non-active tab
will not receive the incoming message but at this point we do not think
the technical trade-offs are worth it to support this feature. We
basically have to somehow exclude a client from an incoming message
which is not easy to do.
Follow-up to fc1fd1b416
246 lines
6.3 KiB
Ruby
246 lines
6.3 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
class TopicsBulkAction
|
|
|
|
def initialize(user, topic_ids, operation, options = {})
|
|
@user = user
|
|
@topic_ids = topic_ids
|
|
@operation = operation
|
|
@changed_ids = []
|
|
@options = options
|
|
end
|
|
|
|
def self.operations
|
|
@operations ||= %w(change_category close archive change_notification_level
|
|
reset_read dismiss_posts delete unlist archive_messages
|
|
move_messages_to_inbox change_tags append_tags remove_tags
|
|
relist dismiss_topics)
|
|
end
|
|
|
|
def self.register_operation(name, &block)
|
|
operations << name
|
|
define_method(name, &block)
|
|
end
|
|
|
|
def perform!
|
|
raise Discourse::InvalidParameters.new(:operation) unless TopicsBulkAction.operations.include?(@operation[:type])
|
|
# careful these are private methods, we need send
|
|
send(@operation[:type])
|
|
@changed_ids.sort
|
|
end
|
|
|
|
private
|
|
|
|
def find_group
|
|
return unless @options[:group]
|
|
|
|
group = Group.where('name ilike ?', @options[:group]).first
|
|
raise Discourse::InvalidParameters.new(:group) unless group
|
|
unless group.group_users.where(user_id: @user.id).exists?
|
|
raise Discourse::InvalidParameters.new(:group)
|
|
end
|
|
group
|
|
end
|
|
|
|
def move_messages_to_inbox
|
|
group = find_group
|
|
topics.each do |t|
|
|
if guardian.can_see?(t) && t.private_message?
|
|
if group
|
|
GroupArchivedMessage.move_to_inbox!(group.id, t, acting_user_id: @user.id)
|
|
else
|
|
UserArchivedMessage.move_to_inbox!(@user.id, t)
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
def archive_messages
|
|
group = find_group
|
|
topics.each do |t|
|
|
if guardian.can_see?(t) && t.private_message?
|
|
if group
|
|
GroupArchivedMessage.archive!(group.id, t, acting_user_id: @user.id)
|
|
else
|
|
UserArchivedMessage.archive!(@user.id, t)
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
def dismiss_posts
|
|
highest_number_source_column = @user.staff? ? 'highest_staff_post_number' : 'highest_post_number'
|
|
sql = <<~SQL
|
|
UPDATE topic_users tu
|
|
SET last_read_post_number = t.#{highest_number_source_column}
|
|
FROM topics t
|
|
WHERE t.id = tu.topic_id AND tu.user_id = :user_id AND t.id IN (:topic_ids)
|
|
SQL
|
|
|
|
DB.exec(sql, user_id: @user.id, topic_ids: @topic_ids)
|
|
@changed_ids.concat @topic_ids
|
|
end
|
|
|
|
def dismiss_topics
|
|
rows = Topic.where(id: @topic_ids)
|
|
.joins("LEFT JOIN topic_users ON topic_users.topic_id = topics.id AND topic_users.user_id = #{@user.id}")
|
|
.where("topics.created_at >= ?", dismiss_topics_since_date)
|
|
.where("topic_users.last_read_post_number IS NULL")
|
|
.order("topics.created_at DESC")
|
|
.limit(SiteSetting.max_new_topics).map do |topic|
|
|
{
|
|
topic_id: topic.id,
|
|
user_id: @user.id,
|
|
created_at: Time.zone.now
|
|
}
|
|
end
|
|
DismissedTopicUser.insert_all(rows) if rows.present?
|
|
@changed_ids = rows.map { |row| row[:topic_id] }
|
|
end
|
|
|
|
def reset_read
|
|
PostTiming.destroy_for(@user.id, @topic_ids)
|
|
end
|
|
|
|
def change_category
|
|
updatable_topics = topics.where.not(category_id: @operation[:category_id])
|
|
|
|
if SiteSetting.create_revision_on_bulk_topic_moves
|
|
opts = {
|
|
bypass_bump: true,
|
|
validate_post: false,
|
|
bypass_rate_limiter: true
|
|
}
|
|
|
|
updatable_topics.each do |t|
|
|
if guardian.can_edit?(t)
|
|
changes = { category_id: @operation[:category_id] }
|
|
@changed_ids << t.id if t.first_post.revise(@user, changes, opts)
|
|
end
|
|
end
|
|
else
|
|
updatable_topics.each do |t|
|
|
if guardian.can_edit?(t)
|
|
@changed_ids << t.id if t.change_category_to_id(@operation[:category_id])
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
def change_notification_level
|
|
topics.each do |t|
|
|
if guardian.can_see?(t)
|
|
TopicUser.change(@user, t.id, notification_level: @operation[:notification_level_id].to_i)
|
|
@changed_ids << t.id
|
|
end
|
|
end
|
|
end
|
|
|
|
def close
|
|
topics.each do |t|
|
|
if guardian.can_moderate?(t)
|
|
t.update_status('closed', true, @user)
|
|
@changed_ids << t.id
|
|
end
|
|
end
|
|
end
|
|
|
|
def unlist
|
|
topics.each do |t|
|
|
if guardian.can_moderate?(t)
|
|
t.update_status('visible', false, @user)
|
|
@changed_ids << t.id
|
|
end
|
|
end
|
|
end
|
|
|
|
def relist
|
|
topics.each do |t|
|
|
if guardian.can_moderate?(t)
|
|
t.update_status('visible', true, @user)
|
|
@changed_ids << t.id
|
|
end
|
|
end
|
|
end
|
|
|
|
def archive
|
|
topics.each do |t|
|
|
if guardian.can_moderate?(t)
|
|
t.update_status('archived', true, @user)
|
|
@changed_ids << t.id
|
|
end
|
|
end
|
|
end
|
|
|
|
def delete
|
|
topics.each do |t|
|
|
if guardian.can_delete?(t)
|
|
post = t.ordered_posts.first
|
|
PostDestroyer.new(@user, post).destroy if post
|
|
end
|
|
end
|
|
end
|
|
|
|
def change_tags
|
|
tags = @operation[:tags]
|
|
tags = DiscourseTagging.tags_for_saving(tags, guardian) if tags.present?
|
|
|
|
topics.each do |t|
|
|
if guardian.can_edit?(t)
|
|
if tags.present?
|
|
DiscourseTagging.tag_topic_by_names(t, guardian, tags)
|
|
else
|
|
t.tags = []
|
|
end
|
|
@changed_ids << t.id
|
|
end
|
|
end
|
|
end
|
|
|
|
def append_tags
|
|
tags = @operation[:tags]
|
|
tags = DiscourseTagging.tags_for_saving(tags, guardian) if tags.present?
|
|
|
|
topics.each do |t|
|
|
if guardian.can_edit?(t)
|
|
if tags.present?
|
|
DiscourseTagging.tag_topic_by_names(t, guardian, tags, append: true)
|
|
end
|
|
@changed_ids << t.id
|
|
end
|
|
end
|
|
end
|
|
|
|
def remove_tags
|
|
topics.each do |t|
|
|
if guardian.can_edit?(t)
|
|
TopicTag.where(topic_id: t.id).delete_all
|
|
@changed_ids << t.id
|
|
end
|
|
end
|
|
end
|
|
|
|
def guardian
|
|
@guardian ||= Guardian.new(@user)
|
|
end
|
|
|
|
def topics
|
|
@topics ||= Topic.where(id: @topic_ids)
|
|
end
|
|
|
|
def dismiss_topics_since_date
|
|
new_topic_duration_minutes = @user.user_option&.new_topic_duration_minutes || SiteSetting.default_other_new_topic_duration_minutes
|
|
setting_date =
|
|
case new_topic_duration_minutes
|
|
when User::NewTopicDuration::LAST_VISIT
|
|
@user.previous_visit_at || @user.created_at
|
|
when User::NewTopicDuration::ALWAYS
|
|
@user.created_at
|
|
else
|
|
new_topic_duration_minutes.minutes.ago
|
|
end
|
|
[setting_date, @user.created_at, Time.at(SiteSetting.min_new_topics_time).to_datetime].max
|
|
end
|
|
|
|
end
|