9f3f47e91f
* Fetch up to 5 replies when discovering a new remote status This is used for resolving threads downwards. The originating server must add a “replies” attributes with such replies for it to be useful. * Add some tests for ActivityPub::FetchRepliesWorker * Add specs for ActivityPub::FetchRepliesService * Serialize up to 5 public self-replies for ActivityPub notes * Add specs for ActivityPub::NoteSerializer * Move exponential backoff logic to a worker concern * Fetch first page of paginated collections when fetching thread replies * Add specs for paginated collections in replies * Move Note replies serialization to a first CollectionPage The collection isn't actually paginable yet as it has no id nor a `next` field. This may come in another PR. * Use pluck(:uri) instead of map(&:uri) to improve performances * Fix fetching replies when they are in a CollectionPage
43 lines
1.2 KiB
Ruby
43 lines
1.2 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
class ActivityPub::CollectionSerializer < ActiveModel::Serializer
|
|
def self.serializer_for(model, options)
|
|
return ActivityPub::NoteSerializer if model.class.name == 'Status'
|
|
return ActivityPub::CollectionSerializer if model.class.name == 'ActivityPub::CollectionPresenter'
|
|
super
|
|
end
|
|
|
|
attribute :id, if: -> { object.id.present? }
|
|
attribute :type
|
|
attribute :total_items, if: -> { object.size.present? }
|
|
attribute :next, if: -> { object.next.present? }
|
|
attribute :prev, if: -> { object.prev.present? }
|
|
attribute :part_of, if: -> { object.part_of.present? }
|
|
|
|
has_one :first, if: -> { object.first.present? }
|
|
has_one :last, if: -> { object.last.present? }
|
|
has_many :items, key: :items, if: -> { (!object.items.nil? || page?) && !ordered? }
|
|
has_many :items, key: :ordered_items, if: -> { (!object.items.nil? || page?) && ordered? }
|
|
|
|
def type
|
|
if page?
|
|
ordered? ? 'OrderedCollectionPage' : 'CollectionPage'
|
|
else
|
|
ordered? ? 'OrderedCollection' : 'Collection'
|
|
end
|
|
end
|
|
|
|
def total_items
|
|
object.size
|
|
end
|
|
|
|
private
|
|
|
|
def ordered?
|
|
object.type == :ordered
|
|
end
|
|
|
|
def page?
|
|
object.part_of.present? || object.page.present?
|
|
end
|
|
end
|