Feat/new projecting system dx

Monorepo/ExampleAppEventSourcing/EcotoneProjection/PriceChangeOverTimeProjectionWithEcotoneProjection.php

@@ -11,7 +11,7 @@
 use Monorepo\ExampleAppEventSourcing\Common\Event\ProductWasRegistered;
 use Monorepo\ExampleAppEventSourcing\Common\PriceChange;
 
-#[\Ecotone\Projecting\Attribute\Projection("price_change_over_time", null)]
+#[\Ecotone\Projecting\Attribute\ProjectionV2("price_change_over_time")]
 class PriceChangeOverTimeProjectionWithEcotoneProjection
 {
     public const NAME = "price_change_over_time";

docker-compose.yml

@@ -55,7 +55,7 @@ services:
       POSTGRES_USER: "ecotone"
       POSTGRES_PASSWORD: "secret"
     ports:
-      - "5432:5432"
+      - "${POSTGRES_PORT:-5432}:5432"
   database-mysql:
     image: mysql:8.0
     environment:
@@ -64,7 +64,7 @@ services:
       MYSQL_PASSWORD: "secret"
       MYSQL_DATABASE: "ecotone"
     ports:
-      - "3306:3306"
+      - "${MYSQL_PORT:-3306}:3306"
   rabbitmq:
     build: ./.docker/rabbitmq
     environment:
@@ -84,7 +84,7 @@ services:
   redis:
     image: redis:7-alpine
     ports:
-      - '6379:6379'
+      - '${REDIS_PORT:-6379}:6379'
   collector:
     image: otel/opentelemetry-collector-contrib:0.73.0
     networks:

packages/Ecotone/src/Messaging/Handler/Router/RouterProcessor.php

@@ -26,7 +26,7 @@ public function process(Message $message): ?Message
             if (count($routes) === 0) {
                 return null;
             } elseif (count($routes) > 1) {
-                throw new InvalidArgumentException('Expected only one route to be selected, but got more');
+                throw new InvalidArgumentException('Expected only one endpoint to route, but got more. Please verify your Message Handlers for possible duplication.');
             }
             $path = $this->routeResolver->resolve($routes[0]);
             return $path->process($message);

packages/Ecotone/src/Messaging/Scheduling/SleepInterface.php

@@ -11,6 +11,7 @@
  */
 /**
  * licence Apache-2.0
+ * @TODO Ecotone 2.0 Think about testing delayed messages based on Clock and Sleep
  */
 interface SleepInterface
 {

packages/Ecotone/src/Projecting/Attribute/Partitioned.php

@@ -0,0 +1,25 @@
+<?php
+
+/*
+ * licence Enterprise
+ */
+declare(strict_types=1);
+
+namespace Ecotone\Projecting\Attribute;
+
+use Attribute;
+use Ecotone\Messaging\MessageHeaders;
+
+/*
+ * Allows configuring a custom partition header name for partitioned projections.
+ * For Aggregate scope, use MessageHeaders::EVENT_AGGREGATE_ID.
+ */
+#[Attribute(Attribute::TARGET_CLASS)]
+class Partitioned
+{
+    public function __construct(
+        public readonly string $partitionHeaderName = MessageHeaders::EVENT_AGGREGATE_ID,
+    ) {
+    }
+}
+

packages/Ecotone/src/Projecting/Attribute/Polling.php

@@ -0,0 +1,25 @@
+<?php
+
+/*
+ * licence Enterprise
+ */
+declare(strict_types=1);
+
+namespace Ecotone\Projecting\Attribute;
+
+use Attribute;
+
+/**
+ * Marks a projection as polling-based.
+ * When combined with ProjectionV2, the projection will be triggered by polling instead of event-driven.
+ * The endpointId is used to identify the polling endpoint.
+ */
+#[Attribute(Attribute::TARGET_CLASS)]
+class Polling
+{
+    public function __construct(
+        public readonly string $endpointId,
+    ) {
+    }
+}
+

packages/Ecotone/src/Projecting/Attribute/ProjectionConfiguration.php

@@ -0,0 +1,23 @@
+<?php
+
+/*
+ * licence Enterprise
+ */
+declare(strict_types=1);
+
+namespace Ecotone\Projecting\Attribute;
+
+use Attribute;
+
+/**
+ * This attribute allows configure additional projection configuration.
+ */
+#[Attribute(Attribute::TARGET_CLASS)]
+class ProjectionConfiguration
+{
+    public function __construct(
+        public readonly bool $automaticInitialization = true,
+    ) {
+    }
+}
+

packages/Ecotone/src/Projecting/Attribute/ProjectionV2.php

@@ -0,0 +1,25 @@
+<?php
+
+/*
+ * licence Enterprise
+ */
+declare(strict_types=1);
+
+namespace Ecotone\Projecting\Attribute;
+
+use Attribute;
+use Ecotone\Messaging\Attribute\StreamBasedSource;
+
+#[Attribute(Attribute::TARGET_CLASS)]
+class ProjectionV2 extends StreamBasedSource
+{
+    public function __construct(
+        public readonly string $name,
+    ) {
+    }
+
+    public function getName(): string
+    {
+        return $this->name;
+    }
+}

packages/Ecotone/src/Projecting/Attribute/Streaming.php

@@ -0,0 +1,25 @@
+<?php
+
+/*
+ * licence Enterprise
+ */
+declare(strict_types=1);
+
+namespace Ecotone\Projecting\Attribute;
+
+use Attribute;
+
+/**
+ * Marks a projection as event-streaming based.
+ * Event streaming projections consume events directly from streaming channels.
+ * This attribute should be combined with #[ProjectionV2] attribute.
+ */
+#[Attribute(Attribute::TARGET_CLASS)]
+class Streaming
+{
+    public function __construct(
+        public readonly string $channelName,
+    ) {
+    }
+}
+