summaryrefslogtreecommitdiff
path: root/tests/src
diff options
context:
space:
mode:
Diffstat (limited to 'tests/src')
-rw-r--r--tests/src/Activity/SimpleActivity.php63
-rw-r--r--tests/src/Client/StartNewWorkflow.php23
-rw-r--r--tests/src/Workflow/SagaWorkflow.php54
3 files changed, 0 insertions, 140 deletions
diff --git a/tests/src/Activity/SimpleActivity.php b/tests/src/Activity/SimpleActivity.php
deleted file mode 100644
index 576b126e..00000000
--- a/tests/src/Activity/SimpleActivity.php
+++ /dev/null
@@ -1,63 +0,0 @@
-<?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
deleted file mode 100644
index 67bc1d01..00000000
--- a/tests/src/Client/StartNewWorkflow.php
+++ /dev/null
@@ -1,23 +0,0 @@
-<?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
deleted file mode 100644
index e47c0203..00000000
--- a/tests/src/Workflow/SagaWorkflow.php
+++ /dev/null
@@ -1,54 +0,0 @@
-<?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;
- }
- }
-}