Merge pull request #10 from vivait/fix/adhoc-2812-store-job-id

Store job ID in static property when job performed
vivait · Jun 30, 2023 · 6396d18 · 6396d18
2 parents 1dfcd40 + c0bf0f1
commit 6396d18
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 0 deletions.
diff --git a/src/Vivait/DelayedEventBundle/Command/ProcessJobCommand.php b/src/Vivait/DelayedEventBundle/Command/ProcessJobCommand.php
@@ -12,6 +12,7 @@
 use Throwable;
 use Vivait\DelayedEventBundle\Exception\TerminalEventException;
 use Vivait\DelayedEventBundle\Exception\TransientEventException;
+use Vivait\DelayedEventBundle\Job;
 use Vivait\DelayedEventBundle\Serializer\SerializerInterface;
 
 class ProcessJobCommand extends Command
@@ -106,6 +107,8 @@ protected function execute(InputInterface $input, OutputInterface $output)
      */
     private function performJob($jobId, $eventName, $event)
     {
+        Job::$id = $jobId;
+
         try {
             $this->eventDispatcher->dispatch($event, $eventName);
         } catch (TerminalEventException $exception) {

diff --git a/src/Vivait/DelayedEventBundle/Job.php b/src/Vivait/DelayedEventBundle/Job.php
@@ -0,0 +1,16 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Vivait\DelayedEventBundle;
+
+/**
+ * Allow job ID or other metadata to be used in process.
+ */
+final class Job
+{
+    /**
+     * The ID of the job currently being processed (null indicates no job).
+     */
+    public static ?string $id = null;
+}