diff options
Diffstat (limited to 'tests')
| -rw-r--r-- | tests/composer.json | 5 | ||||
| -rw-r--r-- | tests/plugins/server/server_plugin_test.go | 2 | ||||
| -rw-r--r-- | tests/psr-worker-bench.php | 2 | ||||
| -rw-r--r-- | tests/src/Activity/SimpleActivity.php | 63 | ||||
| -rw-r--r-- | tests/src/Client/StartNewWorkflow.php | 23 | ||||
| -rw-r--r-- | tests/src/Workflow/SagaWorkflow.php | 54 |
6 files changed, 147 insertions, 2 deletions
diff --git a/tests/composer.json b/tests/composer.json index 52fa3a0e..cff9bd6b 100644 --- a/tests/composer.json +++ b/tests/composer.json @@ -7,5 +7,10 @@ "spiral/roadrunner-http": "^2.0", "temporal/sdk": ">=1.0", "spiral/tokenizer": ">=2.7" + }, + "autoload": { + "psr-4": { + "Temporal\\Tests\\": "src" + } } } diff --git a/tests/plugins/server/server_plugin_test.go b/tests/plugins/server/server_plugin_test.go index f600832a..c0c3c993 100644 --- a/tests/plugins/server/server_plugin_test.go +++ b/tests/plugins/server/server_plugin_test.go @@ -278,7 +278,7 @@ func TestAppWrongRelay(t *testing.T) { } err = container.Init() - assert.Error(t, err) + assert.NoError(t, err) _, err = container.Serve() assert.Error(t, err) diff --git a/tests/psr-worker-bench.php b/tests/psr-worker-bench.php index 3f634443..d0c72eae 100644 --- a/tests/psr-worker-bench.php +++ b/tests/psr-worker-bench.php @@ -49,7 +49,7 @@ if ($env->getMode() === 'http') { $worker->registerWorkflowTypes('Temporal\\Tests\\Workflow\\' . $name); } - // register all activity + // register all activity foreach ($getClasses(__DIR__ . '/src/Activity') as $name) { $class = 'Temporal\\Tests\\Activity\\' . $name; $worker->registerActivityImplementations(new $class); 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; + } + } +} |