Use dedicated connection for EventStore

in order to prevent nested transactions potentially leading to RuntimeException of

    A transaction is active already, can't commit events!

Author: bwaidelich

Neos.ContentRepositoryRegistry/Classes/Factory/EventStore/DoctrineEventStoreFactory.php

@@ -3,7 +3,8 @@
 
 namespace Neos\ContentRepositoryRegistry\Factory\EventStore;
 
-use Doctrine\DBAL\Connection;
+use Doctrine\DBAL\DriverManager;
+use Doctrine\ORM\EntityManagerInterface;
 use Neos\ContentRepository\Core\SharedModel\ContentRepository\ContentRepositoryId;
 use Neos\EventStore\DoctrineAdapter\DoctrineEventStore;
 use Neos\EventStore\EventStoreInterface;
@@ -12,15 +13,17 @@
 class DoctrineEventStoreFactory implements EventStoreFactoryInterface
 {
     public function __construct(
-        private readonly Connection $connection,
+        private readonly EntityManagerInterface $entityManager,
     ) {
     }
 
     /** @param array<string, mixed> $options */
     public function build(ContentRepositoryId $contentRepositoryId, array $options, ClockInterface $clock): EventStoreInterface
     {
+        // We create a new connection instance in order to avoid nested transactions
+        $connection = DriverManager::getConnection($this->entityManager->getConnection()->getParams(), $this->entityManager->getConfiguration(), $this->entityManager->getEventManager());
         return new DoctrineEventStore(
-            $this->connection,
+            $connection,
             self::databaseTableName($contentRepositoryId),
             $clock
         );