fix autoconfigure projectors

Author: DavidBadura

src/DependencyInjection/PatchlevelEventSourcingExtension.php

@@ -16,6 +16,7 @@
 use Doctrine\Migrations\Tools\Console\Command\ExecuteCommand;
 use Doctrine\Migrations\Tools\Console\Command\MigrateCommand;
 use Doctrine\Migrations\Tools\Console\Command\StatusCommand;
+use Patchlevel\EventSourcing\Attribute\Projector;
 use Patchlevel\EventSourcing\Clock\FrozenClock;
 use Patchlevel\EventSourcing\Clock\SystemClock;
 use Patchlevel\EventSourcing\Console\Command\DatabaseCreateCommand;
@@ -55,7 +56,6 @@
 use Patchlevel\EventSourcing\Projection\Projectionist\SyncProjectionistEventBusWrapper;
 use Patchlevel\EventSourcing\Projection\Projector\InMemoryProjectorRepository;
 use Patchlevel\EventSourcing\Projection\Projector\MetadataProjectorResolver;
-use Patchlevel\EventSourcing\Projection\Projector\Projector;
 use Patchlevel\EventSourcing\Projection\Projector\ProjectorRepository;
 use Patchlevel\EventSourcing\Projection\Projector\ProjectorResolver;
 use Patchlevel\EventSourcing\Repository\DefaultRepositoryManager;
@@ -93,6 +93,7 @@
 use Patchlevel\Hydrator\MetadataHydrator;
 use Psr\Log\LoggerInterface;
 use Symfony\Component\DependencyInjection\Argument\TaggedIteratorArgument;
+use Symfony\Component\DependencyInjection\ChildDefinition;
 use Symfony\Component\DependencyInjection\ContainerBuilder;
 use Symfony\Component\DependencyInjection\ContainerInterface;
 use Symfony\Component\DependencyInjection\Reference;
@@ -208,8 +209,12 @@ private function configureEventBus(array $config, ContainerBuilder $container):
     /** @param Config $config */
     private function configureProjection(array $config, ContainerBuilder $container): void
     {
-        $container->registerForAutoconfiguration(Projector::class)
-            ->addTag('event_sourcing.projector');
+        $container->registerAttributeForAutoconfiguration(
+            Projector::class,
+            static function (ChildDefinition $definition): void {
+                $definition->addTag('event_sourcing.projector');
+            },
+        );
 
         $container->register(InMemoryProjectorRepository::class)
             ->setArguments([

tests/Fixtures/ProfileProjector.php

@@ -0,0 +1,10 @@
+<?php
+
+namespace Patchlevel\EventSourcingBundle\Tests\Fixtures;
+
+use Patchlevel\EventSourcing\Attribute\Projector;
+
+#[Projector('profile')]
+class ProfileProjector
+{
+}

tests/Unit/PatchlevelEventSourcingBundleTest.php

@@ -38,6 +38,7 @@
 use Patchlevel\EventSourcing\Projection\Projectionist\SyncProjectionistEventBusWrapper;
 use Patchlevel\EventSourcing\Projection\Projectionist\DefaultProjectionist;
 use Patchlevel\EventSourcing\Projection\Projectionist\Projectionist;
+use Patchlevel\EventSourcing\Projection\Projector\ProjectorRepository;
 use Patchlevel\EventSourcing\Repository\DefaultRepository;
 use Patchlevel\EventSourcing\Repository\DefaultRepositoryManager;
 use Patchlevel\EventSourcing\Repository\RepositoryManager;
@@ -62,6 +63,7 @@
 use Patchlevel\EventSourcingBundle\Tests\Fixtures\Processor2;
 use Patchlevel\EventSourcingBundle\Tests\Fixtures\Profile;
 use Patchlevel\EventSourcingBundle\Tests\Fixtures\ProfileCreated;
+use Patchlevel\EventSourcingBundle\Tests\Fixtures\ProfileProjector;
 use Patchlevel\EventSourcingBundle\Tests\Fixtures\SnapshotableProfile;
 use PHPUnit\Framework\TestCase;
 use Prophecy\PhpUnit\ProphecyTrait;
@@ -202,6 +204,43 @@ public function testProcessorListener(): void
         );
     }
 
+
+    public function testAutoconfigureProcessorListener(): void
+    {
+        $container = new ContainerBuilder();
+        $container->setDefinition(Processor1::class, new Definition(Processor1::class))
+            ->setAutoconfigured(true);
+        $container->setDefinition(Processor2::class, new Definition(Processor1::class))
+            ->setAutoconfigured(false);
+
+        $this->compileContainer(
+            $container,
+            [
+                'patchlevel_event_sourcing' => [
+                    'connection' => [
+                        'service' => 'doctrine.dbal.eventstore_connection',
+                    ],
+                    'projection' => [
+                        'sync' => false,
+                    ],
+                ],
+            ]
+        );
+
+        self::assertInstanceOf(DefaultEventBus::class, $container->get(EventBus::class));
+        self::assertEquals(
+            [
+                'Patchlevel\EventSourcingBundle\Tests\Fixtures\Processor1' => [
+                    [],
+                ],
+                'Patchlevel\EventSourcingBundle\DataCollector\MessageListener' => [
+                    []
+                ]
+            ],
+            $container->findTaggedServiceIds('event_sourcing.processor')
+        );
+    }
+
     public function testSymfonyEventBus(): void
     {
         $container = new ContainerBuilder();
@@ -710,6 +749,30 @@ public function testProjectionistAutoBoot(): void
         self::assertInstanceOf(ProjectionistAutoBootListener::class, $container->get(ProjectionistAutoBootListener::class));
     }
 
+    public function testAutoconfigureProjector(): void
+    {
+        $container = new ContainerBuilder();
+        $container->setDefinition(ProfileProjector::class, new Definition(ProfileProjector::class))
+            ->setAutoconfigured(true);
+
+        $this->compileContainer(
+            $container,
+            [
+                'patchlevel_event_sourcing' => [
+                    'connection' => [
+                        'service' => 'doctrine.dbal.eventstore_connection',
+                    ],
+                ],
+            ]
+        );
+
+        $repository = $container->get(ProjectorRepository::class);
+        $projectors = $repository->projectors();
+
+        self::assertCount(1, $projectors);
+        self::assertInstanceOf(ProfileProjector::class, $projectors[0]);
+    }
+
     public function testSchemaMerge(): void
     {
         $container = new ContainerBuilder();