mirror of
https://github.com/whippyshou/mastodon
synced 2024-12-05 10:18:39 +09:00
8b5179d006
duplicates. Web UI regenerates UUID for that header every time the compose form is changed or successfully submitted Also, fix Farsi i18n overwriting the English one
128 lines
4.7 KiB
Ruby
128 lines
4.7 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
class Api::V1::StatusesController < ApiController
|
|
before_action :authorize_if_got_token, except: [:create, :destroy, :reblog, :unreblog, :favourite, :unfavourite]
|
|
before_action -> { doorkeeper_authorize! :write }, only: [:create, :destroy, :reblog, :unreblog, :favourite, :unfavourite]
|
|
before_action :require_user!, except: [:show, :context, :card, :reblogged_by, :favourited_by]
|
|
before_action :set_status, only: [:show, :context, :card, :reblogged_by, :favourited_by]
|
|
|
|
respond_to :json
|
|
|
|
def show
|
|
cached = Rails.cache.read(@status.cache_key)
|
|
@status = cached unless cached.nil?
|
|
end
|
|
|
|
def context
|
|
ancestors_results = @status.in_reply_to_id.nil? ? [] : @status.ancestors(current_account)
|
|
descendants_results = @status.descendants(current_account)
|
|
loaded_ancestors = cache_collection(ancestors_results, Status)
|
|
loaded_descendants = cache_collection(descendants_results, Status)
|
|
|
|
@context = OpenStruct.new(ancestors: loaded_ancestors, descendants: loaded_descendants)
|
|
statuses = [@status] + @context[:ancestors] + @context[:descendants]
|
|
|
|
set_maps(statuses)
|
|
end
|
|
|
|
def card
|
|
@card = PreviewCard.find_by(status: @status)
|
|
render_empty if @card.nil?
|
|
end
|
|
|
|
def reblogged_by
|
|
results = @status.reblogs.paginate_by_max_id(limit_param(DEFAULT_ACCOUNTS_LIMIT), params[:max_id], params[:since_id])
|
|
accounts = Account.where(id: results.map(&:account_id)).map { |a| [a.id, a] }.to_h
|
|
@accounts = results.map { |r| accounts[r.account_id] }
|
|
|
|
next_path = reblogged_by_api_v1_status_url(pagination_params(max_id: results.last.id)) if results.size == limit_param(DEFAULT_ACCOUNTS_LIMIT)
|
|
prev_path = reblogged_by_api_v1_status_url(pagination_params(since_id: results.first.id)) unless results.empty?
|
|
|
|
set_pagination_headers(next_path, prev_path)
|
|
|
|
render :accounts
|
|
end
|
|
|
|
def favourited_by
|
|
results = @status.favourites.paginate_by_max_id(limit_param(DEFAULT_ACCOUNTS_LIMIT), params[:max_id], params[:since_id])
|
|
accounts = Account.where(id: results.map(&:account_id)).map { |a| [a.id, a] }.to_h
|
|
@accounts = results.map { |f| accounts[f.account_id] }
|
|
|
|
next_path = favourited_by_api_v1_status_url(pagination_params(max_id: results.last.id)) if results.size == limit_param(DEFAULT_ACCOUNTS_LIMIT)
|
|
prev_path = favourited_by_api_v1_status_url(pagination_params(since_id: results.first.id)) unless results.empty?
|
|
|
|
set_pagination_headers(next_path, prev_path)
|
|
|
|
render :accounts
|
|
end
|
|
|
|
def create
|
|
@status = PostStatusService.new.call(current_user.account,
|
|
status_params[:status],
|
|
status_params[:in_reply_to_id].blank? ? nil : Status.find(status_params[:in_reply_to_id]),
|
|
media_ids: status_params[:media_ids],
|
|
sensitive: status_params[:sensitive],
|
|
spoiler_text: status_params[:spoiler_text],
|
|
visibility: status_params[:visibility],
|
|
application: doorkeeper_token.application,
|
|
idempotency: request.headers['Idempotency-Key'])
|
|
|
|
render :show
|
|
end
|
|
|
|
def destroy
|
|
@status = Status.where(account_id: current_user.account).find(params[:id])
|
|
RemovalWorker.perform_async(@status.id)
|
|
render_empty
|
|
end
|
|
|
|
def reblog
|
|
@status = ReblogService.new.call(current_user.account, Status.find(params[:id]))
|
|
render :show
|
|
end
|
|
|
|
def unreblog
|
|
reblog = Status.where(account_id: current_user.account, reblog_of_id: params[:id]).first!
|
|
@status = reblog.reblog
|
|
@reblogs_map = { @status.id => false }
|
|
|
|
RemovalWorker.perform_async(reblog.id)
|
|
|
|
render :show
|
|
end
|
|
|
|
def favourite
|
|
@status = FavouriteService.new.call(current_user.account, Status.find(params[:id])).status.reload
|
|
render :show
|
|
end
|
|
|
|
def unfavourite
|
|
@status = Status.find(params[:id])
|
|
@favourites_map = { @status.id => false }
|
|
|
|
UnfavouriteWorker.perform_async(current_user.account_id, @status.id)
|
|
|
|
render :show
|
|
end
|
|
|
|
private
|
|
|
|
def set_status
|
|
@status = Status.find(params[:id])
|
|
raise ActiveRecord::RecordNotFound unless @status.permitted?(current_account)
|
|
end
|
|
|
|
def status_params
|
|
params.permit(:status, :in_reply_to_id, :sensitive, :spoiler_text, :visibility, media_ids: [])
|
|
end
|
|
|
|
def pagination_params(core_params)
|
|
params.permit(:limit).merge(core_params)
|
|
end
|
|
|
|
def authorize_if_got_token
|
|
request_token = Doorkeeper::OAuth::Token.from_request(request, *Doorkeeper.configuration.access_token_methods)
|
|
doorkeeper_authorize! :read if request_token
|
|
end
|
|
end
|