DCB

Makefile

@@ -41,11 +41,11 @@ phpunit-integration: vendor
 
 .PHONY: phpunit-integration-postgres
 phpunit-integration-postgres: vendor                                            ## run phpunit integration tests on postgres
-	DB_URL="pdo-pgsql://postgres:postgres@localhost:5432/eventstore?charset=utf8" vendor/bin/phpunit --testsuite=integration
+	DB_URL="pdo-pgsql://postgres:postgres@127.0.0.1:5432/eventstore?charset=utf8" vendor/bin/phpunit --testsuite=integration
 
 .PHONY: phpunit-integration-mysql
 phpunit-integration-mysql: vendor                                               ## run phpunit integration tests on mysql
-	DB_URL="pdo-mysql://root@localhost:3306/eventstore?charset=utf8" vendor/bin/phpunit --testsuite=integration
+	DB_URL="pdo-mysql://root@127.0.0.1:3306/eventstore?charset=utf8" vendor/bin/phpunit --testsuite=integration
 
 .PHONY: phpunit-unit
 phpunit-unit: vendor                                             				## run phpunit unit tests
@@ -74,7 +74,7 @@ test: phpunit
 
 .PHONY: benchmark
 benchmark: vendor                                                               ## run benchmarks
-	DB_URL=sqlite3:///:memory: php -d memory_limit=512M vendor/bin/phpbench run tests/Benchmark --report=default
+	DB_URL=sqlite3:///:memory: php -d memory_limit=512M vendor/bin/phpbench run tests/Benchmark --report=default --filter=benchAppend100Events
 
 .PHONY: benchmark-base
 benchmark-base: vendor                                                   	## run benchmarks

docs/mkdocs.yml

@@ -101,6 +101,7 @@ nav:
     - Event Bus:  event_bus.md
     - Query Bus:  query_bus.md
   - Advanced:
+    - Dynamic Consistency Boundary: dynamic_consistency_boundary.md
     - Aggregate ID: aggregate_id.md
     - Normalizer: normalizer.md
     - Snapshots: snapshots.md

docs/pages/dynamic_consistency_boundary.md

@@ -0,0 +1,2 @@
+# Dynamic Consistency Boundary
+

src/Aggregate/AggregateRootId.php

@@ -5,11 +5,12 @@
 namespace Patchlevel\EventSourcing\Aggregate;
 
 use Patchlevel\EventSourcing\Serializer\Normalizer\IdNormalizer;
+use Patchlevel\EventSourcing\Stringable;
 
 #[IdNormalizer]
-interface AggregateRootId
+interface AggregateRootId extends Stringable
 {
     public function toString(): string;
 
-    public static function fromString(string $id): self;
+    public static function fromString(string $value): self;
 }

src/Aggregate/CustomIdBehaviour.php

@@ -11,9 +11,9 @@ public function __construct(
     ) {
     }
 
-    public static function fromString(string $id): self
+    public static function fromString(string $value): self
     {
-        return new self($id);
+        return new self($value);
     }
 
     public function toString(): string

src/Aggregate/RamseyUuidV7Behaviour.php

@@ -14,9 +14,9 @@ public function __construct(
     ) {
     }
 
-    public static function fromString(string $id): self
+    public static function fromString(string $value): self
     {
-        return new self(Uuid::fromString($id));
+        return new self(Uuid::fromString($value));
     }
 
     public function toString(): string

src/Attribute/EventTag.php

@@ -0,0 +1,17 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcing\Attribute;
+
+use Attribute;
+
+#[Attribute(Attribute::TARGET_PROPERTY)]
+final class EventTag
+{
+    public function __construct(
+        public readonly string|null $prefix = null,
+        public readonly string|null $hash = null,
+    ) {
+    }
+}

src/DCB/AttributeEventTagExtractor.php

@@ -0,0 +1,69 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcing\DCB;
+
+use Patchlevel\EventSourcing\Attribute\EventTag;
+use Patchlevel\EventSourcing\Stringable;
+use ReflectionClass;
+use RuntimeException;
+use Stringable as NativeStringable;
+
+use function array_keys;
+use function get_debug_type;
+use function hash;
+use function is_int;
+use function is_string;
+use function sprintf;
+
+/** @experimental */
+final class AttributeEventTagExtractor implements EventTagExtractor
+{
+    /** @return list<string> */
+    public function extract(object $event): array
+    {
+        $reflectionClass = new ReflectionClass($event);
+
+        $tags = [];
+
+        foreach ($reflectionClass->getProperties() as $property) {
+            $attributes = $property->getAttributes(EventTag::class);
+
+            if ($attributes === []) {
+                continue;
+            }
+
+            /** @var EventTag $attribute */
+            $attribute = $attributes[0]->newInstance();
+
+            $value = $property->getValue($event);
+
+            if ($value instanceof Stringable) {
+                $value = $value->toString();
+            }
+
+            if ($value instanceof NativeStringable || is_int($value)) {
+                $value = (string)$value;
+            }
+
+            if (!is_string($value)) {
+                throw new RuntimeException(
+                    sprintf('Event tag value must be stringable, %s given', get_debug_type($value)),
+                );
+            }
+
+            if ($attribute->hash) {
+                $value = hash($attribute->hash, $value);
+            }
+
+            if ($attribute->prefix) {
+                $value = $attribute->prefix . ':' . $value;
+            }
+
+            $tags[$value] = true;
+        }
+
+        return array_keys($tags);
+    }
+}

src/DCB/CompositeProjection.php

@@ -0,0 +1,51 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcing\DCB;
+
+use Patchlevel\EventSourcing\Message\Message;
+use Patchlevel\EventSourcing\Store\Query;
+
+use function array_map;
+
+/**
+ * @experimental
+ * @extends Projection<array<string, mixed>>
+ */
+final class CompositeProjection
+{
+    /** @param array<string, Projection> $projections */
+    public function __construct(
+        private readonly array $projections,
+    ) {
+    }
+
+    public function query(): Query
+    {
+        $query = new Query();
+
+        foreach ($this->projections as $projection) {
+            $query = $query->add($projection->subQuery());
+        }
+
+        return $query;
+    }
+
+    /** @return array<string, mixed> */
+    public function initialState(): array
+    {
+        return array_map(static function (Projection $projection) {
+            return $projection->initialState();
+        }, $this->projections);
+    }
+
+    public function apply(mixed $state, Message $message): mixed
+    {
+        foreach ($this->projections as $name => $projection) {
+            $state[$name] = $projection->apply($state[$name], $message);
+        }
+
+        return $state;
+    }
+}

src/DCB/DecisionModel.php

@@ -0,0 +1,51 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcing\DCB;
+
+use ArrayAccess;
+use LogicException;
+use OutOfBoundsException;
+use Patchlevel\EventSourcing\Store\AppendCondition;
+
+use function array_key_exists;
+
+/**
+ * @experimental
+ * @psalm-immutable
+ * @implements ArrayAccess<string, mixed>
+ */
+final class DecisionModel implements ArrayAccess
+{
+    /** @param array<string, mixed> $state */
+    public function __construct(
+        public readonly array $state,
+        public readonly AppendCondition $appendCondition,
+    ) {
+    }
+
+    public function offsetExists(mixed $offset): bool
+    {
+        return array_key_exists($offset, $this->state);
+    }
+
+    public function offsetGet(mixed $offset): mixed
+    {
+        if (!$this->offsetExists($offset)) {
+            throw new OutOfBoundsException("Offset '$offset' does not exist in the state.");
+        }
+
+        return $this->state[$offset];
+    }
+
+    public function offsetSet(mixed $offset, mixed $value): void
+    {
+        throw new LogicException('State is immutable, cannot set value.');
+    }
+
+    public function offsetUnset(mixed $offset): void
+    {
+        throw new LogicException('State is immutable, cannot unset value.');
+    }
+}

src/DCB/DecisionModelBuilder.php

@@ -0,0 +1,14 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcing\DCB;
+
+/** @experimental */
+interface DecisionModelBuilder
+{
+    /** @param array<string, Projection> $projections */
+    public function build(
+        array $projections,
+    ): DecisionModel;
+}

src/DCB/EventAppender.php

@@ -0,0 +1,18 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcing\DCB;
+
+use Patchlevel\EventSourcing\Store\AppendCondition;
+
+/** @experimental */
+interface EventAppender
+{
+    /** @param iterable<object> $events */
+    public function append(
+        iterable $events,
+        AppendCondition|null $appendCondition = null,
+        string|null $streamName = null,
+    ): void;
+}