gitea/nas
1
0
Fork 2
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions1

Spread stop_emoji_reaction_streaming effective

Browse source
This commit is contained in:
KMY 2023-05-15 17:54:16 +09:00
commit d64f0df8a0
1 changed files with 2 additions and 2 deletions

4
app/workers/delivery_emoji_reaction_worker.rb
View file

@ -7,7 +7,7 @@ class DeliveryEmojiReactionWorker
include AccountLimitable include AccountLimitable
def perform(payload_json, status_id, my_account_id = nil) def perform(payload_json, status_id, my_account_id = nil)
redis.publish("timeline:#{my_account_id}", payload_json) if my_account_id.present? redis.publish("timeline:#{my_account_id}", payload_json) if my_account_id.present? && !Account.find(my_account_id)&.user&.setting_stop_emoji_reaction_streaming
status = Status.find(status_id.to_i) status = Status.find(status_id.to_i)
@ -17,7 +17,7 @@ class DeliveryEmojiReactionWorker
end end
if [:public, :unlisted, :public_unlisted].exclude?(status.visibility.to_sym) && status.account_id != my_account_id && if [:public, :unlisted, :public_unlisted].exclude?(status.visibility.to_sym) && status.account_id != my_account_id &&
redis.exists?("subscribed:timeline:#{status.account_id}") redis.exists?("subscribed:timeline:#{status.account_id}") && !status.account.user&.setting_stop_emoji_reaction_streaming
redis.publish("timeline:#{status.account_id}", payload_json) redis.publish("timeline:#{status.account_id}", payload_json)
end end
end end