mirror of
https://github.com/mastodon/mastodon.git
synced 2026-05-21 23:59:19 -05:00
68 lines
2.4 KiB
Ruby
68 lines
2.4 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
class Api::V1::Statuses::ContextsController < Api::BaseController
|
|
include Authorization
|
|
include AsyncRefreshesConcern
|
|
|
|
before_action -> { authorize_if_got_token! :read, :'read:statuses' }
|
|
before_action :set_status
|
|
|
|
# This API was originally unlimited, pagination cannot be introduced without
|
|
# breaking backwards-compatibility. Arbitrarily high number to cover most
|
|
# conversations as quasi-unlimited, it would be too much work to render more
|
|
# than this anyway
|
|
CONTEXT_LIMIT = 4_096
|
|
|
|
# This remains expensive and we don't want to show everything to logged-out users
|
|
ANCESTORS_LIMIT = 40
|
|
DESCENDANTS_LIMIT = 60
|
|
DESCENDANTS_DEPTH_LIMIT = 20
|
|
|
|
def show
|
|
cache_if_unauthenticated!
|
|
|
|
ancestors_limit = CONTEXT_LIMIT
|
|
descendants_limit = CONTEXT_LIMIT
|
|
descendants_depth_limit = nil
|
|
|
|
if current_account.nil?
|
|
ancestors_limit = ANCESTORS_LIMIT
|
|
descendants_limit = DESCENDANTS_LIMIT
|
|
descendants_depth_limit = DESCENDANTS_DEPTH_LIMIT
|
|
end
|
|
|
|
ancestors_results = @status.in_reply_to_id.nil? ? [] : @status.ancestors(ancestors_limit, current_account)
|
|
descendants_results = @status.descendants(descendants_limit, current_account, descendants_depth_limit)
|
|
loaded_ancestors = preload_collection(ancestors_results, Status)
|
|
loaded_descendants = preload_collection(descendants_results, Status)
|
|
|
|
@context = Context.new(ancestors: loaded_ancestors, descendants: loaded_descendants)
|
|
statuses = [@status] + @context.ancestors + @context.descendants
|
|
|
|
refresh_key = "context:#{@status.id}:refresh"
|
|
async_refresh = AsyncRefresh.new(refresh_key)
|
|
|
|
if async_refresh.running?
|
|
add_async_refresh_header(async_refresh)
|
|
elsif !current_account.nil? && @status.should_fetch_replies?
|
|
add_async_refresh_header(AsyncRefresh.create(refresh_key, count_results: true))
|
|
|
|
WorkerBatch.new.within do |batch|
|
|
batch.connect(refresh_key, threshold: 1.0)
|
|
ActivityPub::FetchAllRepliesWorker.perform_async(@status.id, { 'batch_id' => batch.id })
|
|
end
|
|
end
|
|
|
|
render json: @context, serializer: REST::ContextSerializer, relationships: StatusRelationshipsPresenter.new(statuses, current_user&.account_id)
|
|
end
|
|
|
|
private
|
|
|
|
def set_status
|
|
@status = Status.find(params[:status_id])
|
|
authorize @status, :show?
|
|
rescue ActiveRecord::RecordNotFound, Mastodon::NotPermittedError
|
|
not_found
|
|
end
|
|
end
|