2017-07-14 20:01:39 -05:00
|
|
|
# frozen_string_literal: true
|
|
|
|
|
|
|
|
require 'singleton'
|
|
|
|
|
|
|
|
class ActivityPub::TagManager
|
|
|
|
include Singleton
|
|
|
|
include RoutingHelper
|
|
|
|
|
2017-08-08 14:52:15 -05:00
|
|
|
CONTEXT = 'https://www.w3.org/ns/activitystreams'
|
|
|
|
|
2017-07-14 20:01:39 -05:00
|
|
|
COLLECTIONS = {
|
|
|
|
public: 'https://www.w3.org/ns/activitystreams#Public',
|
|
|
|
}.freeze
|
|
|
|
|
|
|
|
def url_for(target)
|
|
|
|
return target.url if target.respond_to?(:local?) && !target.local?
|
|
|
|
|
2020-03-25 19:56:41 -05:00
|
|
|
return unless target.respond_to?(:object_type)
|
|
|
|
|
2017-07-14 20:01:39 -05:00
|
|
|
case target.object_type
|
|
|
|
when :person
|
2019-07-18 18:44:42 -05:00
|
|
|
target.instance_actor? ? about_more_url(instance_actor: true) : short_account_url(target)
|
2017-07-14 20:01:39 -05:00
|
|
|
when :note, :comment, :activity
|
2017-08-24 09:21:42 -05:00
|
|
|
return activity_account_status_url(target.account, target) if target.reblog?
|
2017-07-14 20:01:39 -05:00
|
|
|
short_account_status_url(target.account, target)
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
def uri_for(target)
|
|
|
|
return target.uri if target.respond_to?(:local?) && !target.local?
|
|
|
|
|
|
|
|
case target.object_type
|
|
|
|
when :person
|
2019-07-18 18:44:42 -05:00
|
|
|
target.instance_actor? ? instance_actor_url : account_url(target)
|
2017-07-14 20:01:39 -05:00
|
|
|
when :note, :comment, :activity
|
2017-08-24 09:21:42 -05:00
|
|
|
return activity_account_status_url(target.account, target) if target.reblog?
|
2017-07-14 20:01:39 -05:00
|
|
|
account_status_url(target.account, target)
|
2017-10-07 10:43:42 -05:00
|
|
|
when :emoji
|
|
|
|
emoji_url(target)
|
2017-07-14 20:01:39 -05:00
|
|
|
end
|
|
|
|
end
|
|
|
|
|
Add follower synchronization mechanism (#14510)
* Add support for followers synchronization on the receiving end
Check the `collectionSynchronization` attribute on `Create` and `Announce`
activities and synchronize followers from provided collection if possible.
* Add tests for followers synchronization on the receiving end
* Add support for follower synchronization on the sender's end
* Add tests for the sending end
* Switch from AS attributes to HTTP header
Replace the custom `collectionSynchronization` ActivityStreams attribute by
an HTTP header (`X-AS-Collection-Synchronization`) with the same syntax as
the `Signature` header and the following fields:
- `collectionId` to specify which collection to synchronize
- `digest` for the SHA256 hex-digest of the list of followers known on the
receiving instance (where “receiving instance” is determined by accounts
sharing the same host name for their ActivityPub actor `id`)
- `url` of a collection that should be fetched by the instance actor
Internally, move away from the webfinger-based `domain` attribute and use
account `uri` prefix to group accounts.
* Add environment variable to disable followers synchronization
Since the whole mechanism relies on some new preconditions that, in some
extremely rare cases, might not be met, add an environment variable
(DISABLE_FOLLOWERS_SYNCHRONIZATION) to disable the mechanism altogether and
avoid followers being incorrectly removed.
The current conditions are:
1. all managed accounts' actor `id` and inbox URL have the same URI scheme and
netloc.
2. all accounts whose actor `id` or inbox URL share the same URI scheme and
netloc as a managed account must be managed by the same Mastodon instance
as well.
As far as Mastodon is concerned, breaking those preconditions require extensive
configuration changes in the reverse proxy and might also cause other issues.
Therefore, this environment variable provides a way out for people with highly
unusual configurations, and can be safely ignored for the overwhelming majority
of Mastodon administrators.
* Only set follower synchronization header on non-public statuses
This is to avoid unnecessary computations and allow Follow-related
activities to be handled by the usual codepath instead of going through
the synchronization mechanism (otherwise, any Follow/Undo/Accept activity
would trigger the synchronization mechanism even if processing the activity
itself would be enough to re-introduce synchronization)
* Change how ActivityPub::SynchronizeFollowersService handles follow requests
If the remote lists a local follower which we only know has sent a follow
request, consider the follow request as accepted instead of sending an Undo.
* Integrate review feeback
- rename X-AS-Collection-Synchronization to Collection-Synchronization
- various minor refactoring and code style changes
* Only select required fields when computing followers_hash
* Use actor URI rather than webfinger domain in synchronization endpoint
* Change hash computation to be a XOR of individual hashes
Makes it much easier to be memory-efficient, and avoid sorting discrepancy issues.
* Marginally improve followers_hash computation speed
* Further improve hash computation performances by using pluck_each
2020-10-21 11:04:09 -05:00
|
|
|
def uri_for_username(username)
|
|
|
|
account_url(username: username)
|
|
|
|
end
|
|
|
|
|
2018-05-04 14:14:34 -05:00
|
|
|
def generate_uri_for(_target)
|
|
|
|
URI.join(root_url, 'payloads', SecureRandom.uuid)
|
|
|
|
end
|
|
|
|
|
2017-08-24 09:21:42 -05:00
|
|
|
def activity_uri_for(target)
|
2017-09-17 06:51:34 -05:00
|
|
|
raise ArgumentError, 'target must be a local activity' unless %i(note comment activity).include?(target.object_type) && target.local?
|
2017-08-24 09:21:42 -05:00
|
|
|
|
|
|
|
activity_account_status_url(target.account, target)
|
|
|
|
end
|
|
|
|
|
2019-02-28 11:16:34 -06:00
|
|
|
def replies_uri_for(target, page_params = nil)
|
|
|
|
raise ArgumentError, 'target must be a local activity' unless %i(note comment activity).include?(target.object_type) && target.local?
|
|
|
|
|
2019-07-08 05:03:45 -05:00
|
|
|
account_status_replies_url(target.account, target, page_params)
|
2019-02-28 11:16:34 -06:00
|
|
|
end
|
|
|
|
|
2017-07-14 20:01:39 -05:00
|
|
|
# Primary audience of a status
|
|
|
|
# Public statuses go out to primarily the public collection
|
|
|
|
# Unlisted and private statuses go out primarily to the followers collection
|
|
|
|
# Others go out only to the people they mention
|
|
|
|
def to(status)
|
|
|
|
case status.visibility
|
|
|
|
when 'public'
|
|
|
|
[COLLECTIONS[:public]]
|
|
|
|
when 'unlisted', 'private'
|
|
|
|
[account_followers_url(status.account)]
|
2018-10-17 10:13:04 -05:00
|
|
|
when 'direct', 'limited'
|
2019-05-09 15:05:43 -05:00
|
|
|
if status.account.silenced?
|
|
|
|
# Only notify followers if the account is locally silenced
|
|
|
|
account_ids = status.active_mentions.pluck(:account_id)
|
2019-12-04 13:36:33 -06:00
|
|
|
to = status.account.followers.where(id: account_ids).each_with_object([]) do |account, result|
|
|
|
|
result << uri_for(account)
|
2020-07-14 12:05:34 -05:00
|
|
|
result << account_followers_url(account) if account.group?
|
2019-12-04 13:36:33 -06:00
|
|
|
end
|
|
|
|
to.concat(FollowRequest.where(target_account_id: status.account_id, account_id: account_ids).each_with_object([]) do |request, result|
|
|
|
|
result << uri_for(request.account)
|
2020-07-14 12:05:34 -05:00
|
|
|
result << account_followers_url(request.account) if request.account.group?
|
2019-12-04 13:36:33 -06:00
|
|
|
end)
|
2019-05-09 15:05:43 -05:00
|
|
|
else
|
2019-12-04 13:36:33 -06:00
|
|
|
status.active_mentions.each_with_object([]) do |mention, result|
|
|
|
|
result << uri_for(mention.account)
|
2020-07-14 12:05:34 -05:00
|
|
|
result << account_followers_url(mention.account) if mention.account.group?
|
2019-12-04 13:36:33 -06:00
|
|
|
end
|
2019-05-09 15:05:43 -05:00
|
|
|
end
|
2017-07-14 20:01:39 -05:00
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
# Secondary audience of a status
|
|
|
|
# Public statuses go out to followers as well
|
|
|
|
# Unlisted statuses go to the public as well
|
|
|
|
# Both of those and private statuses also go to the people mentioned in them
|
|
|
|
# Direct ones don't have a secondary audience
|
|
|
|
def cc(status)
|
|
|
|
cc = []
|
|
|
|
|
2018-01-08 17:47:43 -06:00
|
|
|
cc << uri_for(status.reblog.account) if status.reblog?
|
|
|
|
|
2017-07-14 20:01:39 -05:00
|
|
|
case status.visibility
|
|
|
|
when 'public'
|
|
|
|
cc << account_followers_url(status.account)
|
|
|
|
when 'unlisted'
|
|
|
|
cc << COLLECTIONS[:public]
|
|
|
|
end
|
|
|
|
|
2019-05-09 15:05:43 -05:00
|
|
|
unless status.direct_visibility? || status.limited_visibility?
|
|
|
|
if status.account.silenced?
|
|
|
|
# Only notify followers if the account is locally silenced
|
|
|
|
account_ids = status.active_mentions.pluck(:account_id)
|
2019-12-04 13:36:33 -06:00
|
|
|
cc.concat(status.account.followers.where(id: account_ids).each_with_object([]) do |account, result|
|
|
|
|
result << uri_for(account)
|
2020-07-14 12:05:34 -05:00
|
|
|
result << account_followers_url(account) if account.group?
|
2019-12-04 13:36:33 -06:00
|
|
|
end)
|
|
|
|
cc.concat(FollowRequest.where(target_account_id: status.account_id, account_id: account_ids).each_with_object([]) do |request, result|
|
|
|
|
result << uri_for(request.account)
|
2020-07-14 12:05:34 -05:00
|
|
|
result << account_followers_url(request.account) if request.account.group?
|
2019-12-04 13:36:33 -06:00
|
|
|
end)
|
2019-05-09 15:05:43 -05:00
|
|
|
else
|
2019-12-04 13:36:33 -06:00
|
|
|
cc.concat(status.active_mentions.each_with_object([]) do |mention, result|
|
|
|
|
result << uri_for(mention.account)
|
2020-07-14 12:05:34 -05:00
|
|
|
result << account_followers_url(mention.account) if mention.account.group?
|
2019-12-04 13:36:33 -06:00
|
|
|
end)
|
2019-05-09 15:05:43 -05:00
|
|
|
end
|
|
|
|
end
|
2017-07-14 20:01:39 -05:00
|
|
|
|
|
|
|
cc
|
|
|
|
end
|
2017-08-08 14:52:15 -05:00
|
|
|
|
|
|
|
def local_uri?(uri)
|
2018-05-05 11:22:34 -05:00
|
|
|
return false if uri.nil?
|
|
|
|
|
2017-08-17 20:21:59 -05:00
|
|
|
uri = Addressable::URI.parse(uri)
|
|
|
|
host = uri.normalized_host
|
|
|
|
host = "#{host}:#{uri.port}" if uri.port
|
|
|
|
|
2017-08-17 18:03:18 -05:00
|
|
|
!host.nil? && (::TagManager.instance.local_domain?(host) || ::TagManager.instance.web_domain?(host))
|
2017-08-08 14:52:15 -05:00
|
|
|
end
|
|
|
|
|
|
|
|
def uri_to_local_id(uri, param = :id)
|
|
|
|
path_params = Rails.application.routes.recognize_path(uri)
|
2019-07-18 18:44:42 -05:00
|
|
|
path_params[:username] = Rails.configuration.x.local_domain if path_params[:controller] == 'instance_actors'
|
2017-08-08 14:52:15 -05:00
|
|
|
path_params[param]
|
|
|
|
end
|
|
|
|
|
|
|
|
def uri_to_resource(uri, klass)
|
2018-05-05 11:22:34 -05:00
|
|
|
return if uri.nil?
|
|
|
|
|
2017-08-08 14:52:15 -05:00
|
|
|
if local_uri?(uri)
|
|
|
|
case klass.name
|
|
|
|
when 'Account'
|
|
|
|
klass.find_local(uri_to_local_id(uri, :username))
|
|
|
|
else
|
2017-09-08 11:20:03 -05:00
|
|
|
StatusFinder.new(uri).status
|
2017-08-08 14:52:15 -05:00
|
|
|
end
|
2017-09-19 11:08:08 -05:00
|
|
|
elsif OStatus::TagManager.instance.local_id?(uri)
|
|
|
|
klass.find_by(id: OStatus::TagManager.instance.unique_tag_to_local_id(uri, klass.to_s))
|
2017-08-08 14:52:15 -05:00
|
|
|
else
|
2017-08-21 15:57:34 -05:00
|
|
|
klass.find_by(uri: uri.split('#').first)
|
2017-08-08 14:52:15 -05:00
|
|
|
end
|
2017-09-08 11:20:03 -05:00
|
|
|
rescue ActiveRecord::RecordNotFound
|
|
|
|
nil
|
2017-08-08 14:52:15 -05:00
|
|
|
end
|
2017-07-14 20:01:39 -05:00
|
|
|
end
|