feat: Throw ActivityResetException on Activity reset

Author: roxblnfk

src/Activity/ActivityCancellationDetails.php

@@ -18,5 +18,6 @@ public function __construct(
         public readonly bool $paused = false,
         public readonly bool $timedOut = false,
         public readonly bool $workerShutdown = false,
+        public readonly bool $reset = false,
     ) {}
 }

src/Activity/ActivityContextInterface.php

@@ -17,6 +17,7 @@
 use Temporal\Exception\Client\ActivityCanceledException;
 use Temporal\Exception\Client\ActivityCompletionException;
 use Temporal\Exception\Client\ActivityPausedException;
+use Temporal\Exception\Client\ActivityResetException;
 
 interface ActivityContextInterface
 {
@@ -63,6 +64,7 @@ public function doNotCompleteOnReturn(): void;
      * @throws ActivityCompletionException
      * @throws ActivityCanceledException
      * @throws ActivityPausedException
+     * @throws ActivityResetException
      *
      * @see Activity::heartbeat()
      *

src/Exception/Client/ActivityPausedException.php

@@ -15,6 +15,6 @@
  * Indicates that the activity was paused by the user.
  *
  * Catching this exception directly is discouraged and catching
- * the parent class {@link ActivityCompletionException} is recommended instead.
+ * the parent class {@see ActivityCompletionException} is recommended instead.
  */
 final class ActivityPausedException extends ActivityCompletionException {}

src/Exception/Client/ActivityResetException.php

@@ -0,0 +1,20 @@
+<?php
+
+/**
+ * This file is part of Temporal package.
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+declare(strict_types=1);
+
+namespace Temporal\Exception\Client;
+
+/**
+ * Indicates that the activity attempt was reset by the user.
+ *
+ * Catching this exception directly is discouraged and catching
+ * the parent class {@see ActivityCompletionException} is recommended instead.
+ */
+final class ActivityResetException extends ActivityCompletionException {}

src/Internal/Activity/ActivityContext.php

@@ -21,6 +21,7 @@
 use Temporal\Exception\Client\ActivityCanceledException;
 use Temporal\Exception\Client\ActivityCompletionException;
 use Temporal\Exception\Client\ActivityPausedException;
+use Temporal\Exception\Client\ActivityResetException;
 use Temporal\Exception\Client\ServiceClientException;
 use Temporal\Interceptor\HeaderInterface;
 use Temporal\Internal\Interceptor\HeaderCarrier;
@@ -129,16 +130,20 @@ public function heartbeat(mixed $details): void
 
             $cancelled = (bool) ($response['canceled'] ?? false);
             $paused = (bool) ($response['paused'] ?? false);
+            $reset = (bool) ($response['reset'] ?? false);
 
-            if ($cancelled || $paused) {
+            if ($cancelled || $paused || $reset) {
                 $this->cancellationDetails ??= new ActivityCancellationDetails(
                     cancelRequested: $cancelled,
                     paused: $paused,
+                    reset: $reset,
                 );
 
-                throw $cancelled
-                    ? ActivityCanceledException::fromActivityInfo($this->info)
-                    : ActivityPausedException::fromActivityInfo($this->info);
+                throw match (true) {
+                    $cancelled => ActivityCanceledException::fromActivityInfo($this->info),
+                    $paused => ActivityPausedException::fromActivityInfo($this->info),
+                    $reset => ActivityResetException::fromActivityInfo($this->info),
+                };
             }
         } catch (ServiceClientException $e) {
             throw ActivityCompletionException::fromActivityInfo($this->info, $e);