diff options
Diffstat (limited to 'app/workers/activitypub/reply_distribution_worker.rb')
| -rw-r--r-- | app/workers/activitypub/reply_distribution_worker.rb | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/app/workers/activitypub/reply_distribution_worker.rb b/app/workers/activitypub/reply_distribution_worker.rb index f9044cbf3..6b807e8bc 100644 --- a/app/workers/activitypub/reply_distribution_worker.rb +++ b/app/workers/activitypub/reply_distribution_worker.rb @@ -18,7 +18,7 @@ class ActivityPub::ReplyDistributionWorker return unless @account.present? && @status.distributable? ActivityPub::DeliveryWorker.push_bulk(inboxes) do |inbox_url| - [payload(Addressable::URI.parse(inbox_url).host), @status.account_id, inbox_url] + [payload(inbox_url), @status.account_id, inbox_url] end rescue ActiveRecord::RecordNotFound true @@ -30,7 +30,8 @@ class ActivityPub::ReplyDistributionWorker @inboxes ||= (@options[:all_servers] || @account.id == -99 ? Account.remote.without_suspended.inboxes : @account.followers.inboxes) end - def payload(domain) - @payload[domain] ||= Oj.dump(serialize_payload(ActivityPub::ActivityPresenter.from_status(@status, update: true, embed: false), ActivityPub::ActivitySerializer, signer: @status.account, target_domain: domain)) + def payload(inbox_url) + domain = Addressable::URI.parse(inbox_url).normalized_host + @payload[domain] ||= Oj.dump(serialize_payload(ActivityPub::ActivityPresenter.from_status(@status, domain, update: true, embed: false), ActivityPub::ActivitySerializer, signer: @status.account, domain: domain)) end end |