feat: doctrine event handlers

composer.json

@@ -22,7 +22,7 @@
         "distantmagic/swoole-futures": "^0.1.2",
         "doctrine/dbal": "^3.7",
         "doctrine/migrations": "^3.6",
-        "doctrine/orm": "^2.16",
+        "doctrine/orm": "^3.0",
         "doctrine/sql-formatter": "^1.1",
         "ezyang/htmlpurifier": "^4.16",
         "guzzlehttp/guzzle": "^7.8",

src/Attribute/ListensToDoctrineEntityEvents.php

@@ -0,0 +1,17 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Distantmagic\Resonance\Attribute;
+
+use Attribute;
+use Distantmagic\Resonance\Attribute as BaseAttribute;
+
+#[Attribute(Attribute::TARGET_CLASS)]
+final readonly class ListensToDoctrineEntityEvents extends BaseAttribute
+{
+    /**
+     * @param class-string $className
+     */
+    public function __construct(public string $className) {}
+}

src/Attribute/ListensToDoctrineEvents.php

@@ -0,0 +1,11 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Distantmagic\Resonance\Attribute;
+
+use Attribute;
+use Distantmagic\Resonance\Attribute as BaseAttribute;
+
+#[Attribute(Attribute::TARGET_CLASS)]
+final readonly class ListensToDoctrineEvents extends BaseAttribute {}

src/DatabaseConnectionPoolConfiguration.php

@@ -12,6 +12,7 @@
      * @psalm-taint-source file $unixSocket
      *
      * @param non-empty-string      $host
+     * @param null|non-empty-string $password
      * @param null|non-empty-string $unixSocket
      * @param non-empty-string      $username
      */
@@ -25,7 +26,7 @@ public function __construct(
         #[SensitiveParameter]
         public bool $logQueries,
         #[SensitiveParameter]
-        public string $password,
+        public ?string $password,
         #[SensitiveParameter]
         public bool $poolPrefill,
         #[SensitiveParameter]

src/DoctrineConnectionRepository.php

@@ -6,6 +6,7 @@
 
 use Distantmagic\Resonance\Attribute\GrantsFeature;
 use Distantmagic\Resonance\Attribute\Singleton;
+use Doctrine\Common\EventManager;
 use Doctrine\DBAL\Configuration;
 use Doctrine\DBAL\Connection;
 use Doctrine\DBAL\Driver;
@@ -35,6 +36,7 @@ public function __construct(
         private DoctrineMySQLDriver $doctrineMySQLDriver,
         private DoctrinePostgreSQLDriver $doctrinePostgreSQLDriver,
         private DoctrineSQLiteDriver $doctrineSQLiteDriver,
+        private EventManager $eventManager,
         private LoggerInterface $logger,
     ) {
         /**
@@ -49,13 +51,14 @@ public function __construct(
     public function buildConnection(string $name = 'default'): Connection
     {
         return new Connection(
-            [
+            config: $this->configuration,
+            driver: $this->getDriver($name),
+            eventManager: $this->eventManager,
+            params: [
                 'driverOptions' => [
                     'connectionPoolName' => $name,
                 ],
             ],
-            $this->getDriver($name),
-            $this->configuration,
         );
     }
 

src/DoctrineEntityListener.php

@@ -0,0 +1,7 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Distantmagic\Resonance;
+
+abstract readonly class DoctrineEntityListener {}

src/DoctrineEntityListenerCollection.php

@@ -0,0 +1,33 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Distantmagic\Resonance;
+
+use Ds\Map;
+use Ds\Set;
+
+readonly class DoctrineEntityListenerCollection
+{
+    /**
+     * @var Map<class-string,Set<object>>
+     */
+    public Map $listeners;
+
+    public function __construct()
+    {
+        $this->listeners = new Map();
+    }
+
+    /**
+     * @param class-string $className
+     */
+    public function addEntityListener(string $className, object $listener): void
+    {
+        if (!$this->listeners->hasKey($className)) {
+            $this->listeners->put($className, new Set());
+        }
+
+        $this->listeners->get($className)->add($listener);
+    }
+}