Merge pull request #502 from spiral/plugin/temporalv2.0.0-beta12

plugin(temporal): Add temporal plugins set to the RR2

1 files changed, 54 insertions, 0 deletions

diff --git a/tests/temporal/Workflow/SagaWorkflow.php b/tests/temporal/Workflow/SagaWorkflow.php
new file mode 100644
index 00000000..e47c0203
--- /dev/null
+++ b/tests/temporal/Workflow/SagaWorkflow.php
@@ -0,0 +1,54 @@
+<?php
+
+/**
+ * This file is part of Temporal package.
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Temporal\Tests\Workflow;
+
+use Temporal\Activity\ActivityOptions;
+use Temporal\Common\RetryOptions;
+use Temporal\Tests\Activity\SimpleActivity;
+use Temporal\Workflow;
+
+#[Workflow\WorkflowInterface]
+class SagaWorkflow
+{
+    #[Workflow\WorkflowMethod(name: 'SagaWorkflow')]
+    public function run()
+    {
+        $simple = Workflow::newActivityStub(
+            SimpleActivity::class,
+            ActivityOptions::new()
+                ->withStartToCloseTimeout(60)
+                ->withRetryOptions(RetryOptions::new()->withMaximumAttempts(1))
+        );
+
+        $saga = new Workflow\Saga();
+        $saga->setParallelCompensation(true);
+
+        try {
+            yield $simple->echo('test');
+            $saga->addCompensation(
+                function () use ($simple) {
+                    yield $simple->echo('compensate echo');
+                }
+            );
+
+            yield $simple->lower('TEST');
+            $saga->addCompensation(
+                function () use ($simple) {
+                    yield $simple->lower('COMPENSATE LOWER');
+                }
+            );
+
+            yield $simple->fail();
+        } catch (\Throwable $e) {
+            yield $saga->compensate();
+            throw $e;
+        }
+    }
+}