PoC

Author: DanielBadura

src/Container/Configuration.php

@@ -53,14 +53,13 @@
  */
 final class Configuration
 {
-    public const STORE_DBAL_AGGREGATE = 'dbal_aggregate';
     public const STORE_DBAL_STREAM = 'dbal_stream';
     public const STORE_IN_MEMORY = 'in_memory';
     public const STORE_CUSTOM = 'custom';
 
     public const EVENT_BUS_DEFAULT = 'default';
+    public const EVENT_BUS_PSR14 = 'psr14';
     public const EVENT_BUS_CUSTOM = 'custom';
-    public const EVENT_BUS_NONE = 'none';
 
     public const COMMAND_BUS_DEFAULT = 'default';
     public const COMMAND_BUS_CUSTOM = 'custom';
@@ -156,6 +155,7 @@ final class Configuration
 
     public string $storeType = self::STORE_IN_MEMORY;
     public bool $readOnlyStore = false;
+    public bool $eventBusEnabled = false;
     public string $eventBusType = self::EVENT_BUS_DEFAULT;
     public string|null $connectionService = null;
     public string|null $storeService = null;
@@ -221,6 +221,9 @@ final class Configuration
 
     /** @var array<Guesser> */
     public array $guesser = [];
+    public string|null $connectionUrl = null;
+    public bool $dedicatedProjectionConnection = false;
+    public bool $subscriptionRunAfterAggregateSaveEnabled = false;
 
     public function withAggregates(string ...$aggregates): self
     {
@@ -264,16 +267,44 @@ public function withService(string $id, object $service): self
     }
 
     /** @param StoreOptions $options */
-    public function withStore(string $type, array $options = [], bool $readOnly = false): self
+    public function withStreamStore(array $options = [], bool $readOnly = false): self
     {
         $newConfiguration = clone $this;
-        $newConfiguration->storeType = $type;
+        $newConfiguration->storeType = self::STORE_DBAL_STREAM;
         $newConfiguration->storeOptions = $options;
         $newConfiguration->readOnlyStore = $readOnly;
 
         return $newConfiguration;
     }
 
+    /** @param StoreOptions $options */
+    public function withInMemoryStore(array $options = []): self
+    {
+        $newConfiguration = clone $this;
+        $newConfiguration->storeType = self::STORE_IN_MEMORY;
+        $newConfiguration->storeOptions = $options;
+
+        return $newConfiguration;
+    }
+
+    /** @param StoreOptions $options */
+    public function withCustomStore(string $store): self
+    {
+        $newConfiguration = clone $this;
+        $newConfiguration->storeType = self::STORE_CUSTOM;
+        $newConfiguration->storeService = $store;
+
+        return $newConfiguration;
+    }
+
+    public function withConnectionUrl(string $url): self
+    {
+        $newConfiguration = clone $this;
+        $newConfiguration->connectionUrl = $url;
+
+        return $newConfiguration;
+    }
+
     public function withConnectionService(string|null $connectionService): self
     {
         $newConfiguration = clone $this;
@@ -282,6 +313,14 @@ public function withConnectionService(string|null $connectionService): self
         return $newConfiguration;
     }
 
+    public function withDedicatedProjectionConnection(): self
+    {
+        $newConfiguration = clone $this;
+        $newConfiguration->dedicatedProjectionConnection = true;
+
+        return $newConfiguration;
+    }
+
     public function withStoreService(string|null $storeService): self
     {
         $newConfiguration = clone $this;
@@ -293,6 +332,7 @@ public function withStoreService(string|null $storeService): self
     public function withEventBus(string $type = self::EVENT_BUS_DEFAULT): self
     {
         $newConfiguration = clone $this;
+        $newConfiguration->eventBusEnabled = true;
         $newConfiguration->eventBusType = $type;
 
         return $newConfiguration;
@@ -387,9 +427,7 @@ public function withSnapshotAdapters(array $snapshotAdapters): self
         return $newConfiguration;
     }
 
-    /**
-     * @param array<Guesser> $guesser
-     */
+    /** @param array<Guesser> $guesser */
     public function withLegacyHydrator(array $guesser = []): self
     {
         $newConfiguration = clone $this;
@@ -399,7 +437,6 @@ public function withLegacyHydrator(array $guesser = []): self
         return $newConfiguration;
     }
 
-
     public function withLazyHydrator(bool $hydratorDefaultLazy): self
     {
         $newConfiguration = clone $this;
@@ -480,11 +517,6 @@ public function withCommandBus(string $type = self::COMMAND_BUS_DEFAULT): self
         return $newConfiguration;
     }
 
-    public function withoutCommandBus(): self
-    {
-        return $this->withCommandBus(self::COMMAND_BUS_NONE);
-    }
-
     public function withCommandBusService(string|null $commandBusService): self
     {
         $newConfiguration = clone $this;
@@ -683,6 +715,7 @@ public function withRunSubscriptionsAfterAggregateSave(
         int|null $limit = null,
     ): self {
         $newConfiguration = clone $this;
+        $newConfiguration->subscriptionRunAfterAggregateSaveEnabled = true;
         $newConfiguration->subscriptionRunAfterAggregateSaveIds = $ids;
         $newConfiguration->subscriptionRunAfterAggregateSaveGroups = $groups;
         $newConfiguration->subscriptionRunAfterAggregateSaveLimit = $limit;
@@ -692,12 +725,11 @@ public function withRunSubscriptionsAfterAggregateSave(
 
     /** @param list<int> $retriesInMs */
     public function withSubscriptionGapDetection(
-        bool $enabled = true,
         array $retriesInMs = [0, 5, 50, 500],
         DateInterval|null $detectionWindow = null,
     ): self {
         $newConfiguration = clone $this;
-        $newConfiguration->subscriptionGapDetection = $enabled;
+        $newConfiguration->subscriptionGapDetection = true;
         $newConfiguration->subscriptionGapDetectionRetriesInMs = $retriesInMs;
         $newConfiguration->subscriptionGapDetectionWindow = $detectionWindow;
 

src/Container/Container.php

@@ -8,6 +8,7 @@
 use Throwable;
 
 use function array_key_exists;
+use function is_callable;
 use function sprintf;
 
 /**
@@ -33,11 +34,11 @@ public function __construct(
     }
 
     /**
-     * @template T object
-     *
      * @param string|class-string<T> $id
      *
      * @return ($id is class-string<T> ? T : object)
+     *
+     * @template T object
      */
     public function get(string $id): mixed
     {