Removed unused activitypub controllers from ruby
• Removed: - unused activitypub controllers from ruby
This commit is contained in:
mgabdev
parent
d7cc2419a6
commit
c0d3d1d6c4
|
|
@ -1,63 +0,0 @@
|
||||||
# frozen_string_literal: true
|
|
||||||
|
|
||||||
class ActivityPub::CollectionsController < Api::BaseController
|
|
||||||
include SignatureVerification
|
|
||||||
|
|
||||||
before_action :set_account
|
|
||||||
before_action :set_size
|
|
||||||
before_action :set_statuses
|
|
||||||
before_action :set_cache_headers
|
|
||||||
|
|
||||||
def show
|
|
||||||
skip_session!
|
|
||||||
|
|
||||||
render_cached_json(['activitypub', 'collection', @account, params[:id]], content_type: 'application/activity+json') do
|
|
||||||
ActiveModelSerializers::SerializableResource.new(
|
|
||||||
collection_presenter,
|
|
||||||
serializer: ActivityPub::CollectionSerializer,
|
|
||||||
adapter: ActivityPub::Adapter,
|
|
||||||
skip_activities: true
|
|
||||||
)
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
private
|
|
||||||
|
|
||||||
def set_account
|
|
||||||
@account = Account.find_local!(params[:account_username])
|
|
||||||
end
|
|
||||||
|
|
||||||
def set_statuses
|
|
||||||
@statuses = scope_for_collection
|
|
||||||
@statuses = cache_collection(@statuses, Status)
|
|
||||||
end
|
|
||||||
|
|
||||||
def set_size
|
|
||||||
case params[:id]
|
|
||||||
when 'featured'
|
|
||||||
@account.pinned_statuses.count
|
|
||||||
else
|
|
||||||
raise ActiveRecord::RecordNotFound
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
def scope_for_collection
|
|
||||||
case params[:id]
|
|
||||||
when 'featured'
|
|
||||||
@account.statuses.permitted_for(@account, signed_request_account).tap do |scope|
|
|
||||||
scope.merge!(@account.pinned_statuses)
|
|
||||||
end
|
|
||||||
else
|
|
||||||
raise ActiveRecord::RecordNotFound
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
def collection_presenter
|
|
||||||
ActivityPub::CollectionPresenter.new(
|
|
||||||
id: account_collection_url(@account, params[:id]),
|
|
||||||
type: :ordered,
|
|
||||||
size: @size,
|
|
||||||
items: @statuses
|
|
||||||
)
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
@ -1,54 +0,0 @@
|
||||||
# frozen_string_literal: true
|
|
||||||
|
|
||||||
class ActivityPub::InboxesController < Api::BaseController
|
|
||||||
include SignatureVerification
|
|
||||||
include JsonLdHelper
|
|
||||||
|
|
||||||
before_action :set_account
|
|
||||||
|
|
||||||
def create
|
|
||||||
if unknown_deleted_account?
|
|
||||||
head 202
|
|
||||||
elsif signed_request_account
|
|
||||||
# upgrade_account
|
|
||||||
# process_payload
|
|
||||||
head 202
|
|
||||||
else
|
|
||||||
render plain: signature_verification_failure_reason, status: 401
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
private
|
|
||||||
|
|
||||||
def unknown_deleted_account?
|
|
||||||
json = Oj.load(body, mode: :strict)
|
|
||||||
json['type'] == 'Delete' && json['actor'].present? && json['actor'] == value_or_id(json['object']) && !Account.where(uri: json['actor']).exists?
|
|
||||||
rescue Oj::ParseError
|
|
||||||
false
|
|
||||||
end
|
|
||||||
|
|
||||||
def set_account
|
|
||||||
@account = Account.find_local!(params[:account_username]) if params[:account_username]
|
|
||||||
end
|
|
||||||
|
|
||||||
def body
|
|
||||||
return @body if defined?(@body)
|
|
||||||
@body = request.body.read.force_encoding('UTF-8')
|
|
||||||
request.body.rewind if request.body.respond_to?(:rewind)
|
|
||||||
@body
|
|
||||||
end
|
|
||||||
|
|
||||||
def upgrade_account
|
|
||||||
if signed_request_account.ostatus?
|
|
||||||
signed_request_account.update(last_webfingered_at: nil)
|
|
||||||
ResolveAccountWorker.perform_async(signed_request_account.acct)
|
|
||||||
end
|
|
||||||
|
|
||||||
Pubsubhubbub::UnsubscribeWorker.perform_async(signed_request_account.id) if signed_request_account.subscribed?
|
|
||||||
DeliveryFailureTracker.track_inverse_success!(signed_request_account)
|
|
||||||
end
|
|
||||||
|
|
||||||
def process_payload
|
|
||||||
# ActivityPub::ProcessingWorker.perform_async(signed_request_account.id, body, @account&.id)
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
@ -1,71 +0,0 @@
|
||||||
# frozen_string_literal: true
|
|
||||||
|
|
||||||
class ActivityPub::OutboxesController < Api::BaseController
|
|
||||||
LIMIT = 20
|
|
||||||
|
|
||||||
include SignatureVerification
|
|
||||||
|
|
||||||
before_action :set_account
|
|
||||||
before_action :set_statuses
|
|
||||||
before_action :set_cache_headers
|
|
||||||
|
|
||||||
def show
|
|
||||||
unless page_requested?
|
|
||||||
skip_session!
|
|
||||||
expires_in 1.minute, public: true
|
|
||||||
end
|
|
||||||
|
|
||||||
render json: outbox_presenter, serializer: ActivityPub::OutboxSerializer, adapter: ActivityPub::Adapter, content_type: 'application/activity+json'
|
|
||||||
end
|
|
||||||
|
|
||||||
private
|
|
||||||
|
|
||||||
def set_account
|
|
||||||
@account = Account.find_local!(params[:account_username])
|
|
||||||
end
|
|
||||||
|
|
||||||
def outbox_presenter
|
|
||||||
if page_requested?
|
|
||||||
ActivityPub::CollectionPresenter.new(
|
|
||||||
id: account_outbox_url(@account, page_params),
|
|
||||||
type: :ordered,
|
|
||||||
part_of: account_outbox_url(@account),
|
|
||||||
prev: prev_page,
|
|
||||||
next: next_page,
|
|
||||||
items: @statuses
|
|
||||||
)
|
|
||||||
else
|
|
||||||
ActivityPub::CollectionPresenter.new(
|
|
||||||
id: account_outbox_url(@account),
|
|
||||||
type: :ordered,
|
|
||||||
size: @account.statuses_count,
|
|
||||||
first: account_outbox_url(@account, page: true),
|
|
||||||
last: account_outbox_url(@account, page: true, min_id: 0)
|
|
||||||
)
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
def next_page
|
|
||||||
account_outbox_url(@account, page: true, max_id: @statuses.last.id) if @statuses.size == LIMIT
|
|
||||||
end
|
|
||||||
|
|
||||||
def prev_page
|
|
||||||
account_outbox_url(@account, page: true, min_id: @statuses.first.id) unless @statuses.empty?
|
|
||||||
end
|
|
||||||
|
|
||||||
def set_statuses
|
|
||||||
return unless page_requested?
|
|
||||||
|
|
||||||
@statuses = @account.statuses.permitted_for(@account, signed_request_account)
|
|
||||||
@statuses = params[:min_id].present? ? @statuses.paginate_by_min_id(LIMIT, params[:min_id]).reverse : @statuses.paginate_by_max_id(LIMIT, params[:max_id])
|
|
||||||
@statuses = cache_collection(@statuses, Status)
|
|
||||||
end
|
|
||||||
|
|
||||||
def page_requested?
|
|
||||||
params[:page] == 'true'
|
|
||||||
end
|
|
||||||
|
|
||||||
def page_params
|
|
||||||
{ page: true, max_id: params[:max_id], min_id: params[:min_id] }.compact
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
@ -69,10 +69,6 @@ Rails.application.routes.draw do
|
||||||
resources :following, only: [:index], controller: :following_accounts
|
resources :following, only: [:index], controller: :following_accounts
|
||||||
resource :follow, only: [:create], controller: :account_follow
|
resource :follow, only: [:create], controller: :account_follow
|
||||||
resource :unfollow, only: [:create], controller: :account_unfollow
|
resource :unfollow, only: [:create], controller: :account_unfollow
|
||||||
|
|
||||||
# resource :outbox, only: [:show], module: :activitypub
|
|
||||||
# resource :inbox, only: [:create], module: :activitypub
|
|
||||||
# resources :collections, only: [:show], module: :activitypub
|
|
||||||
end
|
end
|
||||||
|
|
||||||
# resource :inbox, only: [:create], module: :activitypub
|
# resource :inbox, only: [:create], module: :activitypub
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue