fix projectionist config

patchlevel · Aug 5, 2023 · fd63faa · fd63faa
1 parent 535c895
commit fd63faa
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 5 deletions.
diff --git a/composer.lock b/composer.lock
diff --git a/src/DependencyInjection/PatchlevelEventSourcingExtension.php b/src/DependencyInjection/PatchlevelEventSourcingExtension.php
@@ -235,6 +235,7 @@ private function configureProjection(array $config, ContainerBuilder $container)
                 new Reference(ProjectionStore::class),
                 new Reference(ProjectorRepository::class),
                 new Reference(ProjectorResolver::class),
+                new Reference('event_dispatcher', ContainerInterface::NULL_ON_INVALID_REFERENCE),
                 new Reference(LoggerInterface::class, ContainerInterface::NULL_ON_INVALID_REFERENCE),
             ])
             ->addTag('monolog.logger', ['channel' => 'projectionist']);

diff --git a/tests/Unit/PatchlevelEventSourcingBundleTest.php b/tests/Unit/PatchlevelEventSourcingBundleTest.php
@@ -31,6 +31,8 @@
 use Patchlevel\EventSourcing\Metadata\AggregateRoot\AggregateRootRegistry;
 use Patchlevel\EventSourcing\Metadata\Event\EventRegistry;
 use Patchlevel\EventSourcing\Projection\Projectionist\RunProjectionistEventBusWrapper;
+use Patchlevel\EventSourcing\Projection\Projectionist\DefaultProjectionist;
+use Patchlevel\EventSourcing\Projection\Projectionist\Projectionist;
 use Patchlevel\EventSourcing\Repository\DefaultRepository;
 use Patchlevel\EventSourcing\Repository\DefaultRepositoryManager;
 use Patchlevel\EventSourcing\Repository\RepositoryManager;
@@ -59,6 +61,8 @@
 use Prophecy\PhpUnit\ProphecyTrait;
 use Psr\Cache\CacheItemPoolInterface;
 use Psr\Clock\ClockInterface;
+use Psr\EventDispatcher\EventDispatcherInterface;
+use Psr\Log\LoggerInterface;
 use Psr\SimpleCache\CacheInterface;
 use Symfony\Component\DependencyInjection\ContainerBuilder;
 use Symfony\Component\DependencyInjection\Definition;
@@ -652,6 +656,7 @@ public function testProjectionistSync(): void
         );
 
         self::assertInstanceOf(RunProjectionistEventBusWrapper::class, $container->get(EventBus::class));
+        self::assertInstanceOf(DefaultProjectionist::class, $container->get(Projectionist::class));
     }
 
     public function testProjectionistAsync(): void
@@ -761,6 +766,8 @@ private function compileContainer(ContainerBuilder $container, array $config): v
         $container->set('event.bus', $this->prophesize(MessageBusInterface::class)->reveal());
         $container->set('cache.default', $this->prophesize(CacheItemPoolInterface::class)->reveal());
         $container->set('lock.default.factory', $this->prophesize(LockFactory::class)->reveal());
+        $container->set('event_dispatcher', $this->prophesize(EventDispatcherInterface::class)->reveal());
+        $container->set(LoggerInterface::class, $this->prophesize(LoggerInterface::class)->reveal());
 
         $extension = new PatchlevelEventSourcingExtension();
         $extension->load($config, $container);