Workflow inbound interceptor context messages: add isReplaying flag

temporalio · Nov 18, 2024 · b2cdc1a · b2cdc1a
1 parent df36a91
commit b2cdc1a
Show file tree

Hide file tree

Showing 6 changed files with 14 additions and 1 deletion.
diff --git a/src/Interceptor/WorkflowInbound/SignalInput.php b/src/Interceptor/WorkflowInbound/SignalInput.php
@@ -31,6 +31,7 @@ public function __construct(
         public readonly WorkflowInfo $info,
         public readonly ValuesInterface $arguments,
         public readonly HeaderInterface $header,
+        public readonly bool $isReplaying,
     ) {}
 
     public function with(
@@ -43,6 +44,7 @@ public function with(
             $info ?? $this->info,
             $arguments ?? $this->arguments,
             $header ?? $this->header,
+            $this->isReplaying,
         );
     }
 }
diff --git a/src/Interceptor/WorkflowInbound/UpdateInput.php b/src/Interceptor/WorkflowInbound/UpdateInput.php
@@ -32,6 +32,7 @@ public function __construct(
         public readonly WorkflowInfo $info,
         public readonly ValuesInterface $arguments,
         public readonly HeaderInterface $header,
+        public readonly bool $isReplaying,
     ) {}
 
     public function with(
@@ -45,6 +46,7 @@ public function with(
             $info ?? $this->info,
             $arguments ?? $this->arguments,
             $header ?? $this->header,
+            $this->isReplaying,
         );
     }
 }
diff --git a/src/Interceptor/WorkflowInbound/WorkflowInput.php b/src/Interceptor/WorkflowInbound/WorkflowInput.php
@@ -28,6 +28,7 @@ public function __construct(
         public readonly WorkflowInfo $info,
         public readonly ValuesInterface $arguments,
         public readonly HeaderInterface $header,
+        public readonly bool $isReplaying,
     ) {}
 
     public function with(
@@ -39,6 +40,7 @@ public function with(
             $info ?? $this->info,
             $arguments ?? $this->arguments,
             $header ?? $this->header,
+            $this->isReplaying,
         );
     }
 }
diff --git a/src/Internal/Transport/Router/InvokeUpdate.php b/src/Internal/Transport/Router/InvokeUpdate.php
@@ -55,6 +55,7 @@ public function handle(ServerRequestInterface $request, array $headers, Deferred
                 info: $context->getInfo(),
                 arguments: $request->getPayloads(),
                 header: $request->getHeader(),
+                isReplaying: $context->isReplaying(),
             );
 
             // Validation

diff --git a/src/Internal/Transport/Router/StartWorkflow.php b/src/Internal/Transport/Router/StartWorkflow.php
@@ -112,7 +112,12 @@ public function handle(ServerRequestInterface $request, array $headers, Deferred
                 /** @see WorkflowInboundCallsInterceptor::execute() */
                 'execute',
             )(
-                new WorkflowInput($context->getInfo(), $context->getInput(), $context->getHeader()),
+                new WorkflowInput(
+                    $context->getInfo(),
+                    $context->getInput(),
+                    $context->getHeader(),
+                    $context->isReplaying(),
+                ),
             );
     }
 

diff --git a/src/Internal/Workflow/Process/Process.php b/src/Internal/Workflow/Process/Process.php
@@ -155,6 +155,7 @@ function (?\Throwable $error): void {
                     $this->scopeContext->getInfo(),
                     $arguments,
                     $this->scopeContext->getHeader(),
+                    $this->scopeContext->isReplaying(),
                 ));
             },
         );