1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980 |
- # frozen_string_literal: true
- class ActivityPub::RepliesController < ActivityPub::BaseController
- include SignatureVerification
- include Authorization
- include AccountOwnedConcern
- DESCENDANTS_LIMIT = 60
- before_action :require_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
- only_other_accounts = !(@replies&.last&.account_id == @account.id && @replies.size == DESCENDANTS_LIMIT)
- account_status_replies_url(
- @account,
- @status,
- page: true,
- min_id: only_other_accounts && !only_other_accounts? ? nil : @replies&.last&.id,
- only_other_accounts: only_other_accounts
- )
- end
- def page_params
- params_slice(:only_other_accounts, :min_id).merge(page: true)
- end
- end
|