Test start-boundary receiver ordering

Author: durable-workflow-ops

tests/Feature/V2/V2UpdateWorkflowTest.php

@@ -9,6 +9,7 @@
 use Tests\Fixtures\V2\TestAliasedUpdateWorkflow;
 use Tests\Fixtures\V2\TestChildHandleParentWorkflow;
 use Tests\Fixtures\V2\TestSignalThenUpdateWorkflow;
+use Tests\Fixtures\V2\TestStartBoundaryReceiverWorkflow;
 use Tests\Fixtures\V2\TestUpdateWorkflow;
 use Tests\TestCase;
 use Workflow\Serializers\Serializer;
@@ -33,6 +34,70 @@
 
 final class V2UpdateWorkflowTest extends TestCase
 {
+    public function testStartBoundarySignalAndUpdateApplyAfterWorkflowInitialization(): void
+    {
+        Queue::fake();
+
+        $workflow = WorkflowStub::make(TestStartBoundaryReceiverWorkflow::class, 'start-boundary-receivers');
+        $workflow->start();
+
+        $runId = $workflow->runId();
+
+        $this->assertNotNull($runId);
+        $this->assertSame(['StartAccepted', 'WorkflowStarted'], WorkflowHistoryEvent::query()
+            ->where('workflow_run_id', $runId)
+            ->orderBy('sequence')
+            ->pluck('event_type')
+            ->map(static fn ($eventType) => $eventType->value)
+            ->all());
+
+        $update = $workflow->submitUpdate('approve', true, 'api');
+        $signal = $workflow->signal('name-provided', 'Taylor');
+
+        $this->assertTrue($update->accepted());
+        $this->assertFalse($update->completed());
+        $this->assertTrue($signal->accepted());
+        $this->assertSame('signal_received', $signal->outcome());
+
+        $this->runReadyWorkflowTask($runId);
+
+        $this->waitFor(static fn (): bool => $workflow->refresh()->completed());
+
+        $this->assertSame([
+            'stage' => 'completed',
+            'events' => ['initialized', 'update:yes:api:initialized', 'signal:Taylor:completed'],
+            'workflow_id' => 'start-boundary-receivers',
+            'run_id' => $runId,
+        ], $workflow->output());
+
+        $this->assertDatabaseHas('workflow_updates', [
+            'id' => $update->updateId(),
+            'workflow_run_id' => $runId,
+            'status' => 'completed',
+            'outcome' => 'update_completed',
+            'workflow_sequence' => 1,
+        ]);
+
+        $this->assertSame([
+            'StartAccepted',
+            'WorkflowStarted',
+            'UpdateAccepted',
+            'SignalReceived',
+            'UpdateApplied',
+            'UpdateCompleted',
+            'MessageCursorAdvanced',
+            'SignalWaitOpened',
+            'MessageCursorAdvanced',
+            'SignalApplied',
+            'WorkflowCompleted',
+        ], WorkflowHistoryEvent::query()
+            ->where('workflow_run_id', $runId)
+            ->orderBy('sequence')
+            ->pluck('event_type')
+            ->map(static fn ($eventType) => $eventType->value)
+            ->all());
+    }
+
     public function testAttemptUpdateUsesDeclaredAliasAsTheDurableTarget(): void
     {
         $workflow = WorkflowStub::make(TestAliasedUpdateWorkflow::class, 'order-update-alias');

tests/Fixtures/V2/TestStartBoundaryReceiverWorkflow.php

@@ -0,0 +1,52 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Tests\Fixtures\V2;
+
+use Workflow\UpdateMethod;
+use Workflow\V2\Attributes\Signal;
+use Workflow\V2\Attributes\Type;
+use function Workflow\V2\signal;
+use Workflow\V2\Workflow;
+
+#[Type('test-start-boundary-receiver-workflow')]
+#[Signal('name-provided')]
+final class TestStartBoundaryReceiverWorkflow extends Workflow
+{
+    private string $stage = 'booting';
+
+    /**
+     * @var list<string>
+     */
+    private array $events = [];
+
+    public function handle(): array
+    {
+        $this->stage = 'initialized';
+        $this->events[] = 'initialized';
+
+        $name = signal('name-provided');
+
+        $this->stage = 'completed';
+        $this->events[] = sprintf('signal:%s:%s', $name, $this->stage);
+
+        return [
+            'stage' => $this->stage,
+            'events' => $this->events,
+            'workflow_id' => $this->workflowId(),
+            'run_id' => $this->runId(),
+        ];
+    }
+
+    #[UpdateMethod]
+    public function approve(bool $approved, string $source = 'manual'): array
+    {
+        $this->events[] = sprintf('update:%s:%s:%s', $approved ? 'yes' : 'no', $source, $this->stage);
+
+        return [
+            'stage' => $this->stage,
+            'events' => $this->events,
+        ];
+    }
+}