Merge pull request #1007 from griffithlab/account-merge

Introduce Account Merge Tool

server/app/models/actions/merge_accounts.rb

@@ -0,0 +1,154 @@
+module Actions
+  class MergeAccounts
+    include Actions::Transactional
+
+    attr_reader :account_to_keep, :accounts_to_merge, :old_account_ids
+
+    def initialize(account_to_keep:, accounts_to_merge_in:)
+      @account_to_keep = account_to_keep
+      @accounts_to_merge = Array(accounts_to_merge_in)
+      @old_account_ids = @accounts_to_merge.map(&:id)
+    end
+
+    def execute
+      move_authorizations
+      move_activities
+      move_events
+      move_comments
+      move_flags
+      move_subscriptions
+      move_notifications
+      merge_roles
+      move_mentions
+      move_source_suggestions
+      merge_organizations
+      move_legacy_changes
+      account_to_keep.save!
+      accounts_to_merge.each { |u| u.destroy! }
+    end
+
+    private
+    def move_authorizations
+      auths = Authorization.where(user_id: old_account_ids)
+      auths.each do |a|
+        a.user_id = account_to_keep.id
+        a.save!
+      end
+    end
+
+    def move_activities
+      activities = Activity.where(user_id: old_account_ids)
+      activities.each do |a|
+        a.user_id = account_to_keep.id
+        a.save!
+      end
+    end
+
+    def move_events
+      events = Event.where(originating_user_id: old_account_ids)
+      events.each do |e|
+        e.originating_user_id = account_to_keep.id
+        e.save!
+      end
+    end
+
+    def move_comments
+      comments = Comment.where(user_id: old_account_ids)
+      comments.each do |c|
+        c.user_id = account_to_keep.id
+        c.save!
+      end
+    end
+
+    def move_flags
+      flagging = Flag.where(flagging_user_id: old_account_ids)
+      flagging.each do |f|
+        f.flagging_user_id = account_to_keep.id
+        f.save!
+      end
+
+      resolving = Flag.where(resolving_user_id: old_account_ids)
+      resolving.each do |f|
+        f.resolving_user_id = account_to_keep.id
+        f.save!
+      end
+    end
+
+    def move_subscriptions
+      subs = Subscription.where(user_id: old_account_ids)
+      subs.each do |s|
+        if Subscription.where(subscribable: s.subscribable, user_id: account_to_keep.id).exists?
+          s.destroy!
+        else
+          s.user_id = account_to_keep.id
+          s.save!
+        end
+      end
+    end
+
+    def move_notifications
+      notified = Notification.where(notified_user_id: old_account_ids)
+      notified.each do |n|
+        if Notification.where(event_id: n.event_id, notified_user_id: account_to_keep.id).exists?
+          n.destroy!
+        else
+          n.notified_user_id = account_to_keep.id
+          n.save!
+        end
+      end
+
+      notifier = Notification.where(originating_user_id: old_account_ids)
+      notifier.each do |n|
+        if Notification.where(event_id: n.event_id, originating_user_id: account_to_keep.id).exists?
+          n.destroy!
+        else
+          n.originating_user_id = account_to_keep.id
+          n.save!
+        end
+      end
+    end
+
+    def move_mentions
+      mentions = UserMention.where(user_id: old_account_ids)
+      mentions.each do |m|
+        if UserMention.where(user_id: account_to_keep.id, comment_id: m.comment_id)
+          m.destroy!
+        else
+          m.user_id = account_to_keep.id
+          m.save!
+        end
+      end
+    end
+
+    def merge_roles
+      account_to_keep.role = Role.highest_role_for_users(account_to_keep, *accounts_to_merge)
+    end
+
+    def move_source_suggestions
+      suggestions = SourceSuggestion.where(user_id: old_account_ids)
+      suggestions.each do |s|
+        s.user_id = account_to_keep.id
+        s.save!
+      end
+    end
+
+    def merge_organizations
+      orgs_to_add = accounts_to_merge.flat_map(&:organizations)
+      accounts_to_merge.each do |user|
+        user.organizations = []
+      end
+      existing_orgs = account_to_keep.organizations
+      all_orgs = orgs_to_add + existing_orgs
+      account_to_keep.organizations = all_orgs.uniq
+    end
+
+    class SuggestedChange < ActiveRecord::Base; end
+    def move_legacy_changes
+      changes = SuggestedChange.where(user_id: old_account_ids)
+      changes.each do |sc|
+        sc.user_id = account_to_keep.id
+        sc.save!
+      end
+    end
+  end
+end

server/app/models/notification.rb

@@ -3,7 +3,7 @@ class Notification < ActiveRecord::Base
   belongs_to :notified_user, foreign_key: :notified_user_id, class_name: 'User'
   belongs_to :originating_user, foreign_key: :originating_user_id, class_name: 'User'
   belongs_to :event
-  belongs_to :subscription, optional: true
+  belongs_to :subscription, optional: true, dependent: :destroy
 
   enum type: [:subscribed_event, :mention]
 

server/app/models/subscription.rb

@@ -4,6 +4,8 @@ class Subscription < ActiveRecord::Base
   belongs_to :user
   belongs_to :subscribable, polymorphic: true
 
+  has_many :notifications, dependent: :destroy
+
   def send_notification(event)
     raise 'Implement in subclass!'
   end