From 0397c58b61d8a364ff488fc5631bfc751903c242 Mon Sep 17 00:00:00 2001 From: Eugen Rochko Date: Sat, 26 Aug 2017 18:52:53 +0200 Subject: Forward ActivityPub deletes to followers of rebloggers (#4706) --- app/lib/activitypub/activity/delete.rb | 19 ++++++++++++++++++- 1 file changed, 18 insertions(+), 1 deletion(-) (limited to 'app/lib') diff --git a/app/lib/activitypub/activity/delete.rb b/app/lib/activitypub/activity/delete.rb index a1598dfd3..e7eb53a02 100644 --- a/app/lib/activitypub/activity/delete.rb +++ b/app/lib/activitypub/activity/delete.rb @@ -8,7 +8,24 @@ class ActivityPub::Activity::Delete < ActivityPub::Activity if status.nil? delete_later!(object_uri) else - RemoveStatusService.new.call(status) + forward_for_reblogs(status) + delete_now!(status) end end + + private + + def forward_for_reblogs(status) + ActivityPub::RawDistributionWorker.push_bulk(status.reblogs.includes(:account).references(:account).merge(Account.local).pluck(:account_id)) do |account| + [payload, account.id] + end + end + + def delete_now!(status) + RemoveStatusService.new.call(status) + end + + def payload + @payload ||= Oj.dump(@json) + end end -- cgit