add projectionist auto boot feature

src/DependencyInjection/Configuration.php

@@ -94,6 +94,7 @@ public function getConfigTreeBuilder(): TreeBuilder
                 ->addDefaultsIfNotSet()
                 ->children()
                     ->booleanNode('sync')->defaultValue(true)->end()
+                    ->booleanNode('auto_boot')->defaultValue(false)->end()
                 ->end()
             ->end()
 

src/DependencyInjection/PatchlevelEventSourcingExtension.php

@@ -86,6 +86,7 @@
 use Patchlevel\EventSourcing\WatchServer\WatchServerClient;
 use Patchlevel\EventSourcingBundle\DataCollector\EventSourcingCollector;
 use Patchlevel\EventSourcingBundle\DataCollector\MessageListener;
+use Patchlevel\EventSourcingBundle\Listener\ProjectionistAutoBootListener;
 use Patchlevel\Hydrator\Hydrator;
 use Patchlevel\Hydrator\MetadataHydrator;
 use Psr\Log\LoggerInterface;
@@ -101,7 +102,7 @@
 /**
  * @psalm-type Config = array{
  *     event_bus: ?array{type: string, service: string},
- *     projection: array{sync: bool},
+ *     projection: array{sync: bool, auto_boot: bool},
  *     watch_server: array{enabled: bool, host: string},
  *     connection: ?array{service: ?string, url: ?string},
  *     store: array{merge_orm_schema: bool, options: array<string, mixed>},
@@ -272,6 +273,15 @@ private function configureProjection(array $config, ContainerBuilder $container)
             ])
             ->addTag('console.command');
 
+        if ($config['projection']['auto_boot']) {
+            $container->register(ProjectionistAutoBootListener::class)
+                ->setArguments([
+                    new Reference(Projectionist::class),
+                    new Reference('lock.default.factory'),
+                ])
+                ->addTag('kernel.event_listener');
+        }
+
         if (!$config['projection']['sync']) {
             return;
         }

src/Listener/ProjectionistAutoBootListener.php

@@ -0,0 +1,33 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcingBundle\Listener;
+
+use Patchlevel\EventSourcing\Projection\Projectionist\Projectionist;
+use Symfony\Component\HttpKernel\Event\RequestEvent;
+use Symfony\Component\Lock\LockFactory;
+
+final class ProjectionistAutoBootListener
+{
+    public function __construct(
+        private readonly Projectionist $projectionist,
+        private readonly LockFactory $lockFactory,
+    ) {
+    }
+
+    public function __invoke(RequestEvent $event): void
+    {
+        if (!$event->isMainRequest()) {
+            return;
+        }
+
+        $lock = $this->lockFactory->createLock('projectionist-boot');
+
+        if (!$lock->acquire()) {
+            return;
+        }
+
+        $this->projectionist->boot();
+    }
+}

tests/Unit/PatchlevelEventSourcingBundleTest.php

@@ -50,6 +50,7 @@
 use Patchlevel\EventSourcing\WatchServer\WatchServer;
 use Patchlevel\EventSourcing\WatchServer\WatchServerClient;
 use Patchlevel\EventSourcingBundle\DependencyInjection\PatchlevelEventSourcingExtension;
+use Patchlevel\EventSourcingBundle\Listener\ProjectionistAutoBootListener;
 use Patchlevel\EventSourcingBundle\PatchlevelEventSourcingBundle;
 use Patchlevel\EventSourcingBundle\Tests\Fixtures\CreatedSubscriber;
 use Patchlevel\EventSourcingBundle\Tests\Fixtures\Processor1;
@@ -680,6 +681,27 @@ public function testProjectionistAsync(): void
         self::assertInstanceOf(DefaultEventBus::class, $container->get(EventBus::class));
     }
 
+    public function testProjectionistAutoBoot(): void
+    {
+        $container = new ContainerBuilder();
+
+        $this->compileContainer(
+            $container,
+            [
+                'patchlevel_event_sourcing' => [
+                    'connection' => [
+                        'service' => 'doctrine.dbal.eventstore_connection',
+                    ],
+                    'projection' => [
+                        'auto_boot' => true,
+                    ],
+                ],
+            ]
+        );
+
+        self::assertInstanceOf(ProjectionistAutoBootListener::class, $container->get(ProjectionistAutoBootListener::class));
+    }
+
     public function testSchemaMerge(): void
     {
         $container = new ContainerBuilder();