35 lines
1.1 KiB
Ruby
35 lines
1.1 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
class ActivityPub::ProcessFeaturedItemService
|
|
include JsonLdHelper
|
|
include Lockable
|
|
include Redisable
|
|
|
|
def call(collection, uri_or_object)
|
|
item_json = uri_or_object.is_a?(String) ? fetch_resource(uri_or_object, true) : uri_or_object
|
|
return if non_matching_uri_hosts?(collection.uri, item_json['id'])
|
|
|
|
with_redis_lock("collection_item:#{item_json['id']}") do
|
|
return if collection.collection_items.exists?(uri: item_json['id'])
|
|
|
|
@collection_item = collection.collection_items.create!(
|
|
uri: item_json['id'],
|
|
object_uri: item_json['featuredObject'],
|
|
approval_uri: item_json['featureAuthorization']
|
|
)
|
|
|
|
verify_authorization!
|
|
|
|
@collection_item
|
|
end
|
|
end
|
|
|
|
private
|
|
|
|
def verify_authorization!
|
|
ActivityPub::VerifyFeaturedItemService.new.call(@collection_item)
|
|
rescue Mastodon::RecursionLimitExceededError, Mastodon::UnexpectedResponseError, *Mastodon::HTTP_CONNECTION_ERRORS
|
|
ActivityPub::VerifyFeaturedItemWorker.perform_in(rand(30..600).seconds, @collection_item.id)
|
|
end
|
|
end
|