Autowiring for PsrProcessors implementing CommandSubscriberInterface or TopicSubscriberInterface

This will allow to symfony users that have autowiring/autoconfigure enabled to be able to rapidly
create their processors without worrying registering them as a service and adding the tag.

This closes #409 and #405. Also, keeps in mind #410. That's why services are public until a better solution
is implemented.

Author: Matías Navarro Carter

pkg/enqueue-bundle/DependencyInjection/EnqueueExtension.php

@@ -3,7 +3,9 @@
 namespace Enqueue\Bundle\DependencyInjection;
 
 use Enqueue\AsyncEventDispatcher\DependencyInjection\AsyncEventDispatcherExtension;
+use Enqueue\Client\CommandSubscriberInterface;
 use Enqueue\Client\Producer;
+use Enqueue\Client\TopicSubscriberInterface;
 use Enqueue\Client\TraceableProducer;
 use Enqueue\Consumption\QueueConsumer;
 use Enqueue\JobQueue\Job;
@@ -72,6 +74,8 @@ public function load(array $configs, ContainerBuilder $container)
         $loader = new YamlFileLoader($container, new FileLocator(__DIR__.'/../Resources/config'));
         $loader->load('services.yml');
 
+        $this->setupAutowiringForProcessors($container);
+
         foreach ($config['transport'] as $name => $transportConfig) {
             $this->factories[$name]->createConnectionFactory($container, $transportConfig);
             $this->factories[$name]->createContext($container, $transportConfig);
@@ -220,4 +224,19 @@ private function registerJobQueueDoctrineEntityMapping(ContainerBuilder $contain
             }
         }
     }
+
+    private function setupAutowiringForProcessors(ContainerBuilder $container)
+    {
+        if (!method_exists($container, 'registerForAutoconfiguration')) {
+            return;
+        }
+
+        $container->registerForAutoconfiguration(TopicSubscriberInterface::class)
+            ->setPublic(true)
+            ->addTag('enqueue.client.processor');
+
+        $container->registerForAutoconfiguration(CommandSubscriberInterface::class)
+            ->setPublic(true)
+            ->addTag('enqueue.client.processor');
+    }
 }

pkg/enqueue-bundle/Tests/Unit/DependencyInjection/EnqueueExtensionTest.php

@@ -6,8 +6,10 @@
 use Enqueue\Bundle\DependencyInjection\EnqueueExtension;
 use Enqueue\Bundle\Tests\Unit\Mocks\FooTransportFactory;
 use Enqueue\Bundle\Tests\Unit\Mocks\TransportFactoryWithoutDriverFactory;
+use Enqueue\Client\CommandSubscriberInterface;
 use Enqueue\Client\Producer;
 use Enqueue\Client\ProducerInterface;
+use Enqueue\Client\TopicSubscriberInterface;
 use Enqueue\Client\TraceableProducer;
 use Enqueue\Consumption\QueueConsumer;
 use Enqueue\JobQueue\JobRunner;
@@ -633,6 +635,31 @@ public function testShouldThrowIfPackageShouldBeInstalledToUseTransport()
         ]], $container);
     }
 
+    public function testShouldLoadProcessAutoconfigureChildDefinition()
+    {
+        $container = $this->getContainerBuilder(true);
+        $extension = new EnqueueExtension();
+
+        $extension->load([[
+            'client' => [],
+            'transport' => [],
+        ]], $container);
+
+        if (method_exists($container, 'registerForAutoconfiguration')) {
+            $autoconfigured = $container->getAutoconfiguredInstanceof();
+
+            self::assertArrayHasKey(CommandSubscriberInterface::class, $autoconfigured);
+            self::assertTrue($autoconfigured[CommandSubscriberInterface::class]->hasTag('enqueue.client.processor'));
+            self::assertTrue($autoconfigured[CommandSubscriberInterface::class]->isPublic());
+
+            self::assertArrayHasKey(TopicSubscriberInterface::class, $autoconfigured);
+            self::assertTrue($autoconfigured[TopicSubscriberInterface::class]->hasTag('enqueue.client.processor'));
+            self::assertTrue($autoconfigured[TopicSubscriberInterface::class]->isPublic());
+        } else {
+            $this->assertTrue(true);
+        }
+    }
+
     /**
      * @param bool $debug
      *