mirror of
https://github.com/mastodon/mastodon.git
synced 2024-12-15 23:54:52 +01:00
03d59340da
* Fix Sidekiq warnings about JSON serialization This occurs on every symbol argument we pass, and every symbol key in hashes, because Sidekiq expects strings instead. See https://github.com/mperham/sidekiq/pull/5071 We do not need to change how workers parse their arguments because this has not changed and we were already converting to symbols adequately or using `with_indifferent_access`. * Set Sidekiq to raise on unsafe arguments in test mode In order to more easily catch issues that would produce warnings in production code.
122 lines
2.7 KiB
Ruby
122 lines
2.7 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
class Form::AccountBatch
|
|
include ActiveModel::Model
|
|
include Authorization
|
|
include AccountableConcern
|
|
include Payloadable
|
|
|
|
attr_accessor :account_ids, :action, :current_account
|
|
|
|
def save
|
|
case action
|
|
when 'follow'
|
|
follow!
|
|
when 'unfollow'
|
|
unfollow!
|
|
when 'remove_from_followers'
|
|
remove_from_followers!
|
|
when 'block_domains'
|
|
block_domains!
|
|
when 'approve'
|
|
approve!
|
|
when 'reject'
|
|
reject!
|
|
when 'suppress_follow_recommendation'
|
|
suppress_follow_recommendation!
|
|
when 'unsuppress_follow_recommendation'
|
|
unsuppress_follow_recommendation!
|
|
when 'suspend'
|
|
suspend!
|
|
end
|
|
end
|
|
|
|
private
|
|
|
|
def follow!
|
|
accounts.each do |target_account|
|
|
FollowService.new.call(current_account, target_account)
|
|
end
|
|
end
|
|
|
|
def unfollow!
|
|
accounts.each do |target_account|
|
|
UnfollowService.new.call(current_account, target_account)
|
|
end
|
|
end
|
|
|
|
def remove_from_followers!
|
|
RemoveFromFollowersService.new.call(current_account, account_ids)
|
|
end
|
|
|
|
def block_domains!
|
|
AfterAccountDomainBlockWorker.push_bulk(account_domains) do |domain|
|
|
[current_account.id, domain]
|
|
end
|
|
end
|
|
|
|
def account_domains
|
|
accounts.group(:domain).pluck(:domain).compact
|
|
end
|
|
|
|
def accounts
|
|
Account.where(id: account_ids)
|
|
end
|
|
|
|
def approve!
|
|
accounts.includes(:user).find_each do |account|
|
|
approve_account(account)
|
|
end
|
|
end
|
|
|
|
def reject!
|
|
accounts.includes(:user).find_each do |account|
|
|
reject_account(account)
|
|
end
|
|
end
|
|
|
|
def suspend!
|
|
accounts.find_each do |account|
|
|
if account.user_pending?
|
|
reject_account(account)
|
|
else
|
|
suspend_account(account)
|
|
end
|
|
end
|
|
end
|
|
|
|
def suppress_follow_recommendation!
|
|
authorize(:follow_recommendation, :suppress?)
|
|
|
|
accounts.find_each do |account|
|
|
FollowRecommendationSuppression.create(account: account)
|
|
end
|
|
end
|
|
|
|
def unsuppress_follow_recommendation!
|
|
authorize(:follow_recommendation, :unsuppress?)
|
|
|
|
FollowRecommendationSuppression.where(account_id: account_ids).destroy_all
|
|
end
|
|
|
|
def reject_account(account)
|
|
authorize(account.user, :reject?)
|
|
log_action(:reject, account.user, username: account.username)
|
|
account.suspend!(origin: :local)
|
|
AccountDeletionWorker.perform_async(account.id, { 'reserve_username' => false })
|
|
end
|
|
|
|
def suspend_account(account)
|
|
authorize(account, :suspend?)
|
|
log_action(:suspend, account)
|
|
account.suspend!(origin: :local)
|
|
Admin::SuspensionWorker.perform_async(account.id)
|
|
end
|
|
|
|
def approve_account(account)
|
|
authorize(account.user, :approve?)
|
|
log_action(:approve, account.user)
|
|
account.user.approve!
|
|
end
|
|
end
|