Add tests for Prometheus alert processing

Refactor process alert worker spec

app/services/alert_management/process_prometheus_alert_service.rb

@@ -96,7 +96,7 @@ module AlertManagement
       return unless am_alert
       return if am_alert.issue
 
-      IncidentManagement::ProcessAlertWorker.new.perform(nil, nil, am_alert.id)
+      IncidentManagement::ProcessAlertWorker.perform_async(nil, nil, am_alert.id)
     end
 
     def logger

spec/services/alert_management/process_prometheus_alert_service_spec.rb

@@ -83,6 +83,15 @@ RSpec.describe AlertManagement::ProcessPrometheusAlertService do
         context 'when alert does not exist' do
           context 'when alert can be created' do
             it_behaves_like 'creates an alert management alert'
+
+            it 'creates an incident issue' do
+              expect(IncidentManagement::ProcessAlertWorker)
+                .to receive(:perform_async)
+                .with(nil, nil, kind_of(Integer))
+                .once
+
+              expect(subject).to be_success
+            end
           end
 
           context 'when alert cannot be created' do
@@ -102,6 +111,13 @@ RSpec.describe AlertManagement::ProcessPrometheusAlertService do
 
               execute
             end
+
+            it 'does not create incident issue' do
+              expect(IncidentManagement::ProcessAlertWorker)
+                .not_to receive(:perform_async)
+
+              expect(subject).to be_success
+            end
           end
 
           it { is_expected.to be_success }

spec/workers/incident_management/process_alert_worker_spec.rb

@@ -16,11 +16,14 @@ RSpec.describe IncidentManagement::ProcessAlertWorker do
     subject { described_class.new.perform(nil, nil, alert.id) }
 
     before do
+      allow(Gitlab::AppLogger).to receive(:warn).and_call_original
+
       allow(IncidentManagement::CreateIssueService)
         .to receive(:new).with(alert.project, parsed_payload)
         .and_call_original
     end
 
+    shared_examples 'creates issue successfully' do
       it 'creates an issue' do
         expect(IncidentManagement::CreateIssueService)
           .to receive(:new).with(alert.project, parsed_payload)
@@ -28,24 +31,6 @@ RSpec.describe IncidentManagement::ProcessAlertWorker do
         expect { subject }.to change { Issue.count }.by(1)
       end
 
-    context 'with invalid alert' do
-      let(:invalid_alert_id) { non_existing_record_id }
-
-      subject { described_class.new.perform(nil, nil, invalid_alert_id) }
-
-      it 'does not create issues' do
-        expect(IncidentManagement::CreateIssueService).not_to receive(:new)
-
-        expect { subject }.not_to change { Issue.count }
-      end
-    end
-
-    context 'with valid alert' do
-      before do
-        allow(Gitlab::AppLogger).to receive(:warn).and_call_original
-      end
-
-      context 'when alert can be updated' do
       it 'updates AlertManagement::Alert#issue_id' do
         subject
 
@@ -57,6 +42,10 @@ RSpec.describe IncidentManagement::ProcessAlertWorker do
 
         expect(Gitlab::AppLogger).not_to have_received(:warn)
       end
+    end
+
+    context 'with valid alert' do
+      it_behaves_like 'creates issue successfully'
 
       context 'when alert cannot be updated' do
         let_it_be(:alert) { create(:alert_management_alert, :with_validation_errors, project: project, payload: payload) }
@@ -76,6 +65,24 @@ RSpec.describe IncidentManagement::ProcessAlertWorker do
           )
         end
       end
+
+      context 'prometheus alert' do
+        let_it_be(:alert) { create(:alert_management_alert, :prometheus, project: project, started_at: started_at) }
+        let_it_be(:parsed_payload) { alert.payload }
+
+        it_behaves_like 'creates issue successfully'
+      end
+    end
+
+    context 'with invalid alert' do
+      let(:invalid_alert_id) { non_existing_record_id }
+
+      subject { described_class.new.perform(nil, nil, invalid_alert_id) }
+
+      it 'does not create issues' do
+        expect(IncidentManagement::CreateIssueService).not_to receive(:new)
+
+        expect { subject }.not_to change { Issue.count }
       end
     end
   end