RSpec.describe Export, type: :model do describe 'associations' do let(:instructeur) { create(:instructeur) } let(:export) { create(:export, user_profile_type: 'Instructeur', user_profile_id: instructeur.id) } it 'find polymorphic association' do expect(export.user_profile).to eq(instructeur) end end describe 'validations' do let(:groupe_instructeur) { create(:groupe_instructeur) } context 'when everything is ok' do let(:export) { build(:export, groupe_instructeurs: [groupe_instructeur]) } it { expect(export.save).to be true } end context 'when groupe instructeurs are missing' do let(:export) { build(:export, groupe_instructeurs: []) } it { expect(export.save).to be false } end context 'when format is missing' do let(:export) { build(:export, format: nil, groupe_instructeurs: [groupe_instructeur]) } it { expect(export.save).to be false } end end describe '.stale' do let!(:export) { create(:export) } let(:stale_date) { Time.zone.now() - (Export::MAX_DUREE_CONSERVATION_EXPORT + 1.minute) } let!(:stale_export_generated) { create(:export, :generated, updated_at: stale_date) } let!(:stale_export_failed) { create(:export, :failed, updated_at: stale_date) } let!(:stale_export_pending) { create(:export, :pending, updated_at: stale_date) } it { expect(Export.stale(Export::MAX_DUREE_CONSERVATION_EXPORT)).to match_array([stale_export_generated, stale_export_failed]) } end describe '.stuck' do let!(:export) { create(:export) } let(:stuck_date) { Time.zone.now() - (Export::MAX_DUREE_GENERATION + 1.minute) } let!(:stale_export_generated) { create(:export, :generated, updated_at: stuck_date) } let!(:stale_export_failed) { create(:export, :failed, updated_at: stuck_date) } let!(:stale_export_pending) { create(:export, :pending, updated_at: stuck_date) } it { expect(Export.stuck(Export::MAX_DUREE_GENERATION)).to match_array([stale_export_pending]) } end describe '.destroy' do let!(:groupe_instructeur) { create(:groupe_instructeur) } let!(:export) { create(:export, groupe_instructeurs: [groupe_instructeur]) } before { export.destroy! } it { expect(Export.count).to eq(0) } it { expect(groupe_instructeur.reload).to be_present } end describe '.find_by groupe_instructeurs' do let!(:procedure) { create(:procedure) } let!(:gi_1) { create(:groupe_instructeur, procedure: procedure, instructeurs: [create(:instructeur)]) } let!(:gi_2) { create(:groupe_instructeur, procedure: procedure, instructeurs: [create(:instructeur)]) } let!(:gi_3) { create(:groupe_instructeur, procedure: procedure, instructeurs: [create(:instructeur)]) } context 'without procedure_presentation' do context 'when an export is made for one groupe instructeur' do let!(:export) { create(:export, groupe_instructeurs: [gi_1, gi_2]) } it { expect(Export.by_key([gi_1.id], nil)).to be_empty } it { expect(Export.by_key([gi_2.id, gi_1.id], nil)).to eq([export]) } it { expect(Export.by_key([gi_1.id, gi_2.id, gi_3.id], nil)).to be_empty } end end context 'with procedure_presentation and without' do let!(:export_global) { create(:export, statut: Export.statuts.fetch(:tous), groupe_instructeurs: [gi_1, gi_2], procedure_presentation: nil) } let!(:export_with_filter) { create(:export, statut: Export.statuts.fetch(:suivis), groupe_instructeurs: [gi_1, gi_2], procedure_presentation: create(:procedure_presentation, procedure: procedure, assign_to: gi_1.instructeurs.first.assign_to.first)) } let!(:procedure_presentation) { create(:procedure_presentation, procedure: gi_1.procedure) } it 'find global exports as well as filtered one' do expect(Export.by_key([gi_2.id, gi_1.id], export_with_filter.procedure_presentation)) .to contain_exactly(export_with_filter, export_global) end end end describe '.find_or_create_fresh_export' do let!(:procedure) { create(:procedure) } let(:instructeur) { create(:instructeur) } let!(:gi_1) { create(:groupe_instructeur, procedure: procedure, instructeurs: [instructeur]) } let!(:pp) { gi_1.instructeurs.first.procedure_presentation_and_errors_for_procedure_id(procedure.id).first } before { pp.add_filter('tous', 'self/created_at', '10/12/2021') } context 'with procedure_presentation having different filters' do it 'works once' do expect { Export.find_or_create_fresh_export(:zip, [gi_1], instructeur, time_span_type: Export.time_span_types.fetch(:everything), statut: Export.statuts.fetch(:tous), procedure_presentation: pp) } .to change { Export.count }.by(1) end it 'works once, changes procedure_presentation, recreate a new' do expect { Export.find_or_create_fresh_export(:zip, [gi_1], instructeur, time_span_type: Export.time_span_types.fetch(:everything), statut: Export.statuts.fetch(:tous), procedure_presentation: pp) } .to change { Export.count }.by(1) pp.add_filter('tous', 'self/updated_at', '10/12/2021') expect { Export.find_or_create_fresh_export(:zip, [gi_1], instructeur, time_span_type: Export.time_span_types.fetch(:everything), statut: Export.statuts.fetch(:tous), procedure_presentation: pp) } .to change { Export.count }.by(1) end end context 'with existing matching export' do def find_or_create = Export.find_or_create_fresh_export(:zip, [gi_1], instructeur, time_span_type: Export.time_span_types.fetch(:everything), statut: Export.statuts.fetch(:tous), procedure_presentation: pp) context 'freshly generate export' do before { find_or_create.update!(job_status: :generated, updated_at: 1.second.ago) } it 'returns current pending export' do current_export = find_or_create expect(find_or_create).to eq(current_export) end end context 'old generated export' do before { find_or_create.update!(job_status: :generated, updated_at: 1.hour.ago) } it 'returns a new export' do expect { find_or_create }.to change { Export.count }.by(1) end end context 'pending export' do before { find_or_create.update!(updated_at: 1.hour.ago) } it 'returns current pending export' do current_export = find_or_create expect(find_or_create).to eq(current_export) end end end end describe '.dossiers_for_export' do let!(:procedure) { create(:procedure, :published, :with_instructeur) } let!(:dossier_brouillon) { create(:dossier, :brouillon, procedure: procedure) } let!(:dossier_en_construction) { create(:dossier, :en_construction, procedure: procedure) } let!(:dossier_en_instruction) { create(:dossier, :en_instruction, procedure: procedure) } let!(:dossier_accepte) { create(:dossier, :accepte, procedure: procedure) } let(:export) do create(:export, groupe_instructeurs: [procedure.groupe_instructeurs.first], procedure_presentation: procedure_presentation, statut: statut) end context 'without procedure_presentation or since' do let(:procedure_presentation) { nil } let(:statut) { nil } it 'does not includes brouillons' do expect(export.send(:dossiers_for_export)).to include(dossier_en_construction) expect(export.send(:dossiers_for_export)).to include(dossier_en_instruction) expect(export.send(:dossiers_for_export)).to include(dossier_accepte) expect(export.send(:dossiers_for_export)).not_to include(dossier_brouillon) end end context 'with procedure_presentation and statut supprimes_recemment' do let(:statut) { 'supprimes_recemment' } let(:procedure_presentation) do create(:procedure_presentation, procedure: procedure, assign_to: procedure.groupe_instructeurs.first.assign_tos.first) end let!(:dossier_recemment_supprime) { create(:dossier, :accepte, procedure: procedure, hidden_by_administration_at: 2.days.ago) } it 'includes supprimes_recemment' do expect(export.send(:dossiers_for_export)).to include(dossier_recemment_supprime) end end end describe '.for_groupe_instructeurs' do let!(:groupe_instructeur1) { create(:groupe_instructeur) } let!(:groupe_instructeur2) { create(:groupe_instructeur) } let!(:groupe_instructeur3) { create(:groupe_instructeur) } let!(:export1) { create(:export, groupe_instructeurs: [groupe_instructeur1, groupe_instructeur2]) } let!(:export2) { create(:export, groupe_instructeurs: [groupe_instructeur2]) } let!(:export3) { create(:export, groupe_instructeurs: [groupe_instructeur3]) } it 'returns exports for the specified groupe instructeurs' do expect(Export.for_groupe_instructeurs([groupe_instructeur1.id, groupe_instructeur2.id])) .to match_array([export1, export2]) end it 'does not return exports not associated with the specified groupe instructeurs' do expect(Export.for_groupe_instructeurs([groupe_instructeur1.id])).not_to include(export2, export3) end it 'returns unique exports even if they belong to multiple matching groupe instructeurs' do results = Export.for_groupe_instructeurs([groupe_instructeur1.id]) expect(results.count).to eq(1) end end describe '.dossiers_count' do let(:export) { create(:export, :pending) } before do blob_double = instance_double("ActiveStorage::Blob", signed_id: "some_signed_id_value") attachment_double = instance_double("ActiveStorage::Attached::One", attach: true) allow(export).to receive(:blob).and_return(blob_double) allow(export).to receive(:file).and_return(attachment_double) create_list(:dossier, 3, :en_construction, groupe_instructeur: export.groupe_instructeurs.first) end it 'is not set until generation' do expect(export.dossiers_count).to be_nil end it 'is persisted after generation' do export.compute_with_safe_stale_for_purge do export.compute end export.reload expect(export.dossiers_count).to eq(3) end end end