Add all contracts for gember/event-sourcing

Author: Jeroen de Graaf

src/EventStore/Rdbms/RdbmsEvent.php

@@ -0,0 +1,35 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Gember\DependencyContracts\EventStore\Rdbms;
+
+use DateTimeImmutable;
+
+final readonly class RdbmsEvent
+{
+    /**
+     * @param list<string> $domainTags
+     * @param array<string, mixed> $metadata
+     */
+    public function __construct(
+        public string $eventId,
+        public array $domainTags,
+        public string $eventName,
+        public string $payload,
+        public array $metadata,
+        public DateTimeImmutable $appliedAt,
+    ) {}
+
+    public function withDomainTag(string $domainTag): self
+    {
+        return new self(
+            $this->eventId,
+            [...$this->domainTags, $domainTag],
+            $this->eventName,
+            $this->payload,
+            $this->metadata,
+            $this->appliedAt,
+        );
+    }
+}

src/EventStore/Rdbms/RdbmsEventStoreRepository.php

@@ -0,0 +1,29 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Gember\DependencyContracts\EventStore\Rdbms;
+
+use Stringable;
+
+interface RdbmsEventStoreRepository
+{
+    /**
+     * @param list<string|Stringable> $domainTags
+     * @param list<string> $eventNames
+     *
+     * @return list<RdbmsEvent>
+     */
+    public function getEvents(array $domainTags, array $eventNames): array;
+
+    /**
+     * @param list<string|Stringable> $domainTags
+     * @param list<string> $eventNames
+     */
+    public function getLastEventIdPersisted(array $domainTags, array $eventNames): ?string;
+
+    /**
+     * @param list<RdbmsEvent> $events
+     */
+    public function saveEvents(array $events): void;
+}

src/Util/Generator/Identity/IdentityGenerator.php

@@ -0,0 +1,10 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Gember\DependencyContracts\Util\Generator\Identity;
+
+interface IdentityGenerator
+{
+    public function generate(): string;
+}

src/Util/Messaging/MessageBus/EventBus.php

@@ -0,0 +1,13 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Gember\DependencyContracts\Util\Messaging\MessageBus;
+
+interface EventBus
+{
+    /**
+     * @throws HandlingMessageFailedException
+     */
+    public function handle(object $event): void;
+}

src/Util/Messaging/MessageBus/HandlingMessageFailedException.php

@@ -0,0 +1,19 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Gember\DependencyContracts\Util\Messaging\MessageBus;
+
+use Exception;
+use Throwable;
+
+final class HandlingMessageFailedException extends Exception
+{
+    public static function withException(Throwable $exception): self
+    {
+        return new self(
+            sprintf('Handling message failed: %s', $exception->getMessage()),
+            previous: $exception,
+        );
+    }
+}

src/Util/Serialization/Serializer/SerializationFailedException.php

@@ -0,0 +1,24 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Gember\DependencyContracts\Util\Serialization\Serializer;
+
+use Exception;
+use Throwable;
+
+class SerializationFailedException extends Exception
+{
+    public static function withMessage(string $message): self
+    {
+        return new self(sprintf('Serialization failed: %s', $message));
+    }
+
+    public static function withException(Throwable $exception): self
+    {
+        return new self(
+            sprintf('Serialization failed: %s', $exception->getMessage()),
+            previous: $exception,
+        );
+    }
+}

src/Util/Serialization/Serializer/Serializer.php

@@ -0,0 +1,20 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Gember\DependencyContracts\Util\Serialization\Serializer;
+
+interface Serializer
+{
+    /**
+     * @throws SerializationFailedException
+     */
+    public function serialize(object $object): string;
+
+    /**
+     * @param class-string $className
+     *
+     * @throws SerializationFailedException
+     */
+    public function deserialize(string $payload, string $className): object;
+}