24 lines
1,008 B
Ruby
24 lines
1,008 B
Ruby
# frozen_string_literal: true
|
|
|
|
class UnsubscribeAccountService < BaseService
|
|
# UnsubscribeAccount
|
|
# @param [Account] source_account Where to unsubscribe from
|
|
# @param [Account] target_account Which to unsubscribe
|
|
def call(source_account, target_account, options = {})
|
|
if (options[:list_id] == :all)
|
|
subscribes = AccountSubscribe.where(account: source_account, target_account: target_account)
|
|
else
|
|
subscribes = AccountSubscribe.where(account: source_account, target_account: target_account, list_id: options[:list_id])
|
|
end
|
|
|
|
subscribes.each do |subscribe|
|
|
list_id = subscribe.list_id
|
|
subscribe.destroy!
|
|
if list_id.nil? && !source_account.delivery_following?(target_account)
|
|
UnmergeWorker.perform_async(target_account.id, source_account.id)
|
|
elsif !ListAccount.where(list_id: list_id, account_id: target_account.id).exists?
|
|
UnmergeWorker.perform_async(target_account.id, source_account.id, list_id: list_id)
|
|
end
|
|
end
|
|
end
|
|
end
|