Also update default configuration

Author: DanielBadura

docs/pages/configuration.md

@@ -672,7 +672,7 @@ For this you need to enable the crypto shredding.
 ```yaml
 patchlevel_event_sourcing:
     cryptography:
-      use_encrypted_field_name: true,
+      use_encrypted_field_name: true
 ```
 
 !!! tip

docs/pages/installation.md

@@ -39,12 +39,18 @@ patchlevel_event_sourcing:
       provide_dedicated_connection: true
     store:
       type: dbal_stream
-      merge_orm_schema: true
+      # if you are using doctrine bundle you should enable this
+      #merge_orm_schema: true
     command_bus:
-      service: messenger.bus.default
+      service: messenger.default_bus
     query_bus:
-      service: messenger.bus.default
-    cryptography: ~
+      service: messenger.default_bus
+    subscription:
+      gap_detection: ~
+
+    # enable this if you want to use sensitive data encryption
+    #cryptography: ~ 
+    #  use_encrypted_field_name: true
 
 when@dev:
   patchlevel_event_sourcing:

src/DependencyInjection/CommandHandlerCompilerPass.php

@@ -25,7 +25,10 @@ public function process(ContainerBuilder $container): void
             return;
         }
 
-        $bus = $container->getParameter('patchlevel_event_sourcing.aggregate_handlers.bus');
+        $bus = ServiceAliasResolver::resolve(
+            $container,
+            $container->getParameter('patchlevel_event_sourcing.aggregate_handlers.bus'),
+        );
 
         /** @var AggregateRootRegistry $aggregateRootRegistry */
         $aggregateRootRegistry = $container->get(AggregateRootRegistry::class);

src/DependencyInjection/QueryHandlerCompilerPass.php

@@ -19,7 +19,10 @@ public function process(ContainerBuilder $container): void
             return;
         }
 
-        $bus = $container->getParameter('patchlevel_event_sourcing.query_handlers.bus');
+        $bus = ServiceAliasResolver::resolve(
+            $container,
+            $container->getParameter('patchlevel_event_sourcing.query_handlers.bus'),
+        );
         $subscribers = $container->findTaggedServiceIds('event_sourcing.subscriber');
 
         foreach (array_keys($subscribers) as $subscriberServiceName) {

src/DependencyInjection/ServiceAliasResolver.php

@@ -0,0 +1,25 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcingBundle\DependencyInjection;
+
+use Symfony\Component\DependencyInjection\ContainerBuilder;
+
+/**
+ * @interal
+ */
+final readonly class ServiceAliasResolver
+{
+    public static function resolve(ContainerBuilder $container, string $id): string
+    {
+        if ($container->hasAlias($id)) {
+            return self::resolve(
+                $container,
+                (string)$container->getAlias($id),
+            );
+        }
+
+        return $id;
+    }
+}

src/DependencyInjection/SubscriberGuardCompilePass.php

@@ -34,7 +34,7 @@ public function process(ContainerBuilder $container): void
             );
         }
 
-        $subscriptionConnection = $this->resolveService($container, (string)$argument);
+        $subscriptionConnection = ServiceAliasResolver::resolve($container, (string)$argument);
 
         $subscribers = $container->findTaggedServiceIds('event_sourcing.subscriber');
 
@@ -48,7 +48,7 @@ public function process(ContainerBuilder $container): void
                     continue;
                 }
 
-                if ($subscriptionConnection !== $this->resolveService($container, (string)$argument)) {
+                if ($subscriptionConnection !== ServiceAliasResolver::resolve($container, (string)$argument)) {
                     continue;
                 }
 
@@ -68,16 +68,4 @@ public function process(ContainerBuilder $container): void
             }
         }
     }
-
-    private function resolveService(ContainerBuilder $container, string $id): string
-    {
-        if ($container->hasAlias($id)) {
-            return $this->resolveService(
-                $container,
-                (string)$container->getAlias($id),
-            );
-        }
-
-        return $id;
-    }
 }