Merge pull request #200 from patchlevel/add-auto-setup-listener

add auto setup listener

src/DependencyInjection/Configuration.php

@@ -20,6 +20,11 @@
  *              groups: list<string>,
  *              limit: positive-int|null
  *          },
+ *          auto_setup: array{
+ *               enabled: bool,
+ *               ids: list<string>,
+ *               groups: list<string>,
+ *           },
  *          rebuild_after_file_change: bool
  *      },
  *      connection: ?array{service: ?string, url: ?string},
@@ -145,6 +150,15 @@ public function getConfigTreeBuilder(): TreeBuilder
                         ->end()
                     ->end()
 
+                    ->arrayNode('auto_setup')
+                        ->canBeEnabled()
+                        ->addDefaultsIfNotSet()
+                        ->children()
+                            ->arrayNode('ids')->scalarPrototype()->end()->end()
+                            ->arrayNode('groups')->scalarPrototype()->end()->end()
+                        ->end()
+                    ->end()
+
                     ->booleanNode('rebuild_after_file_change')->defaultFalse()->end()
                 ->end()
             ->end()

src/DependencyInjection/PatchlevelEventSourcingExtension.php

@@ -104,6 +104,7 @@
 use Patchlevel\EventSourcingBundle\DataCollector\MessageCollectorEventBus;
 use Patchlevel\EventSourcingBundle\Doctrine\DbalConnectionFactory;
 use Patchlevel\EventSourcingBundle\EventBus\SymfonyEventBus;
+use Patchlevel\EventSourcingBundle\RequestListener\AutoSetupListener;
 use Patchlevel\EventSourcingBundle\RequestListener\SubscriptionRebuildAfterFileChangeListener;
 use Patchlevel\EventSourcingBundle\RequestListener\TraceListener;
 use Patchlevel\EventSourcingBundle\ValueResolver\AggregateRootIdValueResolver;
@@ -358,6 +359,25 @@ static function (ChildDefinition $definition): void {
                 ]);
         }
 
+        if ($config['subscription']['auto_setup']['enabled']) {
+            $container->register(AutoSetupListener::class)
+                ->setArguments([
+                    new Reference(SubscriptionEngine::class),
+                    $config['subscription']['auto_setup']['ids'] ?: null,
+                    $config['subscription']['auto_setup']['groups'] ?: null,
+                ])
+                ->addTag('kernel.event_listener', [
+                    'event' => 'kernel.request',
+                    'priority' => 200,
+                    'method' => 'onKernelRequest',
+                ])
+                ->addTag('kernel.event_listener', [
+                    'priority' => 200,
+                    'event' => 'console.command',
+                    'method' => 'onConsoleCommand',
+                ]);
+        }
+
         if (!$config['subscription']['rebuild_after_file_change']) {
             return;
         }
@@ -371,11 +391,11 @@ static function (ChildDefinition $definition): void {
             ])
             ->addTag('kernel.event_listener', [
                 'event' => 'kernel.request',
-                'priority' => 200,
+                'priority' => 100,
                 'method' => 'onKernelRequest',
             ])
             ->addTag('kernel.event_listener', [
-                'priority' => 200,
+                'priority' => 100,
                 'event' => 'console.command',
                 'method' => 'onConsoleCommand',
             ]);

src/RequestListener/AutoSetupListener.php

@@ -0,0 +1,64 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcingBundle\RequestListener;
+
+use Patchlevel\EventSourcing\Subscription\Engine\SubscriptionEngine;
+use Patchlevel\EventSourcing\Subscription\Engine\SubscriptionEngineCriteria;
+use Patchlevel\EventSourcing\Subscription\Status;
+use Symfony\Component\Console\Event\ConsoleCommandEvent;
+use Symfony\Component\HttpKernel\Event\RequestEvent;
+
+final class AutoSetupListener
+{
+    /**
+     * @param list<string>|null $ids
+     * @param list<string>|null $groups
+     */
+    public function __construct(
+        private readonly SubscriptionEngine $subscriptionEngine,
+        private readonly array|null $ids,
+        private readonly array|null $groups,
+    ) {
+    }
+
+    public function onKernelRequest(RequestEvent $event): void
+    {
+        if (!$event->isMainRequest()) {
+            return;
+        }
+
+        $this->run();
+    }
+
+    public function onConsoleCommand(ConsoleCommandEvent $event): void
+    {
+        $this->run();
+    }
+
+    private function run(): void
+    {
+        $subscriptions = $this->subscriptionEngine->subscriptions(
+            new SubscriptionEngineCriteria(
+                $this->ids,
+                $this->groups,
+            ),
+        );
+
+        $ids = [];
+
+        foreach ($subscriptions as $subscription) {
+            if ($subscription->status() !== Status::New) {
+                continue;
+            }
+
+            $ids[] = $subscription->id();
+        }
+
+        $this->subscriptionEngine->setup(
+            new SubscriptionEngineCriteria($ids),
+            true,
+        );
+    }
+}