From d4e07841829379b3bc88f4de3c7a33626a8c9b0f Mon Sep 17 00:00:00 2001 From: Claire Date: Thu, 7 Aug 2025 10:03:15 +0200 Subject: [PATCH] Fix quote revocation not being streamed (#35710) --- app/lib/activitypub/activity/delete.rb | 1 + app/services/revoke_quote_service.rb | 7 +++++++ 2 files changed, 8 insertions(+) diff --git a/app/lib/activitypub/activity/delete.rb b/app/lib/activitypub/activity/delete.rb index 69b7bd035..ce36cfe76 100644 --- a/app/lib/activitypub/activity/delete.rb +++ b/app/lib/activitypub/activity/delete.rb @@ -61,6 +61,7 @@ class ActivityPub::Activity::Delete < ActivityPub::Activity ActivityPub::Forwarder.new(@account, @json, @quote.status).forward! @quote.reject! + DistributionWorker.perform_async(@quote.status_id, { 'update' => true }) end def forwarder diff --git a/app/services/revoke_quote_service.rb b/app/services/revoke_quote_service.rb index 8f5dc8f91..f4bc07c9d 100644 --- a/app/services/revoke_quote_service.rb +++ b/app/services/revoke_quote_service.rb @@ -8,11 +8,18 @@ class RevokeQuoteService < BaseService @account = quote.quoted_account @quote.reject! + distribute_update! distribute_stamp_deletion! end private + def distribute_update! + return if @quote.status_id.nil? + + DistributionWorker.perform_async(@quote.status_id, { 'update' => true }) + end + def distribute_stamp_deletion! ActivityPub::DeliveryWorker.push_bulk(inboxes, limit: 1_000) do |inbox_url| [signed_activity_json, @account.id, inbox_url]