3 files changed, 45 insertions, 81 deletions
diff --git a/spec/workers/project_export_worker_spec.rb b/spec/workers/project_export_worker_spec.rb
index defecefc3cc..9923d8bde7f 100644
--- a/spec/workers/project_export_worker_spec.rb
+++ b/spec/workers/project_export_worker_spec.rb
@@ -3,84 +3,5 @@
 require 'spec_helper'
 
 RSpec.describe ProjectExportWorker do
-  let!(:user) { create(:user) }
-  let!(:project) { create(:project) }
-
-  subject { described_class.new }
-
-  describe '#perform' do
-    before do
-      allow_next_instance_of(described_class) do |job|
-        allow(job).to receive(:jid).and_return(SecureRandom.hex(8))
-      end
-    end
-
-    context 'when it succeeds' do
-      it 'calls the ExportService' do
-        expect_next_instance_of(::Projects::ImportExport::ExportService) do |service|
-          expect(service).to receive(:execute)
-        end
-
-        subject.perform(user.id, project.id, { 'klass' => 'Gitlab::ImportExport::AfterExportStrategies::DownloadNotificationStrategy' })
-      end
-
-      context 'export job' do
-        before do
-          allow_next_instance_of(::Projects::ImportExport::ExportService) do |service|
-            allow(service).to receive(:execute)
-          end
-        end
-
-        it 'creates an export job record for the project' do
-          expect { subject.perform(user.id, project.id, {}) }.to change { project.export_jobs.count }.from(0).to(1)
-        end
-
-        it 'sets the export job status to started' do
-          expect_next_instance_of(ProjectExportJob) do |job|
-            expect(job).to receive(:start)
-          end
-
-          subject.perform(user.id, project.id, {})
-        end
-
-        it 'sets the export job status to finished' do
-          expect_next_instance_of(ProjectExportJob) do |job|
-            expect(job).to receive(:finish)
-          end
-
-          subject.perform(user.id, project.id, {})
-        end
-      end
-    end
-
-    context 'when it fails' do
-      it 'does not raise an exception when strategy is invalid' do
-        expect(::Projects::ImportExport::ExportService).not_to receive(:new)
-
-        expect { subject.perform(user.id, project.id, { 'klass' => 'Whatever' }) }.not_to raise_error
-      end
-
-      it 'does not raise error when project cannot be found' do
-        expect { subject.perform(user.id, non_existing_record_id, {}) }.not_to raise_error
-      end
-
-      it 'does not raise error when user cannot be found' do
-        expect { subject.perform(non_existing_record_id, project.id, {}) }.not_to raise_error
-      end
-    end
-  end
-
-  describe 'sidekiq options' do
-    it 'disables retry' do
-      expect(described_class.sidekiq_options['retry']).to eq(false)
-    end
-
-    it 'disables dead' do
-      expect(described_class.sidekiq_options['dead']).to eq(false)
-    end
-
-    it 'sets default status expiration' do
-      expect(described_class.sidekiq_options['status_expiration']).to eq(StuckExportJobsWorker::EXPORT_JOBS_EXPIRATION)
-    end
-  end
+  it_behaves_like 'export worker'
 end
diff --git a/spec/workers/create_evidence_worker_spec.rb b/spec/workers/releases/create_evidence_worker_spec.rb
index c700c086163..743f2abc8a7 100644
--- a/spec/workers/create_evidence_worker_spec.rb
+++ b/spec/workers/releases/create_evidence_worker_spec.rb
@@ -2,7 +2,7 @@
 
 require 'spec_helper'
 
-RSpec.describe CreateEvidenceWorker do
+RSpec.describe Releases::CreateEvidenceWorker do
   let(:project) { create(:project, :repository) }
   let(:release) { create(:release, project: project) }
   let(:pipeline) { create(:ci_empty_pipeline, sha: release.sha, project: project) }
diff --git a/spec/workers/releases/manage_evidence_worker_spec.rb b/spec/workers/releases/manage_evidence_worker_spec.rb
new file mode 100644
index 00000000000..2fbfb6c9dc1
--- /dev/null
+++ b/spec/workers/releases/manage_evidence_worker_spec.rb
@@ -0,0 +1,43 @@
+# frozen_string_literal: true
+
+require 'spec_helper'
+
+RSpec.describe Releases::ManageEvidenceWorker do
+  let(:project) { create(:project, :repository) }
+
+  shared_examples_for 'does not create a new Evidence record' do
+    specify :sidekiq_inline do
+      aggregate_failures do
+        expect(::Releases::CreateEvidenceService).not_to receive(:execute)
+        expect { described_class.new.perform }.to change(Releases::Evidence, :count).by(0)
+      end
+    end
+  end
+
+  context 'when `released_at` in inside the window' do
+    context 'when Evidence has not been created' do
+      let(:release) { create(:release, project: project, released_at: 1.hour.since) }
+
+      it 'creates a new Evidence record', :sidekiq_inline do
+        expect_next_instance_of(::Releases::CreateEvidenceService, release, { pipeline: nil }) do |service|
+          expect(service).to receive(:execute).and_call_original
+        end
+
+        expect { described_class.new.perform }.to change(Releases::Evidence, :count).by(1)
+      end
+    end
+
+    context 'when evidence has already been created' do
+      let(:release) { create(:release, project: project, released_at: 1.hour.since) }
+      let!(:evidence) { create(:evidence, release: release )}
+
+      it_behaves_like 'does not create a new Evidence record'
+    end
+  end
+
+  context 'when `released_at` is outside the window' do
+    let(:release) { create(:release, project: project, released_at: 300.minutes.since) }
+
+    it_behaves_like 'does not create a new Evidence record'
+  end
+end