improve handling of HTTP 410 'Gone' exception

georgeboot · Dec 7, 2024 · 2b3eca8 · 2b3eca8
1 parent eb731d4
commit 2b3eca8
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/src/ConnectionRepository.php b/src/ConnectionRepository.php
@@ -4,6 +4,7 @@
 
 use Aws\ApiGatewayManagementApi\ApiGatewayManagementApiClient;
 use Aws\ApiGatewayManagementApi\Exception\ApiGatewayManagementApiException;
+use Symfony\Component\HttpFoundation\Response;
 
 class ConnectionRepository
 {
@@ -30,8 +31,11 @@ public function sendMessage(string $connectionId, string $data): void
                 'Data' => $data,
             ]);
         } catch (ApiGatewayManagementApiException $e) {
-             // GoneException: The connection with the provided id no longer exists.
-             if ($e->getAwsErrorCode() === 'GoneException') {
+            // GoneException: The connection with the provided id no longer exists
+            if (
+                $e->getStatusCode() === Response::HTTP_GONE ||
+                $e->getAwsErrorCode() === 'GoneException'
+            ) {
                 $this->subscriptionRepository->clearConnection($connectionId);
 
                 return;