30 lines
1.2 KiB
Ruby
30 lines
1.2 KiB
Ruby
|
# frozen_string_literal: true
|
||
|
|
|
||
|
|
class AccountSubscribeService < BaseService
|
||
|
|
# Subscribe a remote user
|
||
|
|
# @param [Account] source_account From which to subscribe
|
||
|
|
# @param [String, Account] uri User URI to subscribe in the form of username@domain (or account record)
|
||
|
|
def call(source_account, target_account)
|
||
|
|
begin
|
||
|
|
target_account = ResolveAccountService.new.call(target_account, skip_webfinger: false)
|
||
|
|
rescue
|
||
|
|
target_account = nil
|
||
|
|
end
|
||
|
|
|
||
|
|
raise ActiveRecord::RecordNotFound if target_account.nil? || target_account.id == source_account.id || target_account.suspended?
|
||
|
|
raise Mastodon::NotPermittedError if target_account.blocking?(source_account) || source_account.blocking?(target_account) || (!target_account.local? && target_account.ostatus?) || source_account.domain_blocking?(target_account.domain)
|
||
|
|
|
||
|
|
if source_account.following?(target_account)
|
||
|
|
return
|
||
|
|
elsif source_account.subscribing?(target_account)
|
||
|
|
return
|
||
|
|
end
|
||
|
|
|
||
|
|
ActivityTracker.increment('activity:interactions')
|
||
|
|
|
||
|
|
subscribe = source_account.subscribe!(target_account)
|
||
|
|
MergeWorker.perform_async(target_account.id, source_account.id, true)
|
||
|
|
subscribe
|
||
|
|
end
|
||
|
|
end
|