diff options
author | Fire Demon <firedemon@creature.cafe> | 2020-11-18 21:03:32 -0600 |
---|---|---|
committer | Fire Demon <firedemon@creature.cafe> | 2020-11-18 21:03:32 -0600 |
commit | cfe8a3218addfd7e0cc82c6f0054572f3d8aa296 (patch) | |
tree | abe88187c10217321827913d2e21f6592659ea33 /app/services/remove_status_service.rb | |
parent | b767423188034031bc6c89f5a39f78687506a5ce (diff) |
Break up AP envelope addressing by domain
Diffstat (limited to 'app/services/remove_status_service.rb')
-rw-r--r-- | app/services/remove_status_service.rb | 15 |
1 files changed, 9 insertions, 6 deletions
diff --git a/app/services/remove_status_service.rb b/app/services/remove_status_service.rb index 8025f235b..beb415f94 100644 --- a/app/services/remove_status_service.rb +++ b/app/services/remove_status_service.rb @@ -19,6 +19,8 @@ class RemoveStatusService < BaseService @reblogs = status.reblogs.includes(:account).to_a @options = options + @signed_activity_json = {} + RedisLock.acquire(lock_options) do |lock| if lock.acquired? remove_from_self if status.account.local? && !@options[:unpublish] @@ -95,18 +97,18 @@ class RemoveStatusService < BaseService # ActivityPub ActivityPub::DeliveryWorker.push_bulk(target_accounts.select(&:activitypub?).uniq(&:preferred_inbox_url)) do |target_account| - [signed_activity_json, @account.id, target_account.preferred_inbox_url] + [signed_activity_json(inbox_url), @account.id, target_account.preferred_inbox_url] end end def remove_from_remote_followers # ActivityPub ActivityPub::DeliveryWorker.push_bulk(@account.followers.inboxes) do |inbox_url| - [signed_activity_json, @account.id, inbox_url] + [signed_activity_json(inbox_url), @account.id, inbox_url] end ActivityPub::DeliveryWorker.push_bulk(@account.following.inboxes) do |inbox_url| - [signed_activity_json, @account.id, inbox_url] + [signed_activity_json(inbox_url), @account.id, inbox_url] end relay! if relayable? @@ -118,12 +120,13 @@ class RemoveStatusService < BaseService def relay! ActivityPub::DeliveryWorker.push_bulk(Relay.enabled.pluck(:inbox_url)) do |inbox_url| - [signed_activity_json(Addressable::URI.parse(inbox_url).host), @account.id, inbox_url] + [signed_activity_json(inbox_url), @account.id, inbox_url] end end - def signed_activity_json - @signed_activity_json ||= Oj.dump(serialize_payload(@status, @status.reblog? && @status.spoiler_text.blank? ? ActivityPub::UndoAnnounceSerializer : ActivityPub::DeleteSerializer, signer: @account)) + def signed_activity_json(inbox_url) + domain = Addressable::URI.parse(inbox_url).normalized_host + @signed_activity_json[domain] ||= Oj.dump(serialize_payload(@status, @status.reblog? && @status.spoiler_text.blank? ? ActivityPub::UndoAnnounceSerializer : ActivityPub::DeleteSerializer, signer: @account, domain: domain)) end def remove_reblogs |