[LG-588] Rake task populating email addresses

app/services/populate_email_addresses_table.rb

@@ -0,0 +1,39 @@
+class PopulateEmailAddressesTable
+  def initialize
+    @count = 0
+    @total = 0
+  end
+
+  # :reek:DuplicateMethodCall
+  def call
+    User.in_batches(of: 1000) do |relation|
+      sleep(1)
+      process_batch(relation)
+      Rails.logger.info "#{@count} / #{@total}"
+    end
+    Rails.logger.info "Processed #{@count} user email addresses"
+  end
+
+  private
+
+  def process_batch(relation)
+    User.transaction do
+      relation.each do |user|
+        @total += 1
+        next if user.email_address.present? || user.encrypted_email.blank?
+        user.create_email_address(email_info_for_user(user))
+        @count += 1
+      end
+    end
+  end
+
+  def email_info_for_user(user)
+    {
+      encrypted_email: user.encrypted_email,
+      email_fingerprint: user.email_fingerprint,
+      confirmed_at: user.confirmed_at,
+      confirmation_sent_at: user.confirmation_sent_at,
+      confirmation_token: user.confirmation_token,
+    }
+  end
+end

lib/tasks/migrate_email_addresses.rake

@@ -0,0 +1,7 @@
+namespace :adhoc do
+  desc 'Copy email addresses to the new table'
+  task populate_email_addresses: :environment do
+    Rails.logger = Logger.new(STDOUT)
+    PopulateEmailAddressesTable.new.call
+  end
+end

spec/services/populate_email_addresses_table_spec.rb

@@ -0,0 +1,49 @@
+require 'rails_helper'
+
+describe PopulateEmailAddressesTable do
+  let(:subject) { described_class.new }
+
+  describe '#call' do
+    context 'a user with no email' do
+      let!(:user) { create(:user, email: '', confirmed_at: nil) }
+
+      it 'migrates nothing' do
+        expect(user.email_address).to be_nil
+
+        expect { subject.call }.to change { EmailAddress.count }.by(0)
+      end
+    end
+
+    context 'a user with an email' do
+      let!(:user) { create(:user) }
+
+      context 'and no email_address entry' do
+        before(:each) do
+          user.email_address.delete
+          user.reload
+        end
+
+        it 'migrates without decrypting and re-encrypting' do
+          expect(EncryptedAttribute).to_not receive(:new)
+          subject.call
+        end
+
+        it 'migrates the email' do
+          expect { subject.call }.to change { EmailAddress.count }.by(1)
+
+          address = user.reload.email_address
+          expect(user.email).to eq address.email
+          expect(user.confirmed_at).to eq user.confirmed_at
+          expect(user.confirmation_sent_at).to eq user.confirmation_sent_at
+          expect(user.confirmation_token).to eq user.confirmation_token
+        end
+      end
+
+      context 'and an existing email_address entry' do
+        it 'adds no new rows' do
+          expect { subject.call }.to change { EmailAddress.count }.by(0)
+        end
+      end
+    end
+  end
+end