2017-07-15 03:01:39 +02:00
|
|
|
# frozen_string_literal: true
|
|
|
|
|
2019-07-17 00:00:39 +02:00
|
|
|
class ActivityPub::OutboxesController < ActivityPub::BaseController
|
2018-05-04 19:19:11 +02:00
|
|
|
LIMIT = 20
|
|
|
|
|
2018-02-02 10:19:59 +01:00
|
|
|
include SignatureVerification
|
2019-07-08 12:03:45 +02:00
|
|
|
include AccountOwnedConcern
|
2018-02-02 10:19:59 +01:00
|
|
|
|
2023-04-19 16:07:29 +02:00
|
|
|
vary_by -> { 'Signature' if authorized_fetch_mode? || page_requested? }
|
|
|
|
|
2022-09-21 22:45:57 +02:00
|
|
|
before_action :require_account_signature!, if: :authorized_fetch_mode?
|
2018-05-04 19:19:11 +02:00
|
|
|
before_action :set_statuses
|
2017-07-15 03:01:39 +02:00
|
|
|
|
|
|
|
def show
|
2021-07-03 21:13:47 +02:00
|
|
|
if page_requested?
|
|
|
|
expires_in(1.minute, public: public_fetch_mode? && signed_request_account.nil?)
|
|
|
|
else
|
|
|
|
expires_in(3.minutes, public: public_fetch_mode?)
|
|
|
|
end
|
2023-04-19 16:07:29 +02:00
|
|
|
|
2018-03-04 09:19:11 +01:00
|
|
|
render json: outbox_presenter, serializer: ActivityPub::OutboxSerializer, adapter: ActivityPub::Adapter, content_type: 'application/activity+json'
|
2017-07-15 03:01:39 +02:00
|
|
|
end
|
|
|
|
|
|
|
|
private
|
|
|
|
|
|
|
|
def outbox_presenter
|
2018-05-04 19:19:11 +02:00
|
|
|
if page_requested?
|
|
|
|
ActivityPub::CollectionPresenter.new(
|
2021-05-06 14:22:54 +02:00
|
|
|
id: outbox_url(**page_params),
|
2018-05-04 19:19:11 +02:00
|
|
|
type: :ordered,
|
2020-09-02 18:42:50 +02:00
|
|
|
part_of: outbox_url,
|
2018-05-04 19:19:11 +02:00
|
|
|
prev: prev_page,
|
|
|
|
next: next_page,
|
|
|
|
items: @statuses
|
|
|
|
)
|
|
|
|
else
|
|
|
|
ActivityPub::CollectionPresenter.new(
|
2021-05-31 22:59:30 +02:00
|
|
|
id: outbox_url,
|
2018-05-04 19:19:11 +02:00
|
|
|
type: :ordered,
|
|
|
|
size: @account.statuses_count,
|
2020-09-02 18:42:50 +02:00
|
|
|
first: outbox_url(page: true),
|
|
|
|
last: outbox_url(page: true, min_id: 0)
|
2018-05-04 19:19:11 +02:00
|
|
|
)
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2020-09-02 18:42:50 +02:00
|
|
|
def outbox_url(**kwargs)
|
|
|
|
if params[:account_username].present?
|
|
|
|
account_outbox_url(@account, **kwargs)
|
|
|
|
else
|
|
|
|
instance_actor_outbox_url(**kwargs)
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2018-05-04 19:19:11 +02:00
|
|
|
def next_page
|
2021-05-31 22:59:30 +02:00
|
|
|
outbox_url(page: true, max_id: @statuses.last.id) if @statuses.size == LIMIT
|
2018-05-04 19:19:11 +02:00
|
|
|
end
|
|
|
|
|
|
|
|
def prev_page
|
2021-05-31 22:59:30 +02:00
|
|
|
outbox_url(page: true, min_id: @statuses.first.id) unless @statuses.empty?
|
2018-05-04 19:19:11 +02:00
|
|
|
end
|
|
|
|
|
|
|
|
def set_statuses
|
|
|
|
return unless page_requested?
|
|
|
|
|
2020-08-28 12:31:56 +02:00
|
|
|
@statuses = cache_collection_paginated_by_id(
|
2022-03-08 09:14:39 +01:00
|
|
|
AccountStatusesFilter.new(@account, signed_request_account).results,
|
2020-08-28 12:31:56 +02:00
|
|
|
Status,
|
|
|
|
LIMIT,
|
|
|
|
params_slice(:max_id, :min_id, :since_id)
|
|
|
|
)
|
2018-05-04 19:19:11 +02:00
|
|
|
end
|
|
|
|
|
|
|
|
def page_requested?
|
2020-05-03 16:30:36 +02:00
|
|
|
truthy_param?(:page)
|
2018-05-04 19:19:11 +02:00
|
|
|
end
|
|
|
|
|
|
|
|
def page_params
|
|
|
|
{ page: true, max_id: params[:max_id], min_id: params[:min_id] }.compact
|
2017-07-15 03:01:39 +02:00
|
|
|
end
|
2020-09-02 18:42:50 +02:00
|
|
|
|
|
|
|
def set_account
|
|
|
|
@account = params[:account_username].present? ? Account.find_local!(username_param) : Account.representative
|
|
|
|
end
|
2017-07-15 03:01:39 +02:00
|
|
|
end
|