From bd500ecfc7a1ee3de813a4d944380650189a23ab Mon Sep 17 00:00:00 2001 From: Dmitriy Derepko Date: Thu, 26 Feb 2026 20:02:19 +0400 Subject: [PATCH] test: use absolute namespaces --- .../Extra/Activity/ActivityInfoTest.php | 9 ++- .../Extra/Activity/ActivityMethodTest.php | 8 +-- .../Extra/Activity/ActivityPausedTest.php | 9 ++- .../Extra/Client/WorkflowClientTest.php | 3 +- .../Extra/Interceptors/ContextTest.php | 17 +++-- .../Extra/Stability/DestroyableTest.php | 3 +- .../DynamicSignalWithPromisesTest.php | 3 +- .../Extra/Stability/ResetWorkerTest.php | 9 ++- .../Extra/Update/DynamicUpdateTest.php | 3 +- tests/Acceptance/Extra/Update/TimeoutTest.php | 3 +- .../Extra/Update/UntypedStubTest.php | 20 +++--- .../Extra/Update/UpdateWithStartTest.php | 9 ++- .../Workflow/AllHandlersFinishedTest.php | 13 ++-- .../Workflow/BuiltInPrefixedHandlersTest.php | 10 +-- .../Extra/Workflow/ChildWorkflowIdTest.php | 8 ++- .../Extra/Workflow/FallbackHandlersTest.php | 10 +-- .../Acceptance/Extra/Workflow/LoggerTest.php | 11 ++-- tests/Acceptance/Extra/Workflow/MemoTest.php | 6 +- .../Extra/Workflow/MutexRunLockedTest.php | 17 +++-- .../Extra/Workflow/MutexYieldTest.php | 15 +++-- .../Extra/Workflow/PriorityTest.php | 14 ++-- .../Extra/Workflow/SearchAttributesTest.php | 6 +- .../Workflow/TypedSearchAttributesTest.php | 6 +- .../Extra/Workflow/UserMetadataTest.php | 16 +++-- .../Extra/Workflow/WorkflowMetadataTest.php | 6 +- .../Workflow/WorkflowSearchAttributesTest.php | 2 +- .../Harness/Activity/CancelTryCancelTest.php | 6 +- .../ChildWorkflow/CancelAbandonTest.php | 15 +++-- .../Harness/ChildWorkflow/SignalTest.php | 3 +- .../Harness/Signal/ChildWorkflowTest.php | 3 +- .../Harness/Update/ActivitiesTest.php | 3 +- .../Harness/Update/AsyncAcceptTest.php | 8 ++- .../Harness/Update/BasicAsyncTest.php | 6 +- tests/Acceptance/Harness/Update/BasicTest.php | 3 +- .../Harness/Update/ClientInterceptorTest.php | 3 +- .../Acceptance/Harness/Update/ContextTest.php | 5 +- .../Harness/Update/DeduplicationTest.php | 6 +- .../Harness/Update/NonDurableRejectTest.php | 6 +- tests/Acceptance/Harness/Update/SelfTest.php | 3 +- .../Harness/Update/TaskFailureTest.php | 8 ++- .../Harness/Update/ValidationReplayTest.php | 6 +- .../Harness/Update/WorkerRestartTest.php | 3 +- .../src/Activity/JustLocalActivity.php | 14 ++-- .../Workflow/ActivityReturnTypeWorkflow.php | 3 +- .../src/Workflow/ActivityStubWorkflow.php | 3 +- .../src/Workflow/ArrayOfObjectsWorkflow.php | 3 +- .../src/Workflow/AsyncActivityWorkflow.php | 3 +- .../src/Workflow/AsyncClosureWorkflow.php | 3 +- .../AwaitWithSingleTimeoutWorkflow.php | 3 +- .../src/Workflow/AwaitWithTimeoutWorkflow.php | 3 +- .../src/Workflow/AwaitsUpdateWorkflow.php | 20 +++--- .../Fixtures/src/Workflow/BinaryWorkflow.php | 3 +- .../Workflow/CancelSignaledChildWorkflow.php | 6 +- .../Workflow/CancelSignalledChildWorkflow.php | 6 +- .../Workflow/CanceledHeartbeatWorkflow.php | 3 +- .../Workflow/CancelledMidflightWorkflow.php | 6 +- .../src/Workflow/CancelledNestedWorkflow.php | 6 +- .../src/Workflow/CancelledScopeWorkflow.php | 3 +- .../Workflow/CancelledSingleScopeWorkflow.php | 6 +- .../CancelledWithCompensationWorkflow.php | 6 +- .../src/Workflow/CancelledWorkflow.php | 3 +- .../Fixtures/src/Workflow/Case335Workflow.php | 3 +- .../Fixtures/src/Workflow/ChainedWorkflow.php | 3 +- .../src/Workflow/ChildStubWorkflow.php | 6 +- .../Workflow/ComplexExceptionalWorkflow.php | 6 +- .../ContinuaWithTaskQueueWorkflow.php | 3 +- .../src/Workflow/ContinuableWorkflow.php | 3 +- .../src/Workflow/DetachedScopeWorkflow.php | 3 +- .../Workflow/DynamicObjectReturnWorkflow.php | 3 +- tests/Fixtures/src/Workflow/EmptyWorkflow.php | 4 +- .../Fixtures/src/Workflow/EnumDtoWorkflow.php | 3 +- .../Workflow/ExceptionalActivityWorkflow.php | 3 +- .../src/Workflow/ExceptionalWorkflow.php | 5 +- .../src/Workflow/GeneratorWorkflow.php | 3 +- .../Workflow/Header/ChildedHeaderWorkflow.php | 3 +- .../Workflow/Header/EmptyHeaderWorkflow.php | 4 +- .../src/Workflow/HistoryLengthWorkflow.php | 3 +- .../Interceptor/AwaitHeadersWorkflow.php | 3 +- .../ContinueAsNewHeadersWorkflow.php | 3 +- .../Workflow/Interceptor/HeadersWorkflow.php | 3 +- .../Interceptor/QueryHeadersWorkflow.php | 11 ++-- .../Interceptor/SignalHeadersWorkflow.php | 6 +- .../Interceptor/UpdateHeadersWorkflow.php | 9 ++- .../src/Workflow/LocalActivityWorkflow.php | 3 +- .../src/Workflow/LoopKillerWorkflow.php | 11 ++-- .../src/Workflow/LoopSignallingWorkflow.php | 11 ++-- .../LoopWithSignalCoroutinesWorkflow.php | 3 +- tests/Fixtures/src/Workflow/LoopWorkflow.php | 3 +- .../ActivityNamedArgumentsWorkflow.php | 3 +- .../ChildSignalNamedArgumentsWorkflow.php | 3 +- .../ContinueAsNewNamedArgumentsWorkflow.php | 3 +- .../ExecuteChildNamedArgumentsWorkflow.php | 3 +- .../SignalNamedArgumentsWorkflow.php | 6 +- .../SimpleNamedArgumentsWorkflow.php | 4 +- .../src/Workflow/ParallelScopesWorkflow.php | 3 +- .../ParentWithAbandonedChildWorkflow.php | 3 +- .../src/Workflow/Php82TypesWorkflow.php | 3 +- .../src/Workflow/ProtoPayloadWorkflow.php | 3 +- tests/Fixtures/src/Workflow/QueryWorkflow.php | 9 ++- .../src/Workflow/RuntimeSignalWorkflow.php | 3 +- tests/Fixtures/src/Workflow/SagaWorkflow.php | 9 ++- .../src/Workflow/ScalarEnumWorkflow.php | 3 +- .../src/Workflow/SideEffectWorkflow.php | 3 +- .../Workflow/SignalChildViaStubWorkflow.php | 3 +- .../src/Workflow/SimpleDTOWorkflow.php | 6 +- .../src/Workflow/SimpleEnumWorkflow.php | 3 +- .../src/Workflow/SimpleHeartbeatWorkflow.php | 3 +- .../src/Workflow/SimpleSignaledWorkflow.php | 6 +- .../src/Workflow/SimpleSignalledWorkflow.php | 6 +- .../SimpleSignalledWorkflowWithSleep.php | 6 +- .../src/Workflow/SimpleUuidWorkflow.php | 6 +- .../Fixtures/src/Workflow/SimpleWorkflow.php | 3 +- .../src/Workflow/TestContextLeakWorkflow.php | 9 ++- .../src/Workflow/TimerWayWorkflow.php | 3 +- tests/Fixtures/src/Workflow/TimerWorkflow.php | 3 +- .../src/Workflow/UpdateExceptionsWorkflow.php | 9 +-- .../Fixtures/src/Workflow/UpdateWorkflow.php | 28 ++++---- .../UpsertSearchAttributesWorkflow.php | 3 +- .../src/Workflow/VoidActivityStubWorkflow.php | 3 +- .../src/Workflow/WithChildStubWorkflow.php | 3 +- .../src/Workflow/WithChildWorkflow.php | 6 +- .../src/Workflow/WorkflowWithSequence.php | 3 +- .../Workflow/WorkflowWithSignalledSteps.php | 3 +- .../src/Workflow/YieldGeneratorWorkflow.php | 3 +- .../src/Workflow/YieldScalarsWorkflow.php | 4 +- tests/Unit/Framework/WorkerFactoryMock.php | 3 +- tests/Unit/Framework/WorkerMock.php | 12 ++-- tests/Unit/Framework/WorkerTestCase.php | 3 +- .../Internal/Support/DateIntervalTestCase.php | 5 +- .../Internal/Support/WorkflowFacadeTest.php | 5 +- tests/Unit/Router/DummyWorkflow.php | 7 +- .../WorkflowExecutionInfoMapperTestCase.php | 65 +++++++++++-------- .../AwaitWithTimeoutTestCase.php | 12 ++-- .../WorkflowContext/GetVersionTestCase.php | 3 +- 134 files changed, 536 insertions(+), 312 deletions(-) diff --git a/tests/Acceptance/Extra/Activity/ActivityInfoTest.php b/tests/Acceptance/Extra/Activity/ActivityInfoTest.php index 4a75cb323..5258f2963 100644 --- a/tests/Acceptance/Extra/Activity/ActivityInfoTest.php +++ b/tests/Acceptance/Extra/Activity/ActivityInfoTest.php @@ -14,6 +14,9 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Activity\ActivityInterface; +use Temporal\Activity\ActivityMethod; +use Temporal\Activity\ActivityOptions; class ActivityInfoTest extends TestCase { @@ -51,7 +54,7 @@ private function getRetryOptions(): PromiseInterface { return Workflow::newActivityStub( TestActivity::class, - Activity\ActivityOptions::new() + ActivityOptions::new() ->withRetryOptions( RetryOptions::new() ->withMaximumAttempts(20) @@ -65,10 +68,10 @@ private function getRetryOptions(): PromiseInterface } } -#[Activity\ActivityInterface(prefix: 'Extra_Activity_ActivityInfo.')] +#[ActivityInterface(prefix: 'Extra_Activity_ActivityInfo.')] class TestActivity { - #[Activity\ActivityMethod] + #[ActivityMethod] public function retryOptions() { return Activity::getInfo()->retryOptions; diff --git a/tests/Acceptance/Extra/Activity/ActivityMethodTest.php b/tests/Acceptance/Extra/Activity/ActivityMethodTest.php index 10ae6b8c8..2807ae9b5 100644 --- a/tests/Acceptance/Extra/Activity/ActivityMethodTest.php +++ b/tests/Acceptance/Extra/Activity/ActivityMethodTest.php @@ -4,7 +4,6 @@ namespace Temporal\Tests\Acceptance\Extra\Activity\ActivityMethod; -use Temporal\Activity; use Temporal\Activity\ActivityMethod; use Temporal\Client\WorkflowStubInterface; use Temporal\Exception\Client\WorkflowFailedException; @@ -14,6 +13,8 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Activity\ActivityInterface; +use Temporal\Activity\ActivityOptions; class ActivityMethodTest extends TestCase { @@ -52,7 +53,6 @@ public function testMagicMethodIsIgnored( } } - #[WorkflowInterface] class TestWorkflow { @@ -61,7 +61,7 @@ public function handle(string $method) { $activityStub = Workflow::newActivityStub( TestActivity::class, - Activity\ActivityOptions::new()->withScheduleToCloseTimeout(10), + ActivityOptions::new()->withScheduleToCloseTimeout(10), ); $result = yield $activityStub->{$method}(); @@ -72,7 +72,7 @@ public function handle(string $method) } } -#[Activity\ActivityInterface(prefix: 'Extra_Activity_ActivityMethod.')] +#[ActivityInterface(prefix: 'Extra_Activity_ActivityMethod.')] class TestActivity { #[ActivityMethod] diff --git a/tests/Acceptance/Extra/Activity/ActivityPausedTest.php b/tests/Acceptance/Extra/Activity/ActivityPausedTest.php index acf2edcf5..6e060f98c 100644 --- a/tests/Acceptance/Extra/Activity/ActivityPausedTest.php +++ b/tests/Acceptance/Extra/Activity/ActivityPausedTest.php @@ -17,6 +17,9 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Activity\ActivityInterface; +use Temporal\Activity\ActivityMethod; +use Temporal\Activity\ActivityOptions; class ActivityPausedTest extends TestCase { @@ -67,7 +70,7 @@ class TestWorkflow public function handle() { $stub = Workflow::newUntypedActivityStub( - Activity\ActivityOptions::new()->withScheduleToCloseTimeout('101 seconds'), + ActivityOptions::new()->withScheduleToCloseTimeout('101 seconds'), ); /** @see TestActivity::sleep() */ @@ -82,10 +85,10 @@ public function handle() } } -#[Activity\ActivityInterface(prefix: 'Extra_Activity_ActivityPaused.')] +#[ActivityInterface(prefix: 'Extra_Activity_ActivityPaused.')] class TestActivity { - #[Activity\ActivityMethod] + #[ActivityMethod] public function sleep(int $seconds): string { $start = \microtime(true); diff --git a/tests/Acceptance/Extra/Client/WorkflowClientTest.php b/tests/Acceptance/Extra/Client/WorkflowClientTest.php index 9b97ec7f5..5a24e2cdd 100644 --- a/tests/Acceptance/Extra/Client/WorkflowClientTest.php +++ b/tests/Acceptance/Extra/Client/WorkflowClientTest.php @@ -13,6 +13,7 @@ use Temporal\Workflow\SignalMethod; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowExecutionStatus; class WorkflowClientTest extends TestCase { @@ -48,7 +49,7 @@ public function describeWorkflowExecution( self::assertInstanceOf(\DateTimeInterface::class, $description->info->startTime); self::assertNull($description->info->closeTime); - self::assertSame(Workflow\WorkflowExecutionStatus::Running, $description->info->status); + self::assertSame(WorkflowExecutionStatus::Running, $description->info->status); self::assertGreaterThanOrEqual(2, $description->info->historyLength); self::assertNull($description->info->parentExecution); self::assertNotNull($description->info->executionTime); diff --git a/tests/Acceptance/Extra/Interceptors/ContextTest.php b/tests/Acceptance/Extra/Interceptors/ContextTest.php index 1e18fc7c5..4642221cc 100644 --- a/tests/Acceptance/Extra/Interceptors/ContextTest.php +++ b/tests/Acceptance/Extra/Interceptors/ContextTest.php @@ -25,6 +25,11 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\SignalMethod; +use Temporal\Workflow\WorkflowInit; +use Temporal\Activity\ActivityInterface; +use Temporal\Activity\ActivityMethod; +use Temporal\Activity\ActivityOptions; #[Worker(pipelineProvider: [WorkerServices::class, 'interceptors'])] class ContextTest extends TestCase @@ -105,7 +110,7 @@ public function handle(string $class) $activityClass = yield Workflow::executeActivity( 'Extra_Interceptors_Context.handler', ['foo'], - Activity\ActivityOptions::new()->withScheduleToCloseTimeout('10 seconds'), + ActivityOptions::new()->withScheduleToCloseTimeout('10 seconds'), ); yield Workflow::await(fn() => $this->exit); return [ @@ -115,7 +120,7 @@ public function handle(string $class) ]; } - #[Workflow\SignalMethod] + #[SignalMethod] public function exit(): void { $this->exit = true; @@ -125,7 +130,7 @@ public function exit(): void #[WorkflowInterface] class TestFailingWorkflow { - #[Workflow\WorkflowInit] + #[WorkflowInit] public function __construct(mixed ...$input) { if ($input === []) { @@ -145,7 +150,7 @@ class TestReadonlyConstructorWorkflow { private ?PromiseInterface $uuid = null; - #[Workflow\WorkflowInit] + #[WorkflowInit] public function __construct(mixed ...$input) { try { @@ -162,10 +167,10 @@ public function handle() } } -#[Activity\ActivityInterface(prefix: 'Extra_Interceptors_Context.')] +#[ActivityInterface(prefix: 'Extra_Interceptors_Context.')] class TestActivity { - #[Activity\ActivityMethod] + #[ActivityMethod] public function handler(string $result): string { return $result; diff --git a/tests/Acceptance/Extra/Stability/DestroyableTest.php b/tests/Acceptance/Extra/Stability/DestroyableTest.php index 1e6bf0efa..7fde9b4bf 100644 --- a/tests/Acceptance/Extra/Stability/DestroyableTest.php +++ b/tests/Acceptance/Extra/Stability/DestroyableTest.php @@ -14,6 +14,7 @@ use Temporal\Tests\Acceptance\App\TestCase; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; class DestroyableTest extends TestCase { @@ -30,7 +31,7 @@ public function destroyOnFinish( } } -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class TestWorkflow implements Destroyable { private LoggerInterface $logger; diff --git a/tests/Acceptance/Extra/Stability/DynamicSignalWithPromisesTest.php b/tests/Acceptance/Extra/Stability/DynamicSignalWithPromisesTest.php index f01d9b061..dc37b9116 100644 --- a/tests/Acceptance/Extra/Stability/DynamicSignalWithPromisesTest.php +++ b/tests/Acceptance/Extra/Stability/DynamicSignalWithPromisesTest.php @@ -12,6 +12,7 @@ use Temporal\Tests\Acceptance\App\TestCase; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; class DynamicSignalWithPromisesTest extends TestCase { @@ -37,7 +38,7 @@ public function steps( } } -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class TestWorkflow { #[WorkflowMethod(name: 'Extra_Stability_DynamicSignalWithPromises')] diff --git a/tests/Acceptance/Extra/Stability/ResetWorkerTest.php b/tests/Acceptance/Extra/Stability/ResetWorkerTest.php index 583de204b..592b0fc90 100644 --- a/tests/Acceptance/Extra/Stability/ResetWorkerTest.php +++ b/tests/Acceptance/Extra/Stability/ResetWorkerTest.php @@ -17,6 +17,9 @@ use Temporal\Workflow; use Temporal\Workflow\ReturnType; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\QueryMethod; +use Temporal\Workflow\SignalMethod; +use Temporal\Workflow\WorkflowInterface; class ResetWorkerTest extends TestCase { @@ -111,7 +114,7 @@ public function resetWithSignal( } } -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class TestWorkflow { private bool $exit = false; @@ -125,14 +128,14 @@ public function expire(int $seconds = 10): \Generator return yield $isTimer ? 'Timer' : 'Signal'; } - #[Workflow\QueryMethod('die')] + #[QueryMethod('die')] public function die(int $sleep = 2): void { \sleep($sleep); exit(1); } - #[Workflow\SignalMethod('exit')] + #[SignalMethod('exit')] public function signal() { yield Workflow::uuid7(); diff --git a/tests/Acceptance/Extra/Update/DynamicUpdateTest.php b/tests/Acceptance/Extra/Update/DynamicUpdateTest.php index 1b979b441..3c96d7428 100644 --- a/tests/Acceptance/Extra/Update/DynamicUpdateTest.php +++ b/tests/Acceptance/Extra/Update/DynamicUpdateTest.php @@ -17,6 +17,7 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\SignalMethod; class DynamicUpdateTest extends TestCase { @@ -88,7 +89,7 @@ public function handle() return $this->result; } - #[Workflow\SignalMethod] + #[SignalMethod] public function exit(): void { $this->exit = true; diff --git a/tests/Acceptance/Extra/Update/TimeoutTest.php b/tests/Acceptance/Extra/Update/TimeoutTest.php index 57a01d16e..302701bf7 100644 --- a/tests/Acceptance/Extra/Update/TimeoutTest.php +++ b/tests/Acceptance/Extra/Update/TimeoutTest.php @@ -15,6 +15,7 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\UpdateMethod; class TimeoutTest extends TestCase { @@ -67,7 +68,7 @@ public function handle() yield Workflow::await(static fn() => false); } - #[Workflow\UpdateMethod(name: 'sleep')] + #[UpdateMethod(name: 'sleep')] public function sleep(string $sleep): mixed { yield Workflow::timer(\DateInterval::createFromDateString($sleep)); diff --git a/tests/Acceptance/Extra/Update/UntypedStubTest.php b/tests/Acceptance/Extra/Update/UntypedStubTest.php index 05ee3d217..5d3fa9222 100644 --- a/tests/Acceptance/Extra/Update/UntypedStubTest.php +++ b/tests/Acceptance/Extra/Update/UntypedStubTest.php @@ -16,6 +16,10 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\QueryMethod; +use Temporal\Workflow\SignalMethod; +use Temporal\Workflow\UpdateMethod; +use Temporal\Workflow\UpdateValidatorMethod; class UntypedStubTest extends TestCase { @@ -271,7 +275,7 @@ public function handle() * @param non-empty-string $name * @return mixed */ - #[Workflow\UpdateMethod(name: 'await')] + #[UpdateMethod(name: 'await')] public function add(string $name): mixed { $this->awaits[$name] ??= null; @@ -279,7 +283,7 @@ public function add(string $name): mixed return $this->awaits[$name]; } - #[Workflow\UpdateValidatorMethod(forUpdate: 'await')] + #[UpdateValidatorMethod(forUpdate: 'await')] public function validateAdd(string $name): void { empty($name) and throw new \InvalidArgumentException('Name must not be empty'); @@ -289,7 +293,7 @@ public function validateAdd(string $name): void * @param non-empty-string $name * @return PromiseInterface */ - #[Workflow\UpdateMethod(name: 'awaitWithTimeout')] + #[UpdateMethod(name: 'awaitWithTimeout')] public function addWithTimeout(string $name, string|int $timeout, mixed $value): mixed { $this->awaits[$name] ??= null; @@ -309,7 +313,7 @@ public function addWithTimeout(string $name, string|int $timeout, mixed $value): return $this->awaits[$name]; } - #[Workflow\UpdateValidatorMethod(forUpdate: 'awaitWithTimeout')] + #[UpdateValidatorMethod(forUpdate: 'awaitWithTimeout')] public function validateAddWithTimeout(string $name, string|int $timeout, mixed $value): void { $value === null and throw new \InvalidArgumentException('Value must not be null'); @@ -323,13 +327,13 @@ public function validateAddWithTimeout(string $name, string|int $timeout, mixed * @param non-empty-string $name * @return mixed */ - #[Workflow\UpdateMethod(name: 'resolveValue')] + #[UpdateMethod(name: 'resolveValue')] public function resolve(string $name, mixed $value): mixed { return $this->awaits[$name] = $value; } - #[Workflow\UpdateValidatorMethod(forUpdate: 'resolveValue')] + #[UpdateValidatorMethod(forUpdate: 'resolveValue')] public function validateResolve(string $name, mixed $value): void { $value === null and throw new \InvalidArgumentException('Value must not be null'); @@ -341,13 +345,13 @@ public function validateResolve(string $name, mixed $value): void * @param non-empty-string $name * @return mixed */ - #[Workflow\QueryMethod(name: 'getValue')] + #[QueryMethod(name: 'getValue')] public function get(string $name): mixed { return $this->awaits[$name] ?? null; } - #[Workflow\SignalMethod] + #[SignalMethod] public function exit(): void { $this->exit = true; diff --git a/tests/Acceptance/Extra/Update/UpdateWithStartTest.php b/tests/Acceptance/Extra/Update/UpdateWithStartTest.php index f29a5e639..b5a715a52 100644 --- a/tests/Acceptance/Extra/Update/UpdateWithStartTest.php +++ b/tests/Acceptance/Extra/Update/UpdateWithStartTest.php @@ -16,6 +16,9 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\SignalMethod; +use Temporal\Workflow\UpdateMethod; +use Temporal\Workflow\UpdateValidatorMethod; class UpdateWithStartTest extends TestCase { @@ -113,7 +116,7 @@ public function handle() * @param non-empty-string $name * @return mixed */ - #[Workflow\UpdateMethod(name: 'await')] + #[UpdateMethod(name: 'await')] public function add(string $name): mixed { $this->updateStarted = true; @@ -122,13 +125,13 @@ public function add(string $name): mixed return $this->awaits[$name]; } - #[Workflow\UpdateValidatorMethod(forUpdate: 'await')] + #[UpdateValidatorMethod(forUpdate: 'await')] public function validateAdd(string $name): void { empty($name) and throw new \InvalidArgumentException('Name must not be empty'); } - #[Workflow\SignalMethod] + #[SignalMethod] public function exit(): void { $this->exit = true; diff --git a/tests/Acceptance/Extra/Workflow/AllHandlersFinishedTest.php b/tests/Acceptance/Extra/Workflow/AllHandlersFinishedTest.php index d189b49a3..6522a66ec 100644 --- a/tests/Acceptance/Extra/Workflow/AllHandlersFinishedTest.php +++ b/tests/Acceptance/Extra/Workflow/AllHandlersFinishedTest.php @@ -17,6 +17,9 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\HandlerUnfinishedPolicy; +use Temporal\Workflow\SignalMethod; +use Temporal\Workflow\UpdateMethod; #[CoversFunction('Temporal\Internal\Workflow\Process\Process::logRunningHandlers')] class AllHandlersFinishedTest extends TestCase @@ -270,7 +273,7 @@ public function handle() /** * @param non-empty-string $name */ - #[Workflow\UpdateMethod(name: 'await')] + #[UpdateMethod(name: 'await')] public function addFromUpdate(string $name): mixed { $this->awaits[$name] ??= null; @@ -282,7 +285,7 @@ public function addFromUpdate(string $name): mixed * @param non-empty-string $name * @return PromiseInterface */ - #[Workflow\UpdateMethod(name: 'resolve', unfinishedPolicy: Workflow\HandlerUnfinishedPolicy::Abandon)] + #[UpdateMethod(name: 'resolve', unfinishedPolicy: HandlerUnfinishedPolicy::Abandon)] public function resolveFromUpdate(string $name, mixed $value): mixed { return $this->awaits[$name] = $value; @@ -291,7 +294,7 @@ public function resolveFromUpdate(string $name, mixed $value): mixed /** * @param non-empty-string $name */ - #[Workflow\SignalMethod(name: 'await')] + #[SignalMethod(name: 'await')] public function addFromSignal(string $name) { $this->awaits[$name] ??= null; @@ -301,14 +304,14 @@ public function addFromSignal(string $name) /** * @param non-empty-string $name */ - #[Workflow\SignalMethod(name: 'resolve', unfinishedPolicy: Workflow\HandlerUnfinishedPolicy::Abandon)] + #[SignalMethod(name: 'resolve', unfinishedPolicy: HandlerUnfinishedPolicy::Abandon)] public function resolveFromSignal(string $name, mixed $value) { yield Workflow::await(fn(): bool => \array_key_exists($name, $this->awaits)); $this->awaits[$name] = $value; } - #[Workflow\SignalMethod()] + #[SignalMethod()] public function exit(): void { $this->exit = true; diff --git a/tests/Acceptance/Extra/Workflow/BuiltInPrefixedHandlersTest.php b/tests/Acceptance/Extra/Workflow/BuiltInPrefixedHandlersTest.php index cd857908f..a87fdf0de 100644 --- a/tests/Acceptance/Extra/Workflow/BuiltInPrefixedHandlersTest.php +++ b/tests/Acceptance/Extra/Workflow/BuiltInPrefixedHandlersTest.php @@ -16,6 +16,8 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\SignalMethod; +use Temporal\Workflow\UpdateMethod; class BuiltInPrefixedHandlersTest extends TestCase { @@ -98,7 +100,7 @@ public function handle() yield $this->onExit(); } - #[Workflow\UpdateMethod('register_query_with_prefix')] + #[UpdateMethod('register_query_with_prefix')] public function registerQueryWithPrefix(): string { try { @@ -109,7 +111,7 @@ public function registerQueryWithPrefix(): string } } - #[Workflow\UpdateMethod('register_signals_with_prefix')] + #[UpdateMethod('register_signals_with_prefix')] public function registerSignalWithPrefix(): string { try { @@ -120,7 +122,7 @@ public function registerSignalWithPrefix(): string } } - #[Workflow\UpdateMethod('register_updates_with_prefix')] + #[UpdateMethod('register_updates_with_prefix')] public function registerUpdateWithPrefix(): string { try { @@ -131,7 +133,7 @@ public function registerUpdateWithPrefix(): string } } - #[Workflow\SignalMethod] + #[SignalMethod] public function exit(): void { $this->exit = true; diff --git a/tests/Acceptance/Extra/Workflow/ChildWorkflowIdTest.php b/tests/Acceptance/Extra/Workflow/ChildWorkflowIdTest.php index f6e8b86a2..4efbe86ea 100644 --- a/tests/Acceptance/Extra/Workflow/ChildWorkflowIdTest.php +++ b/tests/Acceptance/Extra/Workflow/ChildWorkflowIdTest.php @@ -13,6 +13,8 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\QueryMethod; +use Temporal\Workflow\SignalMethod; #[CoversFunction('Temporal\Internal\Workflow\Process\Process::logRunningHandlers')] class ChildWorkflowIdTest extends TestCase @@ -65,7 +67,7 @@ public function handle(bool $createChild = false) /** * @return null|non-empty-string */ - #[Workflow\QueryMethod] + #[QueryMethod] public function getChildId(): ?string { return $this->childId; @@ -74,13 +76,13 @@ public function getChildId(): ?string /** * @return null|non-empty-string */ - #[Workflow\QueryMethod] + #[QueryMethod] public function getParentId(): ?string { return Workflow::getInfo()->parentExecution?->getID(); } - #[Workflow\SignalMethod] + #[SignalMethod] public function exit(): void { $this->exit = true; diff --git a/tests/Acceptance/Extra/Workflow/FallbackHandlersTest.php b/tests/Acceptance/Extra/Workflow/FallbackHandlersTest.php index b1a1958db..dd37f8db5 100644 --- a/tests/Acceptance/Extra/Workflow/FallbackHandlersTest.php +++ b/tests/Acceptance/Extra/Workflow/FallbackHandlersTest.php @@ -23,6 +23,8 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\SignalMethod; +use Temporal\Workflow\UpdateMethod; #[Worker(pipelineProvider: [WorkerServices::class, 'interceptors'])] class FallbackHandlersTest extends TestCase @@ -249,7 +251,7 @@ public function handle() ]; } - #[Workflow\UpdateMethod('register_query_fallback')] + #[UpdateMethod('register_query_fallback')] public function registerQueryFallback(): void { Workflow::registerDynamicQuery(static fn(string $name, ValuesInterface $values): string => \sprintf( @@ -259,7 +261,7 @@ public function registerQueryFallback(): void )); } - #[Workflow\UpdateMethod('register_signals_fallback')] + #[UpdateMethod('register_signals_fallback')] public function registerSignalFallback(): void { Workflow::registerDynamicSignal(function (string $name, ValuesInterface $values): void { @@ -267,7 +269,7 @@ public function registerSignalFallback(): void }); } - #[Workflow\UpdateMethod('register_updates_fallback')] + #[UpdateMethod('register_updates_fallback')] public function registerUpdateFallback(bool $validator): void { Workflow::registerDynamicUpdate( @@ -282,7 +284,7 @@ public function registerUpdateFallback(bool $validator): void ); } - #[Workflow\SignalMethod] + #[SignalMethod] public function exit(): void { $this->exit = true; diff --git a/tests/Acceptance/Extra/Workflow/LoggerTest.php b/tests/Acceptance/Extra/Workflow/LoggerTest.php index 185549abd..5f1d6e873 100644 --- a/tests/Acceptance/Extra/Workflow/LoggerTest.php +++ b/tests/Acceptance/Extra/Workflow/LoggerTest.php @@ -13,6 +13,9 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\QueryMethod; +use Temporal\Workflow\SignalMethod; +use Temporal\Workflow\UpdateMethod; class LoggerTest extends TestCase { @@ -217,20 +220,20 @@ public function handle() return true; } - #[Workflow\SignalMethod(name: 'logFromSignal')] + #[SignalMethod(name: 'logFromSignal')] public function logFromSignal(string $message): void { $logger = Workflow::getLogger(); $logger->warning($message); } - #[Workflow\SignalMethod(name: 'exit')] + #[SignalMethod(name: 'exit')] public function exit(): void { $this->exit = true; } - #[Workflow\QueryMethod(name: 'logWithContext')] + #[QueryMethod(name: 'logWithContext')] public function logWithContext() { $logger = Workflow::getLogger(); @@ -242,7 +245,7 @@ public function logWithContext() return 'query executed'; } - #[Workflow\UpdateMethod(name: 'logMultipleLevels')] + #[UpdateMethod(name: 'logMultipleLevels')] public function logMultipleLevels() { $logger = Workflow::getLogger(); diff --git a/tests/Acceptance/Extra/Workflow/MemoTest.php b/tests/Acceptance/Extra/Workflow/MemoTest.php index 0a5b041b8..2e4a9198e 100644 --- a/tests/Acceptance/Extra/Workflow/MemoTest.php +++ b/tests/Acceptance/Extra/Workflow/MemoTest.php @@ -12,6 +12,8 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\SignalMethod; +use Temporal\Workflow\UpdateMethod; #[CoversFunction('Temporal\Workflow::upsertMemo')] class MemoTest extends TestCase @@ -112,13 +114,13 @@ public function handle() return Workflow::getInfo()->memo; } - #[Workflow\UpdateMethod] + #[UpdateMethod] public function setMemo(array $memo): void { Workflow::upsertMemo($memo); } - #[Workflow\SignalMethod] + #[SignalMethod] public function exit(): void { $this->exit = true; diff --git a/tests/Acceptance/Extra/Workflow/MutexRunLockedTest.php b/tests/Acceptance/Extra/Workflow/MutexRunLockedTest.php index 576259480..1b2de9eb8 100644 --- a/tests/Acceptance/Extra/Workflow/MutexRunLockedTest.php +++ b/tests/Acceptance/Extra/Workflow/MutexRunLockedTest.php @@ -2,7 +2,7 @@ declare(strict_types=1); -namespace Temporal\Tests\Acceptance\Extra\Workflow\MutexRunLocked; +namespace Temporal\Tests\Acceptance\Extra\MutexRunLocked; use PHPUnit\Framework\Attributes\Test; use React\Promise\PromiseInterface; @@ -14,6 +14,9 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\Mutex; +use Temporal\Workflow\ReturnType; +use Temporal\Workflow\SignalMethod; class MutexRunLockedTest extends TestCase { @@ -50,7 +53,7 @@ public function runLockedAndCancel( #[WorkflowInterface] class TestWorkflow { - private Workflow\Mutex $mutex; + private Mutex $mutex; private PromiseInterface $promise; private bool $unblock = false; private bool $exit = false; @@ -60,11 +63,11 @@ class TestWorkflow public function __construct() { - $this->mutex = new Workflow\Mutex(); + $this->mutex = new Mutex(); } #[WorkflowMethod(name: "Extra_Workflow_MutexRunLocked")] - #[Workflow\ReturnType(Type::TYPE_ARRAY)] + #[ReturnType(Type::TYPE_ARRAY)] public function handle(): \Generator { $exception = null; @@ -89,19 +92,19 @@ public function handle(): \Generator return [$this->unlocked, $this->unblock, $result, $exception]; } - #[Workflow\SignalMethod] + #[SignalMethod] public function unblock(): void { $this->unblock = true; } - #[Workflow\SignalMethod] + #[SignalMethod] public function cancel(): void { $this->promise->cancel(); } - #[Workflow\SignalMethod] + #[SignalMethod] public function exit(): void { $this->exit = true; diff --git a/tests/Acceptance/Extra/Workflow/MutexYieldTest.php b/tests/Acceptance/Extra/Workflow/MutexYieldTest.php index cb64d73fe..9f4dcb1ad 100644 --- a/tests/Acceptance/Extra/Workflow/MutexYieldTest.php +++ b/tests/Acceptance/Extra/Workflow/MutexYieldTest.php @@ -2,7 +2,7 @@ declare(strict_types=1); -namespace Temporal\Tests\Acceptance\Extra\Workflow\MutexYield; +namespace Temporal\Tests\Acceptance\Extra\MutexYield; use PHPUnit\Framework\Attributes\Test; use Temporal\Client\WorkflowStubInterface; @@ -12,6 +12,9 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\Mutex; +use Temporal\Workflow\ReturnType; +use Temporal\Workflow\SignalMethod; class MutexYieldTest extends TestCase { @@ -59,17 +62,17 @@ public function runWithUnblockExit( #[WorkflowInterface] class TestWorkflow { - private Workflow\Mutex $mutex; + private Mutex $mutex; private bool $exit = false; public function __construct() { - $this->mutex = new Workflow\Mutex(); + $this->mutex = new Mutex(); $this->mutex->lock(); } #[WorkflowMethod(name: "Extra_Workflow_MutexYield")] - #[Workflow\ReturnType(Type::TYPE_ARRAY)] + #[ReturnType(Type::TYPE_ARRAY)] public function handle(): \Generator { yield $this->mutex; @@ -86,13 +89,13 @@ public function handle(): \Generator return [$yieldLocked, $awaitLocked]; } - #[Workflow\SignalMethod] + #[SignalMethod] public function unlock(): void { $this->mutex->unlock(); } - #[Workflow\SignalMethod] + #[SignalMethod] public function exit(): void { $this->exit = true; diff --git a/tests/Acceptance/Extra/Workflow/PriorityTest.php b/tests/Acceptance/Extra/Workflow/PriorityTest.php index a89afa0fe..e9194a04a 100644 --- a/tests/Acceptance/Extra/Workflow/PriorityTest.php +++ b/tests/Acceptance/Extra/Workflow/PriorityTest.php @@ -15,6 +15,10 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\ChildWorkflowOptions; +use Temporal\Activity\ActivityInterface; +use Temporal\Activity\ActivityMethod; +use Temporal\Activity\ActivityOptions; class PriorityTest extends TestCase { @@ -77,7 +81,7 @@ public function handle(bool $runChild = false) { $activity = yield Workflow::executeActivity( 'Extra_Workflow_Priority.handler', - options: Activity\ActivityOptions::new() + options: ActivityOptions::new() ->withScheduleToCloseTimeout('10 seconds') ->withPriority( Priority::new(2) @@ -86,14 +90,14 @@ public function handle(bool $runChild = false) ), ); - Workflow\ChildWorkflowOptions::new()->priority->priorityKey === Workflow::getInfo()->priority->priorityKey or + ChildWorkflowOptions::new()->priority->priorityKey === Workflow::getInfo()->priority->priorityKey or throw new ApplicationFailure('Child Workflow priority is not the same as the parent by default', 'error', true); if ($runChild) { $child = yield Workflow::executeChildWorkflow( 'Extra_Workflow_Priority', [false], - Workflow\ChildWorkflowOptions::new()->withPriority( + ChildWorkflowOptions::new()->withPriority( Priority::new(1) ->withFairnessKey('child-key') ->withFairnessWeight(3.3), @@ -114,10 +118,10 @@ public function handle(bool $runChild = false) } } -#[Activity\ActivityInterface(prefix: 'Extra_Workflow_Priority.')] +#[ActivityInterface(prefix: 'Extra_Workflow_Priority.')] class TestActivity { - #[Activity\ActivityMethod] + #[ActivityMethod] public function handler(): array { return [ diff --git a/tests/Acceptance/Extra/Workflow/SearchAttributesTest.php b/tests/Acceptance/Extra/Workflow/SearchAttributesTest.php index 2b25f0c7e..823ad8998 100644 --- a/tests/Acceptance/Extra/Workflow/SearchAttributesTest.php +++ b/tests/Acceptance/Extra/Workflow/SearchAttributesTest.php @@ -13,6 +13,8 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\SignalMethod; +use Temporal\Workflow\UpdateMethod; #[CoversFunction('Temporal\Client\WorkflowOptions::withSearchAttributes')] #[CoversFunction('Temporal\Workflow::upsertSearchAttributes')] @@ -192,13 +194,13 @@ public function handle() return Workflow::getInfo()->searchAttributes; } - #[Workflow\UpdateMethod] + #[UpdateMethod] public function setAttributes(array $searchAttributes): void { Workflow::upsertSearchAttributes($searchAttributes); } - #[Workflow\SignalMethod] + #[SignalMethod] public function exit(): void { $this->exit = true; diff --git a/tests/Acceptance/Extra/Workflow/TypedSearchAttributesTest.php b/tests/Acceptance/Extra/Workflow/TypedSearchAttributesTest.php index 16baf9283..cd57b5e97 100644 --- a/tests/Acceptance/Extra/Workflow/TypedSearchAttributesTest.php +++ b/tests/Acceptance/Extra/Workflow/TypedSearchAttributesTest.php @@ -15,6 +15,8 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\SignalMethod; +use Temporal\Workflow\UpdateMethod; #[CoversFunction('Temporal\Client\WorkflowOptions::withTypedSearchAttributes')] #[CoversFunction('Temporal\Workflow::upsertTypedSearchAttributes')] @@ -214,7 +216,7 @@ public function handle() return $result; } - #[Workflow\UpdateMethod] + #[UpdateMethod] public function setAttributes(array $searchAttributes): void { $updates = []; @@ -232,7 +234,7 @@ public function setAttributes(array $searchAttributes): void Workflow::upsertTypedSearchAttributes(...$updates); } - #[Workflow\SignalMethod] + #[SignalMethod] public function exit(): void { $this->exit = true; diff --git a/tests/Acceptance/Extra/Workflow/UserMetadataTest.php b/tests/Acceptance/Extra/Workflow/UserMetadataTest.php index 87c165dbf..ecfab7ecd 100644 --- a/tests/Acceptance/Extra/Workflow/UserMetadataTest.php +++ b/tests/Acceptance/Extra/Workflow/UserMetadataTest.php @@ -22,6 +22,10 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\ChildWorkflowOptions; +use Temporal\Workflow\SignalMethod; +use Temporal\Workflow\TimerOptions; +use Temporal\Workflow\UpdateMethod; class UserMetadataTest extends TestCase { @@ -204,30 +208,30 @@ class TestWorkflow #[WorkflowMethod(name: "Extra_Workflow_UserMetadata")] public function handle() { - $timer = Workflow::timer(30, Workflow\TimerOptions::new()->withSummary('test timer summary')); + $timer = Workflow::timer(30, TimerOptions::new()->withSummary('test timer summary')); yield Workflow::await($timer, fn() => $this->exit); return $this->result; } - #[Workflow\UpdateMethod] + #[UpdateMethod] public function ping(): string { return 'pong'; } - #[Workflow\UpdateMethod('start_child')] + #[UpdateMethod('start_child')] public function startChild(string $summary, string $details) { $stub = Workflow::newUntypedChildWorkflowStub( 'Extra_Workflow_UserMetadata', - Workflow\ChildWorkflowOptions::new()->withStaticSummary($summary)->withStaticDetails($details), + ChildWorkflowOptions::new()->withStaticSummary($summary)->withStaticDetails($details), ); $execution = yield $stub->start(); return $execution->getID(); } - #[Workflow\UpdateMethod('execute_activity')] + #[UpdateMethod('execute_activity')] public function executeActivity(string $summary) { /** @see TestActivity::execute() */ @@ -239,7 +243,7 @@ public function executeActivity(string $summary) ); } - #[Workflow\SignalMethod] + #[SignalMethod] public function exit(): void { $this->exit = true; diff --git a/tests/Acceptance/Extra/Workflow/WorkflowMetadataTest.php b/tests/Acceptance/Extra/Workflow/WorkflowMetadataTest.php index 4a90e47b5..3a07de973 100644 --- a/tests/Acceptance/Extra/Workflow/WorkflowMetadataTest.php +++ b/tests/Acceptance/Extra/Workflow/WorkflowMetadataTest.php @@ -12,6 +12,8 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\QueryMethod; +use Temporal\Workflow\SignalMethod; class WorkflowMetadataTest extends TestCase { @@ -46,13 +48,13 @@ public function handle(string $payload) /** * @return null|non-empty-string */ - #[Workflow\QueryMethod] + #[QueryMethod] public function getCurrentDetails(): ?string { return Workflow::getCurrentDetails(); } - #[Workflow\SignalMethod] + #[SignalMethod] public function exit(): void { $this->exit = true; diff --git a/tests/Acceptance/Extra/Workflow/WorkflowSearchAttributesTest.php b/tests/Acceptance/Extra/Workflow/WorkflowSearchAttributesTest.php index 219a00589..699fa0c79 100644 --- a/tests/Acceptance/Extra/Workflow/WorkflowSearchAttributesTest.php +++ b/tests/Acceptance/Extra/Workflow/WorkflowSearchAttributesTest.php @@ -71,7 +71,7 @@ public function handle(?array $searchAttributes): \Generator { return yield Workflow::newChildWorkflowStub( TestWorkflowChild::class, - Workflow\ChildWorkflowOptions::new() + ChildWorkflowOptions::new() ->withSearchAttributes($searchAttributes) )->handle(); } diff --git a/tests/Acceptance/Harness/Activity/CancelTryCancelTest.php b/tests/Acceptance/Harness/Activity/CancelTryCancelTest.php index 1f729401d..e0d18c9eb 100644 --- a/tests/Acceptance/Harness/Activity/CancelTryCancelTest.php +++ b/tests/Acceptance/Harness/Activity/CancelTryCancelTest.php @@ -20,6 +20,8 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\SignalMethod; +use Temporal\Activity\ActivityCancellationType; /* @@ -76,7 +78,7 @@ public function run() ->withHeartbeatTimeout('5 seconds') # Disable retry ->withRetryOptions(RetryOptions::new()->withMaximumAttempts(1)) - ->withCancellationType(Activity\ActivityCancellationType::TryCancel) + ->withCancellationType(ActivityCancellationType::TryCancel) ); $scope = Workflow::async(static fn() => $activity->cancellableActivity()); @@ -97,7 +99,7 @@ public function run() return $this->result; } - #[Workflow\SignalMethod('activity_result')] + #[SignalMethod('activity_result')] public function activityResult(string $result) { $this->result = $result; diff --git a/tests/Acceptance/Harness/ChildWorkflow/CancelAbandonTest.php b/tests/Acceptance/Harness/ChildWorkflow/CancelAbandonTest.php index e7074ba87..a8f647e37 100644 --- a/tests/Acceptance/Harness/ChildWorkflow/CancelAbandonTest.php +++ b/tests/Acceptance/Harness/ChildWorkflow/CancelAbandonTest.php @@ -16,6 +16,9 @@ use Temporal\Workflow\CancellationScopeInterface; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\ChildWorkflowOptions; +use Temporal\Workflow\ParentClosePolicy; +use Temporal\Workflow\SignalMethod; class CancelAbandonTest extends TestCase { @@ -140,9 +143,9 @@ public function run(string $input) /** @see ChildWorkflow */ $stub = Workflow::newUntypedChildWorkflowStub( 'Harness_ChildWorkflow_CancelAbandon_Child', - Workflow\ChildWorkflowOptions::new() + ChildWorkflowOptions::new() ->withWorkflowRunTimeout('20 seconds') - ->withParentClosePolicy(Workflow\ParentClosePolicy::Abandon), + ->withParentClosePolicy(ParentClosePolicy::Abandon), ); yield $stub->start($input); @@ -179,9 +182,9 @@ public function run(string $input) /** @see ChildWorkflow */ $stub = Workflow::newUntypedChildWorkflowStub( 'Harness_ChildWorkflow_CancelAbandon_Child', - Workflow\ChildWorkflowOptions::new() + ChildWorkflowOptions::new() ->withWorkflowRunTimeout('20 seconds') - ->withParentClosePolicy(Workflow\ParentClosePolicy::Abandon), + ->withParentClosePolicy(ParentClosePolicy::Abandon), ); yield $stub->start($input); @@ -208,7 +211,7 @@ public function run(string $input) } } - #[Workflow\SignalMethod('close')] + #[SignalMethod('close')] public function close(): void { $this->scope->cancel(); @@ -227,7 +230,7 @@ public function run(string $input) return $input; } - #[Workflow\SignalMethod('exit')] + #[SignalMethod('exit')] public function exit(): void { $this->exit = true; diff --git a/tests/Acceptance/Harness/ChildWorkflow/SignalTest.php b/tests/Acceptance/Harness/ChildWorkflow/SignalTest.php index 523b8ae7c..f9b8b6a59 100644 --- a/tests/Acceptance/Harness/ChildWorkflow/SignalTest.php +++ b/tests/Acceptance/Harness/ChildWorkflow/SignalTest.php @@ -13,6 +13,7 @@ use Temporal\Workflow\SignalMethod; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\ChildWorkflowOptions; class SignalTest extends TestCase { @@ -35,7 +36,7 @@ public function run() $workflow = Workflow::newChildWorkflowStub( ChildWorkflow::class, // TODO: remove after https://github.com/temporalio/sdk-php/issues/451 is fixed - Workflow\ChildWorkflowOptions::new()->withTaskQueue(Workflow::getInfo()->taskQueue), + ChildWorkflowOptions::new()->withTaskQueue(Workflow::getInfo()->taskQueue), ); $handle = $workflow->run(); yield $workflow->signal('unblock'); diff --git a/tests/Acceptance/Harness/Signal/ChildWorkflowTest.php b/tests/Acceptance/Harness/Signal/ChildWorkflowTest.php index ed4076325..7de5e3bdd 100644 --- a/tests/Acceptance/Harness/Signal/ChildWorkflowTest.php +++ b/tests/Acceptance/Harness/Signal/ChildWorkflowTest.php @@ -12,6 +12,7 @@ use Temporal\Workflow\SignalMethod; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\ChildWorkflowOptions; class ChildWorkflowTest extends TestCase { @@ -31,7 +32,7 @@ public function run() { $wf = Workflow::newChildWorkflowStub( ChildWorkflow::class, - Workflow\ChildWorkflowOptions::new() + ChildWorkflowOptions::new() // TODO: remove after https://github.com/temporalio/sdk-php/issues/451 is fixed ->withTaskQueue(Workflow::getInfo()->taskQueue) ); diff --git a/tests/Acceptance/Harness/Update/ActivitiesTest.php b/tests/Acceptance/Harness/Update/ActivitiesTest.php index 424952586..2f9a33896 100644 --- a/tests/Acceptance/Harness/Update/ActivitiesTest.php +++ b/tests/Acceptance/Harness/Update/ActivitiesTest.php @@ -15,6 +15,7 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\UpdateMethod; const ACTIVITY_COUNT = 5; const ACTIVITY_RESULT = 6; @@ -43,7 +44,7 @@ public function run() return $this->total; } - #[Workflow\UpdateMethod('my_update')] + #[UpdateMethod('my_update')] public function myUpdate() { $promises = []; diff --git a/tests/Acceptance/Harness/Update/AsyncAcceptTest.php b/tests/Acceptance/Harness/Update/AsyncAcceptTest.php index 080906b81..bb7224ef5 100644 --- a/tests/Acceptance/Harness/Update/AsyncAcceptTest.php +++ b/tests/Acceptance/Harness/Update/AsyncAcceptTest.php @@ -18,6 +18,8 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\SignalMethod; +use Temporal\Workflow\UpdateMethod; class AsyncAcceptTest extends TestCase { @@ -84,19 +86,19 @@ public function run() return 'Hello, World!'; } - #[Workflow\SignalMethod('finish')] + #[SignalMethod('finish')] public function finish() { $this->done = true; } - #[Workflow\SignalMethod('unblock')] + #[SignalMethod('unblock')] public function unblock() { $this->blocked = false; } - #[Workflow\UpdateMethod('my_update')] + #[UpdateMethod('my_update')] public function myUpdate(bool $block) { if ($block) { diff --git a/tests/Acceptance/Harness/Update/BasicAsyncTest.php b/tests/Acceptance/Harness/Update/BasicAsyncTest.php index 92954c3c1..39e54d465 100644 --- a/tests/Acceptance/Harness/Update/BasicAsyncTest.php +++ b/tests/Acceptance/Harness/Update/BasicAsyncTest.php @@ -12,6 +12,8 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\UpdateMethod; +use Temporal\Workflow\UpdateValidatorMethod; class BasicAsyncTest extends TestCase { @@ -44,14 +46,14 @@ public function run() return $this->state; } - #[Workflow\UpdateMethod('my_update')] + #[UpdateMethod('my_update')] public function myUpdate(string $arg): string { $this->state = $arg; return 'update-result'; } - #[Workflow\UpdateValidatorMethod('my_update')] + #[UpdateValidatorMethod('my_update')] public function myValidateUpdate(string $arg): void { $arg === 'bad-update-arg' and throw new \Exception('Invalid Update argument'); diff --git a/tests/Acceptance/Harness/Update/BasicTest.php b/tests/Acceptance/Harness/Update/BasicTest.php index 0ce82fb1c..366d30a21 100644 --- a/tests/Acceptance/Harness/Update/BasicTest.php +++ b/tests/Acceptance/Harness/Update/BasicTest.php @@ -11,6 +11,7 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\UpdateMethod; class BasicTest extends TestCase { @@ -36,7 +37,7 @@ public function run() return 'Hello, world!'; } - #[Workflow\UpdateMethod('my_update')] + #[UpdateMethod('my_update')] public function myUpdate() { $this->done = true; diff --git a/tests/Acceptance/Harness/Update/ClientInterceptorTest.php b/tests/Acceptance/Harness/Update/ClientInterceptorTest.php index 47d603042..eb81c56e7 100644 --- a/tests/Acceptance/Harness/Update/ClientInterceptorTest.php +++ b/tests/Acceptance/Harness/Update/ClientInterceptorTest.php @@ -19,6 +19,7 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\UpdateMethod; class ClientInterceptorTest extends TestCase { @@ -51,7 +52,7 @@ public function run() return 'Hello, World!'; } - #[Workflow\UpdateMethod('my_update')] + #[UpdateMethod('my_update')] public function myUpdate(int $arg): int { $this->done = true; diff --git a/tests/Acceptance/Harness/Update/ContextTest.php b/tests/Acceptance/Harness/Update/ContextTest.php index 71e55783d..10527cbda 100644 --- a/tests/Acceptance/Harness/Update/ContextTest.php +++ b/tests/Acceptance/Harness/Update/ContextTest.php @@ -12,6 +12,7 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\UpdateMethod; class ContextTest extends TestCase { @@ -45,7 +46,7 @@ public function run() return Workflow::getUpdateContext()?->getUpdateId(); } - #[Workflow\UpdateMethod('my_update')] + #[UpdateMethod('my_update')] public function myUpdate() { Workflow::getUpdateContext() === null and throw new \RuntimeException('Update context should not be null.'); @@ -62,7 +63,7 @@ public function myUpdate() return $updateId; } - #[Workflow\UpdateMethod('my_update2')] + #[UpdateMethod('my_update2')] public function myUpdate2() { Workflow::getUpdateContext() === null and throw new \RuntimeException('Update context should not be null.'); diff --git a/tests/Acceptance/Harness/Update/DeduplicationTest.php b/tests/Acceptance/Harness/Update/DeduplicationTest.php index 4b6ebb17e..605751500 100644 --- a/tests/Acceptance/Harness/Update/DeduplicationTest.php +++ b/tests/Acceptance/Harness/Update/DeduplicationTest.php @@ -14,6 +14,8 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\SignalMethod; +use Temporal\Workflow\UpdateMethod; class DeduplicationTest extends TestCase { @@ -68,13 +70,13 @@ public function run() return $this->counter; } - #[Workflow\SignalMethod('unblock')] + #[SignalMethod('unblock')] public function unblock() { $this->blocked = false; } - #[Workflow\UpdateMethod('my_update')] + #[UpdateMethod('my_update')] public function myUpdate() { ++$this->counter; diff --git a/tests/Acceptance/Harness/Update/NonDurableRejectTest.php b/tests/Acceptance/Harness/Update/NonDurableRejectTest.php index 786d300af..8dd46a71a 100644 --- a/tests/Acceptance/Harness/Update/NonDurableRejectTest.php +++ b/tests/Acceptance/Harness/Update/NonDurableRejectTest.php @@ -12,6 +12,8 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\UpdateMethod; +use Temporal\Workflow\UpdateValidatorMethod; class NonDurableRejectTest extends TestCase { @@ -52,14 +54,14 @@ public function run() return $this->counter; } - #[Workflow\UpdateMethod('my_update')] + #[UpdateMethod('my_update')] public function myUpdate(int $arg): int { $this->counter += $arg; return $this->counter; } - #[Workflow\UpdateValidatorMethod('my_update')] + #[UpdateValidatorMethod('my_update')] public function validateMyUpdate(int $arg): void { $arg < 0 and throw new \InvalidArgumentException('I *HATE* negative numbers!'); diff --git a/tests/Acceptance/Harness/Update/SelfTest.php b/tests/Acceptance/Harness/Update/SelfTest.php index b4de3ea15..9b53e98dc 100644 --- a/tests/Acceptance/Harness/Update/SelfTest.php +++ b/tests/Acceptance/Harness/Update/SelfTest.php @@ -15,6 +15,7 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\UpdateMethod; class SelfTest extends TestCase { @@ -45,7 +46,7 @@ public function run() return 'Hello, world!'; } - #[Workflow\UpdateMethod('my_update')] + #[UpdateMethod('my_update')] public function myUpdate() { $this->done = true; diff --git a/tests/Acceptance/Harness/Update/TaskFailureTest.php b/tests/Acceptance/Harness/Update/TaskFailureTest.php index 8db8a912b..19c7bcb6c 100644 --- a/tests/Acceptance/Harness/Update/TaskFailureTest.php +++ b/tests/Acceptance/Harness/Update/TaskFailureTest.php @@ -14,6 +14,8 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\UpdateMethod; +use Temporal\Workflow\UpdateValidatorMethod; class TaskFailureTest extends TestCase { @@ -67,7 +69,7 @@ public function run() return static::$fails; } - #[Workflow\UpdateMethod('do_update')] + #[UpdateMethod('do_update')] public function doUpdate(): string { # Don't use static variables like this. We do here because we need to fail the task a @@ -85,13 +87,13 @@ public function __construct() throw new ApplicationFailure("I'll fail update", 'task-failure', true); } - #[Workflow\UpdateMethod('throw_or_done')] + #[UpdateMethod('throw_or_done')] public function throwOrDone(bool $doThrow): void { $this->done = true; } - #[Workflow\UpdateValidatorMethod('throw_or_done')] + #[UpdateValidatorMethod('throw_or_done')] public function validateThrowOrDone(bool $doThrow): void { $doThrow and throw new \RuntimeException('This will fail validation, not task'); diff --git a/tests/Acceptance/Harness/Update/ValidationReplayTest.php b/tests/Acceptance/Harness/Update/ValidationReplayTest.php index d5bf2b894..30a9a1996 100644 --- a/tests/Acceptance/Harness/Update/ValidationReplayTest.php +++ b/tests/Acceptance/Harness/Update/ValidationReplayTest.php @@ -10,6 +10,8 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\UpdateMethod; +use Temporal\Workflow\UpdateValidatorMethod; class ValidationReplayTest extends TestCase { @@ -38,7 +40,7 @@ public function run() return static::$validations; } - #[Workflow\UpdateMethod('do_update')] + #[UpdateMethod('do_update')] public function doUpdate(): void { if (static::$validations === 0) { @@ -54,7 +56,7 @@ public function __construct() $this->done = true; } - #[Workflow\UpdateValidatorMethod('do_update')] + #[UpdateValidatorMethod('do_update')] public function validateDoUpdate(): void { if (static::$validations > 1) { diff --git a/tests/Acceptance/Harness/Update/WorkerRestartTest.php b/tests/Acceptance/Harness/Update/WorkerRestartTest.php index 2875bc30f..fd3faf5dc 100644 --- a/tests/Acceptance/Harness/Update/WorkerRestartTest.php +++ b/tests/Acceptance/Harness/Update/WorkerRestartTest.php @@ -19,6 +19,7 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\UpdateMethod; const KV_ACTIVITY_STARTED = 'update-worker-restart-started'; const KV_ACTIVITY_BLOCKED = 'update-worker-restart-blocked'; @@ -70,7 +71,7 @@ public function run() return 'Hello, World!'; } - #[Workflow\UpdateMethod('do_activities')] + #[UpdateMethod('do_activities')] public function doActivities() { yield Workflow::executeActivity( diff --git a/tests/Fixtures/src/Activity/JustLocalActivity.php b/tests/Fixtures/src/Activity/JustLocalActivity.php index 28ff2fe54..35499a698 100644 --- a/tests/Fixtures/src/Activity/JustLocalActivity.php +++ b/tests/Fixtures/src/Activity/JustLocalActivity.php @@ -11,15 +11,15 @@ namespace Temporal\Tests\Activity; -use Temporal\Activity; +use Temporal\Activity\ActivityMethod; +use Temporal\Activity\LocalActivityInterface; -#[Activity\LocalActivityInterface(prefix: "JustLocalActivity.")] +#[LocalActivityInterface(prefix: "JustLocalActivity.")] class JustLocalActivity { - #[Activity\ActivityMethod] - public function echo( - string $input - ): string { - return strtoupper($input); + #[ActivityMethod] + public function echo(string $input): string + { + return \strtoupper($input); } } diff --git a/tests/Fixtures/src/Workflow/ActivityReturnTypeWorkflow.php b/tests/Fixtures/src/Workflow/ActivityReturnTypeWorkflow.php index d9501b0ba..4fd23506b 100644 --- a/tests/Fixtures/src/Workflow/ActivityReturnTypeWorkflow.php +++ b/tests/Fixtures/src/Workflow/ActivityReturnTypeWorkflow.php @@ -15,8 +15,9 @@ use Temporal\Tests\Activity\SampleActivityInterface; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class ActivityReturnTypeWorkflow { #[WorkflowMethod] diff --git a/tests/Fixtures/src/Workflow/ActivityStubWorkflow.php b/tests/Fixtures/src/Workflow/ActivityStubWorkflow.php index d555fae15..8c561f562 100644 --- a/tests/Fixtures/src/Workflow/ActivityStubWorkflow.php +++ b/tests/Fixtures/src/Workflow/ActivityStubWorkflow.php @@ -15,8 +15,9 @@ use Temporal\Tests\Activity\SimpleActivity; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class ActivityStubWorkflow { #[WorkflowMethod(name: 'ActivityStubWorkflow')] diff --git a/tests/Fixtures/src/Workflow/ArrayOfObjectsWorkflow.php b/tests/Fixtures/src/Workflow/ArrayOfObjectsWorkflow.php index c1a690339..cb94960af 100644 --- a/tests/Fixtures/src/Workflow/ArrayOfObjectsWorkflow.php +++ b/tests/Fixtures/src/Workflow/ArrayOfObjectsWorkflow.php @@ -18,8 +18,9 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; use Temporal\Tests\Activity\SimpleActivity; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class ArrayOfObjectsWorkflow { #[WorkflowMethod(name: 'ArrayOfObjectsWorkflow')] diff --git a/tests/Fixtures/src/Workflow/AsyncActivityWorkflow.php b/tests/Fixtures/src/Workflow/AsyncActivityWorkflow.php index 228faf2d3..1343add39 100644 --- a/tests/Fixtures/src/Workflow/AsyncActivityWorkflow.php +++ b/tests/Fixtures/src/Workflow/AsyncActivityWorkflow.php @@ -17,8 +17,9 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; use Temporal\Tests\Activity\SimpleActivity; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class AsyncActivityWorkflow { #[WorkflowMethod(name: 'AsyncActivityWorkflow')] diff --git a/tests/Fixtures/src/Workflow/AsyncClosureWorkflow.php b/tests/Fixtures/src/Workflow/AsyncClosureWorkflow.php index c527818ea..03ae3d64d 100644 --- a/tests/Fixtures/src/Workflow/AsyncClosureWorkflow.php +++ b/tests/Fixtures/src/Workflow/AsyncClosureWorkflow.php @@ -14,8 +14,9 @@ use Temporal\Exception\Failure\CanceledFailure; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class AsyncClosureWorkflow { private array $result = []; diff --git a/tests/Fixtures/src/Workflow/AwaitWithSingleTimeoutWorkflow.php b/tests/Fixtures/src/Workflow/AwaitWithSingleTimeoutWorkflow.php index 921cc81e1..276a0bfaf 100644 --- a/tests/Fixtures/src/Workflow/AwaitWithSingleTimeoutWorkflow.php +++ b/tests/Fixtures/src/Workflow/AwaitWithSingleTimeoutWorkflow.php @@ -13,8 +13,9 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class AwaitWithSingleTimeoutWorkflow { #[WorkflowMethod()] diff --git a/tests/Fixtures/src/Workflow/AwaitWithTimeoutWorkflow.php b/tests/Fixtures/src/Workflow/AwaitWithTimeoutWorkflow.php index 3cb3cb102..217e4f408 100644 --- a/tests/Fixtures/src/Workflow/AwaitWithTimeoutWorkflow.php +++ b/tests/Fixtures/src/Workflow/AwaitWithTimeoutWorkflow.php @@ -13,8 +13,9 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class AwaitWithTimeoutWorkflow { #[WorkflowMethod()] diff --git a/tests/Fixtures/src/Workflow/AwaitsUpdateWorkflow.php b/tests/Fixtures/src/Workflow/AwaitsUpdateWorkflow.php index f93268eb4..4dd48a919 100644 --- a/tests/Fixtures/src/Workflow/AwaitsUpdateWorkflow.php +++ b/tests/Fixtures/src/Workflow/AwaitsUpdateWorkflow.php @@ -16,6 +16,10 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\QueryMethod; +use Temporal\Workflow\SignalMethod; +use Temporal\Workflow\UpdateMethod; +use Temporal\Workflow\UpdateValidatorMethod; #[WorkflowInterface] class AwaitsUpdateWorkflow @@ -34,7 +38,7 @@ public function greet() * @param non-empty-string $name * @return mixed */ - #[Workflow\UpdateMethod(name: 'await')] + #[UpdateMethod(name: 'await')] public function add(string $name): mixed { $this->awaits[$name] ??= null; @@ -42,7 +46,7 @@ public function add(string $name): mixed return $this->awaits[$name]; } - #[Workflow\UpdateValidatorMethod(forUpdate: 'await')] + #[UpdateValidatorMethod(forUpdate: 'await')] public function validateAdd(string $name): void { empty($name) and throw new \InvalidArgumentException('Name must not be empty'); @@ -52,7 +56,7 @@ public function validateAdd(string $name): void * @param non-empty-string $name * @return PromiseInterface */ - #[Workflow\UpdateMethod(name: 'awaitWithTimeout')] + #[UpdateMethod(name: 'awaitWithTimeout')] public function addWithTimeout(string $name, string|int $timeout, mixed $value): mixed { $this->awaits[$name] ??= null; @@ -72,7 +76,7 @@ public function addWithTimeout(string $name, string|int $timeout, mixed $value): return $this->awaits[$name]; } - #[Workflow\UpdateValidatorMethod(forUpdate: 'awaitWithTimeout')] + #[UpdateValidatorMethod(forUpdate: 'awaitWithTimeout')] public function validateAddWithTimeout(string $name, string|int $timeout, mixed $value): void { $value === null and throw new \InvalidArgumentException('Value must not be null'); @@ -86,13 +90,13 @@ public function validateAddWithTimeout(string $name, string|int $timeout, mixed * @param non-empty-string $name * @return mixed */ - #[Workflow\UpdateMethod(name: 'resolveValue')] + #[UpdateMethod(name: 'resolveValue')] public function resolve(string $name, mixed $value): mixed { return $this->awaits[$name] = $value; } - #[Workflow\UpdateValidatorMethod(forUpdate: 'resolveValue')] + #[UpdateValidatorMethod(forUpdate: 'resolveValue')] public function validateResolve(string $name, mixed $value): void { $value === null and throw new \InvalidArgumentException('Value must not be null'); @@ -104,13 +108,13 @@ public function validateResolve(string $name, mixed $value): void * @param non-empty-string $name * @return mixed */ - #[Workflow\QueryMethod(name: 'getValue')] + #[QueryMethod(name: 'getValue')] public function get(string $name): mixed { return $this->awaits[$name] ?? null; } - #[Workflow\SignalMethod] + #[SignalMethod] public function exit(): void { $this->exit = true; diff --git a/tests/Fixtures/src/Workflow/BinaryWorkflow.php b/tests/Fixtures/src/Workflow/BinaryWorkflow.php index 9fcae7a5f..26caa6313 100644 --- a/tests/Fixtures/src/Workflow/BinaryWorkflow.php +++ b/tests/Fixtures/src/Workflow/BinaryWorkflow.php @@ -15,8 +15,9 @@ use Temporal\DataConverter\Bytes; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class BinaryWorkflow { #[WorkflowMethod(name: 'BinaryWorkflow')] diff --git a/tests/Fixtures/src/Workflow/CancelSignaledChildWorkflow.php b/tests/Fixtures/src/Workflow/CancelSignaledChildWorkflow.php index b9f1f90c6..b44e1ac7f 100644 --- a/tests/Fixtures/src/Workflow/CancelSignaledChildWorkflow.php +++ b/tests/Fixtures/src/Workflow/CancelSignaledChildWorkflow.php @@ -14,13 +14,15 @@ use React\Promise\Deferred; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\QueryMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class CancelSignaledChildWorkflow { private array $status = []; - #[Workflow\QueryMethod(name: 'getStatus')] + #[QueryMethod(name: 'getStatus')] public function getStatus(): array { return $this->status; diff --git a/tests/Fixtures/src/Workflow/CancelSignalledChildWorkflow.php b/tests/Fixtures/src/Workflow/CancelSignalledChildWorkflow.php index bb277eb44..dbdfa0343 100644 --- a/tests/Fixtures/src/Workflow/CancelSignalledChildWorkflow.php +++ b/tests/Fixtures/src/Workflow/CancelSignalledChildWorkflow.php @@ -14,13 +14,15 @@ use React\Promise\Deferred; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\QueryMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class CancelSignalledChildWorkflow { private array $status = []; - #[Workflow\QueryMethod(name: 'getStatus')] + #[QueryMethod(name: 'getStatus')] public function getStatus(): array { return $this->status; diff --git a/tests/Fixtures/src/Workflow/CanceledHeartbeatWorkflow.php b/tests/Fixtures/src/Workflow/CanceledHeartbeatWorkflow.php index e0c3d1848..ecb109c6a 100644 --- a/tests/Fixtures/src/Workflow/CanceledHeartbeatWorkflow.php +++ b/tests/Fixtures/src/Workflow/CanceledHeartbeatWorkflow.php @@ -16,8 +16,9 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; use Temporal\Tests\Activity\HeartBeatActivity; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class CanceledHeartbeatWorkflow { #[WorkflowMethod(name: 'CanceledHeartbeatWorkflow')] diff --git a/tests/Fixtures/src/Workflow/CancelledMidflightWorkflow.php b/tests/Fixtures/src/Workflow/CancelledMidflightWorkflow.php index 0153c1fe1..281c5d1a6 100644 --- a/tests/Fixtures/src/Workflow/CancelledMidflightWorkflow.php +++ b/tests/Fixtures/src/Workflow/CancelledMidflightWorkflow.php @@ -15,13 +15,15 @@ use Temporal\Tests\Activity\SimpleActivity; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\QueryMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class CancelledMidflightWorkflow { private array $status = []; - #[Workflow\QueryMethod(name: 'getStatus')] + #[QueryMethod(name: 'getStatus')] public function getStatus(): array { return $this->status; diff --git a/tests/Fixtures/src/Workflow/CancelledNestedWorkflow.php b/tests/Fixtures/src/Workflow/CancelledNestedWorkflow.php index 772530f66..e9cb7969f 100644 --- a/tests/Fixtures/src/Workflow/CancelledNestedWorkflow.php +++ b/tests/Fixtures/src/Workflow/CancelledNestedWorkflow.php @@ -14,13 +14,15 @@ use Temporal\Exception\Failure\CanceledFailure; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\QueryMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class CancelledNestedWorkflow { private array $status = []; - #[Workflow\QueryMethod(name: 'getStatus')] + #[QueryMethod(name: 'getStatus')] public function getStatus(): array { return $this->status; diff --git a/tests/Fixtures/src/Workflow/CancelledScopeWorkflow.php b/tests/Fixtures/src/Workflow/CancelledScopeWorkflow.php index 22c55c93a..854b13c03 100644 --- a/tests/Fixtures/src/Workflow/CancelledScopeWorkflow.php +++ b/tests/Fixtures/src/Workflow/CancelledScopeWorkflow.php @@ -15,8 +15,9 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; use Temporal\Tests\Activity\SimpleActivity; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class CancelledScopeWorkflow { #[WorkflowMethod(name: 'CancelledScopeWorkflow')] diff --git a/tests/Fixtures/src/Workflow/CancelledSingleScopeWorkflow.php b/tests/Fixtures/src/Workflow/CancelledSingleScopeWorkflow.php index 9b3479666..2f6405007 100644 --- a/tests/Fixtures/src/Workflow/CancelledSingleScopeWorkflow.php +++ b/tests/Fixtures/src/Workflow/CancelledSingleScopeWorkflow.php @@ -16,13 +16,15 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; use Temporal\Tests\Activity\SimpleActivity; +use Temporal\Workflow\QueryMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class CancelledSingleScopeWorkflow { private array $status = []; - #[Workflow\QueryMethod(name: 'getStatus')] + #[QueryMethod(name: 'getStatus')] public function getStatus(): array { return $this->status; diff --git a/tests/Fixtures/src/Workflow/CancelledWithCompensationWorkflow.php b/tests/Fixtures/src/Workflow/CancelledWithCompensationWorkflow.php index 72b76a15e..355632973 100644 --- a/tests/Fixtures/src/Workflow/CancelledWithCompensationWorkflow.php +++ b/tests/Fixtures/src/Workflow/CancelledWithCompensationWorkflow.php @@ -16,13 +16,15 @@ use Temporal\Tests\Activity\SimpleActivity; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\QueryMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class CancelledWithCompensationWorkflow { private array $status = []; - #[Workflow\QueryMethod(name: 'getStatus')] + #[QueryMethod(name: 'getStatus')] public function getStatus(): array { return $this->status; diff --git a/tests/Fixtures/src/Workflow/CancelledWorkflow.php b/tests/Fixtures/src/Workflow/CancelledWorkflow.php index e62a74262..617cb3340 100644 --- a/tests/Fixtures/src/Workflow/CancelledWorkflow.php +++ b/tests/Fixtures/src/Workflow/CancelledWorkflow.php @@ -16,8 +16,9 @@ use Temporal\Tests\Activity\SimpleActivity; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class CancelledWorkflow { #[WorkflowMethod(name: 'CancelledWorkflow')] diff --git a/tests/Fixtures/src/Workflow/Case335Workflow.php b/tests/Fixtures/src/Workflow/Case335Workflow.php index 1b1f1ba96..be9b9d94d 100644 --- a/tests/Fixtures/src/Workflow/Case335Workflow.php +++ b/tests/Fixtures/src/Workflow/Case335Workflow.php @@ -12,8 +12,9 @@ use Temporal\Workflow; use Temporal\Workflow\SignalMethod; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class Case335Workflow { private bool $exit = false; diff --git a/tests/Fixtures/src/Workflow/ChainedWorkflow.php b/tests/Fixtures/src/Workflow/ChainedWorkflow.php index 458e08c0a..ad0885e04 100644 --- a/tests/Fixtures/src/Workflow/ChainedWorkflow.php +++ b/tests/Fixtures/src/Workflow/ChainedWorkflow.php @@ -14,8 +14,9 @@ use Temporal\Activity\ActivityOptions; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class ChainedWorkflow { #[WorkflowMethod(name: 'ChainedWorkflow')] diff --git a/tests/Fixtures/src/Workflow/ChildStubWorkflow.php b/tests/Fixtures/src/Workflow/ChildStubWorkflow.php index 280c0df39..d575a53e2 100644 --- a/tests/Fixtures/src/Workflow/ChildStubWorkflow.php +++ b/tests/Fixtures/src/Workflow/ChildStubWorkflow.php @@ -13,8 +13,10 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowExecution; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class ChildStubWorkflow { #[WorkflowMethod(name: 'ChildStubWorkflow')] @@ -32,7 +34,7 @@ public function handler( $result[] = yield $untyped->execute(['untyped']); $execution = yield $untyped->getExecution(); - assert($execution instanceof Workflow\WorkflowExecution); + assert($execution instanceof WorkflowExecution); return $result; } diff --git a/tests/Fixtures/src/Workflow/ComplexExceptionalWorkflow.php b/tests/Fixtures/src/Workflow/ComplexExceptionalWorkflow.php index 25194f8b4..c57e3c127 100644 --- a/tests/Fixtures/src/Workflow/ComplexExceptionalWorkflow.php +++ b/tests/Fixtures/src/Workflow/ComplexExceptionalWorkflow.php @@ -16,8 +16,10 @@ use Temporal\Tests\Activity\SimpleActivity; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\ChildWorkflowOptions; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class ComplexExceptionalWorkflow { #[WorkflowMethod(name: 'ComplexExceptionalWorkflow')] @@ -25,7 +27,7 @@ public function handler() { $child = Workflow::newChildWorkflowStub( ExceptionalActivityWorkflow::class, - Workflow\ChildWorkflowOptions::new()->withRetryOptions( + ChildWorkflowOptions::new()->withRetryOptions( (new RetryOptions())->withMaximumAttempts(1) ) ); diff --git a/tests/Fixtures/src/Workflow/ContinuaWithTaskQueueWorkflow.php b/tests/Fixtures/src/Workflow/ContinuaWithTaskQueueWorkflow.php index eb3beeec1..c66dda198 100644 --- a/tests/Fixtures/src/Workflow/ContinuaWithTaskQueueWorkflow.php +++ b/tests/Fixtures/src/Workflow/ContinuaWithTaskQueueWorkflow.php @@ -15,8 +15,9 @@ use Temporal\Tests\Activity\SimpleActivity; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class ContinuaWithTaskQueueWorkflow { #[WorkflowMethod(name: 'ContinuaWithTaskQueueWorkflow')] diff --git a/tests/Fixtures/src/Workflow/ContinuableWorkflow.php b/tests/Fixtures/src/Workflow/ContinuableWorkflow.php index c58d23390..807d92b3e 100644 --- a/tests/Fixtures/src/Workflow/ContinuableWorkflow.php +++ b/tests/Fixtures/src/Workflow/ContinuableWorkflow.php @@ -15,8 +15,9 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; use Temporal\Tests\Activity\SimpleActivity; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class ContinuableWorkflow { #[WorkflowMethod(name: 'ContinuableWorkflow')] diff --git a/tests/Fixtures/src/Workflow/DetachedScopeWorkflow.php b/tests/Fixtures/src/Workflow/DetachedScopeWorkflow.php index d92d6b205..a70dce2f0 100644 --- a/tests/Fixtures/src/Workflow/DetachedScopeWorkflow.php +++ b/tests/Fixtures/src/Workflow/DetachedScopeWorkflow.php @@ -13,8 +13,9 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class DetachedScopeWorkflow { #[WorkflowMethod] diff --git a/tests/Fixtures/src/Workflow/DynamicObjectReturnWorkflow.php b/tests/Fixtures/src/Workflow/DynamicObjectReturnWorkflow.php index c8ddca2cc..db801d2ec 100644 --- a/tests/Fixtures/src/Workflow/DynamicObjectReturnWorkflow.php +++ b/tests/Fixtures/src/Workflow/DynamicObjectReturnWorkflow.php @@ -10,8 +10,9 @@ use Temporal\Tests\DTO\B; use Temporal\DataConverter\Type; use Temporal\Activity\ActivityOptions; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class DynamicObjectReturnWorkflow { #[WorkflowMethod] diff --git a/tests/Fixtures/src/Workflow/EmptyWorkflow.php b/tests/Fixtures/src/Workflow/EmptyWorkflow.php index d3fcc0021..42901689e 100644 --- a/tests/Fixtures/src/Workflow/EmptyWorkflow.php +++ b/tests/Fixtures/src/Workflow/EmptyWorkflow.php @@ -12,9 +12,9 @@ namespace Temporal\Tests\Workflow; use Temporal\Workflow\WorkflowMethod; -use Temporal\Workflow; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class EmptyWorkflow { #[WorkflowMethod] diff --git a/tests/Fixtures/src/Workflow/EnumDtoWorkflow.php b/tests/Fixtures/src/Workflow/EnumDtoWorkflow.php index 5152e8db9..0825b2a80 100644 --- a/tests/Fixtures/src/Workflow/EnumDtoWorkflow.php +++ b/tests/Fixtures/src/Workflow/EnumDtoWorkflow.php @@ -17,8 +17,9 @@ use Temporal\Tests\DTO\WithEnum; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class EnumDtoWorkflow { #[WorkflowMethod] diff --git a/tests/Fixtures/src/Workflow/ExceptionalActivityWorkflow.php b/tests/Fixtures/src/Workflow/ExceptionalActivityWorkflow.php index e28baf712..951285ddf 100644 --- a/tests/Fixtures/src/Workflow/ExceptionalActivityWorkflow.php +++ b/tests/Fixtures/src/Workflow/ExceptionalActivityWorkflow.php @@ -16,8 +16,9 @@ use Temporal\Tests\Activity\SimpleActivity; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class ExceptionalActivityWorkflow { #[WorkflowMethod(name: 'ExceptionalActivityWorkflow')] diff --git a/tests/Fixtures/src/Workflow/ExceptionalWorkflow.php b/tests/Fixtures/src/Workflow/ExceptionalWorkflow.php index 96bdd809e..fd8b6eee9 100644 --- a/tests/Fixtures/src/Workflow/ExceptionalWorkflow.php +++ b/tests/Fixtures/src/Workflow/ExceptionalWorkflow.php @@ -13,10 +13,11 @@ use Temporal\Activity\ActivityOptions; use Temporal\Tests\Activity\SimpleActivity; -use Temporal\Workflow; + use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class ExceptionalWorkflow { #[WorkflowMethod(name: 'ExceptionalWorkflow')] diff --git a/tests/Fixtures/src/Workflow/GeneratorWorkflow.php b/tests/Fixtures/src/Workflow/GeneratorWorkflow.php index 7d228b829..f846a8cae 100644 --- a/tests/Fixtures/src/Workflow/GeneratorWorkflow.php +++ b/tests/Fixtures/src/Workflow/GeneratorWorkflow.php @@ -17,8 +17,9 @@ use Temporal\Tests\Activity\SimpleActivity; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class GeneratorWorkflow { #[WorkflowMethod(name: 'GeneratorWorkflow')] diff --git a/tests/Fixtures/src/Workflow/Header/ChildedHeaderWorkflow.php b/tests/Fixtures/src/Workflow/Header/ChildedHeaderWorkflow.php index d5572a109..8cf50eea6 100644 --- a/tests/Fixtures/src/Workflow/Header/ChildedHeaderWorkflow.php +++ b/tests/Fixtures/src/Workflow/Header/ChildedHeaderWorkflow.php @@ -15,8 +15,9 @@ use Temporal\Tests\Interceptor\HeaderChanger; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] final class ChildedHeaderWorkflow { use HandleTrait; diff --git a/tests/Fixtures/src/Workflow/Header/EmptyHeaderWorkflow.php b/tests/Fixtures/src/Workflow/Header/EmptyHeaderWorkflow.php index 0657df33c..a6a979c7f 100644 --- a/tests/Fixtures/src/Workflow/Header/EmptyHeaderWorkflow.php +++ b/tests/Fixtures/src/Workflow/Header/EmptyHeaderWorkflow.php @@ -11,10 +11,10 @@ namespace Temporal\Tests\Workflow\Header; -use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] final class EmptyHeaderWorkflow { use HandleTrait; diff --git a/tests/Fixtures/src/Workflow/HistoryLengthWorkflow.php b/tests/Fixtures/src/Workflow/HistoryLengthWorkflow.php index 5b613c647..58659c0e6 100644 --- a/tests/Fixtures/src/Workflow/HistoryLengthWorkflow.php +++ b/tests/Fixtures/src/Workflow/HistoryLengthWorkflow.php @@ -15,8 +15,9 @@ use Temporal\Tests\Activity\SimpleActivity; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class HistoryLengthWorkflow { #[WorkflowMethod(name: 'HistoryLengthWorkflow')] diff --git a/tests/Fixtures/src/Workflow/Interceptor/AwaitHeadersWorkflow.php b/tests/Fixtures/src/Workflow/Interceptor/AwaitHeadersWorkflow.php index bb5075447..07e3e0934 100644 --- a/tests/Fixtures/src/Workflow/Interceptor/AwaitHeadersWorkflow.php +++ b/tests/Fixtures/src/Workflow/Interceptor/AwaitHeadersWorkflow.php @@ -13,8 +13,9 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class AwaitHeadersWorkflow { #[WorkflowMethod(name: 'InterceptorAwaitHeaderWorkflow')] diff --git a/tests/Fixtures/src/Workflow/Interceptor/ContinueAsNewHeadersWorkflow.php b/tests/Fixtures/src/Workflow/Interceptor/ContinueAsNewHeadersWorkflow.php index 2bed855c8..a85493d62 100644 --- a/tests/Fixtures/src/Workflow/Interceptor/ContinueAsNewHeadersWorkflow.php +++ b/tests/Fixtures/src/Workflow/Interceptor/ContinueAsNewHeadersWorkflow.php @@ -13,8 +13,9 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class ContinueAsNewHeadersWorkflow { #[WorkflowMethod(name: 'InterceptorContinueAsNewHeaderWorkflow')] diff --git a/tests/Fixtures/src/Workflow/Interceptor/HeadersWorkflow.php b/tests/Fixtures/src/Workflow/Interceptor/HeadersWorkflow.php index cb8ea79ec..272359fdc 100644 --- a/tests/Fixtures/src/Workflow/Interceptor/HeadersWorkflow.php +++ b/tests/Fixtures/src/Workflow/Interceptor/HeadersWorkflow.php @@ -16,8 +16,9 @@ use Temporal\Tests\Activity\SimpleActivity; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class HeadersWorkflow { #[WorkflowMethod(name: 'InterceptorHeaderWorkflow')] diff --git a/tests/Fixtures/src/Workflow/Interceptor/QueryHeadersWorkflow.php b/tests/Fixtures/src/Workflow/Interceptor/QueryHeadersWorkflow.php index 1dfec7db9..0ef4a3b3e 100644 --- a/tests/Fixtures/src/Workflow/Interceptor/QueryHeadersWorkflow.php +++ b/tests/Fixtures/src/Workflow/Interceptor/QueryHeadersWorkflow.php @@ -13,8 +13,11 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\QueryMethod; +use Temporal\Workflow\SignalMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class QueryHeadersWorkflow { private bool $signalled = false; @@ -25,19 +28,19 @@ public function handler(): mixed yield Workflow::await(fn() => $this->signalled); } - #[Workflow\SignalMethod] + #[SignalMethod] public function signal(): void { $this->signalled = true; } - #[Workflow\QueryMethod] + #[QueryMethod] public function getHeaders(): array { return \iterator_to_array(Workflow::getCurrentContext()->getHeader()->getIterator()); } - #[Workflow\QueryMethod] + #[QueryMethod] public function getContext(): array { return [ diff --git a/tests/Fixtures/src/Workflow/Interceptor/SignalHeadersWorkflow.php b/tests/Fixtures/src/Workflow/Interceptor/SignalHeadersWorkflow.php index 73a1b1538..37fc10808 100644 --- a/tests/Fixtures/src/Workflow/Interceptor/SignalHeadersWorkflow.php +++ b/tests/Fixtures/src/Workflow/Interceptor/SignalHeadersWorkflow.php @@ -13,8 +13,10 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\SignalMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class SignalHeadersWorkflow { private ?array $headers = null; @@ -27,7 +29,7 @@ public function handler(): mixed return $this->headers; } - #[Workflow\SignalMethod] + #[SignalMethod] public function signal(): void { $this->signalled = true; diff --git a/tests/Fixtures/src/Workflow/Interceptor/UpdateHeadersWorkflow.php b/tests/Fixtures/src/Workflow/Interceptor/UpdateHeadersWorkflow.php index de454dcb0..13b4672f2 100644 --- a/tests/Fixtures/src/Workflow/Interceptor/UpdateHeadersWorkflow.php +++ b/tests/Fixtures/src/Workflow/Interceptor/UpdateHeadersWorkflow.php @@ -13,8 +13,11 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\QueryMethod; +use Temporal\Workflow\UpdateMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class UpdateHeadersWorkflow { private ?array $headers = null; @@ -30,13 +33,13 @@ public function handler(): mixed return $this->headers; } - #[Workflow\UpdateMethod] + #[UpdateMethod] public function update(): void { $this->updated = true; } - #[Workflow\QueryMethod] + #[QueryMethod] public function headers(): mixed { return $this->headers; diff --git a/tests/Fixtures/src/Workflow/LocalActivityWorkflow.php b/tests/Fixtures/src/Workflow/LocalActivityWorkflow.php index a663580b2..8db5ef67d 100644 --- a/tests/Fixtures/src/Workflow/LocalActivityWorkflow.php +++ b/tests/Fixtures/src/Workflow/LocalActivityWorkflow.php @@ -15,8 +15,9 @@ use Temporal\Tests\Activity\JustLocalActivity; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class LocalActivityWorkflow { #[WorkflowMethod(name: 'LocalActivityWorkflow')] diff --git a/tests/Fixtures/src/Workflow/LoopKillerWorkflow.php b/tests/Fixtures/src/Workflow/LoopKillerWorkflow.php index 3fe2bda81..e5ff04198 100644 --- a/tests/Fixtures/src/Workflow/LoopKillerWorkflow.php +++ b/tests/Fixtures/src/Workflow/LoopKillerWorkflow.php @@ -15,17 +15,20 @@ use Temporal\Common\RetryOptions; use Temporal\Tests\Activity\SimpleActivity; use Temporal\Workflow; +use Temporal\Workflow\WorkflowExecution; +use Temporal\Workflow\WorkflowInterface; +use Temporal\Workflow\WorkflowMethod; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class LoopKillerWorkflow { - #[Workflow\WorkflowMethod] + #[WorkflowMethod] public function run( - Workflow\WorkflowExecution $execution, + WorkflowExecution $execution, bool $truncateRunID = false ) { if ($truncateRunID) { - $execution = new Workflow\WorkflowExecution($execution->getID()); + $execution = new WorkflowExecution($execution->getID()); } $loop = Workflow::newUntypedExternalWorkflowStub( $execution); diff --git a/tests/Fixtures/src/Workflow/LoopSignallingWorkflow.php b/tests/Fixtures/src/Workflow/LoopSignallingWorkflow.php index 36e9e8198..6f9ad3d2b 100644 --- a/tests/Fixtures/src/Workflow/LoopSignallingWorkflow.php +++ b/tests/Fixtures/src/Workflow/LoopSignallingWorkflow.php @@ -15,17 +15,20 @@ use Temporal\Common\RetryOptions; use Temporal\Tests\Activity\SimpleActivity; use Temporal\Workflow; +use Temporal\Workflow\WorkflowExecution; +use Temporal\Workflow\WorkflowInterface; +use Temporal\Workflow\WorkflowMethod; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class LoopSignallingWorkflow { - #[Workflow\WorkflowMethod] + #[WorkflowMethod] public function run( - Workflow\WorkflowExecution $execution, + WorkflowExecution $execution, bool $truncateRunID = false ) { if ($truncateRunID) { - $execution = new Workflow\WorkflowExecution($execution->getID()); + $execution = new WorkflowExecution($execution->getID()); } $loop = Workflow::newExternalWorkflowStub(LoopWorkflow::class, $execution); diff --git a/tests/Fixtures/src/Workflow/LoopWithSignalCoroutinesWorkflow.php b/tests/Fixtures/src/Workflow/LoopWithSignalCoroutinesWorkflow.php index d304a8a5d..bff2d5f12 100644 --- a/tests/Fixtures/src/Workflow/LoopWithSignalCoroutinesWorkflow.php +++ b/tests/Fixtures/src/Workflow/LoopWithSignalCoroutinesWorkflow.php @@ -17,8 +17,9 @@ use Temporal\Workflow; use Temporal\Workflow\SignalMethod; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class LoopWithSignalCoroutinesWorkflow { private array $values = []; diff --git a/tests/Fixtures/src/Workflow/LoopWorkflow.php b/tests/Fixtures/src/Workflow/LoopWorkflow.php index 6cceef348..4e2b77ffc 100644 --- a/tests/Fixtures/src/Workflow/LoopWorkflow.php +++ b/tests/Fixtures/src/Workflow/LoopWorkflow.php @@ -17,8 +17,9 @@ use Temporal\Workflow; use Temporal\Workflow\SignalMethod; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class LoopWorkflow { private array $values = []; diff --git a/tests/Fixtures/src/Workflow/NamedArguments/ActivityNamedArgumentsWorkflow.php b/tests/Fixtures/src/Workflow/NamedArguments/ActivityNamedArgumentsWorkflow.php index ddf59f939..943a7a7ae 100644 --- a/tests/Fixtures/src/Workflow/NamedArguments/ActivityNamedArgumentsWorkflow.php +++ b/tests/Fixtures/src/Workflow/NamedArguments/ActivityNamedArgumentsWorkflow.php @@ -16,8 +16,9 @@ use Temporal\Tests\Activity\SimpleActivity; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class ActivityNamedArgumentsWorkflow { #[WorkflowMethod] diff --git a/tests/Fixtures/src/Workflow/NamedArguments/ChildSignalNamedArgumentsWorkflow.php b/tests/Fixtures/src/Workflow/NamedArguments/ChildSignalNamedArgumentsWorkflow.php index eeb983eea..ff8ea1388 100644 --- a/tests/Fixtures/src/Workflow/NamedArguments/ChildSignalNamedArgumentsWorkflow.php +++ b/tests/Fixtures/src/Workflow/NamedArguments/ChildSignalNamedArgumentsWorkflow.php @@ -4,8 +4,9 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class ChildSignalNamedArgumentsWorkflow { #[WorkflowMethod] diff --git a/tests/Fixtures/src/Workflow/NamedArguments/ContinueAsNewNamedArgumentsWorkflow.php b/tests/Fixtures/src/Workflow/NamedArguments/ContinueAsNewNamedArgumentsWorkflow.php index 118a95ebe..3444280d2 100644 --- a/tests/Fixtures/src/Workflow/NamedArguments/ContinueAsNewNamedArgumentsWorkflow.php +++ b/tests/Fixtures/src/Workflow/NamedArguments/ContinueAsNewNamedArgumentsWorkflow.php @@ -15,8 +15,9 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; use Temporal\Tests\Activity\SimpleActivity; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class ContinueAsNewNamedArgumentsWorkflow { #[WorkflowMethod] diff --git a/tests/Fixtures/src/Workflow/NamedArguments/ExecuteChildNamedArgumentsWorkflow.php b/tests/Fixtures/src/Workflow/NamedArguments/ExecuteChildNamedArgumentsWorkflow.php index 7dd86ee11..d4d3b0c73 100644 --- a/tests/Fixtures/src/Workflow/NamedArguments/ExecuteChildNamedArgumentsWorkflow.php +++ b/tests/Fixtures/src/Workflow/NamedArguments/ExecuteChildNamedArgumentsWorkflow.php @@ -4,8 +4,9 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class ExecuteChildNamedArgumentsWorkflow { #[WorkflowMethod] diff --git a/tests/Fixtures/src/Workflow/NamedArguments/SignalNamedArgumentsWorkflow.php b/tests/Fixtures/src/Workflow/NamedArguments/SignalNamedArgumentsWorkflow.php index 602a7658c..7a95bbdea 100644 --- a/tests/Fixtures/src/Workflow/NamedArguments/SignalNamedArgumentsWorkflow.php +++ b/tests/Fixtures/src/Workflow/NamedArguments/SignalNamedArgumentsWorkflow.php @@ -13,8 +13,10 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\SignalMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class SignalNamedArgumentsWorkflow { private int $int = 0; @@ -37,7 +39,7 @@ public function handler(): \Generator|array ]; } - #[Workflow\SignalMethod] + #[SignalMethod] public function setValues( int $int, string $string = '', diff --git a/tests/Fixtures/src/Workflow/NamedArguments/SimpleNamedArgumentsWorkflow.php b/tests/Fixtures/src/Workflow/NamedArguments/SimpleNamedArgumentsWorkflow.php index 666487daf..c1fa5b52b 100644 --- a/tests/Fixtures/src/Workflow/NamedArguments/SimpleNamedArgumentsWorkflow.php +++ b/tests/Fixtures/src/Workflow/NamedArguments/SimpleNamedArgumentsWorkflow.php @@ -11,10 +11,10 @@ namespace Temporal\Tests\Workflow\NamedArguments; -use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class SimpleNamedArgumentsWorkflow { #[WorkflowMethod] diff --git a/tests/Fixtures/src/Workflow/ParallelScopesWorkflow.php b/tests/Fixtures/src/Workflow/ParallelScopesWorkflow.php index 47b6c6863..9575c3e9a 100644 --- a/tests/Fixtures/src/Workflow/ParallelScopesWorkflow.php +++ b/tests/Fixtures/src/Workflow/ParallelScopesWorkflow.php @@ -16,8 +16,9 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; use Temporal\Tests\Activity\SimpleActivity; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class ParallelScopesWorkflow { #[WorkflowMethod(name: 'ParallelScopesWorkflow')] diff --git a/tests/Fixtures/src/Workflow/ParentWithAbandonedChildWorkflow.php b/tests/Fixtures/src/Workflow/ParentWithAbandonedChildWorkflow.php index ae8e387b5..819043663 100644 --- a/tests/Fixtures/src/Workflow/ParentWithAbandonedChildWorkflow.php +++ b/tests/Fixtures/src/Workflow/ParentWithAbandonedChildWorkflow.php @@ -8,9 +8,10 @@ use Temporal\Workflow\ChildWorkflowOptions; use Temporal\Workflow\ParentClosePolicy; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class ParentWithAbandonedChildWorkflow { #[WorkflowMethod] diff --git a/tests/Fixtures/src/Workflow/Php82TypesWorkflow.php b/tests/Fixtures/src/Workflow/Php82TypesWorkflow.php index f9de6060d..262aebb37 100644 --- a/tests/Fixtures/src/Workflow/Php82TypesWorkflow.php +++ b/tests/Fixtures/src/Workflow/Php82TypesWorkflow.php @@ -16,8 +16,9 @@ use Temporal\Tests\Activity\Php82TypesActivity; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class Php82TypesWorkflow { #[WorkflowMethod(name: 'Php82TypesWorkflow')] diff --git a/tests/Fixtures/src/Workflow/ProtoPayloadWorkflow.php b/tests/Fixtures/src/Workflow/ProtoPayloadWorkflow.php index 6c998c7c7..887520879 100644 --- a/tests/Fixtures/src/Workflow/ProtoPayloadWorkflow.php +++ b/tests/Fixtures/src/Workflow/ProtoPayloadWorkflow.php @@ -16,8 +16,9 @@ use Temporal\Tests\Activity\SimpleActivity; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class ProtoPayloadWorkflow { #[WorkflowMethod(name: 'ProtoPayloadWorkflow')] diff --git a/tests/Fixtures/src/Workflow/QueryWorkflow.php b/tests/Fixtures/src/Workflow/QueryWorkflow.php index 3771e9111..9b9a9dd4a 100644 --- a/tests/Fixtures/src/Workflow/QueryWorkflow.php +++ b/tests/Fixtures/src/Workflow/QueryWorkflow.php @@ -13,20 +13,23 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\QueryMethod; +use Temporal\Workflow\SignalMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class QueryWorkflow { private int $counter = 0; - #[Workflow\SignalMethod(name: "add")] + #[SignalMethod(name: "add")] public function add( int $value ) { $this->counter += $value; } - #[Workflow\QueryMethod(name: "get")] + #[QueryMethod(name: "get")] public function get(): int { return $this->counter; diff --git a/tests/Fixtures/src/Workflow/RuntimeSignalWorkflow.php b/tests/Fixtures/src/Workflow/RuntimeSignalWorkflow.php index 2964d3b8e..e064d78a7 100644 --- a/tests/Fixtures/src/Workflow/RuntimeSignalWorkflow.php +++ b/tests/Fixtures/src/Workflow/RuntimeSignalWorkflow.php @@ -14,8 +14,9 @@ use React\Promise\Deferred; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class RuntimeSignalWorkflow { #[WorkflowMethod] diff --git a/tests/Fixtures/src/Workflow/SagaWorkflow.php b/tests/Fixtures/src/Workflow/SagaWorkflow.php index 6d1886172..b50ae8025 100644 --- a/tests/Fixtures/src/Workflow/SagaWorkflow.php +++ b/tests/Fixtures/src/Workflow/SagaWorkflow.php @@ -15,11 +15,14 @@ use Temporal\Common\RetryOptions; use Temporal\Tests\Activity\SimpleActivity; use Temporal\Workflow; +use Temporal\Workflow\Saga; +use Temporal\Workflow\WorkflowInterface; +use Temporal\Workflow\WorkflowMethod; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class SagaWorkflow { - #[Workflow\WorkflowMethod(name: 'SagaWorkflow')] + #[WorkflowMethod(name: 'SagaWorkflow')] public function run() { $simple = Workflow::newActivityStub( @@ -29,7 +32,7 @@ public function run() ->withRetryOptions(RetryOptions::new()->withMaximumAttempts(1)) ); - $saga = new Workflow\Saga(); + $saga = new Saga(); $saga->setParallelCompensation(true); try { diff --git a/tests/Fixtures/src/Workflow/ScalarEnumWorkflow.php b/tests/Fixtures/src/Workflow/ScalarEnumWorkflow.php index e2b6c957f..d44458323 100644 --- a/tests/Fixtures/src/Workflow/ScalarEnumWorkflow.php +++ b/tests/Fixtures/src/Workflow/ScalarEnumWorkflow.php @@ -17,8 +17,9 @@ use Temporal\Tests\Unit\DTO\Type\EnumType\Stub\ScalarEnum; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class ScalarEnumWorkflow { #[WorkflowMethod(name: 'ScalarEnumWorkflow')] diff --git a/tests/Fixtures/src/Workflow/SideEffectWorkflow.php b/tests/Fixtures/src/Workflow/SideEffectWorkflow.php index 3f8474d4e..ca8268d92 100644 --- a/tests/Fixtures/src/Workflow/SideEffectWorkflow.php +++ b/tests/Fixtures/src/Workflow/SideEffectWorkflow.php @@ -15,8 +15,9 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; use Temporal\Tests\Activity\SimpleActivity; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class SideEffectWorkflow { #[WorkflowMethod(name: 'SideEffectWorkflow')] diff --git a/tests/Fixtures/src/Workflow/SignalChildViaStubWorkflow.php b/tests/Fixtures/src/Workflow/SignalChildViaStubWorkflow.php index 13115f93d..d2e8ef2a1 100644 --- a/tests/Fixtures/src/Workflow/SignalChildViaStubWorkflow.php +++ b/tests/Fixtures/src/Workflow/SignalChildViaStubWorkflow.php @@ -13,8 +13,9 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class SignalChildViaStubWorkflow { #[WorkflowMethod(name: 'SignalChildViaStubWorkflow')] diff --git a/tests/Fixtures/src/Workflow/SimpleDTOWorkflow.php b/tests/Fixtures/src/Workflow/SimpleDTOWorkflow.php index 084f5b953..c68ee7a77 100644 --- a/tests/Fixtures/src/Workflow/SimpleDTOWorkflow.php +++ b/tests/Fixtures/src/Workflow/SimpleDTOWorkflow.php @@ -17,12 +17,14 @@ use Temporal\Tests\Activity\SimpleActivity; use Temporal\Tests\DTO\Message; use Temporal\Tests\DTO\User; +use Temporal\Workflow\ReturnType; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class SimpleDTOWorkflow { #[WorkflowMethod(name: 'SimpleDTOWorkflow')] - #[Workflow\ReturnType(Message::class)] + #[ReturnType(Message::class)] public function handler( User $user ) { diff --git a/tests/Fixtures/src/Workflow/SimpleEnumWorkflow.php b/tests/Fixtures/src/Workflow/SimpleEnumWorkflow.php index 36d5aed36..d70b3bfbf 100644 --- a/tests/Fixtures/src/Workflow/SimpleEnumWorkflow.php +++ b/tests/Fixtures/src/Workflow/SimpleEnumWorkflow.php @@ -17,8 +17,9 @@ use Temporal\Tests\Unit\DTO\Type\EnumType\Stub\SimpleEnum; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class SimpleEnumWorkflow { #[WorkflowMethod(name: 'SimpleEnumWorkflow')] diff --git a/tests/Fixtures/src/Workflow/SimpleHeartbeatWorkflow.php b/tests/Fixtures/src/Workflow/SimpleHeartbeatWorkflow.php index 8cbf1f233..60da69163 100644 --- a/tests/Fixtures/src/Workflow/SimpleHeartbeatWorkflow.php +++ b/tests/Fixtures/src/Workflow/SimpleHeartbeatWorkflow.php @@ -15,8 +15,9 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; use Temporal\Tests\Activity\HeartBeatActivity; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class SimpleHeartbeatWorkflow { #[WorkflowMethod(name: 'SimpleHeartbeatWorkflow')] diff --git a/tests/Fixtures/src/Workflow/SimpleSignaledWorkflow.php b/tests/Fixtures/src/Workflow/SimpleSignaledWorkflow.php index 0e7a95869..1639d0b00 100644 --- a/tests/Fixtures/src/Workflow/SimpleSignaledWorkflow.php +++ b/tests/Fixtures/src/Workflow/SimpleSignaledWorkflow.php @@ -13,13 +13,15 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\SignalMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class SimpleSignaledWorkflow { private $counter = 0; - #[Workflow\SignalMethod(name: "add")] + #[SignalMethod(name: "add")] public function add( int $value ) { diff --git a/tests/Fixtures/src/Workflow/SimpleSignalledWorkflow.php b/tests/Fixtures/src/Workflow/SimpleSignalledWorkflow.php index 9e4475883..a355afd65 100644 --- a/tests/Fixtures/src/Workflow/SimpleSignalledWorkflow.php +++ b/tests/Fixtures/src/Workflow/SimpleSignalledWorkflow.php @@ -13,13 +13,15 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\SignalMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class SimpleSignalledWorkflow { private $counter = 0; - #[Workflow\SignalMethod(name: "add")] + #[SignalMethod(name: "add")] public function add( int $value ) { diff --git a/tests/Fixtures/src/Workflow/SimpleSignalledWorkflowWithSleep.php b/tests/Fixtures/src/Workflow/SimpleSignalledWorkflowWithSleep.php index 7b1b43e68..3586d4359 100644 --- a/tests/Fixtures/src/Workflow/SimpleSignalledWorkflowWithSleep.php +++ b/tests/Fixtures/src/Workflow/SimpleSignalledWorkflowWithSleep.php @@ -13,13 +13,15 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\SignalMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class SimpleSignalledWorkflowWithSleep { private $counter = 0; - #[Workflow\SignalMethod(name: "add")] + #[SignalMethod(name: "add")] public function add( int $value ) { diff --git a/tests/Fixtures/src/Workflow/SimpleUuidWorkflow.php b/tests/Fixtures/src/Workflow/SimpleUuidWorkflow.php index e5b80bd3a..491fe9211 100644 --- a/tests/Fixtures/src/Workflow/SimpleUuidWorkflow.php +++ b/tests/Fixtures/src/Workflow/SimpleUuidWorkflow.php @@ -15,12 +15,14 @@ use Ramsey\Uuid\UuidInterface; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\ReturnType; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class SimpleUuidWorkflow { #[WorkflowMethod(name: 'SimpleUuidWorkflow')] - #[Workflow\ReturnType(UuidInterface::class)] + #[ReturnType(UuidInterface::class)] public function handler(UuidInterface $uuid) { // Side effect diff --git a/tests/Fixtures/src/Workflow/SimpleWorkflow.php b/tests/Fixtures/src/Workflow/SimpleWorkflow.php index 3dd731bd3..a7382bf19 100644 --- a/tests/Fixtures/src/Workflow/SimpleWorkflow.php +++ b/tests/Fixtures/src/Workflow/SimpleWorkflow.php @@ -16,8 +16,9 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; use Temporal\Tests\Activity\SimpleActivity; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class SimpleWorkflow { #[WorkflowMethod(name: 'SimpleWorkflow')] diff --git a/tests/Fixtures/src/Workflow/TestContextLeakWorkflow.php b/tests/Fixtures/src/Workflow/TestContextLeakWorkflow.php index 314b3a8c0..829a828d4 100644 --- a/tests/Fixtures/src/Workflow/TestContextLeakWorkflow.php +++ b/tests/Fixtures/src/Workflow/TestContextLeakWorkflow.php @@ -19,10 +19,13 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowExecution; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\QueryMethod; +use Temporal\Workflow\SignalMethod; +use Temporal\Workflow\WorkflowInterface; use function React\Promise\resolve; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class TestContextLeakWorkflow { private string $workflowId = ''; @@ -46,7 +49,7 @@ public function handler(): iterable return $timer; } - #[Workflow\SignalMethod] + #[SignalMethod] public function cancel(): void { $this->checkContext(); @@ -54,7 +57,7 @@ public function cancel(): void $this->checkContext(); } - #[Workflow\QueryMethod()] + #[QueryMethod()] public function wakeup(): DateTimeInterface { $this->checkContext(); diff --git a/tests/Fixtures/src/Workflow/TimerWayWorkflow.php b/tests/Fixtures/src/Workflow/TimerWayWorkflow.php index 983e43eaa..8f1fff0b5 100644 --- a/tests/Fixtures/src/Workflow/TimerWayWorkflow.php +++ b/tests/Fixtures/src/Workflow/TimerWayWorkflow.php @@ -13,8 +13,9 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class TimerWayWorkflow { #[WorkflowMethod(name: 'TimerWayWorkflow')] diff --git a/tests/Fixtures/src/Workflow/TimerWorkflow.php b/tests/Fixtures/src/Workflow/TimerWorkflow.php index b82ac67fd..89e3496b7 100644 --- a/tests/Fixtures/src/Workflow/TimerWorkflow.php +++ b/tests/Fixtures/src/Workflow/TimerWorkflow.php @@ -15,11 +15,12 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; use Temporal\Tests\Activity\SimpleActivity; +use Temporal\Workflow\WorkflowInterface; /** * @see \Temporal\Tests\Functional\WorkflowTestCase::testTimer() */ -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class TimerWorkflow { #[WorkflowMethod(name: 'TimerWorkflow')] diff --git a/tests/Fixtures/src/Workflow/UpdateExceptionsWorkflow.php b/tests/Fixtures/src/Workflow/UpdateExceptionsWorkflow.php index 268618d3b..5577bdf5d 100644 --- a/tests/Fixtures/src/Workflow/UpdateExceptionsWorkflow.php +++ b/tests/Fixtures/src/Workflow/UpdateExceptionsWorkflow.php @@ -19,6 +19,7 @@ use Temporal\Workflow\SignalMethod; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\UpdateMethod; #[WorkflowInterface] class UpdateExceptionsWorkflow @@ -41,21 +42,21 @@ public function greet() } } - #[Workflow\UpdateMethod] + #[UpdateMethod] public function failWithName(string $name): void { $this->greetings[] = $name; throw new \RuntimeException("Signal exception $name"); } - #[Workflow\UpdateMethod] + #[UpdateMethod] public function failInvalidArgument($name = 'foo'): void { $this->greetings[] = "invalidArgument $name"; throw new InvalidArgumentException("Invalid argument $name"); } - #[Workflow\UpdateMethod] + #[UpdateMethod] public function failActivity($name = 'foo') { yield Workflow::newUntypedActivityStub( @@ -68,7 +69,7 @@ public function failActivity($name = 'foo') )->execute('nonExistingActivityName', [$name]); } - #[Workflow\UpdateMethod] + #[UpdateMethod] public function error() { yield Workflow::timer(CarbonInterval::millisecond(10)); diff --git a/tests/Fixtures/src/Workflow/UpdateWorkflow.php b/tests/Fixtures/src/Workflow/UpdateWorkflow.php index 2d5d47e45..25c1fba9e 100644 --- a/tests/Fixtures/src/Workflow/UpdateWorkflow.php +++ b/tests/Fixtures/src/Workflow/UpdateWorkflow.php @@ -19,6 +19,10 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowInterface; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\ReturnType; +use Temporal\Workflow\SignalMethod; +use Temporal\Workflow\UpdateMethod; +use Temporal\Workflow\UpdateValidatorMethod; #[WorkflowInterface] class UpdateWorkflow @@ -33,21 +37,21 @@ public function greet() return $this->greetings; } - #[Workflow\UpdateMethod] + #[UpdateMethod] public function addNameWithoutValidation(string $name): mixed { $this->greetings[] = $result = \sprintf('Hello, %s!', $name); return $result; } - #[Workflow\UpdateMethod] + #[UpdateMethod] public function addName(string $name): mixed { $this->greetings[] = $result = \sprintf('Hello, %s!', $name); return $result; } - #[Workflow\UpdateValidatorMethod(forUpdate: 'addName')] + #[UpdateValidatorMethod(forUpdate: 'addName')] public function validateName(string $name): void { if (\preg_match('/\\d/', $name) === 1) { @@ -55,7 +59,7 @@ public function validateName(string $name): void } } - #[Workflow\UpdateMethod] + #[UpdateMethod] public function randomizeName(int $count = 1): mixed { $promises = []; @@ -72,7 +76,7 @@ function (string $greeting) { return $this->greetings; } - #[Workflow\UpdateMethod] + #[UpdateMethod] public function addNameViaActivity(string $name): mixed { $name = yield Workflow::newActivityStub( @@ -83,33 +87,33 @@ public function addNameViaActivity(string $name): mixed return $result; } - #[Workflow\UpdateMethod] + #[UpdateMethod] public function throwException(string $name): mixed { throw new \Exception("Test exception with $name"); } - #[Workflow\UpdateMethod] + #[UpdateMethod] public function returnNilUuid(): UuidInterface { return Uuid::fromString(Uuid::NIL); } - #[Workflow\UpdateMethod] - #[Workflow\ReturnType(UuidInterface::class)] + #[UpdateMethod] + #[ReturnType(UuidInterface::class)] public function returnUuid(UuidInterface $datetime) { return $datetime; } - #[Workflow\UpdateMethod] - #[Workflow\ReturnType('object')] + #[UpdateMethod] + #[ReturnType('object')] public function returnAsObject(mixed $mixed): object { return (object)(array)$mixed; } - #[Workflow\SignalMethod] + #[SignalMethod] public function exit(): void { $this->exit = true; diff --git a/tests/Fixtures/src/Workflow/UpsertSearchAttributesWorkflow.php b/tests/Fixtures/src/Workflow/UpsertSearchAttributesWorkflow.php index f046ff6e7..b1a65d151 100644 --- a/tests/Fixtures/src/Workflow/UpsertSearchAttributesWorkflow.php +++ b/tests/Fixtures/src/Workflow/UpsertSearchAttributesWorkflow.php @@ -15,8 +15,9 @@ use Temporal\Tests\Activity\SampleActivityInterface; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class UpsertSearchAttributesWorkflow { #[WorkflowMethod] diff --git a/tests/Fixtures/src/Workflow/VoidActivityStubWorkflow.php b/tests/Fixtures/src/Workflow/VoidActivityStubWorkflow.php index 4b5796256..1e958e4e8 100644 --- a/tests/Fixtures/src/Workflow/VoidActivityStubWorkflow.php +++ b/tests/Fixtures/src/Workflow/VoidActivityStubWorkflow.php @@ -15,8 +15,9 @@ use Temporal\Tests\Activity\SimpleActivity; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class VoidActivityStubWorkflow { #[WorkflowMethod(name: 'VoidActivityStubWorkflow')] diff --git a/tests/Fixtures/src/Workflow/WithChildStubWorkflow.php b/tests/Fixtures/src/Workflow/WithChildStubWorkflow.php index e2fa9b908..58f3ca2d8 100644 --- a/tests/Fixtures/src/Workflow/WithChildStubWorkflow.php +++ b/tests/Fixtures/src/Workflow/WithChildStubWorkflow.php @@ -13,8 +13,9 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class WithChildStubWorkflow { #[WorkflowMethod(name: 'WithChildStubWorkflow')] diff --git a/tests/Fixtures/src/Workflow/WithChildWorkflow.php b/tests/Fixtures/src/Workflow/WithChildWorkflow.php index bcd5e82cc..29f64f06c 100644 --- a/tests/Fixtures/src/Workflow/WithChildWorkflow.php +++ b/tests/Fixtures/src/Workflow/WithChildWorkflow.php @@ -13,8 +13,10 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\ChildWorkflowOptions; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class WithChildWorkflow { #[WorkflowMethod(name: 'WithChildWorkflow')] @@ -24,7 +26,7 @@ public function handler( $result = yield Workflow::executeChildWorkflow( 'SimpleWorkflow', ['child ' . $input], - Workflow\ChildWorkflowOptions::new(), + ChildWorkflowOptions::new(), ); return 'Child: ' . $result; diff --git a/tests/Fixtures/src/Workflow/WorkflowWithSequence.php b/tests/Fixtures/src/Workflow/WorkflowWithSequence.php index fdb74af81..d4e1ff27b 100644 --- a/tests/Fixtures/src/Workflow/WorkflowWithSequence.php +++ b/tests/Fixtures/src/Workflow/WorkflowWithSequence.php @@ -15,8 +15,9 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; use Temporal\Tests\Activity\SimpleActivity; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class WorkflowWithSequence { #[WorkflowMethod(name: 'WorkflowWithSequence')] diff --git a/tests/Fixtures/src/Workflow/WorkflowWithSignalledSteps.php b/tests/Fixtures/src/Workflow/WorkflowWithSignalledSteps.php index 13c7a5a25..ced06dfcf 100644 --- a/tests/Fixtures/src/Workflow/WorkflowWithSignalledSteps.php +++ b/tests/Fixtures/src/Workflow/WorkflowWithSignalledSteps.php @@ -17,8 +17,9 @@ use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; use Temporal\Tests\Activity\SimpleActivity; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class WorkflowWithSignalledSteps { #[WorkflowMethod(name: 'WorkflowWithSignalledSteps')] diff --git a/tests/Fixtures/src/Workflow/YieldGeneratorWorkflow.php b/tests/Fixtures/src/Workflow/YieldGeneratorWorkflow.php index 54a05da2f..5cc3efe4d 100644 --- a/tests/Fixtures/src/Workflow/YieldGeneratorWorkflow.php +++ b/tests/Fixtures/src/Workflow/YieldGeneratorWorkflow.php @@ -15,10 +15,11 @@ use Temporal\Tests\Activity\SimpleActivity; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; use function React\Promise\resolve; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class YieldGeneratorWorkflow { #[WorkflowMethod(name: 'YieldGeneratorWorkflow')] diff --git a/tests/Fixtures/src/Workflow/YieldScalarsWorkflow.php b/tests/Fixtures/src/Workflow/YieldScalarsWorkflow.php index a5eec7197..e9d19ead2 100644 --- a/tests/Fixtures/src/Workflow/YieldScalarsWorkflow.php +++ b/tests/Fixtures/src/Workflow/YieldScalarsWorkflow.php @@ -11,10 +11,10 @@ namespace Temporal\Tests\Workflow; -use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; -#[Workflow\WorkflowInterface] +#[WorkflowInterface] class YieldScalarsWorkflow { #[WorkflowMethod(name: 'YieldScalarsWorkflow')] diff --git a/tests/Unit/Framework/WorkerFactoryMock.php b/tests/Unit/Framework/WorkerFactoryMock.php index 07b1779e9..448d37bfe 100644 --- a/tests/Unit/Framework/WorkerFactoryMock.php +++ b/tests/Unit/Framework/WorkerFactoryMock.php @@ -28,6 +28,7 @@ use Temporal\Internal\ServiceContainer; use Temporal\Internal\Transport\ClientInterface; use Temporal\Internal\Transport\Router; +use Temporal\Internal\Transport\Router\GetWorkerInfo; use Temporal\Internal\Transport\RouterInterface; use Temporal\Internal\Transport\Server; use Temporal\Internal\Transport\ServerInterface; @@ -193,7 +194,7 @@ private function createReader(): ReaderInterface private function createRouter(): RouterInterface { $router = new Router(); - $router->add(new Router\GetWorkerInfo($this->queues, $this->marshaller, ServiceCredentials::create())); + $router->add(new GetWorkerInfo($this->queues, $this->marshaller, ServiceCredentials::create())); return $router; } diff --git a/tests/Unit/Framework/WorkerMock.php b/tests/Unit/Framework/WorkerMock.php index d09ff2976..66aa73ebb 100644 --- a/tests/Unit/Framework/WorkerMock.php +++ b/tests/Unit/Framework/WorkerMock.php @@ -13,6 +13,10 @@ use Temporal\Internal\Queue\QueueInterface; use Temporal\Internal\ServiceContainer; use Temporal\Internal\Transport\Router; +use Temporal\Internal\Transport\Router\DestroyWorkflow; +use Temporal\Internal\Transport\Router\InvokeActivity; +use Temporal\Internal\Transport\Router\InvokeSignal as InvokeSignalRoute; +use Temporal\Internal\Transport\Router\StartWorkflow as StartWorkflowRoute; use Temporal\Internal\Transport\RouterInterface; use Temporal\Tests\Unit\Framework\Expectation\ActivityCall; use Temporal\Tests\Unit\Framework\Expectation\Timer; @@ -200,10 +204,10 @@ public function registerActivityFinalizer(\Closure $finalizer): WorkerInterface private function createRouter(): RouterInterface { $router = new Router(); - $router->add(new Router\StartWorkflow($this->services)); - $router->add(new Router\InvokeActivity($this->services, Goridge::create(), $this->interceptorProvider)); - $router->add(new Router\DestroyWorkflow($this->services->running, $this->services->loop)); - $router->add(new Router\InvokeSignal($this->services->running)); + $router->add(new StartWorkflowRoute($this->services)); + $router->add(new InvokeActivity($this->services, Goridge::create(), $this->interceptorProvider)); + $router->add(new DestroyWorkflow($this->services->running, $this->services->loop)); + $router->add(new InvokeSignalRoute($this->services->running)); return $router; } diff --git a/tests/Unit/Framework/WorkerTestCase.php b/tests/Unit/Framework/WorkerTestCase.php index 63e2e51f6..f959c4ee1 100644 --- a/tests/Unit/Framework/WorkerTestCase.php +++ b/tests/Unit/Framework/WorkerTestCase.php @@ -9,6 +9,7 @@ use Temporal\Worker\WorkerInterface; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; use function PHPUnit\Framework\assertFalse; @@ -33,7 +34,7 @@ public function testRunWorker(): void { $this->worker->registerWorkflowObject( new - #[Workflow\WorkflowInterface] + #[WorkflowInterface] class { #[WorkflowMethod(name: 'SimpleWorkflow')] public function handler(): iterable diff --git a/tests/Unit/Internal/Support/DateIntervalTestCase.php b/tests/Unit/Internal/Support/DateIntervalTestCase.php index 270b7dcac..385109dff 100644 --- a/tests/Unit/Internal/Support/DateIntervalTestCase.php +++ b/tests/Unit/Internal/Support/DateIntervalTestCase.php @@ -7,6 +7,7 @@ use PHPUnit\Framework\Attributes\CoversClass; use PHPUnit\Framework\Attributes\DataProvider; use PHPUnit\Framework\TestCase; +use Carbon\CarbonInterval; use Temporal\Internal\Support\DateInterval; #[CoversClass(DateInterval::class)] @@ -156,7 +157,7 @@ public function testParseTriggersWarningWhenCarbonAndDateIntervalDiffer( } // Assert - self::assertInstanceOf(\Carbon\CarbonInterval::class, $result); + self::assertInstanceOf(CarbonInterval::class, $result); if ($shouldTriggerWarning) { self::assertTrue( @@ -221,7 +222,7 @@ public function testParseDoesNotTriggerWarningForNonIso8601Formats(string $inter } // Assert - self::assertInstanceOf(\Carbon\CarbonInterval::class, $result); + self::assertInstanceOf(CarbonInterval::class, $result); self::assertFalse( $warningTriggered, \sprintf( diff --git a/tests/Unit/Internal/Support/WorkflowFacadeTest.php b/tests/Unit/Internal/Support/WorkflowFacadeTest.php index 259cdd095..e5268603d 100644 --- a/tests/Unit/Internal/Support/WorkflowFacadeTest.php +++ b/tests/Unit/Internal/Support/WorkflowFacadeTest.php @@ -9,6 +9,7 @@ use PHPUnit\Framework\TestCase; use Temporal\Exception\OutOfContextException; use Temporal\Workflow; +use Temporal\Workflow\WorkflowExecution; class WorkflowFacadeTest extends TestCase { @@ -62,7 +63,7 @@ public static function outOfContextMethods(): iterable ]; yield 'newExternalWorkflowStub' => [ - static fn() => Workflow::newExternalWorkflowStub('test', new Workflow\WorkflowExecution()), + static fn() => Workflow::newExternalWorkflowStub('test', new WorkflowExecution()), ]; yield 'continueAsNew' => [ @@ -173,7 +174,7 @@ public static function outOfContextMethods(): iterable ]; yield 'newUntypedExternalWorkflowStub' => [ - static fn() => Workflow::newUntypedExternalWorkflowStub(new Workflow\WorkflowExecution()), + static fn() => Workflow::newUntypedExternalWorkflowStub(new WorkflowExecution()), ]; yield 'upsertTypedSearchAttributes' => [ diff --git a/tests/Unit/Router/DummyWorkflow.php b/tests/Unit/Router/DummyWorkflow.php index 57d8bca41..c0f72b3b0 100644 --- a/tests/Unit/Router/DummyWorkflow.php +++ b/tests/Unit/Router/DummyWorkflow.php @@ -4,12 +4,13 @@ namespace Temporal\Tests\Unit\Router; -use Temporal\Workflow; +use Temporal\Workflow\WorkflowInterface; +use Temporal\Workflow\WorkflowMethod; -#[Workflow\WorkflowInterface()] +#[WorkflowInterface()] final class DummyWorkflow { - #[Workflow\WorkflowMethod] + #[WorkflowMethod] public function doNothing(): void { } diff --git a/tests/Unit/Schedule/Mapper/WorkflowExecutionInfoMapperTestCase.php b/tests/Unit/Schedule/Mapper/WorkflowExecutionInfoMapperTestCase.php index 110af0972..7f197a77e 100644 --- a/tests/Unit/Schedule/Mapper/WorkflowExecutionInfoMapperTestCase.php +++ b/tests/Unit/Schedule/Mapper/WorkflowExecutionInfoMapperTestCase.php @@ -7,10 +7,23 @@ use PHPUnit\Framework\Attributes\CoversClass; use PHPUnit\Framework\TestCase; use Spiral\Attributes\AttributeReader; +use Carbon\CarbonInterval; use Temporal\Api\Enums\V1\ScheduleOverlapPolicy; use Temporal\Api\Workflow\V1\NewWorkflowExecutionInfo; -use Temporal\Client\Schedule; -use Temporal\Api\Schedule\V1; +use Temporal\Api\Schedule\V1\CalendarSpec as V1CalendarSpec; +use Temporal\Api\Schedule\V1\IntervalSpec as V1IntervalSpec; +use Temporal\Api\Schedule\V1\Schedule as V1Schedule; +use Temporal\Api\Schedule\V1\ScheduleAction as V1ScheduleAction; +use Temporal\Api\Schedule\V1\SchedulePolicies as V1SchedulePolicies; +use Temporal\Api\Schedule\V1\ScheduleSpec as V1ScheduleSpec; +use Temporal\Api\Schedule\V1\ScheduleState as V1ScheduleState; +use Temporal\Client\Schedule\Action\StartWorkflowAction; +use Temporal\Client\Schedule\Policy\ScheduleOverlapPolicy as ClientScheduleOverlapPolicy; +use Temporal\Client\Schedule\Policy\SchedulePolicies; +use Temporal\Client\Schedule\Schedule; +use Temporal\Client\Schedule\Spec\CalendarSpec; +use Temporal\Client\Schedule\Spec\ScheduleSpec; +use Temporal\Client\Schedule\Spec\ScheduleState; use Temporal\Common\IdReusePolicy; use Temporal\Common\RetryOptions; use Temporal\DataConverter\DataConverter; @@ -30,15 +43,15 @@ public function testToMessage(): void $mapper = $this->createMapper(); $schedule = $mapper->toMessage( - Schedule\Schedule::new()->withAction( - Schedule\Action\StartWorkflowAction::new('PingSite') + Schedule::new()->withAction( + StartWorkflowAction::new('PingSite') ->withInput(['google.com']) ->withTaskQueue('default') ->withRetryPolicy( RetryOptions::new() ->withMaximumAttempts(3) - ->withInitialInterval(\Carbon\CarbonInterval::seconds(10)) - ->withMaximumInterval(\Carbon\CarbonInterval::seconds(20)), + ->withInitialInterval(CarbonInterval::seconds(10)) + ->withMaximumInterval(CarbonInterval::seconds(20)), ) ->withHeader(['foo' => 'bar']) ->withWorkflowExecutionTimeout('40m') @@ -51,9 +64,9 @@ public function testToMessage(): void IdReusePolicy::AllowDuplicateFailedOnly, ), )->withSpec( - Schedule\Spec\ScheduleSpec::new() + ScheduleSpec::new() ->withCalendarList( - Schedule\Spec\CalendarSpec::new() + CalendarSpec::new() ->withSecond(6)->withMinute('*/6')->withHour('*/5') ->withDayOfWeek('*/2')->withDayOfMonth('*/4')->withMonth('*/3') ->withComment('test comment'), @@ -66,12 +79,12 @@ public function testToMessage(): void ->withTimezoneData('America/New_York') ->withTimezoneName('Europe/London'), )->withPolicies( - Schedule\Policy\SchedulePolicies::new() + SchedulePolicies::new() ->withCatchupWindow('10m') ->withPauseOnFailure(true) - ->withOverlapPolicy(Schedule\Policy\ScheduleOverlapPolicy::CancelOther), + ->withOverlapPolicy(ClientScheduleOverlapPolicy::CancelOther), )->withState( - Schedule\Spec\ScheduleState::new() + ScheduleState::new() ->withLimitedActions(true) ->withRemainingActions(10) ->withPaused(true) @@ -79,16 +92,16 @@ public function testToMessage(): void ), ); - $this->assertInstanceOf(V1\Schedule::class, $schedule); + $this->assertInstanceOf(V1Schedule::class, $schedule); $spec = $schedule->getSpec(); $state = $schedule->getState(); $policies = $schedule->getPolicies(); - $this->assertInstanceOf(V1\ScheduleSpec::class, $spec); - $this->assertInstanceOf(V1\ScheduleState::class, $state); - $this->assertInstanceOf(V1\SchedulePolicies::class, $policies); + $this->assertInstanceOf(V1ScheduleSpec::class, $spec); + $this->assertInstanceOf(V1ScheduleState::class, $state); + $this->assertInstanceOf(V1SchedulePolicies::class, $policies); // Test Action - $this->assertInstanceOf(V1\ScheduleAction::class, $schedule->getAction()); + $this->assertInstanceOf(V1ScheduleAction::class, $schedule->getAction()); $this->assertSame('start_workflow', $schedule->getAction()->getAction()); $startWorkflow = $schedule->getAction()->getStartWorkflow(); $this->assertInstanceOf(NewWorkflowExecutionInfo::class, $startWorkflow); @@ -129,7 +142,7 @@ public function testToMessage(): void // Test Spec // Calendar $dto = $spec->getCalendar()[0]; - $this->assertInstanceOf(V1\CalendarSpec::class, $dto); + $this->assertInstanceOf(V1CalendarSpec::class, $dto); $this->assertEquals('test comment', $dto->getComment()); $this->assertEquals(6, $dto->getSecond()); $this->assertEquals('*/6', $dto->getMinute()); @@ -142,10 +155,10 @@ public function testToMessage(): void $this->assertEquals('0 12 * * 1', $spec->getCronString()[1]); // Interval $dto = $spec->getInterval()[0]; - $this->assertInstanceOf(V1\IntervalSpec::class, $dto); + $this->assertInstanceOf(V1IntervalSpec::class, $dto); $this->assertEquals(120, $dto->getInterval()->getSeconds()); $dto = $spec->getInterval()[1]; - $this->assertInstanceOf(V1\IntervalSpec::class, $dto); + $this->assertInstanceOf(V1IntervalSpec::class, $dto); $this->assertEquals(180, $dto->getInterval()->getSeconds()); // StartTime and StopTime $this->assertEquals(172800, $spec->getStartTime()->getSeconds()); @@ -173,21 +186,21 @@ public function testToMessageEmptyValues(): void $mapper = $this->createMapper(); $schedule = $mapper->toMessage( - Schedule\Schedule::new()->withAction( - Schedule\Action\StartWorkflowAction::new('PingSite'), + Schedule::new()->withAction( + StartWorkflowAction::new('PingSite'), ), ); - $this->assertInstanceOf(V1\Schedule::class, $schedule); + $this->assertInstanceOf(V1Schedule::class, $schedule); $spec = $schedule->getSpec(); $state = $schedule->getState(); $policies = $schedule->getPolicies(); - $this->assertInstanceOf(V1\ScheduleSpec::class, $spec); - $this->assertInstanceOf(V1\ScheduleState::class, $state); - $this->assertInstanceOf(V1\SchedulePolicies::class, $policies); + $this->assertInstanceOf(V1ScheduleSpec::class, $spec); + $this->assertInstanceOf(V1ScheduleState::class, $state); + $this->assertInstanceOf(V1SchedulePolicies::class, $policies); // Test Action - $this->assertInstanceOf(V1\ScheduleAction::class, $schedule->getAction()); + $this->assertInstanceOf(V1ScheduleAction::class, $schedule->getAction()); $this->assertSame('start_workflow', $schedule->getAction()->getAction()); $startWorkflow = $schedule->getAction()->getStartWorkflow(); $this->assertInstanceOf(NewWorkflowExecutionInfo::class, $startWorkflow); diff --git a/tests/Unit/WorkflowContext/AwaitWithTimeoutTestCase.php b/tests/Unit/WorkflowContext/AwaitWithTimeoutTestCase.php index 30ef4348f..f51e0eefb 100644 --- a/tests/Unit/WorkflowContext/AwaitWithTimeoutTestCase.php +++ b/tests/Unit/WorkflowContext/AwaitWithTimeoutTestCase.php @@ -11,6 +11,8 @@ use Temporal\Worker\WorkerInterface; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\SignalMethod; +use Temporal\Workflow\WorkflowInterface; use function PHPUnit\Framework\assertFalse; use function PHPUnit\Framework\assertTrue; @@ -33,7 +35,7 @@ public function testAwaitWithTimeoutReturnsFalseIfTimeoutWasOff(): void { $this->worker->registerWorkflowObject( new - #[Workflow\WorkflowInterface] + #[WorkflowInterface] class { #[WorkflowMethod(name: 'AwaitWorkflow')] public function handler(): iterable @@ -57,7 +59,7 @@ public function testAwaitWithTimeoutStartsTimerWithConditionIsNotMet(): void $this->worker->registerWorkflowObject( new - #[Workflow\WorkflowInterface] + #[WorkflowInterface] class { #[WorkflowMethod(name: 'AwaitWorkflow')] public function handler(): iterable @@ -78,7 +80,7 @@ public function testAwaitWithTimeoutReturnsTrueWithMetCondition(): void { $this->worker->registerWorkflowObject( new - #[Workflow\WorkflowInterface] + #[WorkflowInterface] class { #[WorkflowMethod(name: 'AwaitWorkflow')] public function handler(): iterable @@ -100,7 +102,7 @@ public function testTimerIsCanceledOnceConditionIsMet(): void $this->addToAssertionCount(1); $this->worker->registerWorkflowObject( new - #[Workflow\WorkflowInterface] + #[WorkflowInterface] class { private bool $doCancel = false; #[WorkflowMethod(name: 'AwaitWorkflow')] @@ -119,7 +121,7 @@ public function handler(): iterable return 'OK'; } - #[Workflow\SignalMethod] + #[SignalMethod] public function cancel(): void { $this->doCancel = true; diff --git a/tests/Unit/WorkflowContext/GetVersionTestCase.php b/tests/Unit/WorkflowContext/GetVersionTestCase.php index c8c372042..e809ded82 100644 --- a/tests/Unit/WorkflowContext/GetVersionTestCase.php +++ b/tests/Unit/WorkflowContext/GetVersionTestCase.php @@ -11,6 +11,7 @@ use Temporal\Worker\WorkerInterface; use Temporal\Workflow; use Temporal\Workflow\WorkflowMethod; +use Temporal\Workflow\WorkflowInterface; final class GetVersionTestCase extends AbstractUnit { @@ -26,7 +27,7 @@ public function testVersionIsRetrieved(): void $this->worker->registerWorkflowObject( new - #[Workflow\WorkflowInterface] + #[WorkflowInterface] class { #[WorkflowMethod(name: 'VersionWorkflow')] public function handler(): iterable