test full workflow execution

tests/Fixtures/WorkflowDiscovery/Activities/DemoActivity.php

@@ -2,8 +2,13 @@
 
 namespace Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Activities;
 
-class DemoActivity implements DemoActivityInterface
+use Temporal\Activity\ActivityInterface;
+use Temporal\Activity\ActivityMethod;
+
+#[ActivityInterface(prefix: 'demo')]
+class DemoActivity
 {
+    #[ActivityMethod(name: 'greet')]
     public function greet(string $name): string
     {
         return sprintf('Hello %s', $name);

tests/Fixtures/WorkflowDiscovery/Activities/DemoActivityInterface.php

@@ -5,7 +5,7 @@
 use Temporal\Activity\ActivityInterface;
 use Temporal\Activity\ActivityMethod;
 
-#[ActivityInterface(prefix: 'demo')]
+#[ActivityInterface(prefix: 'demo_interface')]
 interface DemoActivityInterface
 {
     #[ActivityMethod(name: 'greet')]

tests/Fixtures/WorkflowDiscovery/Activities/DemoActivityWithInterface.php

@@ -0,0 +1,11 @@
+<?php
+
+namespace Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Activities;
+
+class DemoActivityWithInterface implements DemoActivityInterface
+{
+    public function greet(string $name): string
+    {
+        return sprintf('Hello %s', $name);
+    }
+}

tests/Fixtures/WorkflowDiscovery/Activities/DemoActivityWithoutInterface.php → tests/Fixtures/WorkflowDiscovery/Activities/DemoLocalActivity.php

@@ -2,15 +2,15 @@
 
 namespace Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Activities;
 
-use Temporal\Activity\ActivityInterface;
 use Temporal\Activity\ActivityMethod;
+use Temporal\Activity\LocalActivityInterface;
 
-#[ActivityInterface(prefix: 'demo_without_interface')]
-class DemoActivityWithoutInterface
+#[LocalActivityInterface(prefix: 'demo_local')]
+class DemoLocalActivity
 {
     #[ActivityMethod(name: 'greet')]
     public function greet(string $name): string
     {
-        return sprintf('Hello %s', $name);
+        return sprintf('(local) Hello %s', $name);
     }
 }

tests/Fixtures/WorkflowDiscovery/Workflows/DebugOptionsWorkflow.php → tests/Fixtures/WorkflowDiscovery/Workflows/ActivityOptionsWorkflow.php

@@ -11,9 +11,9 @@
 use Temporal\Workflow\WorkflowMethod;
 
 #[WorkflowInterface]
-class DebugOptionsWorkflow
+class ActivityOptionsWorkflow
 {
-    #[WorkflowMethod(name: 'debug.activityOptions')]
+    #[WorkflowMethod(name: 'activityOptions')]
     #[Workflow\ReturnType('array')]
     public function activityOptions(): \Generator
     {

tests/Fixtures/WorkflowDiscovery/Workflows/DemoWorkflow.php

@@ -4,7 +4,7 @@
 
 use Carbon\CarbonInterval;
 use Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Activities\DemoActivityInterface;
-use Temporal\Activity\LocalActivityOptions;
+use Temporal\Activity\ActivityOptions;
 use Temporal\Workflow;
 
 class DemoWorkflow implements DemoWorkflowInterface
@@ -18,7 +18,7 @@ public function __construct()
     {
         $this->activity = Workflow::newActivityStub(
             DemoActivityInterface::class,
-            LocalActivityOptions::new()
+            ActivityOptions::new()
                 ->withStartToCloseTimeout(CarbonInterval::seconds(1))
         );
     }

tests/Fixtures/WorkflowDiscovery/Workflows/DemoWorkflowInterface.php

@@ -2,12 +2,14 @@
 
 namespace Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Workflows;
 
+use Temporal\Workflow\ReturnType;
 use Temporal\Workflow\WorkflowInterface;
 use Temporal\Workflow\WorkflowMethod;
 
 #[WorkflowInterface]
 interface DemoWorkflowInterface
 {
     #[WorkflowMethod(name: 'demo.greet')]
+    #[ReturnType('string')]
     public function greet(string $name): \Generator;
 }

tests/Fixtures/WorkflowDiscovery/Workflows/DemoWorkflowWithoutInterface.php

@@ -3,7 +3,7 @@
 namespace Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Workflows;
 
 use Carbon\CarbonInterval;
-use Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Activities\DemoActivityWithoutInterface;
+use Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Activities\DemoActivity;
 use Temporal\Activity\ActivityOptions;
 use Temporal\Workflow;
 use Temporal\Workflow\WorkflowInterface;
@@ -16,7 +16,7 @@ class DemoWorkflowWithoutInterface
     public function greet(string $name): \Generator
     {
         $activity = Workflow::newActivityStub(
-            DemoActivityWithoutInterface::class,
+            DemoActivity::class,
             ActivityOptions::new()->withStartToCloseTimeout(CarbonInterval::seconds(1))
         );
 

tests/Fixtures/WorkflowDiscovery/Workflows/TesterWorkflow.php

@@ -0,0 +1,58 @@
+<?php
+
+namespace Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Workflows;
+
+use Carbon\CarbonInterval;
+use Keepsuit\LaravelTemporal\Facade\Temporal;
+use Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Activities\DemoActivityInterface;
+use Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Activities\DemoActivityWithInterface;
+use Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Activities\DemoLocalActivity;
+use Temporal\Internal\Workflow\ActivityProxy;
+use Temporal\Workflow;
+use Temporal\Workflow\WorkflowInterface;
+use Temporal\Workflow\WorkflowMethod;
+
+#[WorkflowInterface]
+class TesterWorkflow
+{
+    /**
+     * @var ActivityProxy<DemoActivityWithInterface>
+     */
+    protected ActivityProxy $activity;
+
+    /**
+     * @var ActivityProxy<DemoLocalActivity>
+     */
+    protected ActivityProxy $localActivity;
+
+    public function __construct()
+    {
+        $this->activity = Temporal::newActivity()
+            ->withStartToCloseTimeout(CarbonInterval::seconds(1))
+            ->build(DemoActivityInterface::class);
+
+        $this->localActivity = Temporal::newLocalActivity()
+            ->withStartToCloseTimeout(CarbonInterval::seconds(1))
+            ->build(DemoLocalActivity::class);
+
+        $this->childWorkflow = Temporal::newChildWorkflow()
+            ->withWorkflowRunTimeout(CarbonInterval::seconds(1))
+            ->build(DemoWorkflow::class);
+    }
+
+    #[WorkflowMethod(name: 'tester')]
+    #[Workflow\ReturnType('array')]
+    public function tester(string $target): \Generator
+    {
+        return match ($target) {
+            'activity' => ['activity' => yield $this->activity->greet('John')],
+            'local_activity' => ['local_activity' => yield $this->localActivity->greet('John')],
+            'child' => ['child' => sprintf('(child) %s', yield $this->childWorkflow->greet('John'))],
+            default => [
+                'activity' => yield $this->activity->greet('John'),
+                'local_activity' => yield $this->localActivity->greet('John'),
+                'child' => sprintf('(child) %s', yield $this->childWorkflow->greet('John')),
+            ]
+        };
+    }
+}

tests/Integrations/Temporal/FullWorkflowExecutionTest.php

@@ -0,0 +1,59 @@
+<?php
+
+use Carbon\CarbonInterval;
+use Keepsuit\LaravelTemporal\Facade\Temporal;
+use Keepsuit\LaravelTemporal\Testing\WithTemporal;
+use Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Workflows\TesterWorkflow;
+use Temporal\Common\RetryOptions;
+
+uses(WithTemporal::class);
+
+beforeEach(function () {
+    Temporal::fake();
+});
+
+it('execute workflow with activity', function () {
+    $workflow = Temporal::newWorkflow()
+        ->withWorkflowRunTimeout(CarbonInterval::seconds(2))
+        ->build(TesterWorkflow::class);
+
+    $result = $workflow->tester('activity');
+
+    expect($result)->toBe(['activity' => 'Hello John']);
+});
+
+it('execute workflow with local activity', function () {
+    $workflow = Temporal::newWorkflow()
+        ->withWorkflowRunTimeout(CarbonInterval::seconds(2))
+        ->build(TesterWorkflow::class);
+
+    $result = $workflow->tester('local_activity');
+
+    expect($result)->toBe(['local_activity' => '(local) Hello John']);
+});
+
+it('execute workflow with child', function () {
+    $workflow = Temporal::newWorkflow()
+        ->withWorkflowRunTimeout(CarbonInterval::seconds(2))
+        ->withRetryOptions(RetryOptions::new()->withMaximumAttempts(2))
+        ->build(TesterWorkflow::class);
+
+    $result = $workflow->tester('child');
+
+    expect($result)->toBe(['child' => '(child) Hello John']);
+});
+
+it('execute workflow full', function () {
+    $workflow = Temporal::newWorkflow()
+        ->withWorkflowRunTimeout(CarbonInterval::seconds(2))
+        ->withRetryOptions(RetryOptions::new()->withMaximumAttempts(2))
+        ->build(TesterWorkflow::class);
+
+    $result = $workflow->tester('all');
+
+    expect($result)->toBe([
+        'activity' => 'Hello John',
+        'local_activity' => '(local) Hello John',
+        'child' => '(child) Hello John',
+    ]);
+});

tests/Pest.php

@@ -14,6 +14,7 @@
 use Temporal\Workflow\ScopedContextInterface;
 
 uses(TestCase::class)->in(__DIR__.'/Unit');
+uses(TestCase::class)->in(__DIR__.'/Integrations/Temporal');
 uses(LaravelDataTestCase::class)->in(__DIR__.'/Integrations/LaravelData');
 
 /**

tests/TestCase.php

@@ -5,9 +5,11 @@
 use Illuminate\Config\Repository;
 use Illuminate\Database\Eloquent\Factories\Factory;
 use Keepsuit\LaravelTemporal\LaravelTemporalServiceProvider;
-use Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Activities\DemoActivity;
-use Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Workflows\DebugOptionsWorkflow;
+use Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Activities\DemoActivityWithInterface;
+use Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Activities\DemoLocalActivity;
+use Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Workflows\ActivityOptionsWorkflow;
 use Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Workflows\DemoWorkflow;
+use Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Workflows\TesterWorkflow;
 use Orchestra\Testbench\TestCase as Orchestra;
 
 class TestCase extends Orchestra
@@ -33,11 +35,13 @@ public function defineEnvironment($app)
         tap($app['config'], function (Repository $config) {
             $config->set('database.default', 'testing');
             $config->set('temporal.workflows', [
-                DebugOptionsWorkflow::class,
+                ActivityOptionsWorkflow::class,
                 DemoWorkflow::class,
+                TesterWorkflow::class,
             ]);
             $config->set('temporal.activities', [
-                DemoActivity::class,
+                DemoActivityWithInterface::class,
+                DemoLocalActivity::class,
             ]);
         });
     }

tests/Unit/Discovery/ActivityDiscoveryTest.php

@@ -4,13 +4,14 @@
 use Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Activities\DemoActivity;
 use Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Activities\DemoActivityInterface;
 use Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Activities\DemoActivityInterfaceOnly;
-use Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Activities\DemoActivityWithoutInterface;
+use Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Activities\DemoActivityWithInterface;
+use Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Activities\DemoLocalActivity;
 
 it('can discovery activities', function () {
-    class_alias(DemoActivity::class, 'Tests\Fixtures\WorkflowDiscovery\Activities\DemoActivity');
+    class_alias(DemoActivityWithInterface::class, 'Tests\Fixtures\WorkflowDiscovery\Activities\DemoActivity');
     class_alias(DemoActivityInterface::class, 'Tests\Fixtures\WorkflowDiscovery\Activities\DemoActivityInterface');
     class_alias(DemoActivityInterfaceOnly::class, 'Tests\Fixtures\WorkflowDiscovery\Activities\DemoActivityInterfaceOnly');
-    class_alias(DemoActivityWithoutInterface::class, 'Tests\Fixtures\WorkflowDiscovery\Activities\DemoActivityWithoutInterface');
+    class_alias(DemoActivity::class, 'Tests\Fixtures\WorkflowDiscovery\Activities\DemoActivityWithoutInterface');
 
     $activities = DiscoverActivities::within(
         __DIR__.'/../../Fixtures/WorkflowDiscovery/Activities',
@@ -19,6 +20,7 @@ class_alias(DemoActivityWithoutInterface::class, 'Tests\Fixtures\WorkflowDiscove
     expect($activities)->toBe([
         DemoActivity::class,
         DemoActivityInterfaceOnly::class,
-        DemoActivityWithoutInterface::class,
+        DemoActivityWithInterface::class,
+        DemoLocalActivity::class,
     ]);
 });

tests/Unit/Discovery/WorkflowDiscoveryTest.php

@@ -1,20 +1,22 @@
 <?php
 
 use Keepsuit\LaravelTemporal\Support\DiscoverWorkflows;
-use Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Workflows\DebugOptionsWorkflow;
+use Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Workflows\ActivityOptionsWorkflow;
 use Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Workflows\DemoWorkflow;
 use Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Workflows\DemoWorkflowInterfaceOnly;
 use Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Workflows\DemoWorkflowWithoutInterface;
+use Keepsuit\LaravelTemporal\Tests\Fixtures\WorkflowDiscovery\Workflows\TesterWorkflow;
 
 it('can discovery workflows', function () {
     $workflows = DiscoverWorkflows::within(
         __DIR__.'/../../Fixtures/WorkflowDiscovery/Workflows',
     );
 
     expect($workflows)->toBe([
-        DebugOptionsWorkflow::class,
+        ActivityOptionsWorkflow::class,
         DemoWorkflow::class,
         DemoWorkflowInterfaceOnly::class,
         DemoWorkflowWithoutInterface::class,
+        TesterWorkflow::class,
     ]);
 });