Make private toots get PuSHed to subscription URLs that belong to domains where you have approved followers
parent
9783d8b6c0
commit
bd110a3d7d
|
@ -128,6 +128,10 @@ class Account < ApplicationRecord
|
|||
!subscription_expires_at.blank?
|
||||
end
|
||||
|
||||
def followers_domains
|
||||
followers.reorder(nil).pluck('distinct accounts.domain')
|
||||
end
|
||||
|
||||
def favourited?(status)
|
||||
status.proper.favourites.where(account: self).count.positive?
|
||||
end
|
||||
|
|
|
@ -8,12 +8,14 @@ class Pubsubhubbub::DistributionWorker
|
|||
def perform(stream_entry_id)
|
||||
stream_entry = StreamEntry.find(stream_entry_id)
|
||||
|
||||
return if stream_entry.hidden?
|
||||
return if stream_entry.status.direct_visibility?
|
||||
|
||||
account = stream_entry.account
|
||||
payload = AtomSerializer.render(AtomSerializer.new.feed(account, [stream_entry]))
|
||||
domains = account.followers_domains
|
||||
|
||||
Subscription.where(account: account).active.select('id, callback_url').find_each do |subscription|
|
||||
next unless domains.include?(Addressable::URI.parse(subscription.callback_url).host)
|
||||
Pubsubhubbub::DeliveryWorker.perform_async(subscription.id, payload)
|
||||
end
|
||||
rescue ActiveRecord::RecordNotFound
|
||||
|
|
Loading…
Reference in New Issue