add event sourcing 3.18 features

DavidBadura · DavidBadura · commit b9bdc667d23f · 2026-03-24T12:53:18.000+01:00
diff --git a/.gitignore b/.gitignore
@@ -6,3 +6,4 @@ phpunit.xml
 phpstan.neon
 infection.html
 infection.log
+/docs_php
diff --git a/composer.json b/composer.json
@@ -19,7 +19,7 @@
   ],
   "require": {
     "php": "~8.2.0 || ~8.3.0 || ~8.4.0 || ~8.5.0",
-    "patchlevel/event-sourcing": "^3.13.0",
+    "patchlevel/event-sourcing": "^3.18.0",
     "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",
diff --git a/composer.lock b/composer.lock
diff --git a/src/Command/StoreMigrateCommand.php b/src/Command/StoreMigrateCommand.php
@@ -17,6 +17,7 @@
 
 use function count;
 
+/** @deprecated since version 3.15.0, to be removed in 4.0.0. Use the StoreMigrateCommand from the patchlevel/event-sourcing package instead. */
 #[AsCommand(
     'event-sourcing:store:migrate',
     'migrate events from one store to another',
diff --git a/src/DependencyInjection/DoctrineCleanupCompilerPass.php b/src/DependencyInjection/DoctrineCleanupCompilerPass.php
@@ -0,0 +1,30 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcingBundle\DependencyInjection;
+
+use Patchlevel\EventSourcing\Subscription\Cleanup\Dbal\DbalCleanupTaskHandler;
+use Symfony\Component\DependencyInjection\Compiler\CompilerPassInterface;
+use Symfony\Component\DependencyInjection\ContainerBuilder;
+use Symfony\Component\DependencyInjection\Reference;
+
+final class DoctrineCleanupCompilerPass implements CompilerPassInterface
+{
+    public function process(ContainerBuilder $container): void
+    {
+        if ($container->has('doctrine')) {
+            $container->register(DbalCleanupTaskHandler::class, DbalCleanupTaskHandler::class)
+                ->setArguments([
+                    new Reference('doctrine'),
+                ])
+                ->addTag('event_sourcing.cleanup_task_handler');
+        } elseif ($container->has('event_sourcing.dbal_public_connection')) {
+            $container->register(DbalCleanupTaskHandler::class, DbalCleanupTaskHandler::class)
+                ->setArguments([
+                    new Reference('event_sourcing.dbal_public_connection'),
+                ])
+                ->addTag('event_sourcing.cleanup_task_handler');
+        }
+    }
+}
diff --git a/src/DependencyInjection/PatchlevelEventSourcingExtension.php b/src/DependencyInjection/PatchlevelEventSourcingExtension.php
@@ -32,9 +32,11 @@
 use Patchlevel\EventSourcing\Console\Command\SchemaUpdateCommand;
 use Patchlevel\EventSourcing\Console\Command\ShowAggregateCommand;
 use Patchlevel\EventSourcing\Console\Command\ShowCommand;
+use Patchlevel\EventSourcing\Console\Command\StoreMigrateCommand;
 use Patchlevel\EventSourcing\Console\Command\SubscriptionBootCommand;
 use Patchlevel\EventSourcing\Console\Command\SubscriptionPauseCommand;
 use Patchlevel\EventSourcing\Console\Command\SubscriptionReactivateCommand;
+use Patchlevel\EventSourcing\Console\Command\SubscriptionRefreshCommand;
 use Patchlevel\EventSourcing\Console\Command\SubscriptionRemoveCommand;
 use Patchlevel\EventSourcing\Console\Command\SubscriptionRunCommand;
 use Patchlevel\EventSourcing\Console\Command\SubscriptionSetupCommand;
@@ -94,6 +96,9 @@
 use Patchlevel\EventSourcing\Store\Store;
 use Patchlevel\EventSourcing\Store\StreamDoctrineDbalStore;
 use Patchlevel\EventSourcing\Store\StreamReadOnlyStore;
+use Patchlevel\EventSourcing\Subscription\Cleanup\Cleaner;
+use Patchlevel\EventSourcing\Subscription\Cleanup\CleanupTaskHandler;
+use Patchlevel\EventSourcing\Subscription\Cleanup\DefaultCleaner;
 use Patchlevel\EventSourcing\Subscription\Engine\CatchUpSubscriptionEngine;
 use Patchlevel\EventSourcing\Subscription\Engine\DefaultSubscriptionEngine;
 use Patchlevel\EventSourcing\Subscription\Engine\GapResolverStoreMessageLoader;
@@ -116,7 +121,6 @@
 use Patchlevel\EventSourcing\Subscription\Subscriber\SubscriberHelper;
 use Patchlevel\EventSourcingBundle\Attribute\AsListener;
 use Patchlevel\EventSourcingBundle\Clock\FrozenClockFactory;
-use Patchlevel\EventSourcingBundle\Command\StoreMigrateCommand;
 use Patchlevel\EventSourcingBundle\CommandBus\SymfonyCommandBus;
 use Patchlevel\EventSourcingBundle\DataCollector\EventSourcingCollector;
 use Patchlevel\EventSourcingBundle\DataCollector\MessageCollectorEventBus;
@@ -516,13 +520,24 @@ static function (ChildDefinition $definition): void {
 
         $container->setAlias(SubscriberAccessorRepository::class, MetadataSubscriberAccessorRepository::class);
 
+        $container->registerForAutoconfiguration(CleanupTaskHandler::class)
+            ->addTag('event_sourcing.cleanup_task_handler');
+
+        $container->register(DefaultCleaner::class)
+            ->setArguments([
+                new TaggedIteratorArgument('event_sourcing.cleanup_task_handler'),
+            ]);
+
+        $container->setAlias(Cleaner::class, DefaultCleaner::class);
+
         $container->register(DefaultSubscriptionEngine::class)
             ->setArguments([
                 new Reference(MessageLoader::class),
                 new Reference(SubscriptionStore::class),
                 new Reference(SubscriberAccessorRepository::class),
                 new Reference(RetryStrategyRepository::class),
                 new Reference('logger', ContainerInterface::NULL_ON_INVALID_REFERENCE),
+                new Reference(Cleaner::class),
             ])
             ->addTag('monolog.logger', ['channel' => 'event_sourcing']);
 
@@ -981,6 +996,12 @@ private function configureCommands(ContainerBuilder $container): void
                 new Reference(SubscriptionEngine::class),
             ])
             ->addTag('console.command');
+
+        $container->register(SubscriptionRefreshCommand::class)
+            ->setArguments([
+                new Reference(SubscriptionEngine::class),
+            ])
+            ->addTag('console.command');
     }
 
     /** @param Config $config */
diff --git a/src/PatchlevelEventSourcingBundle.php b/src/PatchlevelEventSourcingBundle.php
@@ -5,6 +5,7 @@
 namespace Patchlevel\EventSourcingBundle;
 
 use Patchlevel\EventSourcingBundle\DependencyInjection\CommandHandlerCompilerPass;
+use Patchlevel\EventSourcingBundle\DependencyInjection\DoctrineCleanupCompilerPass;
 use Patchlevel\EventSourcingBundle\DependencyInjection\HandlerServiceLocatorCompilerPass;
 use Patchlevel\EventSourcingBundle\DependencyInjection\QueryHandlerCompilerPass;
 use Patchlevel\EventSourcingBundle\DependencyInjection\RepositoryCompilerPass;
@@ -23,5 +24,6 @@ public function build(ContainerBuilder $container): void
         $container->addCompilerPass(new QueryHandlerCompilerPass(), priority: 100);
         $container->addCompilerPass(new HandlerServiceLocatorCompilerPass(), priority: -100);
         $container->addCompilerPass(new TranslatorCompilerPass());
+        $container->addCompilerPass(new DoctrineCleanupCompilerPass());
     }
 }
diff --git a/tests/Unit/PatchlevelEventSourcingBundleTest.php b/tests/Unit/PatchlevelEventSourcingBundleTest.php
@@ -10,6 +10,7 @@
 use Doctrine\Migrations\Tools\Console\Command\ExecuteCommand;
 use Doctrine\Migrations\Tools\Console\Command\MigrateCommand;
 use Doctrine\Migrations\Tools\Console\Command\StatusCommand;
+use Doctrine\Persistence\ManagerRegistry;
 use InvalidArgumentException;
 use Patchlevel\EventSourcing\Attribute\Aggregate;
 use Patchlevel\EventSourcing\Attribute\Event;
@@ -26,9 +27,11 @@
 use Patchlevel\EventSourcing\Console\Command\SchemaUpdateCommand;
 use Patchlevel\EventSourcing\Console\Command\ShowAggregateCommand;
 use Patchlevel\EventSourcing\Console\Command\ShowCommand;
+use Patchlevel\EventSourcing\Console\Command\StoreMigrateCommand;
 use Patchlevel\EventSourcing\Console\Command\SubscriptionBootCommand;
 use Patchlevel\EventSourcing\Console\Command\SubscriptionPauseCommand;
 use Patchlevel\EventSourcing\Console\Command\SubscriptionReactivateCommand;
+use Patchlevel\EventSourcing\Console\Command\SubscriptionRefreshCommand;
 use Patchlevel\EventSourcing\Console\Command\SubscriptionRemoveCommand;
 use Patchlevel\EventSourcing\Console\Command\SubscriptionRunCommand;
 use Patchlevel\EventSourcing\Console\Command\SubscriptionSetupCommand;
@@ -67,6 +70,9 @@
 use Patchlevel\EventSourcing\Store\StreamDoctrineDbalStore;
 use Patchlevel\EventSourcing\Store\StreamReadOnlyStore;
 use Patchlevel\EventSourcing\Store\StreamStore;
+use Patchlevel\EventSourcing\Subscription\Cleanup\Cleaner;
+use Patchlevel\EventSourcing\Subscription\Cleanup\Dbal\DbalCleanupTaskHandler;
+use Patchlevel\EventSourcing\Subscription\Cleanup\DefaultCleaner;
 use Patchlevel\EventSourcing\Subscription\Engine\CatchUpSubscriptionEngine;
 use Patchlevel\EventSourcing\Subscription\Engine\DefaultSubscriptionEngine;
 use Patchlevel\EventSourcing\Subscription\Engine\GapResolverStoreMessageLoader;
@@ -82,8 +88,6 @@
 use Patchlevel\EventSourcing\Subscription\Store\InMemorySubscriptionStore;
 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;
@@ -786,6 +790,60 @@ public function testGapDetectionWithExplicitValues(): void
         self::assertInstanceOf(GapResolverStoreMessageLoader::class, $messageLoader);
     }
 
+    public function testSubscriptionCleanupWithDoctrine(): void
+    {
+        $registry = $this->createMock(ManagerRegistry::class);
+
+        $container = new ContainerBuilder();
+        $container->set('doctrine', $registry);
+
+        $this->compileContainer(
+            $container,
+            [
+                'patchlevel_event_sourcing' => [
+                    'connection' => [
+                        'service' => 'doctrine.dbal.eventstore_connection',
+                    ],
+                    'store' => [
+                        'merge_orm_schema' => true,
+                    ],
+                ],
+            ]
+        );
+
+        $definition = $container->getDefinition(DbalCleanupTaskHandler::class);
+        $tags = $definition->getTag('event_sourcing.cleanup_task_handler');
+
+        self::assertCount(1, $tags);
+
+        $cleaner = $container->get(Cleaner::class);
+        self::assertInstanceOf(DefaultCleaner::class, $cleaner);
+    }
+
+    public function testSubscriptionCleanupWithProjectionConnection(): void
+    {
+        $container = new ContainerBuilder();
+        $this->compileContainer(
+            $container,
+            [
+                'patchlevel_event_sourcing' => [
+                    'connection' => [
+                        'url' => 'sqlite3:///:memory:',
+                        'provide_dedicated_connection' => true,
+                    ],
+                ],
+            ]
+        );
+
+        $definition = $container->getDefinition(DbalCleanupTaskHandler::class);
+        $tags = $definition->getTag('event_sourcing.cleanup_task_handler');
+
+        self::assertCount(1, $tags);
+
+        $cleaner = $container->get(Cleaner::class);
+        self::assertInstanceOf(DefaultCleaner::class, $cleaner);
+    }
+
     public function testSnapshotStore(): void
     {
         $container = new ContainerBuilder();
@@ -1013,6 +1071,7 @@ public function testCommands(): void
         self::assertInstanceOf(SubscriptionSetupCommand::class, $container->get(SubscriptionSetupCommand::class));
         self::assertInstanceOf(SubscriptionStatusCommand::class, $container->get(SubscriptionStatusCommand::class));
         self::assertInstanceOf(SubscriptionTeardownCommand::class, $container->get(SubscriptionTeardownCommand::class));
+        self::assertInstanceOf(SubscriptionRefreshCommand::class, $container->get(SubscriptionRefreshCommand::class));
         self::assertInstanceOf(SchemaCreateCommand::class, $container->get(SchemaCreateCommand::class));
         self::assertInstanceOf(SchemaUpdateCommand::class, $container->get(SchemaUpdateCommand::class));
         self::assertInstanceOf(SchemaDropCommand::class, $container->get(SchemaDropCommand::class));

Original file line number	Diff line number	Diff line change
`@@ -5,6 +5,7 @@`
`5`	`5`	`namespace Patchlevel\EventSourcingBundle;`
`6`	`6`
`7`	`7`	`use Patchlevel\EventSourcingBundle\DependencyInjection\CommandHandlerCompilerPass;`
	`8`	`+use Patchlevel\EventSourcingBundle\DependencyInjection\DoctrineCleanupCompilerPass;`
`8`	`9`	`use Patchlevel\EventSourcingBundle\DependencyInjection\HandlerServiceLocatorCompilerPass;`
`9`	`10`	`use Patchlevel\EventSourcingBundle\DependencyInjection\QueryHandlerCompilerPass;`
`10`	`11`	`use Patchlevel\EventSourcingBundle\DependencyInjection\RepositoryCompilerPass;`
`@@ -23,5 +24,6 @@ public function build(ContainerBuilder $container): void`
`23`	`24`	`$container->addCompilerPass(new QueryHandlerCompilerPass(), priority: 100);`
`24`	`25`	`$container->addCompilerPass(new HandlerServiceLocatorCompilerPass(), priority: -100);`
`25`	`26`	`$container->addCompilerPass(new TranslatorCompilerPass());`
	`27`	`+ $container->addCompilerPass(new DoctrineCleanupCompilerPass());`
`26`	`28`	`}`
`27`	`29`	`}`