.circleci
.github
app
chewy
controllers
activitypub
admin
api
v1
accounts
credentials_controller.rb
follower_accounts_controller.rb
following_accounts_controller.rb
lists_controller.rb
relationships_controller.rb
search_controller.rb
statuses_controller.rb
apps
instances
lists
statuses
timelines
accounts_controller.rb
apps_controller.rb
blocks_controller.rb
custom_emojis_controller.rb
domain_blocks_controller.rb
favourites_controller.rb
follow_requests_controller.rb
follows_controller.rb
instances_controller.rb
lists_controller.rb
media_controller.rb
mutes_controller.rb
notifications_controller.rb
reports_controller.rb
search_controller.rb
statuses_controller.rb
streaming_controller.rb
web
base_controller.rb
oembed_controller.rb
push_controller.rb
salmon_controller.rb
subscriptions_controller.rb
auth
concerns
oauth
settings
well_known
about_controller.rb
account_follow_controller.rb
account_unfollow_controller.rb
accounts_controller.rb
application_controller.rb
authorize_follows_controller.rb
emojis_controller.rb
follower_accounts_controller.rb
following_accounts_controller.rb
home_controller.rb
intents_controller.rb
invites_controller.rb
manifests_controller.rb
media_controller.rb
media_proxy_controller.rb
remote_follow_controller.rb
remote_unfollows.rb
shares_controller.rb
statuses_controller.rb
stream_entries_controller.rb
tags_controller.rb
helpers
javascript
lib
mailers
models
policies
presenters
serializers
services
validators
views
workers
bin
config
db
docs
lib
log
nanobox
public
spec
streaming
vendor
.babelrc
.buildpacks
.codeclimate.yml
.dockerignore
.editorconfig
.env.nanobox
.env.production.sample
.env.test
.env.vagrant
.eslintignore
.eslintrc.yml
.foreman
.gitattributes
.gitignore
.haml-lint.yml
.nanoignore
.nvmrc
.postcssrc.yml
.profile
.rspec
.rubocop.yml
.ruby-version
.scss-lint.yml
.slugignore
.yarnclean
AUTHORS.md
Aptfile
CODE_OF_CONDUCT.md
CONTRIBUTING.md
Capfile
Dockerfile
Gemfile
Gemfile.lock
LICENSE
Procfile
Procfile.dev
README.md
Rakefile
Vagrantfile
app.json
boxfile.yml
config.ru
docker-compose.yml
dump.rdb
jest.config.js
package.json
scalingo.json
yarn.lock
103 lines
2.8 KiB
Ruby
103 lines
2.8 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
class Api::V1::Accounts::StatusesController < Api::BaseController
|
|
before_action -> { doorkeeper_authorize! :read }
|
|
before_action :set_account
|
|
after_action :insert_pagination_headers
|
|
|
|
respond_to :json
|
|
|
|
def index
|
|
@statuses = load_statuses
|
|
render json: @statuses, each_serializer: REST::StatusSerializer, relationships: StatusRelationshipsPresenter.new(@statuses, current_user&.account_id)
|
|
end
|
|
|
|
private
|
|
|
|
def set_account
|
|
@account = Account.find(params[:account_id])
|
|
end
|
|
|
|
def load_statuses
|
|
cached_account_statuses
|
|
end
|
|
|
|
def cached_account_statuses
|
|
cache_collection account_statuses, Status
|
|
end
|
|
|
|
def account_statuses
|
|
default_statuses.tap do |statuses|
|
|
statuses.merge!(only_media_scope) if truthy_param?(:only_media)
|
|
statuses.merge!(pinned_scope) if truthy_param?(:pinned)
|
|
statuses.merge!(no_replies_scope) if truthy_param?(:exclude_replies)
|
|
end
|
|
end
|
|
|
|
def default_statuses
|
|
permitted_account_statuses.paginate_by_max_id(
|
|
limit_param(DEFAULT_STATUSES_LIMIT),
|
|
params[:max_id],
|
|
params[:since_id]
|
|
)
|
|
end
|
|
|
|
def permitted_account_statuses
|
|
@account.statuses.permitted_for(@account, current_account)
|
|
end
|
|
|
|
def only_media_scope
|
|
Status.where(id: account_media_status_ids)
|
|
end
|
|
|
|
def account_media_status_ids
|
|
# `SELECT DISTINCT id, updated_at` is too slow, so pluck ids at first, and then select id, updated_at with ids.
|
|
# Also, Avoid getting slow by not narrowing down by `statuses.account_id`.
|
|
# When narrowing down by `statuses.account_id`, `index_statuses_20180106` will be used
|
|
# and the table will be joined by `Merge Semi Join`, so the query will be slow.
|
|
Status.joins(:media_attachments).merge(@account.media_attachments).permitted_for(@account, current_account)
|
|
.paginate_by_max_id(limit_param(DEFAULT_STATUSES_LIMIT), params[:max_id], params[:since_id])
|
|
.reorder(id: :desc).distinct(:id).pluck(:id)
|
|
end
|
|
|
|
def pinned_scope
|
|
@account.pinned_statuses
|
|
end
|
|
|
|
def no_replies_scope
|
|
Status.without_replies
|
|
end
|
|
|
|
def pagination_params(core_params)
|
|
params.slice(:limit, :only_media, :exclude_replies).permit(:limit, :only_media, :exclude_replies).merge(core_params)
|
|
end
|
|
|
|
def insert_pagination_headers
|
|
set_pagination_headers(next_path, prev_path)
|
|
end
|
|
|
|
def next_path
|
|
if records_continue?
|
|
api_v1_account_statuses_url pagination_params(max_id: pagination_max_id)
|
|
end
|
|
end
|
|
|
|
def prev_path
|
|
unless @statuses.empty?
|
|
api_v1_account_statuses_url pagination_params(since_id: pagination_since_id)
|
|
end
|
|
end
|
|
|
|
def records_continue?
|
|
@statuses.size == limit_param(DEFAULT_STATUSES_LIMIT)
|
|
end
|
|
|
|
def pagination_max_id
|
|
@statuses.last.id
|
|
end
|
|
|
|
def pagination_since_id
|
|
@statuses.first.id
|
|
end
|
|
end
|