mirror of
https://github.com/discourse/discourse.git
synced 2025-03-22 13:05:35 +08:00
update pr based on review
This commit is contained in:
parent
be1df3ba75
commit
3986367f3f
app/jobs/onceoff
spec/jobs
@ -10,14 +10,11 @@ module Jobs
|
||||
.count
|
||||
.each_key do |email|
|
||||
|
||||
query = users.where("email_tokens.email = ?", email)
|
||||
.order(id: :asc)
|
||||
query = users.where("email_tokens.email = ?", email).order(id: :asc)
|
||||
|
||||
original_user = query.first
|
||||
|
||||
query.offset(1)
|
||||
.each do |user|
|
||||
|
||||
query.offset(1).each do |user|
|
||||
user.posts.each do |post|
|
||||
post.set_owner(original_user, acting_user)
|
||||
end
|
||||
|
@ -1,36 +1,31 @@
|
||||
require 'rails_helper'
|
||||
|
||||
RSpec.describe Jobs::FixPrimaryEmailsForStagedUsers do
|
||||
let(:common_email) { 'test@reply' }
|
||||
let(:staged_user) { Fabricate(:user, staged: true, active: false) }
|
||||
let(:staged_user2) { Fabricate(:user, staged: true, active: false) }
|
||||
let(:staged_user3) { Fabricate(:user, staged: true, active: false) }
|
||||
let(:active_user) { Fabricate(:coding_horror) }
|
||||
|
||||
before do
|
||||
[staged_user, staged_user2, staged_user3].each do |user|
|
||||
user.email_tokens = [Fabricate.create(:email_token, email: common_email, user: user)]
|
||||
end
|
||||
|
||||
UserEmail.delete_all
|
||||
end
|
||||
|
||||
it 'should clean up duplicated staged users' do
|
||||
expect { described_class.new.execute_onceoff({}) }
|
||||
.to change { User.count }.by(-2)
|
||||
common_email = 'test@reply'
|
||||
|
||||
expect(User.all).to contain_exactly(Discourse.system_user, staged_user, active_user)
|
||||
expect(staged_user.reload.email).to eq(common_email)
|
||||
end
|
||||
staged_user = Fabricate(:user, staged: true, active: false)
|
||||
staged_user2 = Fabricate(:user, staged: true, active: false)
|
||||
staged_user3 = Fabricate(:user, staged: true, active: false)
|
||||
|
||||
it 'should move posts owned by duplicate users to the original' do
|
||||
post1 = Fabricate(:post, user: staged_user2)
|
||||
post2 = Fabricate(:post, user: staged_user2)
|
||||
post3 = Fabricate(:post, user: staged_user3)
|
||||
|
||||
expect { described_class.new.execute_onceoff({}) }
|
||||
.to change { staged_user.posts.count }.by(+3)
|
||||
[staged_user, staged_user2, staged_user3].each do |user|
|
||||
user.email_tokens = [Fabricate.create(:email_token, email: common_email, user: user)]
|
||||
end
|
||||
|
||||
active_user = Fabricate(:coding_horror)
|
||||
|
||||
UserEmail.delete_all
|
||||
|
||||
expect { described_class.new.execute_onceoff({}) }
|
||||
.to change { User.count }.by(-2)
|
||||
.and change { staged_user.posts.count }.by(3)
|
||||
|
||||
expect(User.all).to contain_exactly(Discourse.system_user, staged_user, active_user)
|
||||
expect(staged_user.posts.all).to contain_exactly(post1, post2, post3)
|
||||
expect(staged_user.reload.email).to eq(common_email)
|
||||
end
|
||||
end
|
||||
|
Loading…
x
Reference in New Issue
Block a user