3 files changed, 140 insertions, 0 deletions
diff --git a/tests/src/Activity/SimpleActivity.php b/tests/src/Activity/SimpleActivity.php
new file mode 100644
index 00000000..576b126e
--- /dev/null
+++ b/tests/src/Activity/SimpleActivity.php
@@ -0,0 +1,63 @@
+<?php
+
+namespace Temporal\Tests\Activity;
+
+use Temporal\Activity\ActivityInterface;
+use Temporal\Activity\ActivityMethod;
+use Temporal\Api\Common\V1\WorkflowExecution;
+use Temporal\DataConverter\Bytes;
+use Temporal\Tests\DTO\Message;
+use Temporal\Tests\DTO\User;
+
+#[ActivityInterface(prefix: "SimpleActivity.")]
+class SimpleActivity
+{
+    #[ActivityMethod]
+    public function echo(
+        string $input
+    ): string {
+        return strtoupper($input);
+    }
+
+    #[ActivityMethod]
+    public function lower(
+        string $input
+    ): string {
+        return strtolower($input);
+    }
+
+    #[ActivityMethod]
+    public function greet(
+        User $user
+    ): Message {
+        return new Message(sprintf("Hello %s <%s>", $user->name, $user->email));
+    }
+
+    #[ActivityMethod]
+    public function slow(
+        string $input
+    ): string {
+        sleep(2);
+
+        return strtolower($input);
+    }
+
+    #[ActivityMethod]
+    public function sha512(
+        Bytes $input
+    ): string {
+        return hash("sha512", ($input->getData()));
+    }
+
+    public function updateRunID(WorkflowExecution $e): WorkflowExecution
+    {
+        $e->setRunId('updated');
+        return $e;
+    }
+
+    #[ActivityMethod]
+    public function fail()
+    {
+        throw new \Error("failed activity");
+    }
+}
+\ No newline at end of file
diff --git a/tests/src/Client/StartNewWorkflow.php b/tests/src/Client/StartNewWorkflow.php
new file mode 100644
index 00000000..67bc1d01
--- /dev/null
+++ b/tests/src/Client/StartNewWorkflow.php
@@ -0,0 +1,23 @@
+<?php
+
+
+namespace Temporal\Tests\Client;
+
+use Temporal\Client;
+use Temporal\Tests\Workflow\SimpleDTOWorkflow;
+
+use function Symfony\Component\String\s;
+
+class StartNewWorkflow
+{
+    private $stub;
+
+    public function __construct(Client\ClientInterface $client)
+    {
+        $this->stub = $client->newWorkflowStub(SimpleDTOWorkflow::class);
+    }
+
+    public function __invoke()
+    {
+    }
+}
diff --git a/tests/src/Workflow/SagaWorkflow.php b/tests/src/Workflow/SagaWorkflow.php
new file mode 100644
index 00000000..e47c0203
--- /dev/null
+++ b/tests/src/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;
+        }
+    }
+}