mirror of
https://github.com/mastodon/mastodon.git
synced 2026-06-11 02:00:48 -05:00
79 lines
2.6 KiB
Ruby
79 lines
2.6 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
class ActivityPub::ProcessFeaturedItemService
|
|
include JsonLdHelper
|
|
include Lockable
|
|
include Redisable
|
|
|
|
PROCESSING_DELAY = (30.seconds)..(10.minutes)
|
|
|
|
def call(collection, uri_or_object, position: nil, request_id: nil)
|
|
@collection = collection
|
|
@request_id = request_id
|
|
@item_json = uri_or_object.is_a?(String) ? fetch_resource(uri_or_object, true) : uri_or_object
|
|
@actor_uri = value_or_id(@item_json['featuredObject'])
|
|
@approval_uri = value_or_id(@item_json['featureAuthorization'])
|
|
return if non_matching_uri_hosts?(@collection.uri, @item_json['id'])
|
|
return if non_matching_actor_and_approval_uris?
|
|
return if non_supported_object_type?
|
|
|
|
with_redis_lock("collection_item:#{@item_json['id']}") do
|
|
@collection_item = existing_item || pre_approved_item || new_item
|
|
|
|
@collection_item.position = position unless position.nil?
|
|
@collection_item.update!(
|
|
uri: @item_json['id'],
|
|
object_uri: value_or_id(@item_json['featuredObject'])
|
|
)
|
|
|
|
verify_authorization! unless @collection_item&.account&.local?
|
|
|
|
@collection_item
|
|
end
|
|
end
|
|
|
|
private
|
|
|
|
def existing_item
|
|
@collection.collection_items.find_by(uri: @item_json['id'])
|
|
end
|
|
|
|
def pre_approved_item
|
|
# This is a local account that has authorized this item already
|
|
local_account = ActivityPub::TagManager.instance.uris_to_local_accounts([@actor_uri]).first
|
|
@collection.collection_items.accepted_partial(local_account).first if local_account.present?
|
|
end
|
|
|
|
def new_item
|
|
@collection.collection_items.new(
|
|
created_at: @item_json['published']
|
|
)
|
|
end
|
|
|
|
def local_actor_uri?
|
|
return @local_actor_uri if instance_variable_defined?(:@local_actor_uri)
|
|
|
|
@local_actor_uri = ActivityPub::TagManager.instance.local_uri?(@actor_uri)
|
|
end
|
|
|
|
def non_matching_actor_and_approval_uris?
|
|
return false if local_actor_uri?
|
|
|
|
non_matching_uri_hosts?(@actor_uri, @approval_uri)
|
|
end
|
|
|
|
def non_supported_object_type?
|
|
return false if local_actor_uri?
|
|
return false if Account.exists?(uri: @actor_uri)
|
|
|
|
object_json = fetch_resource(@actor_uri, true)
|
|
(Array(object_json['type']) & ActivityPub::FetchRemoteActorService::SUPPORTED_TYPES).empty?
|
|
end
|
|
|
|
def verify_authorization!
|
|
ActivityPub::VerifyFeaturedItemService.new.call(@collection_item, @approval_uri, request_id: @request_id)
|
|
rescue Mastodon::RecursionLimitExceededError, Mastodon::UnexpectedResponseError, *Mastodon::HTTP_CONNECTION_ERRORS
|
|
ActivityPub::VerifyFeaturedItemWorker.perform_in(rand(PROCESSING_DELAY), @collection_item.id, @approval_uri, @request_id)
|
|
end
|
|
end
|