discourse
/
discourse-assign
mirror of https://github.com/discourse/discourse-assign.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

FIX: refresh topic when topic or post is deleted or recovered (#269) 

Additional check was added to only refresh if there were affected assignments
This commit is contained in:
Krzysztof Kotlarek 2021-12-15 07:53:12 +01:00 committed by GitHub
parent 99811d493d
commit 9ac8b70b14
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
plugin.rb
View File

@ -701,7 +701,8 @@ after_initialize do
end end
on(:topic_status_updated) do |topic, status, enabled| on(:topic_status_updated) do |topic, status, enabled|
if SiteSetting.unassign_on_close && (status == 'closed' || status == 'autoclosed') && enabled if SiteSetting.unassign_on_close && (status == 'closed' || status == 'autoclosed') && enabled && Assignment.exists?(topic_id: topic.id, active: true)
assigner = ::Assigner.new(topic, Discourse.system_user) assigner = ::Assigner.new(topic, Discourse.system_user)
assigner.unassign(silent: true, deactivate: true) assigner.unassign(silent: true, deactivate: true)
@ -709,20 +710,23 @@ after_initialize do
assigner = ::Assigner.new(post, Discourse.system_user) assigner = ::Assigner.new(post, Discourse.system_user)
assigner.unassign(silent: true, deactivate: true) assigner.unassign(silent: true, deactivate: true)
end end
MessageBus.publish("/topic/#{topic.id}", reload_topic: true, refresh_stream: true)
end end
if SiteSetting.reassign_on_open && (status == 'closed' || status == 'autoclosed') && !enabled if SiteSetting.reassign_on_open && (status == 'closed' || status == 'autoclosed') && !enabled && Assignment.exists?(topic_id: topic.id, active: false)
Assignment.where(topic_id: topic.id, target_type: "Topic").update_all(active: true) Assignment.where(topic_id: topic.id, target_type: "Topic").update_all(active: true)
Assignment Assignment
.where(topic_id: topic.id, target_type: "Post") .where(topic_id: topic.id, target_type: "Post")
.joins("INNER JOIN posts ON posts.id = target_id AND posts.deleted_at IS NULL") .joins("INNER JOIN posts ON posts.id = target_id AND posts.deleted_at IS NULL")
.update_all(active: true) .update_all(active: true)
MessageBus.publish("/topic/#{topic.id}", reload_topic: true, refresh_stream: true)
end end
end end
on(:post_destroyed) do |post| on(:post_destroyed) do |post|
if SiteSetting.unassign_on_close if SiteSetting.unassign_on_close && Assignment.exists?(target_type: "Post", target_id: post.id, active: true)
Assignment.where(target_type: "Post", target_id: post.id).update_all(active: false) Assignment.where(target_type: "Post", target_id: post.id).update_all(active: false)
MessageBus.publish("/topic/#{post.topic_id}", reload_topic: true, refresh_stream: true)
end end
# small actions have to be destroyed as link is incorrect # small actions have to be destroyed as link is incorrect
@ -733,8 +737,9 @@ after_initialize do
end end
on(:post_recovered) do |post| on(:post_recovered) do |post|
if SiteSetting.reassign_on_open if SiteSetting.reassign_on_open && Assignment.where(target_type: "Post", target_id: post.id, active: false)
Assignment.where(target_type: "Post", target_id: post.id).update_all(active: true) Assignment.where(target_type: "Post", target_id: post.id).update_all(active: true)
MessageBus.publish("/topic/#{post.topic_id}", reload_topic: true, refresh_stream: true)
end end
end end