159 lines
		
	
	
	
		
			4 KiB
		
	
	
	
		
			Ruby
		
	
	
	
	
	
			
		
		
	
	
			159 lines
		
	
	
	
		
			4 KiB
		
	
	
	
		
			Ruby
		
	
	
	
	
	
| # frozen_string_literal: true
 | |
| 
 | |
| class Api::V1::Admin::AccountsController < Api::BaseController
 | |
|   include Authorization
 | |
|   include AccountableConcern
 | |
| 
 | |
|   LIMIT = 100
 | |
| 
 | |
|   before_action -> { authorize_if_got_token! :'admin:read', :'admin:read:accounts' }, only: [:index, :show]
 | |
|   before_action -> { authorize_if_got_token! :'admin:write', :'admin:write:accounts' }, except: [:index, :show]
 | |
|   before_action :set_accounts, only: :index
 | |
|   before_action :set_account, except: :index
 | |
|   before_action :require_local_account!, only: [:enable, :approve, :reject]
 | |
| 
 | |
|   after_action :verify_authorized
 | |
|   after_action :insert_pagination_headers, only: :index
 | |
| 
 | |
|   FILTER_PARAMS = %i(
 | |
|     local
 | |
|     remote
 | |
|     by_domain
 | |
|     active
 | |
|     pending
 | |
|     disabled
 | |
|     sensitized
 | |
|     silenced
 | |
|     suspended
 | |
|     username
 | |
|     display_name
 | |
|     email
 | |
|     ip
 | |
|     staff
 | |
|   ).freeze
 | |
| 
 | |
|   PAGINATION_PARAMS = (%i(limit) + FILTER_PARAMS).freeze
 | |
| 
 | |
|   def index
 | |
|     authorize :account, :index?
 | |
|     render json: @accounts, each_serializer: REST::Admin::AccountSerializer
 | |
|   end
 | |
| 
 | |
|   def show
 | |
|     authorize @account, :show?
 | |
|     render json: @account, serializer: REST::Admin::AccountSerializer
 | |
|   end
 | |
| 
 | |
|   def enable
 | |
|     authorize @account.user, :enable?
 | |
|     @account.user.enable!
 | |
|     log_action :enable, @account.user
 | |
|     render json: @account, serializer: REST::Admin::AccountSerializer
 | |
|   end
 | |
| 
 | |
|   def approve
 | |
|     authorize @account.user, :approve?
 | |
|     @account.user.approve!
 | |
|     render json: @account, serializer: REST::Admin::AccountSerializer
 | |
|   end
 | |
| 
 | |
|   def reject
 | |
|     authorize @account.user, :reject?
 | |
|     DeleteAccountService.new.call(@account, reserve_email: false, reserve_username: false)
 | |
|     render_empty
 | |
|   end
 | |
| 
 | |
|   def destroy
 | |
|     authorize @account, :destroy?
 | |
|     Admin::AccountDeletionWorker.perform_async(@account.id)
 | |
|     render_empty
 | |
|   end
 | |
| 
 | |
|   def unsensitive
 | |
|     authorize @account, :unsensitive?
 | |
|     @account.unsensitize!
 | |
|     log_action :unsensitive, @account
 | |
|     render json: @account, serializer: REST::Admin::AccountSerializer
 | |
|   end
 | |
| 
 | |
|   def unsilence
 | |
|     authorize @account, :unsilence?
 | |
|     @account.unsilence!
 | |
|     log_action :unsilence, @account
 | |
|     render json: @account, serializer: REST::Admin::AccountSerializer
 | |
|   end
 | |
| 
 | |
|   def unsuspend
 | |
|     authorize @account, :unsuspend?
 | |
|     @account.unsuspend!
 | |
|     Admin::UnsuspensionWorker.perform_async(@account.id)
 | |
|     log_action :unsuspend, @account
 | |
|     render json: @account, serializer: REST::Admin::AccountSerializer
 | |
|   end
 | |
| 
 | |
|   private
 | |
| 
 | |
|   def set_accounts
 | |
|     @accounts = filtered_accounts.order(id: :desc).includes(user: [:invite_request, :invite, :ips]).to_a_paginated_by_id(limit_param(LIMIT), params_slice(:max_id, :since_id, :min_id))
 | |
|   end
 | |
| 
 | |
|   def set_account
 | |
|     @account = Account.find(params[:id])
 | |
|   end
 | |
| 
 | |
|   def filtered_accounts
 | |
|     AccountFilter.new(translated_filter_params).results
 | |
|   end
 | |
| 
 | |
|   def filter_params
 | |
|     params.permit(*FILTER_PARAMS)
 | |
|   end
 | |
| 
 | |
|   def translated_filter_params
 | |
|     translated_params = { origin: 'local', status: 'active' }.merge(filter_params.slice(*AccountFilter::KEYS))
 | |
| 
 | |
|     translated_params[:origin] = 'remote' if params[:remote].present?
 | |
| 
 | |
|     %i(active pending disabled silenced suspended).each do |status|
 | |
|       translated_params[:status] = status.to_s if params[status].present?
 | |
|     end
 | |
| 
 | |
|     if params[:staff].present?
 | |
|       translated_params[:role_ids] = UserRole.that_can(:manage_reports).map(&:id)
 | |
|     end
 | |
| 
 | |
|     translated_params
 | |
|   end
 | |
| 
 | |
|   def insert_pagination_headers
 | |
|     set_pagination_headers(next_path, prev_path)
 | |
|   end
 | |
| 
 | |
|   def next_path
 | |
|     api_v1_admin_accounts_url(pagination_params(max_id: pagination_max_id)) if records_continue?
 | |
|   end
 | |
| 
 | |
|   def prev_path
 | |
|     api_v1_admin_accounts_url(pagination_params(min_id: pagination_since_id)) unless @accounts.empty?
 | |
|   end
 | |
| 
 | |
|   def pagination_max_id
 | |
|     @accounts.last.id
 | |
|   end
 | |
| 
 | |
|   def pagination_since_id
 | |
|     @accounts.first.id
 | |
|   end
 | |
| 
 | |
|   def records_continue?
 | |
|     @accounts.size == limit_param(LIMIT)
 | |
|   end
 | |
| 
 | |
|   def pagination_params(core_params)
 | |
|     params.slice(*PAGINATION_PARAMS).permit(*PAGINATION_PARAMS).merge(core_params)
 | |
|   end
 | |
| 
 | |
|   def require_local_account!
 | |
|     forbidden unless @account.local? && @account.user.present?
 | |
|   end
 | |
| end
 |