Scheduling the same command multiple times for multiple handlers

Author: unixslayer

packages/PdoEventSourcing/tests/Fixture/MultipleAsyncHandlersForOneMessage/ActionCalled.php

@@ -0,0 +1,12 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Test\Ecotone\EventSourcing\Fixture\MultipleAsyncHandlersForOneMessage;
+
+final class ActionCalled
+{
+    public function __construct(public string $id)
+    {
+    }
+}

packages/PdoEventSourcing/tests/Fixture/MultipleAsyncHandlersForOneMessage/ActionCommand.php

@@ -0,0 +1,12 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Test\Ecotone\EventSourcing\Fixture\MultipleAsyncHandlersForOneMessage;
+
+final class ActionCommand
+{
+    public function __construct(public string $id)
+    {
+    }
+}

packages/PdoEventSourcing/tests/Fixture/MultipleAsyncHandlersForOneMessage/EventConverter.php

@@ -0,0 +1,22 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Test\Ecotone\EventSourcing\Fixture\MultipleAsyncHandlersForOneMessage;
+
+use Ecotone\Messaging\Attribute\Converter;
+
+final class EventConverter
+{
+    #[Converter]
+    public function convertFromEvent(ActionCalled $event): array
+    {
+        return ['id' => $event->id];
+    }
+
+    #[Converter]
+    public function convertToEvent(array $payload): ActionCalled
+    {
+        return new ActionCalled($payload['id']);
+    }
+}

packages/PdoEventSourcing/tests/Fixture/MultipleAsyncHandlersForOneMessage/TestAggregate.php

@@ -0,0 +1,48 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Test\Ecotone\EventSourcing\Fixture\MultipleAsyncHandlersForOneMessage;
+
+use Ecotone\Messaging\Attribute\Asynchronous;
+use Ecotone\Modelling\Attribute\CommandHandler;
+use Ecotone\Modelling\Attribute\EventSourcingAggregate;
+use Ecotone\Modelling\Attribute\EventSourcingHandler;
+use Ecotone\Modelling\Attribute\Identifier;
+use Ecotone\Modelling\WithAggregateVersioning;
+
+#[Asynchronous('testAggregate')]
+#[EventSourcingAggregate]
+final class TestAggregate
+{
+    use WithAggregateVersioning;
+
+    #[Identifier]
+    private string $id;
+
+    private int $counter = 0;
+
+    #[CommandHandler(endpointId: 'testAggregate.staticAction')]
+    public static function staticAction(ActionCommand $command): array
+    {
+        return [new ActionCalled($command->id)];
+    }
+
+    #[CommandHandler(endpointId: 'testAggregate.action')]
+    public function action(ActionCommand $command): array
+    {
+        return [new ActionCalled($command->id)];
+    }
+
+    #[EventSourcingHandler]
+    public function applyActionCalled(ActionCalled $event): void
+    {
+        $this->id = $event->id;
+        ++$this->counter;
+    }
+
+    public function counter(): int
+    {
+        return $this->counter;
+    }
+}

packages/PdoEventSourcing/tests/Integration/MultipleAsyncHandlersForOneMessageTest.php

@@ -0,0 +1,50 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Test\Ecotone\EventSourcing\Integration;
+
+use Ecotone\Dbal\Configuration\DbalConfiguration;
+use Ecotone\Dbal\DbalBackedMessageChannelBuilder;
+use Ecotone\EventSourcing\EventSourcingConfiguration;
+use Ecotone\Lite\EcotoneLite;
+use Ecotone\Messaging\Config\ModulePackageList;
+use Ecotone\Messaging\Config\ServiceConfiguration;
+use Ecotone\Messaging\Endpoint\ExecutionPollingMetadata;
+use Enqueue\Dbal\DbalConnectionFactory;
+use Test\Ecotone\EventSourcing\EventSourcingMessagingTestCase;
+use Test\Ecotone\EventSourcing\Fixture\MultipleAsyncHandlersForOneMessage\ActionCommand;
+use Test\Ecotone\EventSourcing\Fixture\MultipleAsyncHandlersForOneMessage\EventConverter;
+use Test\Ecotone\EventSourcing\Fixture\MultipleAsyncHandlersForOneMessage\TestAggregate;
+
+final class MultipleAsyncHandlersForOneMessageTest extends EventSourcingMessagingTestCase
+{
+    public function test_handling_multiple_same_messages(): void
+    {
+        $ecotone = EcotoneLite::bootstrapFlowTestingWithEventStore(
+            classesToResolve: [TestAggregate::class, EventConverter::class],
+            containerOrAvailableServices: [
+                new EventConverter(),
+                DbalConnectionFactory::class => self::getConnectionFactory(),
+            ],
+            configuration: ServiceConfiguration::createWithDefaults()
+                ->withSkippedModulePackageNames(ModulePackageList::allPackagesExcept([ModulePackageList::EVENT_SOURCING_PACKAGE, ModulePackageList::ASYNCHRONOUS_PACKAGE]))
+                ->withNamespaces(['Test\Ecotone\Modelling\Fixture\MultipleAsyncHandlersForOneMessage'])
+                ->withExtensionObjects([
+                    DbalConfiguration::createWithDefaults(),
+                    EventSourcingConfiguration::createWithDefaults(),
+                    DbalBackedMessageChannelBuilder::create("testAggregate"),
+                ]),
+            runForProductionEventStore: true
+        );
+
+        $ecotone->sendCommand(new ActionCommand('123'));
+        $ecotone->sendCommand(new ActionCommand('123'));
+
+        $ecotone->run('testAggregate', ExecutionPollingMetadata::createWithTestingSetup());
+        self::assertEquals(1, $ecotone->getAggregate(TestAggregate::class, '123')->counter());
+
+        $ecotone->run('testAggregate', ExecutionPollingMetadata::createWithTestingSetup());
+        self::assertEquals(2, $ecotone->getAggregate(TestAggregate::class, '123')->counter());
+    }
+}