You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
95 lines
2.7 KiB
95 lines
2.7 KiB
# frozen_string_literal: true |
|
|
|
class ActivityPub::RepliesController < ActivityPub::BaseController |
|
include SignatureVerification |
|
include Authorization |
|
include AccountOwnedConcern |
|
|
|
DESCENDANTS_LIMIT = 60 |
|
|
|
vary_by -> { 'Signature' if authorized_fetch_mode? } |
|
|
|
before_action :require_account_signature!, if: :authorized_fetch_mode? |
|
before_action :set_status |
|
before_action :set_replies |
|
|
|
def index |
|
expires_in 0, public: public_fetch_mode? |
|
render json: replies_collection_presenter, serializer: ActivityPub::CollectionSerializer, adapter: ActivityPub::Adapter, content_type: 'application/activity+json', skip_activities: true |
|
end |
|
|
|
private |
|
|
|
def pundit_user |
|
signed_request_account |
|
end |
|
|
|
def set_status |
|
@status = @account.statuses.find(params[:status_id]) |
|
authorize @status, :show? |
|
rescue Mastodon::NotPermittedError |
|
not_found |
|
end |
|
|
|
def set_replies |
|
@replies = only_other_accounts? ? Status.where.not(account_id: @account.id).joins(:account).merge(Account.without_suspended) : @account.statuses |
|
@replies = @replies.where(in_reply_to_id: @status.id, visibility: [:public, :unlisted]) |
|
@replies = @replies.paginate_by_min_id(DESCENDANTS_LIMIT, params[:min_id]) |
|
end |
|
|
|
def replies_collection_presenter |
|
page = ActivityPub::CollectionPresenter.new( |
|
id: account_status_replies_url(@account, @status, page_params), |
|
type: :unordered, |
|
part_of: account_status_replies_url(@account, @status), |
|
next: next_page, |
|
items: @replies.map { |status| status.local? ? status : status.uri } |
|
) |
|
|
|
return page if page_requested? |
|
|
|
ActivityPub::CollectionPresenter.new( |
|
id: account_status_replies_url(@account, @status), |
|
type: :unordered, |
|
first: page |
|
) |
|
end |
|
|
|
def page_requested? |
|
truthy_param?(:page) |
|
end |
|
|
|
def only_other_accounts? |
|
truthy_param?(:only_other_accounts) |
|
end |
|
|
|
def next_page |
|
if only_other_accounts? |
|
# Only consider remote accounts |
|
return nil if @replies.size < DESCENDANTS_LIMIT |
|
|
|
account_status_replies_url( |
|
@account, |
|
@status, |
|
page: true, |
|
min_id: @replies&.last&.id, |
|
only_other_accounts: true |
|
) |
|
else |
|
# For now, we're serving only self-replies, but next page might be other accounts |
|
next_only_other_accounts = @replies&.last&.account_id != @account.id || @replies.size < DESCENDANTS_LIMIT |
|
|
|
account_status_replies_url( |
|
@account, |
|
@status, |
|
page: true, |
|
min_id: next_only_other_accounts ? nil : @replies&.last&.id, |
|
only_other_accounts: next_only_other_accounts |
|
) |
|
end |
|
end |
|
|
|
def page_params |
|
params_slice(:only_other_accounts, :min_id).merge(page: true) |
|
end |
|
end
|
|
|