Simplification of job strategies

src/Metadata/JobMetadataEnricher.php

@@ -16,6 +16,8 @@
 
 final class JobMetadataEnricher implements MetadataEnricherInterface
 {
+    public const JOB = 'job';
+
     private JobDefinitionMap $jobDefinitionMap;
 
     private array $settings;
@@ -32,11 +34,11 @@ public function enrich(MetadataInterface $metadata): MetadataInterface
 
         /** @var JobDefinitionInterface $jobDefinition */
         $jobDefinition = $this->jobDefinitionMap->get($this->settings['job']);
-        $metadata = $metadata->with('job', $this->settings['job']);
+        $metadata = $metadata->with(self::JOB, $this->settings['job']);
         foreach ($jobDefinition->getSettings() as $setting => $value) {
             $metadata = $metadata->with($setting, $value);
         }
 
-        return $metadata;
+        return $jobDefinition->getStrategy()->enrich($metadata);
     }
 }

src/Strategy/JobStrategyInterface.php

@@ -9,12 +9,9 @@
 namespace Daikon\AsyncJob\Strategy;
 
 use Daikon\MessageBus\EnvelopeInterface;
+use Daikon\Metadata\MetadataEnricherInterface;
 
-interface JobStrategyInterface
+interface JobStrategyInterface extends MetadataEnricherInterface
 {
-    public function getRetryInterval(EnvelopeInterface $envelope): ?int;
-
-    public function hasFailed(EnvelopeInterface $envelope): bool;
-
     public function canRetry(EnvelopeInterface $envelope): bool;
 }

src/Strategy/NoRetry.php

@@ -0,0 +1,26 @@
+<?php declare(strict_types=1);
+/**
+ * This file is part of the daikon-cqrs/async-job project.
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Daikon\AsyncJob\Strategy;
+
+use Daikon\AsyncJob\Strategy\JobStrategyInterface;
+use Daikon\MessageBus\EnvelopeInterface;
+use Daikon\Metadata\MetadataInterface;
+
+class NoRetry implements JobStrategyInterface
+{
+    public function canRetry(EnvelopeInterface $envelope): bool
+    {
+        return false;
+    }
+
+    public function enrich(MetadataInterface $metadata): MetadataInterface
+    {
+        return $metadata;
+    }
+}