mirror of
https://github.com/discourse/discourse.git
synced 2025-02-08 04:18:23 +00:00
c659e3e95b
When we call Bookmark.cleanup! we want to make sure that topic_user.bookmarked is updated for topics linked to the bookmarks that were deleted. Also when PostDestroyer calls destroy and recover. We have a job for this already -- SyncTopicUserBookmarked -- so we just utilize that.
33 lines
1.1 KiB
Ruby
33 lines
1.1 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
module Jobs
|
|
class SyncTopicUserBookmarked < ::Jobs::Base
|
|
def execute(args = {})
|
|
topic_id = args[:topic_id]
|
|
|
|
DB.exec(<<~SQL, topic_id: topic_id)
|
|
UPDATE topic_users SET bookmarked = true
|
|
FROM bookmarks AS b
|
|
INNER JOIN posts ON posts.id = b.post_id
|
|
WHERE NOT topic_users.bookmarked AND
|
|
posts.deleted_at IS NULL AND
|
|
topic_users.topic_id = b.topic_id AND
|
|
topic_users.user_id = b.user_id #{topic_id.present? ? "AND topic_users.topic_id = :topic_id" : ""}
|
|
SQL
|
|
|
|
DB.exec(<<~SQL, topic_id: topic_id)
|
|
UPDATE topic_users SET bookmarked = false
|
|
WHERE topic_users.bookmarked AND
|
|
(
|
|
SELECT COUNT(*)
|
|
FROM bookmarks
|
|
INNER JOIN posts ON posts.id = bookmarks.post_id
|
|
WHERE bookmarks.topic_id = topic_users.topic_id
|
|
AND bookmarks.user_id = topic_users.user_id
|
|
AND posts.deleted_at IS NULL
|
|
) = 0 #{topic_id.present? ? "AND topic_users.topic_id = :topic_id" : ""}
|
|
SQL
|
|
end
|
|
end
|
|
end
|