Merge release 3.14.0 into 4.0.x

docs/configuration.md

@@ -343,6 +343,8 @@ patchlevel_event_sourcing:
     store: 
       type: 'custom' # default is 'dbal'
       service: 'my_subscription_store'
+      options:
+        table_name: 'my_subscription_store'
 ```
 :::tip
 If you are using the [doctrine-test-bundle](https://github.com/dmaicher/doctrine-test-bundle),
@@ -672,7 +674,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
 You should activate `use_encrypted_field_name` to mark the fields that are encrypted.

docs/installation.md

@@ -37,6 +37,20 @@ patchlevel_event_sourcing:
     connection:
       url: '%env(EVENTSTORE_URL)%'
       provide_dedicated_connection: true
+    store:
+      type: dbal_stream
+      # if you are using doctrine bundle you should enable this
+      #merge_orm_schema: true
+    command_bus:
+      service: messenger.default_bus
+    query_bus:
+      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:
@@ -50,6 +64,8 @@ when@dev:
 when@test:
   patchlevel_event_sourcing:
     subscription:
+      store:
+        type: 'static_in_memory'
       catch_up: true
       throw_on_error: true
       run_after_aggregate_save: true

docs/usage.md

@@ -1,7 +1,7 @@
 # Usage
 
 Here you will find some examples of how to use the bundle.
-But we provide only examples for specific symfo
+But we provide only examples for specific symfony features.
 
 :::info
 You can find out more about event sourcing in the library

phpstan-baseline.neon

@@ -1,7 +1,67 @@
 parameters:
 	ignoreErrors:
+		-
+			message: '#^Parameter \#2 \$id of static method Patchlevel\\EventSourcingBundle\\DependencyInjection\\ServiceAliasResolver\:\:resolve\(\) expects string, array\|bool\|float\|int\|string\|null given\.$#'
+			identifier: argument.type
+			count: 1
+			path: src/DependencyInjection/CommandHandlerCompilerPass.php
+
 		-
 			message: '#^Parameter \#1 \$classString of static method Patchlevel\\EventSourcing\\QueryBus\\HandlerFinder\:\:findInClass\(\) expects class\-string, string given\.$#'
 			identifier: argument.type
 			count: 1
 			path: src/DependencyInjection/QueryHandlerCompilerPass.php
+
+		-
+			message: '#^Parameter \#2 \$id of static method Patchlevel\\EventSourcingBundle\\DependencyInjection\\ServiceAliasResolver\:\:resolve\(\) expects string, array\|bool\|float\|int\|string\|null given\.$#'
+			identifier: argument.type
+			count: 1
+			path: src/DependencyInjection/QueryHandlerCompilerPass.php
+
+		-
+			message: '#^Property Patchlevel\\EventSourcingBundle\\Tests\\Fixtures\\Profile\:\:\$id is never read, only written\.$#'
+			identifier: property.onlyWritten
+			count: 1
+			path: tests/Fixtures/Profile.php
+
+		-
+			message: '#^Property Patchlevel\\EventSourcingBundle\\Tests\\Fixtures\\SnapshotableProfile\:\:\$id is unused\.$#'
+			identifier: property.unused
+			count: 1
+			path: tests/Fixtures/SnapshotableProfile.php
+
+		-
+			message: '#^Call to an undefined method Symfony\\Component\\DependencyInjection\\ContainerBuilder\:\:getAutoconfiguredAttributes\(\)\.$#'
+			identifier: method.notFound
+			count: 1
+			path: tests/Unit/PatchlevelEventSourcingBundleTest.php
+
+		-
+			message: '#^Cannot access offset ''Patchlevel\\\\EventSourcing\\\\Attribute\\\\Aggregate''\|''Patchlevel\\\\EventSourcing\\\\Attribute\\\\Event'' on mixed\.$#'
+			identifier: offsetAccess.nonOffsetAccessible
+			count: 1
+			path: tests/Unit/PatchlevelEventSourcingBundleTest.php
+
+		-
+			message: '#^Cannot access offset ''bus'' on mixed\.$#'
+			identifier: offsetAccess.nonOffsetAccessible
+			count: 3
+			path: tests/Unit/PatchlevelEventSourcingBundleTest.php
+
+		-
+			message: '#^Cannot access offset ''handles'' on mixed\.$#'
+			identifier: offsetAccess.nonOffsetAccessible
+			count: 3
+			path: tests/Unit/PatchlevelEventSourcingBundleTest.php
+
+		-
+			message: '#^Cannot access offset ''method'' on mixed\.$#'
+			identifier: offsetAccess.nonOffsetAccessible
+			count: 2
+			path: tests/Unit/PatchlevelEventSourcingBundleTest.php
+
+		-
+			message: '#^Trying to invoke mixed but it''s not a callable\.$#'
+			identifier: callable.nonCallable
+			count: 1
+			path: tests/Unit/PatchlevelEventSourcingBundleTest.php

phpstan.neon.dist

@@ -6,3 +6,4 @@ parameters:
 	level: max
 	paths:
 		- src
+		- tests

src/DependencyInjection/CommandHandlerCompilerPass.php

@@ -25,7 +25,10 @@
             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);
@@ -34,7 +37,7 @@
             $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;
 
                 $container->register($handlerId, $handlerClass)

src/DependencyInjection/Configuration.php

@@ -22,7 +22,11 @@
  *      },
  *      query_bus: array{enabled: bool, service: string},
  *      subscription: array{
- *          store: array{type: string, service: string|null},
+ *          store: array{
+ *              type: string,
+ *              service: string|null,
+ *              options: array{table_name: string}
+ *          },
  *          retry_strategy?: array{base_delay: int, delay_factor: int, max_attempts: int},
  *          retry_strategies: array<string, array{type: string, service: string, options: array<string, mixed>}>,
  *          default_retry_strategy: string,
@@ -194,10 +198,16 @@
                         ->addDefaultsIfNotSet()
                         ->children()
                             ->enumNode('type')
                                 ->values(['dbal', 'in_memory', 'static_in_memory', 'custom'])
                                 ->defaultValue('dbal')
                             ->end()
                             ->scalarNode('service')->defaultNull()->end()
+                            ->arrayNode('options')
+                                ->addDefaultsIfNotSet()
+                                ->children()
+                                    ->scalarNode('table_name')->defaultValue('subscriptions')->end()
+                                ->end()
+                            ->end()
                         ->end()
                     ->end()
 
@@ -208,8 +218,8 @@
                             'The "%node%" option is deprecated and will be removed in 4.0. Use "patchlevel_event_sourcing.subscription.retry_strategies" instead.'
                         )
                         ->children()
                             ->integerNode('base_delay')->defaultValue(5)->end()
                             ->integerNode('delay_factor')->defaultValue(2)->end()
                             ->integerNode('max_attempts')->defaultValue(5)->end()
                         ->end()
                     ->end()

src/DependencyInjection/PatchlevelEventSourcingExtension.php

@@ -498,6 +498,8 @@ static function (ChildDefinition $definition): void {
             $container->register(DoctrineSubscriptionStore::class)
                 ->setArguments([
                     new Reference('event_sourcing.dbal_connection'),
+                    new Reference('event_sourcing.clock'),
+                    $config['subscription']['store']['options']['table_name'],
                 ])
                 ->addTag('event_sourcing.doctrine_schema_configurator');
 

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,23 @@
+<?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;
-    }
 }

tests/Fixtures/Profile.php

@@ -16,6 +16,7 @@ class Profile extends BasicAggregateRoot
     #[Id]
     private CustomId $id;
 
+    /**  @param Repository<self> $profileRepository */
     #[Handle]
     public static function create(
         CreateProfile $command,

tests/Unit/DataCollector/EventSourcingCollectorTest.php

@@ -67,7 +67,6 @@ public function testCollectData(): void
         self::assertEquals(ProfileCreated::class, $message['event_class']);
         self::assertEquals('profile.created', $message['event_name']);
         self::assertInstanceOf(Data::class, $message['event']);
-        self::assertIsArray($message['headers']);
         self::assertCount(3, $message['headers']);
         self::assertInstanceOf(Data::class, $message['headers'][0]);
     }

tests/Unit/PatchlevelEventSourcingBundleTest.php

@@ -85,6 +85,7 @@
 use Patchlevel\EventSourcing\Subscription\Store\SubscriptionStore;
 use Patchlevel\EventSourcing\Subscription\Subscriber\MetadataSubscriberAccessorRepository;
 use Patchlevel\EventSourcingBundle\Command\StoreMigrateCommand;
+use Patchlevel\EventSourcingBundle\DependencyInjection\Configuration;
 use Patchlevel\EventSourcingBundle\DependencyInjection\PatchlevelEventSourcingExtension;
 use Patchlevel\EventSourcingBundle\EventBus\SymfonyEventBus;
 use Patchlevel\EventSourcingBundle\PatchlevelEventSourcingBundle;
@@ -1553,6 +1554,9 @@ public function testNamedRepository(): void
         self::assertSame($profileRepository, $namedArgumentProfileRepository);
     }
 
+    /**
+     * @param array{patchlevel_event_sourcing: array<string, mixed>} $config
+     */
     private function compileContainer(ContainerBuilder $container, array $config): void
     {
         $bundle = new PatchlevelEventSourcingBundle();