fedibird-fe/app/services/account_subscribe_service.rb

# 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_acct, options = {})
    @options = { show_reblogs: true, list_id: nil }.merge(options)

    if target_acct.class.name == 'Account'
      target_account = target_acct
    else
      begin
        target_account = ResolveAccountService.new.call(target_acct, skip_webfinger: true)
        target_account ||= ResolveAccountService.new.call(target_acct, skip_webfinger: false)
      rescue
        target_account = nil
      end
    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.subscribing?(target_account, @options[:list_id])
      return
    end

    ActivityTracker.increment('activity:interactions')

    subscribe = source_account.subscribe!(target_account, @options[:show_reblogs], @options[:list_id])
    MergeWorker.perform_async(target_account.id, source_account.id, true) if @options[:list_id].nil?
    subscribe
  end
end