stateful event sourced workflow with multiple aggregates

Author: unixslayer

packages/PdoEventSourcing/tests/Fixture/StatefulEventSourcedWorkflowWithMultipleAggregates/AddItemToBasket.php

@@ -0,0 +1,10 @@
+<?php
+
+namespace Test\Ecotone\EventSourcing\Fixture\StatefulEventSourcedWorkflowWithMultipleAggregates;
+
+class AddItemToBasket
+{
+    public function __construct(public string $basketId, public string $itemId, public int $quantity)
+    {
+    }
+}

packages/PdoEventSourcing/tests/Fixture/StatefulEventSourcedWorkflowWithMultipleAggregates/Basket.php

@@ -0,0 +1,35 @@
+<?php
+
+namespace Test\Ecotone\EventSourcing\Fixture\StatefulEventSourcedWorkflowWithMultipleAggregates;
+
+use Ecotone\Messaging\Attribute\Parameter\Payload;
+use Ecotone\Modelling\Attribute\CommandHandler;
+use Ecotone\Modelling\Attribute\EventSourcingAggregate;
+use Ecotone\Modelling\Attribute\EventSourcingHandler;
+use Ecotone\Modelling\Attribute\Identifier;
+use Ecotone\Modelling\WithAggregateVersioning;
+use Ecotone\Modelling\WithEvents;
+
+#[EventSourcingAggregate(withInternalEventRecorder: true)]
+class Basket
+{
+    use WithEvents;
+    use WithAggregateVersioning;
+
+    #[Identifier]
+    private string $basketId;
+
+    #[CommandHandler(outputChannelName: 'itemInventory.makeReservation')]
+    public function addItemToBasket(#[Payload] AddItemToBasket $command): ItemReservation
+    {
+        $this->recordThat(new ItemWasAddedToBasket($this->basketId, $command->itemId, $command->quantity));
+
+        return new ItemReservation($command->itemId, $command->quantity);
+    }
+
+    #[EventSourcingHandler]
+    public function applyBasketCreated(BasketCreated $event): void
+    {
+        $this->basketId = $event->basketId;
+    }
+}

packages/PdoEventSourcing/tests/Fixture/StatefulEventSourcedWorkflowWithMultipleAggregates/BasketCreated.php

@@ -0,0 +1,13 @@
+<?php
+
+namespace Test\Ecotone\EventSourcing\Fixture\StatefulEventSourcedWorkflowWithMultipleAggregates;
+
+use Ecotone\Modelling\Attribute\NamedEvent;
+
+#[NamedEvent('BasketCreated')]
+class BasketCreated
+{
+    public function __construct(public string $basketId)
+    {
+    }
+}

packages/PdoEventSourcing/tests/Fixture/StatefulEventSourcedWorkflowWithMultipleAggregates/Converters.php

@@ -0,0 +1,87 @@
+<?php
+
+namespace Test\Ecotone\EventSourcing\Fixture\StatefulEventSourcedWorkflowWithMultipleAggregates;
+
+use Ecotone\Messaging\Attribute\Converter;
+
+class Converters
+{
+    #[Converter]
+    public function fromBasketCreated(BasketCreated $message): array
+    {
+        return ['basketId' => $message->basketId];
+    }
+
+    #[Converter]
+    public function toBasketCreated(array $payload): BasketCreated
+    {
+        return new BasketCreated(basketId: $payload['basketId']);
+    }
+
+    #[Converter]
+    public function fromItemInventoryCreated(ItemInventoryCreated $message): array
+    {
+        return ['itemId' => $message->itemId];
+    }
+
+    #[Converter]
+    public function toItemInventoryCreated(array $payload): ItemInventoryCreated
+    {
+        return new ItemInventoryCreated(itemId: $payload['itemId']);
+    }
+
+    #[Converter]
+    public function fromInventoryStockIncreased(InventoryStockIncreased $message): array
+    {
+        return ['itemId' => $message->itemId, 'quantity' => $message->quantity];
+    }
+
+    #[Converter]
+    public function toInventoryStockIncreased(array $payload): InventoryStockIncreased
+    {
+        return new InventoryStockIncreased(itemId: $payload['itemId'], quantity: $payload['quantity']);
+    }
+
+    #[Converter]
+    public function fromItemReserved(ItemReserved $message): array
+    {
+        return ['itemId' => $message->itemId, 'quantity' => $message->quantity];
+    }
+
+    #[Converter]
+    public function toItemReserved(array $payload): ItemReserved
+    {
+        return new ItemReserved(itemId: $payload['itemId'], quantity: $payload['quantity']);
+    }
+
+    #[Converter]
+    public function fromItemWasAddedToBasket(ItemWasAddedToBasket $message): array
+    {
+        return ['basketId' => $message->basketId, 'itemId' => $message->itemId, 'quantity' => $message->quantity];
+    }
+
+    #[Converter]
+    public function toItemWasAddedToBasket(array $payload): ItemWasAddedToBasket
+    {
+        return new ItemWasAddedToBasket(
+            basketId: $payload['basketId'],
+            itemId: $payload['itemId'],
+            quantity: $payload['quantity']
+        );
+    }
+
+    #[Converter]
+    public function fromItemReservation(ItemReservation $message): array
+    {
+        return ['itemId' => $message->itemId, 'quantity' => $message->quantity];
+    }
+
+    #[Converter]
+    public function toItemReservation(array $payload): ItemReservation
+    {
+        return new ItemReservation(
+            itemId: $payload['itemId'],
+            quantity: $payload['quantity']
+        );
+    }
+}

packages/PdoEventSourcing/tests/Fixture/StatefulEventSourcedWorkflowWithMultipleAggregates/InventoryStockIncreased.php

@@ -0,0 +1,13 @@
+<?php
+
+namespace Test\Ecotone\EventSourcing\Fixture\StatefulEventSourcedWorkflowWithMultipleAggregates;
+
+use Ecotone\Modelling\Attribute\NamedEvent;
+
+#[NamedEvent('InventoryStockIncreased')]
+class InventoryStockIncreased
+{
+    public function __construct(public string $itemId, public int $quantity)
+    {
+    }
+}

packages/PdoEventSourcing/tests/Fixture/StatefulEventSourcedWorkflowWithMultipleAggregates/ItemInventory.php

@@ -0,0 +1,41 @@
+<?php
+
+namespace Test\Ecotone\EventSourcing\Fixture\StatefulEventSourcedWorkflowWithMultipleAggregates;
+
+use Ecotone\Messaging\Attribute\Parameter\Payload;
+use Ecotone\Modelling\Attribute\CommandHandler;
+use Ecotone\Modelling\Attribute\EventSourcingAggregate;
+use Ecotone\Modelling\Attribute\EventSourcingHandler;
+use Ecotone\Modelling\Attribute\Identifier;
+use Ecotone\Modelling\WithAggregateVersioning;
+use Ecotone\Modelling\WithEvents;
+
+#[EventSourcingAggregate(withInternalEventRecorder: true)]
+class ItemInventory
+{
+    use WithEvents;
+    use WithAggregateVersioning;
+
+    #[Identifier]
+    private string $itemId;
+
+    private int $quantity = 0;
+
+    #[CommandHandler(routingKey: 'itemInventory.makeReservation')]
+    public function makeReservation(#[Payload] ItemReservation $itemReservation): void
+    {
+        $this->recordThat(new ItemReserved($this->itemId, $itemReservation->quantity));
+    }
+
+    #[EventSourcingHandler]
+    public function applyItemInventoryCreated(ItemInventoryCreated $event): void
+    {
+        $this->itemId = $event->itemId;
+    }
+
+    #[EventSourcingHandler]
+    public function applyInventoryStockIncreased(InventoryStockIncreased $event): void
+    {
+        $this->quantity += $event->quantity;
+    }
+}

packages/PdoEventSourcing/tests/Fixture/StatefulEventSourcedWorkflowWithMultipleAggregates/ItemInventoryCreated.php

@@ -0,0 +1,13 @@
+<?php
+
+namespace Test\Ecotone\EventSourcing\Fixture\StatefulEventSourcedWorkflowWithMultipleAggregates;
+
+use Ecotone\Modelling\Attribute\NamedEvent;
+
+#[NamedEvent('ItemInventoryCreated')]
+class ItemInventoryCreated
+{
+    public function __construct(public string $itemId)
+    {
+    }
+}

packages/PdoEventSourcing/tests/Fixture/StatefulEventSourcedWorkflowWithMultipleAggregates/ItemReservation.php

@@ -0,0 +1,12 @@
+<?php
+
+namespace Test\Ecotone\EventSourcing\Fixture\StatefulEventSourcedWorkflowWithMultipleAggregates;
+
+use Ecotone\Modelling\Attribute\TargetIdentifier;
+
+class ItemReservation
+{
+    public function __construct(#[TargetIdentifier] public string $itemId, public int $quantity)
+    {
+    }
+}

packages/PdoEventSourcing/tests/Fixture/StatefulEventSourcedWorkflowWithMultipleAggregates/ItemReserved.php

@@ -0,0 +1,13 @@
+<?php
+
+namespace Test\Ecotone\EventSourcing\Fixture\StatefulEventSourcedWorkflowWithMultipleAggregates;
+
+use Ecotone\Modelling\Attribute\NamedEvent;
+
+#[NamedEvent('ItemReserved')]
+class ItemReserved
+{
+    public function __construct(public string $itemId, public int $quantity)
+    {
+    }
+}

packages/PdoEventSourcing/tests/Fixture/StatefulEventSourcedWorkflowWithMultipleAggregates/ItemWasAddedToBasket.php

@@ -0,0 +1,13 @@
+<?php
+
+namespace Test\Ecotone\EventSourcing\Fixture\StatefulEventSourcedWorkflowWithMultipleAggregates;
+
+use Ecotone\Modelling\Attribute\NamedEvent;
+
+#[NamedEvent('ItemWasAddedToBasket')]
+class ItemWasAddedToBasket
+{
+    public function __construct(public string $basketId, public string $itemId, public int $quantity)
+    {
+    }
+}