Introduce SseAdapterException for more specific error handling

klapaudius · klapaudius · commit 60b036defdc9 · 2025-05-15T17:07:26.000+02:00
Replaces generic Exception with SseAdapterException in SseAdapter-related classes. Improves error specificity and aligns exception types with the domain logic, enhancing maintainability and debugging clarity.
diff --git a/src/Server/Notification/PongHandler.php b/src/Server/Notification/PongHandler.php
@@ -4,6 +4,7 @@
 
 use Exception;
 use KLP\KlpMcpServer\Protocol\Handlers\NotificationHandler;
+use KLP\KlpMcpServer\Transports\SseAdapters\SseAdapterException;
 use KLP\KlpMcpServer\Transports\SseAdapters\SseAdapterInterface;
 
 /**
@@ -31,7 +32,7 @@ public function execute(?array $params = null): array
     {
         try {
             $this->adapter?->storeLastPongResponseTimestamp($params['clientId'], time());
-        } catch (Exception) {
+        } catch (SseAdapterException) {
             // Nothing to do here the client will be disconnected anyway
         }
 
diff --git a/src/Transports/SseAdapters/RedisAdapter.php b/src/Transports/SseAdapters/RedisAdapter.php
@@ -45,7 +45,7 @@ public function __construct(
             $this->redis->setOption(Redis::OPT_PREFIX, $this->keyPrefix);
         } catch (Exception $e) {
             $this->logger?->error(self::FAILED_TO_INITIALIZE.$e->getMessage());
-            throw new \Exception(self::FAILED_TO_INITIALIZE.$e->getMessage());
+            throw new SseAdapterException(self::FAILED_TO_INITIALIZE.$e->getMessage());
         }
     }
 
@@ -55,7 +55,7 @@ public function __construct(
      * @param  string  $clientId  The unique identifier for the client
      * @param  string  $message  The message to be queued
      *
-     * @throws Exception If the message cannot be added to the queue
+     * @throws SseAdapterException If the message cannot be added to the queue
      */
     public function pushMessage(string $clientId, string $message): void
     {
@@ -68,7 +68,7 @@ public function pushMessage(string $clientId, string $message): void
 
         } catch (Exception $e) {
             $this->logger?->error('Failed to add message to Redis queue: '.$e->getMessage());
-            throw new Exception('Failed to add message to Redis queue: '.$e->getMessage());
+            throw new SseAdapterException('Failed to add message to Redis queue: '.$e->getMessage());
         }
     }
 
@@ -88,7 +88,7 @@ protected function getQueueKey(string $clientId): string
      *
      * @param  string  $clientId  The unique identifier for the client
      *
-     * @throws Exception If the messages cannot be removed
+     * @throws SseAdapterException If the messages cannot be removed
      */
     public function removeAllMessages(string $clientId): void
     {
@@ -99,7 +99,7 @@ public function removeAllMessages(string $clientId): void
 
         } catch (Exception $e) {
             $this->logger?->error('Failed to remove messages from Redis queue: '.$e->getMessage());
-            throw new Exception('Failed to remove messages from Redis queue: '.$e->getMessage());
+            throw new SseAdapterException('Failed to remove messages from Redis queue: '.$e->getMessage());
         }
     }
 
@@ -109,7 +109,7 @@ public function removeAllMessages(string $clientId): void
      * @param  string  $clientId  The unique identifier for the client
      * @return array<string> Array of messages
      *
-     * @throws Exception If the messages cannot be retrieved
+     * @throws SseAdapterException If the messages cannot be retrieved
      */
     public function receiveMessages(string $clientId): array
     {
@@ -123,7 +123,7 @@ public function receiveMessages(string $clientId): array
 
             return $messages;
         } catch (Exception $e) {
-            throw new Exception('Failed to receive messages from Redis queue: '.$e->getMessage());
+            throw new SseAdapterException('Failed to receive messages from Redis queue: '.$e->getMessage());
         }
     }
 
@@ -133,7 +133,7 @@ public function receiveMessages(string $clientId): array
      * @param  string  $clientId  The unique identifier for the client
      * @return string|null The message or null if the queue is empty
      *
-     * @throws Exception If the message cannot be popped
+     * @throws SseAdapterException If the message cannot be popped
      */
     public function popMessage(string $clientId): ?string
     {
@@ -149,7 +149,7 @@ public function popMessage(string $clientId): ?string
             return $message;
         } catch (Exception $e) {
             $this->logger?->error('Failed to pop message from Redis queue: '.$e->getMessage());
-            throw new Exception('Failed to pop message from Redis queue: '.$e->getMessage());
+            throw new SseAdapterException('Failed to pop message from Redis queue: '.$e->getMessage());
         }
     }
 
@@ -201,7 +201,7 @@ public function getMessageCount(string $clientId): int
      * @param  string  $clientId  The unique identifier for the client
      * @param  int|null  $timestamp  The timestamp to store (defaults to current time if null)
      *
-     * @throws Exception If the timestamp cannot be stored
+     * @throws SseAdapterException If the timestamp cannot be stored
      */
     public function storeLastPongResponseTimestamp(string $clientId, ?int $timestamp = null): void
     {
@@ -214,7 +214,7 @@ public function storeLastPongResponseTimestamp(string $clientId, ?int $timestamp
 
         } catch (Exception $e) {
             $this->logger?->error('Failed to store last pong timestamp: '.$e->getMessage());
-            throw new Exception('Failed to store last pong timestamp: '.$e->getMessage());
+            throw new SseAdapterException('Failed to store last pong timestamp: '.$e->getMessage());
         }
     }
 
@@ -224,7 +224,7 @@ public function storeLastPongResponseTimestamp(string $clientId, ?int $timestamp
      * @param  string  $clientId  The unique identifier for the client
      * @return int|null The timestamp or null if no timestamp is stored
      *
-     * @throws Exception If the timestamp cannot be retrieved
+     * @throws SseAdapterException If the timestamp cannot be retrieved
      */
     public function getLastPongResponseTimestamp(string $clientId): ?int
     {
@@ -241,7 +241,7 @@ public function getLastPongResponseTimestamp(string $clientId): ?int
 
         } catch (Exception $e) {
             $this->logger?->error('Failed to get last pong timestamp: '.$e->getMessage());
-            throw new Exception('Failed to get last pong timestamp: '.$e->getMessage());
+            throw new SseAdapterException('Failed to get last pong timestamp: '.$e->getMessage());
         }
     }
 }
diff --git a/src/Transports/SseAdapters/SseAdapterException.php b/src/Transports/SseAdapters/SseAdapterException.php
@@ -0,0 +1,7 @@
+<?php
+
+namespace KLP\KlpMcpServer\Transports\SseAdapters;
+
+use Exception;
+
+class SseAdapterException extends Exception {}
diff --git a/src/Transports/SseAdapters/SseAdapterInterface.php b/src/Transports/SseAdapters/SseAdapterInterface.php
@@ -19,7 +19,7 @@ interface SseAdapterInterface
      * @param  string  $clientId  The unique identifier for the client
      * @param  string  $message  The message to be queued
      *
-     * @throws \Exception If the message cannot be added to the queue
+     * @throws SseAdapterException If the message cannot be added to the queue
      */
     public function pushMessage(string $clientId, string $message): void;
 
@@ -28,7 +28,7 @@ public function pushMessage(string $clientId, string $message): void;
      *
      * @param  string  $clientId  The unique identifier for the client
      *
-     * @throws \Exception If the messages cannot be removed
+     * @throws SseAdapterException If the messages cannot be removed
      */
     public function removeAllMessages(string $clientId): void;
 
@@ -38,7 +38,7 @@ public function removeAllMessages(string $clientId): void;
      * @param  string  $clientId  The unique identifier for the client
      * @return array<string> Array of messages
      *
-     * @throws \Exception If the messages cannot be retrieved
+     * @throws SseAdapterException If the messages cannot be retrieved
      */
     public function receiveMessages(string $clientId): array;
 
@@ -48,7 +48,7 @@ public function receiveMessages(string $clientId): array;
      * @param  string  $clientId  The unique identifier for the client
      * @return string|null The message or null if the queue is empty
      *
-     * @throws \Exception If the message cannot be popped
+     * @throws SseAdapterException If the message cannot be popped
      */
     public function popMessage(string $clientId): ?string;
 
@@ -74,7 +74,7 @@ public function getMessageCount(string $clientId): int;
      * @param  string  $clientId  The unique identifier for the client
      * @param  int|null  $timestamp  The timestamp to store (defaults to current time if null)
      *
-     * @throws \Exception If the timestamp cannot be stored
+     * @throws SseAdapterException If the timestamp cannot be stored
      */
     public function storeLastPongResponseTimestamp(string $clientId, ?int $timestamp = null): void;
 
@@ -84,7 +84,7 @@ public function storeLastPongResponseTimestamp(string $clientId, ?int $timestamp
      * @param  string  $clientId  The unique identifier for the client
      * @return int|null The timestamp or null if no timestamp is stored
      *
-     * @throws \Exception If the timestamp cannot be retrieved
+     * @throws SseAdapterException If the timestamp cannot be retrieved
      */
     public function getLastPongResponseTimestamp(string $clientId): ?int;
 }
diff --git a/src/Transports/SseTransport.php b/src/Transports/SseTransport.php
@@ -3,6 +3,7 @@
 namespace KLP\KlpMcpServer\Transports;
 
 use Exception;
+use KLP\KlpMcpServer\Transports\SseAdapters\SseAdapterException;
 use KLP\KlpMcpServer\Transports\SseAdapters\SseAdapterInterface;
 use Psr\Log\LoggerInterface;
 
@@ -98,15 +99,15 @@ public function start(): void
      * Initializes the transport: generates client ID and sends the initial 'endpoint' event.
      * Adapter-specific initialization might occur here or externally.
      *
-     * @throws Exception If sending the initial event fails.
+     * @throws SseAdapterException If sending the initial event fails.
      */
     public function initialize(): void
     {
         if ($this->clientId === null) {
             $this->clientId = uniqid();
         }
         $this->lastPingTimestamp = time();
-        $this->adapter->storeLastPongResponseTimestamp($this->clientId, time());
+        $this->adapter?->storeLastPongResponseTimestamp($this->clientId, time());
 
         $this->sendEvent(event: 'endpoint', data: $this->getEndpoint(sessionId: $this->clientId));
     }
@@ -173,7 +174,7 @@ public function close(): void
         if ($this->adapter !== null && $this->clientId !== null) {
             try {
                 $this->adapter->removeAllMessages($this->clientId);
-            } catch (Exception $e) {
+            } catch (SseAdapterException $e) {
                 $this->logger?->error('Error cleaning up SSE adapter resources on close: '.$e->getMessage());
             }
         }
@@ -245,7 +246,7 @@ public function receive(): array
                 $messages = $this->adapter->receiveMessages($this->clientId);
 
                 return $messages ?: [];
-            } catch (Exception $e) {
+            } catch (SseAdapterException $e) {
                 $this->triggerError('SSE Failed to receive messages via adapter: '.$e->getMessage());
             }
         } elseif ($this->adapter === null) {
@@ -338,7 +339,8 @@ private function getEndpoint(string $sessionId): string
     }
 
     /**
-     * @throws Exception
+     * @return int|null
+     * @throws SseAdapterException
      */
     protected function getLastPongResponseTimestamp(): ?int
     {
diff --git a/tests/Transports/SseTransportTest.php b/tests/Transports/SseTransportTest.php
@@ -2,6 +2,7 @@
 
 namespace KLP\KlpMcpServer\Tests\Transports;
 
+use KLP\KlpMcpServer\Transports\SseAdapters\SseAdapterException;
 use KLP\KlpMcpServer\Transports\SseAdapters\SseAdapterInterface;
 use KLP\KlpMcpServer\Transports\SseTransport;
 use KLP\KlpMcpServer\Transports\SseTransportException;
@@ -310,7 +311,7 @@ public function test_close_logs_exceptions_in_handlers_or_cleanup(): void
         $this->setProtectedProperty($this->instance, 'clientId', 'test-client-id');
         $adapterMock->expects($this->once())
             ->method('removeAllMessages')
-            ->willThrowException(new \Exception('Adapter Exception'));
+            ->willThrowException(new SseAdapterException('Adapter Exception'));
 
         // Act
         ob_start();
@@ -404,7 +405,7 @@ public function test_receive_triggers_error_handlers_on_adapter_exception(): voi
 
         $adapterMock->expects($this->once())
             ->method('receiveMessages')
-            ->willThrowException(new \Exception('Adapter Exception'));
+            ->willThrowException(new SseAdapterException('Adapter Exception'));
 
         $errorTriggered = false;
         $this->instance->onError(function (string $error) use (&$errorTriggered) {

Original file line number	Diff line number	Diff line change
`@@ -4,6 +4,7 @@`
`4`	`4`
`5`	`5`	`use Exception;`
`6`	`6`	`use KLP\KlpMcpServer\Protocol\Handlers\NotificationHandler;`
	`7`	`+use KLP\KlpMcpServer\Transports\SseAdapters\SseAdapterException;`
`7`	`8`	`use KLP\KlpMcpServer\Transports\SseAdapters\SseAdapterInterface;`
`8`	`9`
`9`	`10`	`/**`
`@@ -31,7 +32,7 @@ public function execute(?array $params = null): array`
`31`	`32`	`{`
`32`	`33`	`try {`
`33`	`34`	`$this->adapter?->storeLastPongResponseTimestamp($params['clientId'], time());`
`34`		`- } catch (Exception) {`
	`35`	`+ } catch (SseAdapterException) {`
`35`	`36`	`// Nothing to do here the client will be disconnected anyway`
`36`	`37`	`}`
`37`	`38`
Original file line number	Diff line number	Diff line change
`@@ -45,7 +45,7 @@ public function __construct(`
`45`	`45`	`$this->redis->setOption(Redis::OPT_PREFIX, $this->keyPrefix);`
`46`	`46`	`} catch (Exception $e) {`
`47`	`47`	`$this->logger?->error(self::FAILED_TO_INITIALIZE.$e->getMessage());`
`48`		`- throw new \Exception(self::FAILED_TO_INITIALIZE.$e->getMessage());`
	`48`	`+ throw new SseAdapterException(self::FAILED_TO_INITIALIZE.$e->getMessage());`
`49`	`49`	`}`
`50`	`50`	`}`
`51`	`51`
`@@ -55,7 +55,7 @@ public function __construct(`
`55`	`55`	`* @param string $clientId The unique identifier for the client`
`56`	`56`	`* @param string $message The message to be queued`
`57`	`57`	`*`
`58`		`- * @throws Exception If the message cannot be added to the queue`
	`58`	`+ * @throws SseAdapterException If the message cannot be added to the queue`
`59`	`59`	`*/`
`60`	`60`	`public function pushMessage(string $clientId, string $message): void`
`61`	`61`	`{`
`@@ -68,7 +68,7 @@ public function pushMessage(string $clientId, string $message): void`
`68`	`68`
`69`	`69`	`} catch (Exception $e) {`
`70`	`70`	`$this->logger?->error('Failed to add message to Redis queue: '.$e->getMessage());`
`71`		`- throw new Exception('Failed to add message to Redis queue: '.$e->getMessage());`
	`71`	`+ throw new SseAdapterException('Failed to add message to Redis queue: '.$e->getMessage());`
`72`	`72`	`}`
`73`	`73`	`}`
`74`	`74`
`@@ -88,7 +88,7 @@ protected function getQueueKey(string $clientId): string`
`88`	`88`	`*`
`89`	`89`	`* @param string $clientId The unique identifier for the client`
`90`	`90`	`*`
`91`		`- * @throws Exception If the messages cannot be removed`
	`91`	`+ * @throws SseAdapterException If the messages cannot be removed`
`92`	`92`	`*/`
`93`	`93`	`public function removeAllMessages(string $clientId): void`
`94`	`94`	`{`
`@@ -99,7 +99,7 @@ public function removeAllMessages(string $clientId): void`
`99`	`99`
`100`	`100`	`} catch (Exception $e) {`
`101`	`101`	`$this->logger?->error('Failed to remove messages from Redis queue: '.$e->getMessage());`
`102`		`- throw new Exception('Failed to remove messages from Redis queue: '.$e->getMessage());`
	`102`	`+ throw new SseAdapterException('Failed to remove messages from Redis queue: '.$e->getMessage());`
`103`	`103`	`}`
`104`	`104`	`}`
`105`	`105`
`@@ -109,7 +109,7 @@ public function removeAllMessages(string $clientId): void`
`109`	`109`	`* @param string $clientId The unique identifier for the client`
`110`	`110`	`* @return array<string> Array of messages`
`111`	`111`	`*`
`112`		`- * @throws Exception If the messages cannot be retrieved`
	`112`	`+ * @throws SseAdapterException If the messages cannot be retrieved`
`113`	`113`	`*/`
`114`	`114`	`public function receiveMessages(string $clientId): array`
`115`	`115`	`{`
`@@ -123,7 +123,7 @@ public function receiveMessages(string $clientId): array`
`123`	`123`
`124`	`124`	`return $messages;`
`125`	`125`	`} catch (Exception $e) {`
`126`		`- throw new Exception('Failed to receive messages from Redis queue: '.$e->getMessage());`
	`126`	`+ throw new SseAdapterException('Failed to receive messages from Redis queue: '.$e->getMessage());`
`127`	`127`	`}`
`128`	`128`	`}`
`129`	`129`
`@@ -133,7 +133,7 @@ public function receiveMessages(string $clientId): array`
`133`	`133`	`* @param string $clientId The unique identifier for the client`
`134`	`134`	`* @return string\|null The message or null if the queue is empty`
`135`	`135`	`*`
`136`		`- * @throws Exception If the message cannot be popped`
	`136`	`+ * @throws SseAdapterException If the message cannot be popped`
`137`	`137`	`*/`
`138`	`138`	`public function popMessage(string $clientId): ?string`
`139`	`139`	`{`
`@@ -149,7 +149,7 @@ public function popMessage(string $clientId): ?string`
`149`	`149`	`return $message;`
`150`	`150`	`} catch (Exception $e) {`
`151`	`151`	`$this->logger?->error('Failed to pop message from Redis queue: '.$e->getMessage());`
`152`		`- throw new Exception('Failed to pop message from Redis queue: '.$e->getMessage());`
	`152`	`+ throw new SseAdapterException('Failed to pop message from Redis queue: '.$e->getMessage());`
`153`	`153`	`}`
`154`	`154`	`}`
`155`	`155`
`@@ -201,7 +201,7 @@ public function getMessageCount(string $clientId): int`
`201`	`201`	`* @param string $clientId The unique identifier for the client`
`202`	`202`	`* @param int\|null $timestamp The timestamp to store (defaults to current time if null)`
`203`	`203`	`*`
`204`		`- * @throws Exception If the timestamp cannot be stored`
	`204`	`+ * @throws SseAdapterException If the timestamp cannot be stored`
`205`	`205`	`*/`
`206`	`206`	`public function storeLastPongResponseTimestamp(string $clientId, ?int $timestamp = null): void`
`207`	`207`	`{`
`@@ -214,7 +214,7 @@ public function storeLastPongResponseTimestamp(string $clientId, ?int $timestamp`
`214`	`214`
`215`	`215`	`} catch (Exception $e) {`
`216`	`216`	`$this->logger?->error('Failed to store last pong timestamp: '.$e->getMessage());`
`217`		`- throw new Exception('Failed to store last pong timestamp: '.$e->getMessage());`
	`217`	`+ throw new SseAdapterException('Failed to store last pong timestamp: '.$e->getMessage());`
`218`	`218`	`}`
`219`	`219`	`}`
`220`	`220`
`@@ -224,7 +224,7 @@ public function storeLastPongResponseTimestamp(string $clientId, ?int $timestamp`
`224`	`224`	`* @param string $clientId The unique identifier for the client`
`225`	`225`	`* @return int\|null The timestamp or null if no timestamp is stored`
`226`	`226`	`*`
`227`		`- * @throws Exception If the timestamp cannot be retrieved`
	`227`	`+ * @throws SseAdapterException If the timestamp cannot be retrieved`
`228`	`228`	`*/`
`229`	`229`	`public function getLastPongResponseTimestamp(string $clientId): ?int`
`230`	`230`	`{`
`@@ -241,7 +241,7 @@ public function getLastPongResponseTimestamp(string $clientId): ?int`
`241`	`241`
`242`	`242`	`} catch (Exception $e) {`
`243`	`243`	`$this->logger?->error('Failed to get last pong timestamp: '.$e->getMessage());`
`244`		`- throw new Exception('Failed to get last pong timestamp: '.$e->getMessage());`
	`244`	`+ throw new SseAdapterException('Failed to get last pong timestamp: '.$e->getMessage());`
`245`	`245`	`}`
`246`	`246`	`}`
`247`	`247`	`}`
Original file line number	Diff line number	Diff line change
`@@ -19,7 +19,7 @@ interface SseAdapterInterface`
`19`	`19`	`* @param string $clientId The unique identifier for the client`
`20`	`20`	`* @param string $message The message to be queued`
`21`	`21`	`*`
`22`		`- * @throws \Exception If the message cannot be added to the queue`
	`22`	`+ * @throws SseAdapterException If the message cannot be added to the queue`
`23`	`23`	`*/`
`24`	`24`	`public function pushMessage(string $clientId, string $message): void;`
`25`	`25`
`@@ -28,7 +28,7 @@ public function pushMessage(string $clientId, string $message): void;`
`28`	`28`	`*`
`29`	`29`	`* @param string $clientId The unique identifier for the client`
`30`	`30`	`*`
`31`		`- * @throws \Exception If the messages cannot be removed`
	`31`	`+ * @throws SseAdapterException If the messages cannot be removed`
`32`	`32`	`*/`
`33`	`33`	`public function removeAllMessages(string $clientId): void;`
`34`	`34`
`@@ -38,7 +38,7 @@ public function removeAllMessages(string $clientId): void;`
`38`	`38`	`* @param string $clientId The unique identifier for the client`
`39`	`39`	`* @return array<string> Array of messages`
`40`	`40`	`*`
`41`		`- * @throws \Exception If the messages cannot be retrieved`
	`41`	`+ * @throws SseAdapterException If the messages cannot be retrieved`
`42`	`42`	`*/`
`43`	`43`	`public function receiveMessages(string $clientId): array;`
`44`	`44`
`@@ -48,7 +48,7 @@ public function receiveMessages(string $clientId): array;`
`48`	`48`	`* @param string $clientId The unique identifier for the client`
`49`	`49`	`* @return string\|null The message or null if the queue is empty`
`50`	`50`	`*`
`51`		`- * @throws \Exception If the message cannot be popped`
	`51`	`+ * @throws SseAdapterException If the message cannot be popped`
`52`	`52`	`*/`
`53`	`53`	`public function popMessage(string $clientId): ?string;`
`54`	`54`
`@@ -74,7 +74,7 @@ public function getMessageCount(string $clientId): int;`
`74`	`74`	`* @param string $clientId The unique identifier for the client`
`75`	`75`	`* @param int\|null $timestamp The timestamp to store (defaults to current time if null)`
`76`	`76`	`*`
`77`		`- * @throws \Exception If the timestamp cannot be stored`
	`77`	`+ * @throws SseAdapterException If the timestamp cannot be stored`
`78`	`78`	`*/`
`79`	`79`	`public function storeLastPongResponseTimestamp(string $clientId, ?int $timestamp = null): void;`
`80`	`80`
`@@ -84,7 +84,7 @@ public function storeLastPongResponseTimestamp(string $clientId, ?int $timestamp`
`84`	`84`	`* @param string $clientId The unique identifier for the client`
`85`	`85`	`* @return int\|null The timestamp or null if no timestamp is stored`
`86`	`86`	`*`
`87`		`- * @throws \Exception If the timestamp cannot be retrieved`
	`87`	`+ * @throws SseAdapterException If the timestamp cannot be retrieved`
`88`	`88`	`*/`
`89`	`89`	`public function getLastPongResponseTimestamp(string $clientId): ?int;`
`90`	`90`	`}`
Original file line number	Diff line number	Diff line change
`@@ -3,6 +3,7 @@`
`3`	`3`	`namespace KLP\KlpMcpServer\Transports;`
`4`	`4`
`5`	`5`	`use Exception;`
	`6`	`+use KLP\KlpMcpServer\Transports\SseAdapters\SseAdapterException;`
`6`	`7`	`use KLP\KlpMcpServer\Transports\SseAdapters\SseAdapterInterface;`
`7`	`8`	`use Psr\Log\LoggerInterface;`
`8`	`9`
`@@ -98,15 +99,15 @@ public function start(): void`
`98`	`99`	`* Initializes the transport: generates client ID and sends the initial 'endpoint' event.`
`99`	`100`	`* Adapter-specific initialization might occur here or externally.`
`100`	`101`	`*`
`101`		`- * @throws Exception If sending the initial event fails.`
	`102`	`+ * @throws SseAdapterException If sending the initial event fails.`
`102`	`103`	`*/`
`103`	`104`	`public function initialize(): void`
`104`	`105`	`{`
`105`	`106`	`if ($this->clientId === null) {`
`106`	`107`	`$this->clientId = uniqid();`
`107`	`108`	`}`
`108`	`109`	`$this->lastPingTimestamp = time();`
`109`		`- $this->adapter->storeLastPongResponseTimestamp($this->clientId, time());`
	`110`	`+ $this->adapter?->storeLastPongResponseTimestamp($this->clientId, time());`
`110`	`111`
`111`	`112`	`$this->sendEvent(event: 'endpoint', data: $this->getEndpoint(sessionId: $this->clientId));`
`112`	`113`	`}`
`@@ -173,7 +174,7 @@ public function close(): void`
`173`	`174`	`if ($this->adapter !== null && $this->clientId !== null) {`
`174`	`175`	`try {`
`175`	`176`	`$this->adapter->removeAllMessages($this->clientId);`
`176`		`- } catch (Exception $e) {`
	`177`	`+ } catch (SseAdapterException $e) {`
`177`	`178`	`$this->logger?->error('Error cleaning up SSE adapter resources on close: '.$e->getMessage());`
`178`	`179`	`}`
`179`	`180`	`}`
`@@ -245,7 +246,7 @@ public function receive(): array`
`245`	`246`	`$messages = $this->adapter->receiveMessages($this->clientId);`
`246`	`247`
`247`	`248`	`return $messages ?: [];`
`248`		`- } catch (Exception $e) {`
	`249`	`+ } catch (SseAdapterException $e) {`
`249`	`250`	`$this->triggerError('SSE Failed to receive messages via adapter: '.$e->getMessage());`
`250`	`251`	`}`
`251`	`252`	`} elseif ($this->adapter === null) {`
`@@ -338,7 +339,8 @@ private function getEndpoint(string $sessionId): string`
`338`	`339`	`}`
`339`	`340`
`340`	`341`	`/**`
`341`		`- * @throws Exception`
	`342`	`+ * @return int\|null`
	`343`	`+ * @throws SseAdapterException`
`342`	`344`	`*/`
`343`	`345`	`protected function getLastPongResponseTimestamp(): ?int`
`344`	`346`	`{`