mirror of
https://github.com/discourse/discourse.git
synced 2024-12-02 05:29:17 -06:00
ad3ec5809f
Original PR was reverted because of broken migration https://github.com/discourse/discourse/pull/12058 I fixed it by adding this line ``` AND topics.id IN(SELECT id FROM topics ORDER BY created_at DESC LIMIT :max_new_topics) ``` This time it is left joining a limited amount of topics. I tested it on few databases and it worked quite smooth
46 lines
1.3 KiB
Ruby
46 lines
1.3 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
class DismissTopics
|
|
def initialize(user, topics_scope)
|
|
@user = user
|
|
@topics_scope = topics_scope
|
|
end
|
|
|
|
def perform!
|
|
DismissedTopicUser.insert_all(rows) if rows.present?
|
|
@rows.map { |row| row[:topic_id] }
|
|
end
|
|
|
|
private
|
|
|
|
def rows
|
|
@rows ||= @topics_scope
|
|
.joins("LEFT JOIN topic_users ON topic_users.topic_id = topics.id AND topic_users.user_id = #{@user.id}")
|
|
.where("topics.created_at >= ?", since_date)
|
|
.where("topic_users.id IS NULL")
|
|
.where("topics.archetype <> ?", Archetype.private_message)
|
|
.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
|
|
end
|
|
|
|
def 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
|