diff options
| author | Eugen Rochko <eugen@zeonfederated.com> | 2018-07-13 02:16:06 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2018-07-13 02:16:06 +0200 |
| commit | e55dce3176b7ac0a23a8a652c2626707a1b74dbb (patch) | |
| tree | 12d129849083dc0d17e372cb13d549c39dc40d51 /app/workers/activitypub/update_distribution_worker.rb | |
| parent | 401559c376078ef98e11c3034977b835b4086b5b (diff) | |
Add federation relay support (#7998)
* Add federation relay support * Add admin UI for managing relays * Include actor on relay-related activities * Fix i18n
Diffstat (limited to 'app/workers/activitypub/update_distribution_worker.rb')
| -rw-r--r-- | app/workers/activitypub/update_distribution_worker.rb | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/app/workers/activitypub/update_distribution_worker.rb b/app/workers/activitypub/update_distribution_worker.rb index f3377dcec..87efafb3e 100644 --- a/app/workers/activitypub/update_distribution_worker.rb +++ b/app/workers/activitypub/update_distribution_worker.rb @@ -9,7 +9,11 @@ class ActivityPub::UpdateDistributionWorker @account = Account.find(account_id) ActivityPub::DeliveryWorker.push_bulk(inboxes) do |inbox_url| - [payload, @account.id, inbox_url] + [signed_payload, @account.id, inbox_url] + end + + ActivityPub::DeliveryWorker.push_bulk(Relay.enabled.pluck(:inbox_url)) do |inbox_url| + [signed_payload, @account.id, inbox_url] end rescue ActiveRecord::RecordNotFound true @@ -21,6 +25,10 @@ class ActivityPub::UpdateDistributionWorker @inboxes ||= @account.followers.inboxes end + def signed_payload + @signed_payload ||= Oj.dump(ActivityPub::LinkedDataSignature.new(payload).sign!(@account)) + end + def payload @payload ||= ActiveModelSerializers::SerializableResource.new( @account, |