remove_status_service.rb 5.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166
  1. # frozen_string_literal: true
  2. class RemoveStatusService < BaseService
  3. include StreamEntryRenderer
  4. def call(status, **options)
  5. @payload = Oj.dump(event: :delete, payload: status.id.to_s)
  6. @status = status
  7. @account = status.account
  8. @tags = status.tags.pluck(:name).to_a
  9. @mentions = status.mentions.includes(:account).to_a
  10. @reblogs = status.reblogs.to_a
  11. @stream_entry = status.stream_entry
  12. @options = options
  13. remove_from_self if status.account.local?
  14. remove_from_followers
  15. remove_from_lists
  16. remove_from_affected
  17. remove_reblogs
  18. remove_from_hashtags
  19. remove_from_public
  20. remove_from_media if status.media_attachments.any?
  21. remove_from_direct if status.direct_visibility?
  22. @status.destroy!
  23. # There is no reason to send out Undo activities when the
  24. # cause is that the original object has been removed, since
  25. # original object being removed implicitly removes reblogs
  26. # of it. The Delete activity of the original is forwarded
  27. # separately.
  28. return if !@account.local? || @options[:original_removed]
  29. remove_from_remote_followers
  30. remove_from_remote_affected
  31. end
  32. private
  33. def remove_from_self
  34. FeedManager.instance.unpush_from_home(@account, @status)
  35. end
  36. def remove_from_followers
  37. @account.followers_for_local_distribution.reorder(nil).find_each do |follower|
  38. FeedManager.instance.unpush_from_home(follower, @status)
  39. end
  40. end
  41. def remove_from_lists
  42. @account.lists_for_local_distribution.select(:id, :account_id).reorder(nil).find_each do |list|
  43. FeedManager.instance.unpush_from_list(list, @status)
  44. end
  45. end
  46. def remove_from_affected
  47. @mentions.map(&:account).select(&:local?).each do |account|
  48. Redis.current.publish("timeline:#{account.id}", @payload)
  49. end
  50. end
  51. def remove_from_remote_affected
  52. # People who got mentioned in the status, or who
  53. # reblogged it from someone else might not follow
  54. # the author and wouldn't normally receive the
  55. # delete notification - so here, we explicitly
  56. # send it to them
  57. target_accounts = (@mentions.map(&:account).reject(&:local?) + @reblogs.map(&:account).reject(&:local?))
  58. target_accounts << @status.reblog.account if @status.reblog? && !@status.reblog.account.local?
  59. target_accounts.uniq!(&:id)
  60. # Ostatus
  61. NotificationWorker.push_bulk(target_accounts.select(&:ostatus?).uniq(&:domain)) do |target_account|
  62. [salmon_xml, @account.id, target_account.id]
  63. end
  64. # ActivityPub
  65. ActivityPub::DeliveryWorker.push_bulk(target_accounts.select(&:activitypub?).uniq(&:inbox_url)) do |target_account|
  66. [signed_activity_json, @account.id, target_account.inbox_url]
  67. end
  68. end
  69. def remove_from_remote_followers
  70. # OStatus
  71. Pubsubhubbub::RawDistributionWorker.perform_async(salmon_xml, @account.id)
  72. # ActivityPub
  73. ActivityPub::DeliveryWorker.push_bulk(@account.followers.inboxes) do |inbox_url|
  74. [signed_activity_json, @account.id, inbox_url]
  75. end
  76. relay! if relayable?
  77. end
  78. def relayable?
  79. @status.public_visibility?
  80. end
  81. def relay!
  82. ActivityPub::DeliveryWorker.push_bulk(Relay.enabled.pluck(:inbox_url)) do |inbox_url|
  83. [signed_activity_json, @account.id, inbox_url]
  84. end
  85. end
  86. def salmon_xml
  87. @salmon_xml ||= stream_entry_to_xml(@stream_entry)
  88. end
  89. def signed_activity_json
  90. @signed_activity_json ||= Oj.dump(ActivityPub::LinkedDataSignature.new(activity_json).sign!(@account))
  91. end
  92. def activity_json
  93. @activity_json ||= ActiveModelSerializers::SerializableResource.new(
  94. @status,
  95. serializer: @status.reblog? ? ActivityPub::UndoAnnounceSerializer : ActivityPub::DeleteSerializer,
  96. adapter: ActivityPub::Adapter
  97. ).as_json
  98. end
  99. def remove_reblogs
  100. # We delete reblogs of the status before the original status,
  101. # because once original status is gone, reblogs will disappear
  102. # without us being able to do all the fancy stuff
  103. @reblogs.each do |reblog|
  104. RemoveStatusService.new.call(reblog, original_removed: true)
  105. end
  106. end
  107. def remove_from_hashtags
  108. return unless @status.public_visibility?
  109. @tags.each do |hashtag|
  110. Redis.current.publish("timeline:hashtag:#{hashtag}", @payload)
  111. Redis.current.publish("timeline:hashtag:#{hashtag}:local", @payload) if @status.local?
  112. end
  113. end
  114. def remove_from_public
  115. return unless @status.public_visibility?
  116. Redis.current.publish('timeline:public', @payload)
  117. Redis.current.publish('timeline:public:local', @payload) if @status.local?
  118. end
  119. def remove_from_media
  120. return unless @status.public_visibility?
  121. Redis.current.publish('timeline:public:media', @payload)
  122. Redis.current.publish('timeline:public:local:media', @payload) if @status.local?
  123. end
  124. def remove_from_direct
  125. @mentions.each do |mention|
  126. Redis.current.publish("timeline:direct:#{mention.account.id}", @payload) if mention.account.local?
  127. end
  128. Redis.current.publish("timeline:direct:#{@account.id}", @payload) if @account.local?
  129. end
  130. def redis
  131. Redis.current
  132. end
  133. end