use resource tags for aggregates, events & headers

composer.json

@@ -23,7 +23,7 @@
     "symfony/cache": "^6.4.0 || ^7.0.0 || ^8.0.0",
     "symfony/config": "^6.4.0 || ^7.0.0 || ^8.0.0",
     "symfony/console": "^6.4.1 || ^7.0.1 || ^8.0.0",
-    "symfony/dependency-injection": "^6.4.1 || ^7.0.1 || ^8.0.0",
+    "symfony/dependency-injection": "^7.3.0 || ^8.0.0",
     "symfony/event-dispatcher": "^6.4.1 || ^7.0.1 || ^8.0.0",
     "symfony/finder": "^6.4.0 || ^7.0.0 || ^8.0.0",
     "symfony/http-kernel": "^6.4.1 || ^7.0.1 || ^8.0.0",

src/DependencyInjection/CommandHandlerCompilerPass.php

@@ -7,7 +7,6 @@
 use Patchlevel\EventSourcing\CommandBus\Handler\CreateAggregateHandler;
 use Patchlevel\EventSourcing\CommandBus\Handler\UpdateAggregateHandler;
 use Patchlevel\EventSourcing\CommandBus\HandlerFinder;
-use Patchlevel\EventSourcing\Metadata\AggregateRoot\AggregateRootRegistry;
 use Patchlevel\EventSourcing\Repository\RepositoryManager;
 use Symfony\Component\DependencyInjection\Compiler\CompilerPassInterface;
 use Symfony\Component\DependencyInjection\ContainerBuilder;
@@ -27,13 +26,10 @@
 
         $bus = $container->getParameter('patchlevel_event_sourcing.aggregate_handlers.bus');
 
-        /** @var AggregateRootRegistry $aggregateRootRegistry */
-        $aggregateRootRegistry = $container->get(AggregateRootRegistry::class);
-
-        foreach ($aggregateRootRegistry->aggregateClasses() as $aggregateName => $aggregateClass) {
+        foreach ($container->getParameter('event_sourcing.aggregates') as $aggregateName => $aggregateClass) {
             $parameterResolverId = sprintf('.event_sourcing.handler_parameter_resolver.%s', $aggregateName);
 
             foreach (HandlerFinder::findInClass($aggregateClass) as $aggregateHandler) {
                 $handlerId = strtolower(sprintf('event_sourcing.handler.%s.%s', $aggregateName, $aggregateHandler->method));
                 $handlerClass = $aggregateHandler->static ? CreateAggregateHandler::class : UpdateAggregateHandler::class;
 

src/DependencyInjection/Configuration.php

@@ -65,9 +65,6 @@
  *              translators: list<string>
  *          }
  *      },
- *      aggregates: list<string>,
- *      events: list<string>,
- *      headers: list<string>,
  *      snapshot_stores: array<string, array{type: string, service: string}>,
  *      migration: array{path: string, namespace: string},
  *      cryptography: array{
@@ -143,24 +140,6 @@ public function getConfigTreeBuilder(): TreeBuilder
                 ->end()
             ->end()
 
-            ->arrayNode('events')
-                ->beforeNormalization()->castToArray()->end()
-                ->defaultValue([])
-                ->scalarPrototype()->end()
-            ->end()
-
-            ->arrayNode('aggregates')
-                ->beforeNormalization()->castToArray()->end()
-                ->defaultValue([])
-                ->scalarPrototype()->end()
-            ->end()
-
-            ->arrayNode('headers')
-                ->beforeNormalization()->castToArray()->end()
-                ->defaultValue([])
-                ->scalarPrototype()->end()
-            ->end()
-
             ->arrayNode('clock')
                 ->addDefaultsIfNotSet()
                 ->children()

src/DependencyInjection/HandlerServiceLocatorCompilerPass.php

@@ -7,7 +7,6 @@
 use Patchlevel\EventSourcing\Attribute\Inject;
 use Patchlevel\EventSourcing\CommandBus\Handler\ServiceNotResolvable;
 use Patchlevel\EventSourcing\CommandBus\HandlerFinder;
-use Patchlevel\EventSourcing\Metadata\AggregateRoot\AggregateRootRegistry;
 use Patchlevel\EventSourcingBundle\CommandBus\SymfonyParameterResolver;
 use Psr\Container\ContainerInterface;
 use ReflectionAttribute;
@@ -32,15 +31,12 @@
             return;
         }
 
-        /** @var AggregateRootRegistry $aggregateRootRegistry */
-        $aggregateRootRegistry = $container->get(AggregateRootRegistry::class);
-
-        foreach ($aggregateRootRegistry->aggregateClasses() as $aggregateName => $aggregateClass) {
+        foreach ($container->getParameter('event_sourcing.aggregates') as $aggregateName => $aggregateClass) {
             $parameterResolverId = sprintf('.event_sourcing.handler_parameter_resolver.%s', $aggregateName);
             $services = [];
 
             foreach (HandlerFinder::findInClass($aggregateClass) as $aggregateHandler) {
                 $services += $this->services(new ReflectionMethod($aggregateClass, $aggregateHandler->method), $container);
             }
 
             $container->register($parameterResolverId, SymfonyParameterResolver::class)

src/DependencyInjection/PatchlevelEventSourcingExtension.php

@@ -19,6 +19,7 @@
 use Doctrine\ORM\Tools\ToolEvents;
 use Patchlevel\EventSourcing\Attribute\Aggregate;
 use Patchlevel\EventSourcing\Attribute\Event;
+use Patchlevel\EventSourcing\Attribute\Header;
 use Patchlevel\EventSourcing\Attribute\Processor;
 use Patchlevel\EventSourcing\Attribute\Projector;
 use Patchlevel\EventSourcing\Attribute\Subscriber;
@@ -61,9 +62,7 @@
 use Patchlevel\EventSourcing\Metadata\AggregateRoot\AggregateRootMetadataAwareMetadataFactory;
 use Patchlevel\EventSourcing\Metadata\AggregateRoot\AggregateRootMetadataFactory;
 use Patchlevel\EventSourcing\Metadata\AggregateRoot\AggregateRootRegistry;
-use Patchlevel\EventSourcing\Metadata\AggregateRoot\AttributeAggregateRootRegistryFactory;
 use Patchlevel\EventSourcing\Metadata\Event\AttributeEventMetadataFactory;
-use Patchlevel\EventSourcing\Metadata\Event\AttributeEventRegistryFactory;
 use Patchlevel\EventSourcing\Metadata\Event\EventMetadataFactory;
 use Patchlevel\EventSourcing\Metadata\Event\EventRegistry;
 use Patchlevel\EventSourcing\Metadata\Message\AttributeMessageHeaderRegistryFactory;
@@ -153,6 +152,7 @@
 use Symfony\Component\DependencyInjection\ContainerInterface;
 use Symfony\Component\DependencyInjection\Exception\InvalidArgumentException;
 use Symfony\Component\DependencyInjection\Extension\Extension;
+use Symfony\Component\DependencyInjection\Parameter;
 use Symfony\Component\DependencyInjection\Reference;
 
 use function class_exists;
@@ -164,8 +164,6 @@ final class PatchlevelEventSourcingExtension extends Extension
     /** @param array<array-key, mixed> $configs */
     public function load(array $configs, ContainerBuilder $container): void
     {
-        $this->removeNonServices($container);
-
         $configuration = new Configuration();
 
         /** @var Config $config */
@@ -185,7 +183,7 @@ public function load(array $configs, ContainerBuilder $container): void
         $this->configureConnection($config, $container);
         $this->configureStore($config, $container);
         $this->configureSnapshots($config, $container);
-        $this->configureAggregates($config, $container);
+        $this->configureAggregates($container);
         $this->configureCommands($container);
         $this->configureProfiler($container);
         $this->configureClock($config, $container);
@@ -202,11 +200,17 @@ public function load(array $configs, ContainerBuilder $container): void
     /** @param Config $config */
     private function configureSerializer(array $config, ContainerBuilder $container): void
     {
-        $container->register(AttributeEventRegistryFactory::class);
+        $container->registerAttributeForAutoconfiguration(
+            Event::class,
+            static function (ChildDefinition $definition, Event $attribute): void {
+                $definition->addResourceTag('event_sourcing.event', ['name' => $attribute->name]);
+            },
+        );
+
+        $container->setParameter('event_sourcing.events', []);
 
         $container->register(EventRegistry::class)
-            ->setFactory([new Reference(AttributeEventRegistryFactory::class), 'create'])
-            ->setArguments([$config['events']]);
+            ->setArguments([new Parameter('event_sourcing.events')]);
 
         $container->register(AttributeEventMetadataFactory::class);
         $container->setAlias(EventMetadataFactory::class, AttributeEventMetadataFactory::class);
@@ -224,12 +228,15 @@ private function configureSerializer(array $config, ContainerBuilder $container)
 
         $container->setAlias(EventSerializer::class, DefaultEventSerializer::class);
 
-        $container->register(AttributeMessageHeaderRegistryFactory::class);
-        $container->setAlias(MessageHeaderRegistryFactory::class, AttributeMessageHeaderRegistryFactory::class);
+        $container->registerAttributeForAutoconfiguration(
+            Header::class,
+            static function (ChildDefinition $definition, Header $attribute): void {
+                $definition->addResourceTag('event_sourcing.header', ['name' => $attribute->name]);
+            },
+        );
 
         $container->register(MessageHeaderRegistry::class)
-            ->setFactory([new Reference(MessageHeaderRegistryFactory::class), 'create'])
-            ->setArguments([$config['headers']]);
+            ->setArguments([new Parameter('event_sourcing.headers')]);
 
         $container->register(DefaultHeadersSerializer::class)
             ->setArguments([
@@ -879,17 +886,22 @@ private function configureSnapshots(array $config, ContainerBuilder $container):
         $container->setAlias(SnapshotStore::class, DefaultSnapshotStore::class);
     }
 
-    /** @param Config $config */
-    private function configureAggregates(array $config, ContainerBuilder $container): void
+    private function configureAggregates(ContainerBuilder $container): void
     {
+        $container->registerAttributeForAutoconfiguration(
+            Aggregate::class,
+            static function (ChildDefinition $definition, Aggregate $attribute): void {
+                $definition->addResourceTag('event_sourcing.aggregate', ['name' => $attribute->name]);
+            },
+        );
+
         $container->register(AggregateRootMetadataAwareMetadataFactory::class);
         $container->setAlias(AggregateRootMetadataFactory::class, AggregateRootMetadataAwareMetadataFactory::class);
 
-        $container->register(AttributeAggregateRootRegistryFactory::class);
+        $container->setParameter('event_sourcing.aggregates', []);
 
         $container->register(AggregateRootRegistry::class)
-            ->setFactory([new Reference(AttributeAggregateRootRegistryFactory::class), 'create'])
-            ->setArguments([$config['aggregates']]);
+            ->setArguments([new Parameter('event_sourcing.aggregates')]);
 
         $container->register(DefaultRepositoryManager::class)
             ->setArguments([
@@ -1221,26 +1233,4 @@ private function configureValueResolver(ContainerBuilder $container): void
         $container->register(IdentifierValueResolver::class)
             ->addTag('controller.argument_value_resolver', ['priority' => 200]);
     }
-
-    private function removeNonServices(ContainerBuilder $container): void
-    {
-        $container->registerAttributeForAutoconfiguration(
-            Aggregate::class,
-            static function (ChildDefinition $definition): void {
-                $definition->setAbstract(true)->addTag(
-                    'container.excluded',
-                    ['source' => sprintf('with #[%s] attribute', Aggregate::class)],
-                );
-            },
-        );
-        $container->registerAttributeForAutoconfiguration(
-            Event::class,
-            static function (ChildDefinition $definition): void {
-                $definition->setAbstract(true)->addTag(
-                    'container.excluded',
-                    ['source' => sprintf('with #[%s] attribute', Event::class)],
-                );
-            },
-        );
-    }
 }

src/DependencyInjection/RepositoryCompilerPass.php

@@ -4,12 +4,10 @@
 
 namespace Patchlevel\EventSourcingBundle\DependencyInjection;
 
-use Patchlevel\EventSourcing\Metadata\AggregateRoot\AggregateRootRegistry;
 use Patchlevel\EventSourcing\Repository\Repository;
 use Patchlevel\EventSourcing\Repository\RepositoryManager;
 use Symfony\Component\DependencyInjection\Compiler\CompilerPassInterface;
 use Symfony\Component\DependencyInjection\ContainerBuilder;
-use Symfony\Component\DependencyInjection\ContainerInterface;
 use Symfony\Component\DependencyInjection\Definition;
 use Symfony\Component\DependencyInjection\Reference;
 
@@ -18,20 +16,14 @@
 {
     public function process(ContainerBuilder $container): void
     {
-        $aggregateRootRegistry = $container->get(AggregateRootRegistry::class, ContainerInterface::NULL_ON_INVALID_REFERENCE);
-
-        if (!$aggregateRootRegistry instanceof AggregateRootRegistry) {
-            return;
-        }
-
-        foreach ($aggregateRootRegistry->aggregateNames() as $aggregateName) {
+        foreach ($container->getParameter('event_sourcing.aggregates') as $aggregateName => $aggregateClass) {
             $aggregateRepositoryName = $aggregateName . 'Repository';
             $aggregateRepositoryId = 'event_sourcing.' . $aggregateName . '.repository';
 
             $definition = new Definition(Repository::class);
             $definition->setPublic(false);
             $definition->setFactory([new Reference(RepositoryManager::class), 'get']);
-            $definition->setArgument(0, $aggregateRootRegistry->aggregateClass($aggregateName));
+            $definition->setArgument(0, $aggregateClass);
 
             $container->setDefinition($aggregateRepositoryId, $definition);
             $container->registerAliasForArgument($aggregateRepositoryId, Repository::class, $aggregateRepositoryName)->setPublic(false);

src/DependencyInjection/ResourceCompilerPass.php

@@ -0,0 +1,32 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcingBundle\DependencyInjection;
+
+use Symfony\Component\DependencyInjection\Compiler\CompilerPassInterface;
+use Symfony\Component\DependencyInjection\ContainerBuilder;
+
+/** @internal */
+final class ResourceCompilerPass implements CompilerPassInterface
+{
+    private const RESSOURCES = [
+        'event_sourcing.aggregate' => 'event_sourcing.aggregates',
+        'event_sourcing.event' => 'event_sourcing.events',
+        'event_sourcing.header' => 'event_sourcing.headers',
+    ];
+
+    public function process(ContainerBuilder $container): void
+    {
+        foreach (self::RESSOURCES as $tag => $parameter) {
+            $map = [];
+            foreach ($container->findTaggedResourceIds($tag) as $id => $tags) {
+                foreach ($tags as $tag) {
+                    $map[$tag['name']] = $id;
+                }
+            }
+
+            $container->setParameter($parameter, $map);
+        }
+    }
+}

src/PatchlevelEventSourcingBundle.php

@@ -4,6 +4,7 @@
 
 namespace Patchlevel\EventSourcingBundle;
 
+use Patchlevel\EventSourcingBundle\DependencyInjection\ResourceCompilerPass;
 use Patchlevel\EventSourcingBundle\DependencyInjection\CommandHandlerCompilerPass;
 use Patchlevel\EventSourcingBundle\DependencyInjection\HandlerServiceLocatorCompilerPass;
 use Patchlevel\EventSourcingBundle\DependencyInjection\QueryHandlerCompilerPass;
@@ -17,6 +18,7 @@ final class PatchlevelEventSourcingBundle extends Bundle
 {
     public function build(ContainerBuilder $container): void
     {
+        $container->addCompilerPass(new ResourceCompilerPass(), priority: 100);
         $container->addCompilerPass(new RepositoryCompilerPass());
         $container->addCompilerPass(new SubscriberGuardCompilePass());
         $container->addCompilerPass(new CommandHandlerCompilerPass(), priority: 100);