app/workers/account_merging_worker.rb


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

# frozen_string_literal: true

class AccountMergingWorker
  include Sidekiq::Worker

  sidekiq_options queue: 'pull'

  def perform(account_id)
    account = Account.find(account_id)

    return true if account.nil? || account.local?

    Account.where(uri: account.uri).where.not(id: account.id).find_each do |duplicate|
      account.merge_with!(duplicate)
      duplicate.destroy
    end
  end
end