Release 1.219.0

Author: dgafka

BuildingBlocks/src/Infrastructure/MessagingConfiguration.php

@@ -16,7 +16,7 @@ public function enableDocumentStoreAggregates()
         /** This also works for state-stored sagas */
         return DbalConfiguration::createWithDefaults()
             ->withDocumentStore(
-                enableDocumentStoreAggregateRepository: true
+                enableDocumentStoreStandardRepository: true,
             );
     }
 

ErrorHandling/src/Infrastructure/EcotoneConfiguration.php

@@ -30,7 +30,7 @@ public function retryConfiguration(): ErrorHandlerConfiguration
     public function aggregateRepository(): DbalConfiguration
     {
         return DbalConfiguration::createWithDefaults()
-                ->withDocumentStore(enableDocumentStoreAggregateRepository: true);
+                ->withDocumentStore(enableDocumentStoreStandardRepository: true,);
     }
 
     #[ServiceContext]

MicroservicesAdvanced/CustomerService/src/Infrastructure/EcotoneConfiguration.php

@@ -28,7 +28,7 @@ public function asynchronous_messages()
     public function documentStoreRepository()
     {
         return DbalConfiguration::createWithDefaults()
-            ->withDocumentStore(enableDocumentStoreAggregateRepository: true);
+            ->withDocumentStore(enableDocumentStoreStandardRepository: true,);
     }
 
     #[ServiceContext]

MultiTenant/General/HookIntoTenantSwitch/src/Configuration/EcotoneConfiguration.php

@@ -26,7 +26,7 @@ public function getMultiTenantConfiguration(): MultiTenantConfiguration
     public function getDbalConfiguration(): DbalConfiguration
     {
         return DbalConfiguration::createWithDefaults()
-                    ->withDocumentStore(enableDocumentStoreAggregateRepository: true);
+                    ->withDocumentStore(enableDocumentStoreStandardRepository: true);
     }
 
 }

OutboxPattern/src/Infrastructure/Configuration.php

@@ -44,6 +44,6 @@ public function consumerDefinition()
     public function enableDocumentStoreRepository()
     {
         return DbalConfiguration::createWithDefaults()
-                ->withDocumentStore(enableDocumentStoreAggregateRepository: true);
+                ->withDocumentStore(enableDocumentStoreStandardRepository: true);
     }
 }

Testing/src/Infrastructure/MessagingConfiguration.php

@@ -22,6 +22,6 @@ public function registerInMemoryPollableChannel() : MessageChannelBuilder
     #[ServiceContext]
     public function registerDocumentStoreRepository(): DbalConfiguration
     {
-        return DbalConfiguration::createWithDefaults()->withDocumentStore(enableDocumentStoreAggregateRepository: true);
+        return DbalConfiguration::createWithDefaults()->withDocumentStore(enableDocumentStoreStandardRepository: true);
     }
 }

Testing/tests/Unit/Domain/Verification/VerificationProcessTest.php

@@ -104,9 +104,9 @@ private function bootstrapFlowTesting(StubTokenGenerator $tokenGenerator): \Ecot
                 ->withExtensionObjects([
                     SimpleMessageChannelBuilder::createQueueChannel(MessagingConfiguration::ASYNCHRONOUS_MESSAGES, true),
                     PollingMetadata::create(MessagingConfiguration::ASYNCHRONOUS_MESSAGES)->withTestingSetup(),
-                    /** We don't want command bus to fail, when command handler is not found, as we want to assert if commands were sent */
-                    TestConfiguration::createWithDefaults()->withFailOnCommandHandlerNotFound(false)
                 ]),
+            /** We don't want command bus to fail, when command handler is not found, as we want to assert if commands were sent */
+            testConfiguration: TestConfiguration::createWithDefaults()->withFailOnCommandHandlerNotFound(false)
         );
     }
 }

Workflows/.gitignore

@@ -0,0 +1,3 @@
+ecotone_logo_resized.png
+S3Storage
+!S3Storage/README.md

Workflows/AsynchronousStateless/README.md

@@ -0,0 +1,11 @@
+# Asynchronous Stateless Workflows
+
+This is example of Workflow which is asynchronous and stateless.     
+All the steps are executed in defined order.
+
+# Example 
+
+In this example we will simulate validating image format, resizing it and then uploading to external storage.  
+The workflow consists of three steps: `validate`, `resize` and `upload`.  
+We want to execute `validate` step synchronously to stop the action directly if file is not valid.  
+Then `resize` and `upload` steps will be done asynchronously together.

Workflows/AsynchronousStateless/composer.json

@@ -0,0 +1,44 @@
+{
+    "type": "ecotone-quickstart",
+    "license": "MIT",
+    "authors": [
+        {
+            "name": "Dariusz Gafka",
+            "email": "[email protected]"
+        }
+    ],
+    "autoload": {
+        "psr-4": {
+            "App\\Workflow\\": "src"
+        }
+    },
+    "autoload-dev": {
+        "psr-4": {
+            "Tests\\App\\Workflow\\": "tests"
+        }
+    },
+    "require": {
+        "ecotone/lite-dbal-starter": "^1.0.1",
+        "intervention/image": "^3.5.1"
+    },
+    "require-dev": {
+        "phpunit/phpunit": "^9.5",
+        "doctrine/orm": "^2.0|^3.0",
+        "wikimedia/composer-merge-plugin": "^2.0"
+    },
+    "minimum-stability": "dev",
+    "prefer-stable": true,
+    "config": {
+        "sort-packages": true,
+        "allow-plugins": {
+            "wikimedia/composer-merge-plugin": true
+        }
+    },
+    "extra": {
+        "merge-plugin": {
+            "include": [
+                "../../../packages/local_packages.json"
+            ]
+        }
+    }
+}