Merge pull request #9041 from tchak/fix-published-cloned-revisions

fix(dossier): task to fix cloned published revisions
This commit is contained in:
LeSim 2023-05-12 17:03:30 +02:00 committed by GitHub
commit e02294cbd0
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 188 additions and 0 deletions

View file

@ -0,0 +1,46 @@
namespace :after_party do
desc 'Deployment task: fix_cloned_published_revisions'
task fix_cloned_published_revisions: :environment do
puts "Running deploy task 'fix_cloned_published_revisions'"
parent_procedures = Procedure
.joins(:published_revision)
.where('procedure_revisions.procedure_id != procedures.id')
parent_procedures.find_each do |parent_procedure|
cloned_procedures = Procedure
.where(parent_procedure:)
.includes(:revisions)
.filter { parent_procedure.published_revision_id.in?(_1.revisions.ids) }
cloned_procedures.each do |cloned_procedure|
foreign_revision = cloned_procedure.revisions.find parent_procedure.published_revision_id
new_revision = parent_procedure.create_new_revision(foreign_revision)
cloned_groupe_instructeur_ids = cloned_procedure.groupe_instructeurs.ids
cloned_procedure_dossiers, _ = cloned_procedure
.dossiers
.partition { _1.groupe_instructeur_id.in?(cloned_groupe_instructeur_ids) }
if cloned_procedure.draft_revision_id == foreign_revision.id
cloned_procedure.update(draft_revision: new_revision)
puts "Update draft_revision for procedure #{cloned_procedure.id}"
elsif cloned_procedure.published_revision_id == foreign_revision.id
cloned_procedure.update(published_revision: new_revision)
puts "Update published_revision for procedure #{cloned_procedure.id}"
end
cloned_procedure_dossiers.each { _1.update(revision_id: new_revision.id) }
puts "Update dossiers #{cloned_procedure_dossiers.map(&:id)} for procedure: #{cloned_procedure.id}"
foreign_revision.update(procedure_id: parent_procedure.id)
puts "Update revision #{foreign_revision.id} for procedure: #{cloned_procedure.id}"
end
end
# Update task as completed. If you remove the line below, the task will
# run with every deploy (or every time you call after_party:run).
AfterParty::TaskRecord
.create version: AfterParty::TaskRecorder.new(__FILE__).timestamp
end
end

View file

@ -0,0 +1,142 @@
describe.skip '20230512103830_fix_cloned_published_revisions' do
let(:rake_task) { Rake::Task['after_party:fix_cloned_published_revisions'] }
subject(:run_task) { rake_task.invoke }
after(:each) { rake_task.reenable }
let(:procedure) { create(:procedure, types_de_champ_public: [{}]) }
let(:cloned_procedure) { procedure.clone(procedure.administrateurs.first, false) }
let(:dossier_parent_procedure) { create(:dossier, procedure:) }
let(:dossier_cloned_procedure) { create(:dossier, procedure: cloned_procedure) }
before do
procedure.publish!
dossier_parent_procedure
procedure.reload
cloned_procedure
dossier_cloned_procedure
procedure.reload
end
context 'just clone' do
it do
# procedures
expect(procedure.published_revision.procedure_id).not_to eq(procedure.id)
expect(cloned_procedure.draft_revision_id).to eq(procedure.published_revision_id)
# dossiers
expect(dossier_parent_procedure.revision_id).to eq(dossier_cloned_procedure.revision_id)
expect(dossier_parent_procedure.groupe_instructeur_id).not_to be_nil
expect(dossier_cloned_procedure.groupe_instructeur_id).not_to be_nil
expect(dossier_parent_procedure.groupe_instructeur_id).not_to eq(dossier_cloned_procedure.groupe_instructeur_id)
expect(procedure.dossiers).to match_array([])
expect(procedure.published_revision.dossiers).to match_array([dossier_parent_procedure, dossier_cloned_procedure])
expect(cloned_procedure.dossiers).to match_array([dossier_parent_procedure, dossier_cloned_procedure])
# subject
subject
procedure.reload
cloned_procedure.reload
dossier_parent_procedure.reload
dossier_cloned_procedure.reload
expect(procedure.published_revision.procedure_id).to eq(procedure.id)
expect(cloned_procedure.draft_revision_id).not_to eq(procedure.published_revision_id)
expect(cloned_procedure.draft_revision.procedure_id).to eq(cloned_procedure.id)
expect(procedure.draft_revision_id).not_to eq(cloned_procedure.draft_revision_id)
expect(procedure.published_revision_id).not_to eq(cloned_procedure.published_revision_id)
# dossiers
expect(dossier_parent_procedure.revision_id).not_to eq(dossier_cloned_procedure.revision_id)
expect(dossier_parent_procedure.groupe_instructeur_id).not_to eq(dossier_cloned_procedure.groupe_instructeur_id)
expect(procedure.dossiers).to match_array([dossier_parent_procedure])
expect(procedure.published_revision.dossiers).to match_array([dossier_parent_procedure])
expect(cloned_procedure.dossiers).to match_array([dossier_cloned_procedure])
end
end
context 'clone and publish' do
before do
cloned_procedure.publish!
cloned_procedure.reload
end
it do
# procedures
expect(procedure.published_revision.procedure_id).not_to eq(procedure.id)
expect(cloned_procedure.published_revision_id).to eq(procedure.published_revision_id)
# dossiers
expect(dossier_parent_procedure.revision_id).to eq(dossier_cloned_procedure.revision_id)
expect(dossier_parent_procedure.groupe_instructeur_id).not_to be_nil
expect(dossier_cloned_procedure.groupe_instructeur_id).not_to be_nil
expect(dossier_parent_procedure.groupe_instructeur_id).not_to eq(dossier_cloned_procedure.groupe_instructeur_id)
expect(procedure.dossiers).to match_array([])
expect(procedure.published_revision.dossiers).to match_array([dossier_parent_procedure, dossier_cloned_procedure])
expect(cloned_procedure.dossiers).to match_array([dossier_parent_procedure, dossier_cloned_procedure])
# subject
subject
procedure.reload
cloned_procedure.reload
dossier_parent_procedure.reload
dossier_cloned_procedure.reload
expect(procedure.published_revision.procedure_id).to eq(procedure.id)
expect(cloned_procedure.draft_revision.procedure_id).to eq(cloned_procedure.id)
expect(cloned_procedure.published_revision_id).not_to eq(procedure.published_revision_id)
expect(cloned_procedure.published_revision.procedure_id).to eq(cloned_procedure.id)
expect(procedure.draft_revision_id).not_to eq(cloned_procedure.draft_revision_id)
expect(procedure.published_revision_id).not_to eq(cloned_procedure.published_revision_id)
# dossiers
expect(dossier_parent_procedure.revision_id).not_to eq(dossier_cloned_procedure.revision_id)
expect(dossier_parent_procedure.groupe_instructeur_id).not_to eq(dossier_cloned_procedure.groupe_instructeur_id)
expect(procedure.dossiers).to match_array([dossier_parent_procedure])
expect(procedure.published_revision.dossiers).to match_array([dossier_parent_procedure])
expect(cloned_procedure.dossiers).to match_array([dossier_cloned_procedure])
end
end
context 'clone, publish and publish again' do
before do
cloned_procedure.publish!
cloned_procedure.reload
cloned_procedure.draft_revision.add_type_de_champ(libelle: 'test', type_champ: 'text')
cloned_procedure.reload
cloned_procedure.publish_revision!
cloned_procedure.reload
end
it do
# procedures
expect(procedure.published_revision.procedure_id).not_to eq(procedure.id)
expect(procedure.published_revision_id.in?(cloned_procedure.revisions.ids)).to be_truthy
# dossiers
expect(dossier_parent_procedure.revision_id).to eq(dossier_cloned_procedure.revision_id)
expect(dossier_parent_procedure.groupe_instructeur_id).not_to be_nil
expect(dossier_cloned_procedure.groupe_instructeur_id).not_to be_nil
expect(dossier_parent_procedure.groupe_instructeur_id).not_to eq(dossier_cloned_procedure.groupe_instructeur_id)
expect(procedure.dossiers).to match_array([])
expect(procedure.published_revision.dossiers).to match_array([dossier_parent_procedure, dossier_cloned_procedure])
expect(cloned_procedure.dossiers).to match_array([dossier_parent_procedure, dossier_cloned_procedure])
# subject
subject
procedure.reload
cloned_procedure.reload
dossier_parent_procedure.reload
dossier_cloned_procedure.reload
expect(procedure.published_revision.procedure_id).to eq(procedure.id)
expect(procedure.published_revision_id.in?(cloned_procedure.revisions.ids)).to be_falsey
expect(procedure.draft_revision_id).not_to eq(cloned_procedure.draft_revision_id)
expect(procedure.published_revision_id).not_to eq(cloned_procedure.published_revision_id)
# # dossiers
expect(dossier_parent_procedure.revision_id).not_to eq(dossier_cloned_procedure.revision_id)
expect(dossier_parent_procedure.groupe_instructeur_id).not_to eq(dossier_cloned_procedure.groupe_instructeur_id)
expect(procedure.dossiers).to match_array([dossier_parent_procedure])
expect(procedure.published_revision.dossiers).to match_array([dossier_parent_procedure])
expect(cloned_procedure.dossiers).to match_array([dossier_cloned_procedure])
end
end
end