Fix styling

Author: klapaudius

src/Data/Requests/NotificationData.php

@@ -10,10 +10,8 @@
  */
 class NotificationData
 {
-
     /**
      * The client ID of the client that sent the notification.
-     *
      */
     public string $clientId;
 
@@ -59,6 +57,7 @@ public static function fromArray(array $data): self
         if (isset($data['clientId']) && empty($data['params'])) {
             $data['params'] = ['clientId' => $data['clientId']];
         }
+
         return new self(
             method: $data['method'] ?? null,
             jsonRpc: $data['jsonrpc'],

src/Protocol/MCPProtocol.php

@@ -46,7 +46,7 @@ public function __construct(private readonly TransportInterface $transport)
         $this->transport->onMessage([$this, 'handleMessage']);
         if ($this->transport instanceof SseTransportInterface) {
             $this->registerNotificationHandler(new PongHandler($this->transport->getAdapter()));
-            $this->registerRequestHandler(new PingHandler( $this->transport ));
+            $this->registerRequestHandler(new PingHandler($this->transport));
         }
     }
 

src/Server/Notification/PongHandler.php

@@ -6,7 +6,6 @@
 use KLP\KlpMcpServer\Protocol\Handlers\NotificationHandler;
 use KLP\KlpMcpServer\Transports\SseAdapters\SseAdapterInterface;
 
-
 /**
  * Handles the processing of "Pong" notifications for managing client-server interactions.
  * This class specifically implements the NotificationHandler interface.
@@ -15,9 +14,7 @@
  */
 readonly class PongHandler implements NotificationHandler
 {
-    public function __construct(private ?SseAdapterInterface $adapter = null)
-    {
-    }
+    public function __construct(private ?SseAdapterInterface $adapter = null) {}
 
     public function isHandle(?string $method): bool
     {
@@ -27,7 +24,7 @@ public function isHandle(?string $method): bool
     /**
      * Executes a specified method with optional parameters.
      *
-     * @param array|null $params Optional parameters to pass to the method. Null if not provided.
+     * @param  array|null  $params  Optional parameters to pass to the method. Null if not provided.
      * @return array The result of the execution, returned as an array.
      */
     public function execute(?array $params = null): array

src/Server/Request/PingHandler.php

@@ -2,28 +2,22 @@
 
 namespace KLP\KlpMcpServer\Server\Request;
 
-use KLP\KlpMcpServer\Data\Requests\InitializeData;
-use KLP\KlpMcpServer\Exceptions\JsonRpcErrorException;
 use KLP\KlpMcpServer\Protocol\Handlers\RequestHandler;
-use KLP\KlpMcpServer\Server\MCPServer;
 use KLP\KlpMcpServer\Transports\SseTransportInterface;
 
 class PingHandler implements RequestHandler
 {
-
-    public function __construct(private readonly SseTransportInterface $transport)
-    {
-    }
+    public function __construct(private readonly SseTransportInterface $transport) {}
 
     public function isHandle(string $method): bool
     {
         return $method === 'ping';
     }
 
-
     public function execute(string $method, string|int $messageId, ?array $params = null): array
     {
-        $this->transport->send(["id" => $messageId, "jsonrpc" => "2.0", "result" => []]);
+        $this->transport->send(['id' => $messageId, 'jsonrpc' => '2.0', 'result' => []]);
+
         return [];
     }
 }

src/Server/Request/ToolsCallHandler.php

@@ -27,7 +27,7 @@ public function isHandle(string $method): bool
      * Executes a specified method with provided parameters and returns the result.
      *
      * @param  string  $method  The method to be executed.
-     * @param  string|int $messageId  The ID of the request message. Used for response identification.
+     * @param  string|int  $messageId  The ID of the request message. Used for response identification.
      * @param  array|null  $params  An associative array of parameters required for execution. Must include 'name' as the tool identifier and optionally 'arguments'.
      * @return array The response array containing the execution result, which may vary based on the method.
      *

src/Transports/SseAdapters/RedisAdapter.php

@@ -206,7 +206,7 @@ public function getMessageCount(string $clientId): int
     public function storeLastPongResponseTimestamp(string $clientId, ?int $timestamp = null): void
     {
         try {
-            $key = $this->getQueueKey($clientId).":last_pong";
+            $key = $this->getQueueKey($clientId).':last_pong';
             $timestamp = $timestamp ?? time();
 
             $this->redis->set($key, $timestamp);
@@ -229,7 +229,7 @@ public function storeLastPongResponseTimestamp(string $clientId, ?int $timestamp
     public function getLastPongResponseTimestamp(string $clientId): ?int
     {
         try {
-            $key = $this->getQueueKey($clientId).":last_pong";
+            $key = $this->getQueueKey($clientId).':last_pong';
 
             $timestamp = $this->redis->get($key);
 

src/Transports/SseAdapters/SseAdapterInterface.php

@@ -67,7 +67,7 @@ public function hasMessages(string $clientId): bool;
      * @return int The number of messages
      */
     public function getMessageCount(string $clientId): int;
-    
+
     /**
      * Store the last pong response timestamp for a specific client
      *
@@ -77,7 +77,7 @@ public function getMessageCount(string $clientId): int;
      * @throws \Exception If the timestamp cannot be stored
      */
     public function storeLastPongResponseTimestamp(string $clientId, ?int $timestamp = null): void;
-    
+
     /**
      * Get the last pong response timestamp for a specific client
      *

src/Transports/SseTransport.php

@@ -219,14 +219,15 @@ public function onMessage(callable $handler): void
      */
     public function isConnected(): bool
     {
-        if ( time() - $this->lastPingTimestamp > $this->pingInterval / 1000 ) {
+        if (time() - $this->lastPingTimestamp > $this->pingInterval / 1000) {
             $this->lastPingTimestamp = time();
             $this->send(message: ['jsonrpc' => '2.0', 'method' => 'ping']);
         }
         $pingTest = time() - $this->getLastPongResponseTimestamp() < ($this->pingInterval / 1000) + 5;
         if (! $pingTest) {
             $this->logger?->info('SSE Transport::isConnected: pingTest failed');
         }
+
         return $pingTest && connection_aborted() === 0;
     }
 
@@ -337,7 +338,6 @@ private function getEndpoint(string $sessionId): string
     }
 
     /**
-     * @return int|null
      * @throws Exception
      */
     protected function getLastPongResponseTimestamp(): ?int
@@ -348,9 +348,8 @@ protected function getLastPongResponseTimestamp(): ?int
     /**
      * Sets the interval for sending ping requests.
      *
-     * @param int $pingInterval The interval in milliseconds at which ping requests should be sent.
-     *                          The value must be between 10,000 and 30,000 ms.
-     * @return void
+     * @param  int  $pingInterval  The interval in milliseconds at which ping requests should be sent.
+     *                             The value must be between 10,000 and 30,000 ms.
      */
     protected function setPingInterval(int $pingInterval): void
     {