Event store

composer.json

@@ -35,10 +35,8 @@
                 "packages/Ecotone/src/Enqueue/",
                 "packages/Enqueue/src"
             ],
-            "Ecotone\\EventSourcing\\": [
-                "packages/PdoEventSourcing/src",
-                "packages/PdoEventSourcing/src"
-            ],
+            "Ecotone\\EventSourcing\\": "packages/PdoEventSourcing/src",
+            "Ecotone\\EventSourcingV2\\": "packages/EventSourcingV2/src",
             "Ecotone\\JMSConverter\\": "packages/JmsConverter/src",
             "Ecotone\\Redis\\": "packages/Redis/src",
             "Ecotone\\Sqs\\": "packages/Sqs/src",
@@ -82,9 +80,11 @@
                 "packages/LiteApplication/tests"
             ],
             "Test\\Ecotone\\EventSourcing\\": [
-                "packages/EventSourcing/tests",
                 "packages/PdoEventSourcing/tests"
             ],
+            "Test\\Ecotone\\EventSourcingV2\\": [
+                "packages/EventSourcingV2/tests"
+            ],
             "Test\\Ecotone\\JMSConverter\\": [
                 "packages/JmsConverter/tests"
             ],
@@ -200,6 +200,7 @@
         "ecotone/jms-converter": "1.82.0",
         "ecotone/laravel": "1.82.0",
         "ecotone/pdo-event-sourcing": "1.82.0",
+        "ecotone/event-sourcing": "1.82.0",
         "ecotone/symfony-bundle": "1.82.0"
     },
     "scripts": {

docker-compose.yml

@@ -22,6 +22,7 @@ services:
       APP_DB_HOST: database-mysql
       APP_DB_PORT: 3306
       APP_DB_DRIVER: pdo_mysql
+      DATABASE_POSTGRES: pgsql://ecotone:secret@database:5432/ecotone
       DATABASE_MYSQL: mysql://ecotone:secret@database-mysql:3306/ecotone
       SQS_DSN: sqs:?key=key&secret=secret&region=us-east-1&endpoint=http://localstack:4566&version=latest
       REDIS_DSN: redis://redis:6379
@@ -50,6 +51,7 @@ services:
       APP_DB_HOST: database-mysql
       APP_DB_PORT: 3306
       APP_DB_DRIVER: pdo_mysql
+      DATABASE_POSTGRES: pgsql://ecotone:secret@database:5432/ecotone
       DATABASE_MYSQL: mysql://ecotone:secret@database-mysql:3306/ecotone
       SQS_DSN: sqs:?key=key&secret=secret&region=us-east-1&endpoint=http://localstack:4566&version=latest
       REDIS_DSN: redis://redis:6379

local-packages.json

@@ -39,6 +39,10 @@
       {
         "type": "path",
         "url": "packages/Kafka"
+      },
+      {
+        "type": "path",
+        "url": "packages/EventSourcingV2"
       }
     ]
 }

packages/Ecotone/src/AnnotationFinder/AnnotatedDefinition.php

@@ -4,6 +4,7 @@
 
 namespace Ecotone\AnnotationFinder;
 
+use Ecotone\Messaging\Handler\TypeDescriptor;
 use InvalidArgumentException;
 
 /**
@@ -155,9 +156,9 @@ public function hasClassAnnotation(string $type): bool
         return false;
     }
 
-    public function hasAnnotation(string $type): bool
+    public function hasAnnotation(string|TypeDescriptor $type): bool
     {
-        return $this->hasMethodAnnotation($type) || $this->hasClassAnnotation($type);
+        return $this->hasMethodAnnotation((string) $type) || $this->hasClassAnnotation((string) $type);
     }
 
 

packages/Ecotone/src/Messaging/Config/ModuleClassList.php

@@ -15,6 +15,7 @@
 use Ecotone\Dbal\ObjectManager\ObjectManagerModule;
 use Ecotone\Dbal\Recoverability\DbalDeadLetterModule;
 use Ecotone\EventSourcing\Config\EventSourcingModule;
+use Ecotone\EventSourcingV2\Ecotone\Config\EventSourcingV2Module;
 use Ecotone\JMSConverter\Configuration\JMSConverterConfigurationModule;
 use Ecotone\JMSConverter\Configuration\JMSDefaultSerialization;
 use Ecotone\Kafka\Configuration\KafkaModule;
@@ -138,6 +139,10 @@ class ModuleClassList
         EventSourcingModule::class,
     ];
 
+    public const EVENT_SOURCING_V2_MODULES = [
+        EventSourcingV2Module::class,
+    ];
+
     public const JMS_CONVERTER_MODULES = [
         JMSConverterConfigurationModule::class,
         JMSDefaultSerialization::class,

packages/Ecotone/src/Messaging/Config/ModulePackageList.php

@@ -17,6 +17,7 @@ final class ModulePackageList
     public const SQS_PACKAGE = 'sqs';
     public const KAFKA_PACKAGE = 'kafka';
     public const EVENT_SOURCING_PACKAGE = 'eventSourcing';
+    public const EVENT_SOURCING_V2_PACKAGE = 'eventSourcingV2';
     public const JMS_CONVERTER_PACKAGE = 'jmsConverter';
     public const TRACING_PACKAGE = 'tracing';
     public const LARAVEL_PACKAGE = 'laravel';
@@ -34,6 +35,7 @@ public static function getModuleClassesForPackage(string $packageName): array
             ModulePackageList::SQS_PACKAGE => ModuleClassList::SQS_MODULES,
             ModulePackageList::KAFKA_PACKAGE => ModuleClassList::KAFKA_MODULES,
             ModulePackageList::EVENT_SOURCING_PACKAGE => ModuleClassList::EVENT_SOURCING_MODULES,
+            ModulePackageList::EVENT_SOURCING_V2_PACKAGE => ModuleClassList::EVENT_SOURCING_V2_MODULES,
             ModulePackageList::JMS_CONVERTER_PACKAGE => ModuleClassList::JMS_CONVERTER_MODULES,
             ModulePackageList::TRACING_PACKAGE => ModuleClassList::TRACING_MODULES,
             ModulePackageList::TEST_PACKAGE => ModuleClassList::TEST_MODULES,
@@ -57,6 +59,7 @@ public static function allPackages(): array
             self::KAFKA_PACKAGE,
             self::DBAL_PACKAGE,
             self::EVENT_SOURCING_PACKAGE,
+            self::EVENT_SOURCING_V2_PACKAGE,
             self::JMS_CONVERTER_PACKAGE,
             self::TRACING_PACKAGE,
             self::LARAVEL_PACKAGE,

packages/Ecotone/src/Modelling/AggregateFlow/CallAggregate/CallAggregateServiceBuilder.php

@@ -72,7 +72,7 @@ private function initialize(ClassDefinition $aggregateClassDefinition, string $m
         $this->interfaceToCall = $interfaceToCall;
         $isFactoryMethod = $this->interfaceToCall->isFactoryMethod();
         if (! $this->isEventSourced && $isFactoryMethod) {
-            Assert::isTrue($this->interfaceToCall->getReturnType()->isClassNotInterface(), "Factory method {$this->interfaceToCall} for standard aggregate should return object. Did you wanted to register Event Sourced Aggregate?");
+//            Assert::isTrue($this->interfaceToCall->getReturnType()->isClassNotInterface(), "Factory method {$this->interfaceToCall} for standard aggregate should return object. Did you wanted to register Event Sourced Aggregate?");
         }
     }
 

packages/EventSourcingV2/.gitattributes

@@ -0,0 +1,7 @@
+tests/          export-ignore
+.coveralls.yml  export-ignore
+.gitattributes  export-ignore
+.gitignore      export-ignore
+behat.yaml      export-ignore
+phpstan.neon    export-ignore
+phpunit.xml     export-ignore

packages/EventSourcingV2/.github/FUNDING.yml

@@ -0,0 +1,12 @@
+# These are supported funding model platforms
+
+github: [dgafka]
+patreon: # Replace with a single Open Collective username
+open_collective: # Replace with a single Open Collective username
+ko_fi: # Replace with a single Ko-fi username
+tidelift: # Replace with a single Tidelift platform-name/package-name e.g., npm/babel
+community_bridge: # Replace with a single Community Bridge project-name e.g., cloud-foundry
+liberapay: # Replace with a single Liberapay username
+issuehunt: # Replace with a single IssueHunt username
+otechie: # Replace with a single Otechie username
+custom: # Replace with up to 4 custom sponsorship URLs e.g., ['link1', 'link2']

packages/EventSourcingV2/.github/ISSUE_TEMPLATE/bug_report.md

@@ -0,0 +1,10 @@
+---
+name: This is Read-Only repository
+about: Report at ecotoneframework/ecotone-dev
+title: ''
+labels: ''
+assignees: ''
+
+---
+
+Report issue at [ecotone-dev](ecotoneframework/ecotone-dev)

packages/EventSourcingV2/.gitignore

@@ -0,0 +1,9 @@
+.idea/
+vendor/
+bin/
+tests/coverage
+!tests/coverage/.gitkeep
+file
+.phpunit.result.cache
+composer.lock
+phpunit.xml

packages/EventSourcingV2/LICENSE

@@ -0,0 +1,21 @@
+Copyright (c) 2024 Dariusz Gafka <[email protected]>
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+   http://www.apache.org/licenses/LICENSE-2.0
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
+THE SOFTWARE.
+
+**Scope of the License**
+
+Apache-2.0 Licence applies to non Enterprise Functionalities of the Ecotone Framework.
+Functionalities of the Ecotone Framework referred to as Enterprise functionalities, are not covered under the Apache-2.0 license. These functionalities are provided under a separate Enterprise License.
+For details on the Enterprise License, please write to [email protected].

packages/EventSourcingV2/README.md

@@ -0,0 +1,50 @@
+# This is Read Only Repository
+To contribute make use of [Ecotone-Dev repository](https://github.com/ecotoneframework/ecotone-dev).
+
+<p align="left"><a href="https://ecotone.tech" target="_blank">
+    <img src="https://github.com/ecotoneframework/ecotone-dev/blob/main/ecotone_small.png?raw=true">
+</a></p>
+
+![Github Actions](https://github.com/ecotoneFramework/ecotone-dev/actions/workflows/split-testing.yml/badge.svg)
+[![Latest Stable Version](https://poser.pugx.org/ecotone/ecotone/v/stable)](https://packagist.org/packages/ecotone/ecotone)
+[![License](https://poser.pugx.org/ecotone/ecotone/license)](https://packagist.org/packages/ecotone/ecotone)
+[![Total Downloads](https://img.shields.io/packagist/dt/ecotone/ecotone)](https://packagist.org/packages/ecotone/ecotone)
+[![PHP Version Require](https://img.shields.io/packagist/dependency-v/ecotone/ecotone/php.svg)](https://packagist.org/packages/ecotone/ecotone)
+
+`Ecotone Framework` is a `Service Bus` which enables `Message-Driven` architecture in `PHP`.  
+Based on  resilient Message-Driven principles provides support for building applications that follows `Domain-Driven Design` (DDD), `Command Query Responsibility Segregation` (CQRS) and `Event Sourcing` (ES).
+
+> The term "Ecotone", in ecology means transition area between ecosystems, such as forest and grassland.  
+The Ecotone Framework functions as transition area between your components, modules and services. It glues things together, yet respects the boundaries of each area.
+
+> Ecotone can be used with [Symfony](https://docs.ecotone.tech/modules/symfony-ddd-cqrs-event-sourcing) and [Laravel](https://docs.ecotone.tech/modules/laravel-ddd-cqrs-event-sourcing) frameworks.
+
+## Getting started
+
+The quickstart [page](https://docs.ecotone.tech/quick-start) of the
+[reference guide](https://docs.ecotone.tech) provides a starting point for using Ecotone.  
+Read more on the [Ecotone's Blog](https://blog.ecotone.tech).
+
+## Feature requests and issue reporting
+
+Use [issue tracking system](https://github.com/ecotoneframework/ecotone-dev/issues) for new feature request and bugs. 
+Please verify that it's not already reported by someone else.
+
+## Contact
+
+If you want to talk or ask question about Ecotone
+
+- [**Twitter**](https://twitter.com/EcotonePHP)
+- **[email protected]**
+- [**Community Channel**](https://discord.gg/CctGMcrYnV)
+
+## Support Ecotone
+
+If you want to help building and improving Ecotone consider becoming a sponsor:
+
+- [Sponsor Ecotone](https://github.com/sponsors/dgafka)
+- [Contribute to Ecotone](https://github.com/ecotoneframework/ecotone-dev).
+
+## Tags
+
+PHP DDD CQRS Event Sourcing Symfony Laravel Service Bus

packages/EventSourcingV2/composer.json

@@ -0,0 +1,83 @@
+{
+    "name": "ecotone/event-sourcing",
+    "license": [
+        "Apache-2.0",
+        "proprietary"
+    ],
+    "homepage": "https://docs.ecotone.tech/",
+    "forum": "https://discord.gg/CctGMcrYnV",
+    "type": "library",
+    "minimum-stability": "dev",
+    "prefer-stable": true,
+    "authors": [
+        {
+            "name": "Jean de La Bédoyère"
+        }
+    ],
+    "keywords": ["ecotone", "EventSourcingV2"],
+    "description": "Extends Ecotone with EventSourcingV2 integration",
+    "autoload": {
+        "psr-4": {
+            "Ecotone\\EventSourcingV2\\": "src"
+        }
+    },
+    "autoload-dev": {
+        "psr-4": {
+            "Test\\Ecotone\\EventSourcingV2\\": [
+                "tests"
+            ]
+        }
+    },
+    "require": {
+        "ecotone/ecotone": "^1.62"
+    },
+    "require-dev": {
+        "ext-pdo": "*",
+        "ext-pdo_pgsql": "*",
+        "doctrine/dbal": "^3.0",
+        "phpunit/phpunit": "^9.5",
+        "phpstan/phpstan": "^1.8",
+        "psr/container": "^2.0",
+        "symfony/event-dispatcher": "^7.2",
+        "symfony/process": "^7.2",
+        "symfony/console": "^7.2",
+        "wikimedia/composer-merge-plugin": "^2.1"
+    },
+    "scripts": {
+        "tests:phpstan": "vendor/bin/phpstan",
+        "tests:phpunit": "vendor/bin/phpunit",
+        "tests:ci": [
+            "@tests:phpstan",
+            "@tests:phpunit"
+        ]
+    },
+    "extra": {
+        "branch-alias": {
+            "dev-main": "1.62-dev"
+        },
+        "ecotone": {
+            "repository": "EventSourcingV2"
+        },
+        "merge-plugin": {
+            "include": [
+                "../local_packages.json"
+            ]
+        },
+        "license-info": {
+            "Apache-2.0": {
+                "name": "Apache License 2.0",
+                "url": "https://github.com/ecotoneframework/ecotone-dev/blob/main/LICENSE",
+                "description": "Allows to use non Enterprise features of Ecotone. For more information please write to [email protected]"
+            },
+            "proprietary": {
+                "name": "Enterprise License",
+                "description": "Allows to use Enterprise features of Ecotone. For more information please write to [email protected]"
+            }
+        }
+    },
+    "config": {
+        "allow-plugins": {
+            "wikimedia/composer-merge-plugin": true
+        }
+    }
+}

packages/EventSourcingV2/phpstan.neon

@@ -0,0 +1,4 @@
+parameters:
+	level: 1
+	paths:
+		- src

packages/EventSourcingV2/phpunit.xml.dist

@@ -0,0 +1,20 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<phpunit
+        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+        xsi:noNamespaceSchemaLocation="https://schema.phpunit.de/9.5/phpunit.xsd"
+        backupGlobals="true"
+>
+    <coverage processUncoveredFiles="true">
+        <include>
+            <directory suffix=".php">./src</directory>
+        </include>
+        <report>
+            <text outputFile="php://stdout" showOnlySummary="true" />
+        </report>
+    </coverage>
+    <testsuites>
+        <testsuite name="Unit Tests">
+            <directory>tests</directory>
+        </testsuite>
+    </testsuites>
+</phpunit>

packages/EventSourcingV2/src/Ecotone/Attribute/EventSourced.php

@@ -0,0 +1,16 @@
+<?php
+/*
+ * licence Apache-2.0
+ */
+declare(strict_types=1);
+
+namespace Ecotone\EventSourcingV2\Ecotone\Attribute;
+
+#[\Attribute]
+class EventSourced
+{
+    public function __construct(
+        public readonly string $name
+    ) {
+    }
+}

packages/EventSourcingV2/src/Ecotone/Attribute/EventSourcingHandler.php

@@ -0,0 +1,12 @@
+<?php
+/*
+ * licence Apache-2.0
+ */
+declare(strict_types=1);
+
+namespace Ecotone\EventSourcingV2\Ecotone\Attribute;
+
+#[\Attribute]
+class EventSourcingHandler
+{
+}