Introduce Producer

Author: WyriHaximus

bin/mammatus-queue

@@ -15,5 +15,5 @@ use Mammatus\ContainerFactory;
     /**
      * Create and run that one cron job
      */
-    exit((static fn (string $className): int => ContainerFactory::create()->get(App::class)->run($className))($className));
+    exit((static fn (string $className): int => ContainerFactory::create()->get(App::class)->run($className)->value)($className));
 })($argv[1]);

composer.json

@@ -8,13 +8,13 @@
     "ext-json": "^8.2",
     "composer-plugin-api": "^2.0",
     "eventsauce/object-hydrator": "^1.6.1",
-    "mammatus/app": "dev-master",
+    "mammatus/app": "dev-introduce-run-tooling",
     "mammatus/kubernetes-attributes": "^1",
     "mammatus/kubernetes-contracts": "^1",
     "mammatus/kubernetes-events": "^1",
     "mammatus/life-cycle-events": "^2",
     "mammatus/queue-attributes": "dev-main",
-    "mammatus/queue-contracts": "dev-main",
+    "mammatus/queue-contracts": "dev-introduce-producer",
     "psr/container": "^1.1.2",
     "psr/event-dispatcher": "^1.0",
     "psr/log": "^2",

composer.lock

@@ -6,7 +6,6 @@ namespace Mammatus\Queue\Generated;
 
 use Mammatus\Queue\Worker;
 
-// phpcs:disable
 /**
  * Autogenerated file, do not edit. Changes will be overwritten on the next composer (install|update)
  */

etc/generated_templates/AbstractList.php.twig

@@ -0,0 +1,28 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Mammatus\Queue\Generated;
+
+use Mammatus\Queue\Contracts\Work;
+
+/**
+ * Autogenerated file, do not edit. Changes will be overwritten on the next composer (install|update)
+ */
+abstract class WorkQueueMap
+{
+    private const MAP = [
+{% for worker in workers %}
+        \{{ worker.dtoClass }}::class => '{{ worker.consumer.queue }}',
+{% endfor %}
+    ];
+
+    final protected function lookUp(Work $work): string
+    {
+        if (array_key_exists($work::class, self::MAP)) {
+            return self::MAP[$work::class];
+        }
+
+        throw new \RuntimeException('Unknown work: ' . $work::class);
+    }
+}

etc/generated_templates/WorkQueueMap.php.twig

@@ -9,7 +9,7 @@
     <file>../../src</file>
     <file>../../tests</file>
 
-    <exclude-pattern>src/Generated/*</exclude-pattern>
+    <exclude-pattern>src/Generated/Hydrator.php</exclude-pattern>
 
     <rule ref="WyriHaximus-OSS" />
 </ruleset>

etc/qa/phpcs.xml

@@ -15,6 +15,8 @@ parameters:
 			classesAllowedToBeExtended:
 				- Composer\IO\NullIO
 				- Mammatus\Queue\Generated\AbstractList
+				- Mammatus\Queue\Generated\WorkQueueMap
+				- RuntimeException
 
 includes:
 	- ../../vendor/wyrihaximus/async-test-utilities/rules.neon