Emit restart events when a job is enqueued

With this commit once the job goes to execute its final stage, it will
check if it can be restarted. If yes, it will send the new job to
the minion queue via `enqueue_restart`, where now it should populate
the event.

issue: https://progress.opensuse.org/issues/190557
Signed-off-by: Ioannis Bonatakis <[email protected]>

Author: d3flex

lib/OpenQA/Schema/Result/Jobs.pm

@@ -2050,6 +2050,7 @@ sub enqueue_restart ($self, $options = {}) {
     my $openqa_job_id = $self->id;
     my $minion_job_id = OpenQA::App->singleton->gru->enqueue(restart_job => [$openqa_job_id], $options)->{minion_id};
     log_debug "Enqueued restarting openQA job $openqa_job_id via Minion job $minion_job_id";
+    OpenQA::App->singleton->emit_event(openqa_job_restart => {id => $openqa_job_id});
     return $minion_job_id;
 }
 

t/23-amqp.t

@@ -334,4 +334,16 @@ subtest 'extra TLS query params' => sub {
     is($last_publisher->url, $expected, 'url has all params');
 };
 
+subtest 'enqueue_restart triggers amqp event and log' => sub {
+    my $test_job = $schema->resultset('Jobs')->find(99945);
+    my $minion_id;
+    %published = ();    # just to be sure
+    combined_like { $minion_id = $test_job->enqueue_restart }
+    qr/Enqueued restarting openQA job 99945 via Minion job \d+/, 'Debug log for enqueue_restart is present';
+    ok $minion_id, 'Got a Minion job ID back';
+    # each event contains keys(headers args body)
+    is scalar(%published), 3, 'Exactly one event was published';
+    is $published{args}{routing_key}, 'openqa.job.restart', 'enqueue_restart published amqp events';
+};
+
 done_testing();