8cf7006d4e
* Move ActivityPub::FetchRemoteAccountService to ActivityPub::FetchRemoteActorService ActivityPub::FetchRemoteAccountService is kept as a wrapper for when the actor is specifically required to be an Account * Refactor SignatureVerification to allow non-Account actors * fixup! Move ActivityPub::FetchRemoteAccountService to ActivityPub::FetchRemoteActorService * Refactor ActivityPub::FetchRemoteKeyService to potentially return non-Account actors * Refactor inbound ActivityPub payload processing to accept non-Account actors * Refactor inbound ActivityPub processing to accept activities relayed through non-Account * Refactor how Account key URIs are built * Refactor Request and drop unused key_id_format parameter * Rename ActivityPub::Dereferencer `signature_account` to `signature_actor`
94 lines
2.6 KiB
Ruby
94 lines
2.6 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
class ActivityPub::RepliesController < ActivityPub::BaseController
|
|
include SignatureVerification
|
|
include Authorization
|
|
include AccountOwnedConcern
|
|
|
|
DESCENDANTS_LIMIT = 60
|
|
|
|
before_action :require_account_signature!, if: :authorized_fetch_mode?
|
|
before_action :set_status
|
|
before_action :set_cache_headers
|
|
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
|