1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495 |
- # 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
|