Fix styling

kargnas · github-actions[bot] · commit 9372358ebc70 · 2025-04-17T18:15:56.000Z
diff --git a/src/Services/SseAdapterFactory.php b/src/Services/SseAdapterFactory.php
@@ -59,14 +59,14 @@ public function createAdapter(): SseAdapterInterface
      */
     private function initializeAdapter(): void
     {
-        $adapterConfig = Config::get('mcp-server.adapters.' . $this->adapterType, []);
+        $adapterConfig = Config::get('mcp-server.adapters.'.$this->adapterType, []);
 
         switch ($this->adapterType) {
             case 'redis':
                 $this->adapter = new RedisAdapter;
                 break;
             default:
-                throw new Exception('Unsupported SSE adapter type: ' . $this->adapterType);
+                throw new Exception('Unsupported SSE adapter type: '.$this->adapterType);
         }
 
         $this->adapter->initialize($adapterConfig);
diff --git a/src/Transports/SseAdapters/RedisAdapter.php b/src/Transports/SseAdapters/RedisAdapter.php
@@ -52,8 +52,8 @@ public function initialize(array $config): void
                 $this->messageTtl = (int) $config['ttl'];
             }
         } catch (Exception $e) {
-            Log::error('Failed to initialize Redis SSE Adapter: ' . $e->getMessage());
-            throw new Exception('Failed to initialize Redis SSE Adapter: ' . $e->getMessage());
+            Log::error('Failed to initialize Redis SSE Adapter: '.$e->getMessage());
+            throw new Exception('Failed to initialize Redis SSE Adapter: '.$e->getMessage());
         }
     }
 
@@ -75,8 +75,8 @@ public function pushMessage(string $clientId, string $message): void
             $this->redis->expire($key, $this->messageTtl);
 
         } catch (Exception $e) {
-            Log::error('Failed to add message to Redis queue: ' . $e->getMessage());
-            throw new Exception('Failed to add message to Redis queue: ' . $e->getMessage());
+            Log::error('Failed to add message to Redis queue: '.$e->getMessage());
+            throw new Exception('Failed to add message to Redis queue: '.$e->getMessage());
         }
     }
 
@@ -108,8 +108,8 @@ public function removeAllMessages(string $clientId): void
             $this->redis->del($key);
 
         } catch (Exception $e) {
-            Log::error('Failed to remove messages from Redis queue: ' . $e->getMessage());
-            throw new Exception('Failed to remove messages from Redis queue: ' . $e->getMessage());
+            Log::error('Failed to remove messages from Redis queue: '.$e->getMessage());
+            throw new Exception('Failed to remove messages from Redis queue: '.$e->getMessage());
         }
     }
 
@@ -133,7 +133,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 Exception('Failed to receive messages from Redis queue: '.$e->getMessage());
         }
     }
 
@@ -158,8 +158,8 @@ public function popMessage(string $clientId): ?string
 
             return $message;
         } catch (Exception $e) {
-            Log::error('Failed to pop message from Redis queue: ' . $e->getMessage());
-            throw new Exception('Failed to pop message from Redis queue: ' . $e->getMessage());
+            Log::error('Failed to pop message from Redis queue: '.$e->getMessage());
+            throw new Exception('Failed to pop message from Redis queue: '.$e->getMessage());
         }
     }
 
@@ -178,7 +178,7 @@ public function hasMessages(string $clientId): bool
 
             return $count > 0;
         } catch (Exception $e) {
-            Log::error('Failed to check for messages in Redis queue: ' . $e->getMessage());
+            Log::error('Failed to check for messages in Redis queue: '.$e->getMessage());
 
             return false;
         }
@@ -199,7 +199,7 @@ public function getMessageCount(string $clientId): int
 
             return (int) $count;
         } catch (Exception $e) {
-            Log::error('Failed to get message count from Redis queue: ' . $e->getMessage());
+            Log::error('Failed to get message count from Redis queue: '.$e->getMessage());
 
             return 0;
         }
diff --git a/src/Transports/SseTransport.php b/src/Transports/SseTransport.php
@@ -97,7 +97,7 @@ public function initialize(): void
     private function sendEvent(string $event, string $data): void
     {
         // 헤더 설정이 이미 전송되었는지 확인
-        if (!headers_sent()) {
+        if (! headers_sent()) {
             // 버퍼링 비활성화
             ini_set('output_buffering', 'off');
             ini_set('zlib.output_compression', false);
@@ -114,8 +114,8 @@ private function sendEvent(string $event, string $data): void
             ob_end_flush();
         }
 
-        echo sprintf("event: %s", $event) . PHP_EOL;
-        echo sprintf("data: %s", $data) . PHP_EOL;
+        echo sprintf('event: %s', $event).PHP_EOL;
+        echo sprintf('data: %s', $data).PHP_EOL;
         echo PHP_EOL;
 
         flush();
@@ -146,7 +146,7 @@ public function send(string|array $message): void
      */
     public function close(): void
     {
-        if (!$this->connected) {
+        if (! $this->connected) {
             return;
         }
 
@@ -156,22 +156,22 @@ public function close(): void
             try {
                 call_user_func($handler);
             } catch (Exception $e) {
-                Log::error('Error in SSE close handler: ' . $e->getMessage());
+                Log::error('Error in SSE close handler: '.$e->getMessage());
             }
         }
 
         if ($this->adapter !== null && $this->clientId !== null) {
             try {
                 $this->adapter->removeAllMessages($this->clientId);
             } catch (Exception $e) {
-                Log::error('Error cleaning up SSE adapter resources on close: ' . $e->getMessage());
+                Log::error('Error cleaning up SSE adapter resources on close: '.$e->getMessage());
             }
         }
 
         try {
             $this->sendEvent(event: 'close', data: '{"reason":"server_closed"}');
         } catch (Exception $e) {
-            Log::info('Could not send final SSE close event: ' . $e->getMessage());
+            Log::info('Could not send final SSE close event: '.$e->getMessage());
         }
     }
 
@@ -230,7 +230,7 @@ public function receive(): array
 
                 return $messages ?: [];
             } catch (Exception $e) {
-                $this->triggerError('SSE Failed to receive messages via adapter: ' . $e->getMessage());
+                $this->triggerError('SSE Failed to receive messages via adapter: '.$e->getMessage());
             }
         } elseif ($this->adapter === null) {
             Log::info('SSE Transport::receive called but no adapter is configured.');
@@ -247,13 +247,13 @@ public function receive(): array
      */
     protected function triggerError(string $message): void
     {
-        Log::error('SSE Transport error: ' . $message);
+        Log::error('SSE Transport error: '.$message);
 
         foreach ($this->errorHandlers as $handler) {
             try {
                 call_user_func($handler, $message);
             } catch (Exception $e) {
-                Log::error('Error in SSE error handler itself: ' . $e->getMessage());
+                Log::error('Error in SSE error handler itself: '.$e->getMessage());
             }
         }
     }
@@ -281,7 +281,7 @@ public function processMessage(string $clientId, array $message): void
             try {
                 $handler($clientId, $message);
             } catch (Exception $e) {
-                Log::error('Error processing SSE message via handler: ' . $e->getMessage(), [
+                Log::error('Error processing SSE message via handler: '.$e->getMessage(), [
                     'clientId' => $clientId,
                     // Avoid logging potentially sensitive message content in production
                     // 'message_summary' => is_array($message) ? json_encode(array_keys($message)) : substr($message, 0, 100)
@@ -307,7 +307,7 @@ public function pushMessage(string $clientId, array $message): void
 
         $messageString = json_encode($message);
         if ($messageString === false) {
-            throw new Exception('Failed to JSON encode message for pushing: ' . json_last_error_msg());
+            throw new Exception('Failed to JSON encode message for pushing: '.json_last_error_msg());
         }
 
         $this->adapter->pushMessage(clientId: $clientId, message: $messageString);

Original file line number	Diff line number	Diff line change
`@@ -52,8 +52,8 @@ public function initialize(array $config): void`
`52`	`52`	`$this->messageTtl = (int) $config['ttl'];`
`53`	`53`	`}`
`54`	`54`	`} catch (Exception $e) {`
`55`		`- Log::error('Failed to initialize Redis SSE Adapter: ' . $e->getMessage());`
`56`		`- throw new Exception('Failed to initialize Redis SSE Adapter: ' . $e->getMessage());`
	`55`	`+ Log::error('Failed to initialize Redis SSE Adapter: '.$e->getMessage());`
	`56`	`+ throw new Exception('Failed to initialize Redis SSE Adapter: '.$e->getMessage());`
`57`	`57`	`}`
`58`	`58`	`}`
`59`	`59`
`@@ -75,8 +75,8 @@ public function pushMessage(string $clientId, string $message): void`
`75`	`75`	`$this->redis->expire($key, $this->messageTtl);`
`76`	`76`
`77`	`77`	`} catch (Exception $e) {`
`78`		`- Log::error('Failed to add message to Redis queue: ' . $e->getMessage());`
`79`		`- throw new Exception('Failed to add message to Redis queue: ' . $e->getMessage());`
	`78`	`+ Log::error('Failed to add message to Redis queue: '.$e->getMessage());`
	`79`	`+ throw new Exception('Failed to add message to Redis queue: '.$e->getMessage());`
`80`	`80`	`}`
`81`	`81`	`}`
`82`	`82`
`@@ -108,8 +108,8 @@ public function removeAllMessages(string $clientId): void`
`108`	`108`	`$this->redis->del($key);`
`109`	`109`
`110`	`110`	`} catch (Exception $e) {`
`111`		`- Log::error('Failed to remove messages from Redis queue: ' . $e->getMessage());`
`112`		`- throw new Exception('Failed to remove messages from Redis queue: ' . $e->getMessage());`
	`111`	`+ Log::error('Failed to remove messages from Redis queue: '.$e->getMessage());`
	`112`	`+ throw new Exception('Failed to remove messages from Redis queue: '.$e->getMessage());`
`113`	`113`	`}`
`114`	`114`	`}`
`115`	`115`
`@@ -133,7 +133,7 @@ public function receiveMessages(string $clientId): array`
`133`	`133`
`134`	`134`	`return $messages;`
`135`	`135`	`} catch (Exception $e) {`
`136`		`- throw new Exception('Failed to receive messages from Redis queue: ' . $e->getMessage());`
	`136`	`+ throw new Exception('Failed to receive messages from Redis queue: '.$e->getMessage());`
`137`	`137`	`}`
`138`	`138`	`}`
`139`	`139`
`@@ -158,8 +158,8 @@ public function popMessage(string $clientId): ?string`
`158`	`158`
`159`	`159`	`return $message;`
`160`	`160`	`} catch (Exception $e) {`
`161`		`- Log::error('Failed to pop message from Redis queue: ' . $e->getMessage());`
`162`		`- throw new Exception('Failed to pop message from Redis queue: ' . $e->getMessage());`
	`161`	`+ Log::error('Failed to pop message from Redis queue: '.$e->getMessage());`
	`162`	`+ throw new Exception('Failed to pop message from Redis queue: '.$e->getMessage());`
`163`	`163`	`}`
`164`	`164`	`}`
`165`	`165`
`@@ -178,7 +178,7 @@ public function hasMessages(string $clientId): bool`
`178`	`178`
`179`	`179`	`return $count > 0;`
`180`	`180`	`} catch (Exception $e) {`
`181`		`- Log::error('Failed to check for messages in Redis queue: ' . $e->getMessage());`
	`181`	`+ Log::error('Failed to check for messages in Redis queue: '.$e->getMessage());`
`182`	`182`
`183`	`183`	`return false;`
`184`	`184`	`}`
`@@ -199,7 +199,7 @@ public function getMessageCount(string $clientId): int`
`199`	`199`
`200`	`200`	`return (int) $count;`
`201`	`201`	`} catch (Exception $e) {`
`202`		`- Log::error('Failed to get message count from Redis queue: ' . $e->getMessage());`
	`202`	`+ Log::error('Failed to get message count from Redis queue: '.$e->getMessage());`
`203`	`203`
`204`	`204`	`return 0;`
`205`	`205`	`}`
Original file line number	Diff line number	Diff line change
`@@ -97,7 +97,7 @@ public function initialize(): void`
`97`	`97`	`private function sendEvent(string $event, string $data): void`
`98`	`98`	`{`
`99`	`99`	`// 헤더 설정이 이미 전송되었는지 확인`
`100`		`- if (!headers_sent()) {`
	`100`	`+ if (! headers_sent()) {`
`101`	`101`	`// 버퍼링 비활성화`
`102`	`102`	`ini_set('output_buffering', 'off');`
`103`	`103`	`ini_set('zlib.output_compression', false);`
`@@ -114,8 +114,8 @@ private function sendEvent(string $event, string $data): void`
`114`	`114`	`ob_end_flush();`
`115`	`115`	`}`
`116`	`116`
`117`		`- echo sprintf("event: %s", $event) . PHP_EOL;`
`118`		`- echo sprintf("data: %s", $data) . PHP_EOL;`
	`117`	`+ echo sprintf('event: %s', $event).PHP_EOL;`
	`118`	`+ echo sprintf('data: %s', $data).PHP_EOL;`
`119`	`119`	`echo PHP_EOL;`
`120`	`120`
`121`	`121`	`flush();`
`@@ -146,7 +146,7 @@ public function send(string\|array $message): void`
`146`	`146`	`*/`
`147`	`147`	`public function close(): void`
`148`	`148`	`{`
`149`		`- if (!$this->connected) {`
	`149`	`+ if (! $this->connected) {`
`150`	`150`	`return;`
`151`	`151`	`}`
`152`	`152`
`@@ -156,22 +156,22 @@ public function close(): void`
`156`	`156`	`try {`
`157`	`157`	`call_user_func($handler);`
`158`	`158`	`} catch (Exception $e) {`
`159`		`- Log::error('Error in SSE close handler: ' . $e->getMessage());`
	`159`	`+ Log::error('Error in SSE close handler: '.$e->getMessage());`
`160`	`160`	`}`
`161`	`161`	`}`
`162`	`162`
`163`	`163`	`if ($this->adapter !== null && $this->clientId !== null) {`
`164`	`164`	`try {`
`165`	`165`	`$this->adapter->removeAllMessages($this->clientId);`
`166`	`166`	`} catch (Exception $e) {`
`167`		`- Log::error('Error cleaning up SSE adapter resources on close: ' . $e->getMessage());`
	`167`	`+ Log::error('Error cleaning up SSE adapter resources on close: '.$e->getMessage());`
`168`	`168`	`}`
`169`	`169`	`}`
`170`	`170`
`171`	`171`	`try {`
`172`	`172`	`$this->sendEvent(event: 'close', data: '{"reason":"server_closed"}');`
`173`	`173`	`} catch (Exception $e) {`
`174`		`- Log::info('Could not send final SSE close event: ' . $e->getMessage());`
	`174`	`+ Log::info('Could not send final SSE close event: '.$e->getMessage());`
`175`	`175`	`}`
`176`	`176`	`}`
`177`	`177`
`@@ -230,7 +230,7 @@ public function receive(): array`
`230`	`230`
`231`	`231`	`return $messages ?: [];`
`232`	`232`	`} catch (Exception $e) {`
`233`		`- $this->triggerError('SSE Failed to receive messages via adapter: ' . $e->getMessage());`
	`233`	`+ $this->triggerError('SSE Failed to receive messages via adapter: '.$e->getMessage());`
`234`	`234`	`}`
`235`	`235`	`} elseif ($this->adapter === null) {`
`236`	`236`	`Log::info('SSE Transport::receive called but no adapter is configured.');`
`@@ -247,13 +247,13 @@ public function receive(): array`
`247`	`247`	`*/`
`248`	`248`	`protected function triggerError(string $message): void`
`249`	`249`	`{`
`250`		`- Log::error('SSE Transport error: ' . $message);`
	`250`	`+ Log::error('SSE Transport error: '.$message);`
`251`	`251`
`252`	`252`	`foreach ($this->errorHandlers as $handler) {`
`253`	`253`	`try {`
`254`	`254`	`call_user_func($handler, $message);`
`255`	`255`	`} catch (Exception $e) {`
`256`		`- Log::error('Error in SSE error handler itself: ' . $e->getMessage());`
	`256`	`+ Log::error('Error in SSE error handler itself: '.$e->getMessage());`
`257`	`257`	`}`
`258`	`258`	`}`
`259`	`259`	`}`
`@@ -281,7 +281,7 @@ public function processMessage(string $clientId, array $message): void`
`281`	`281`	`try {`
`282`	`282`	`$handler($clientId, $message);`
`283`	`283`	`} catch (Exception $e) {`
`284`		`- Log::error('Error processing SSE message via handler: ' . $e->getMessage(), [`
	`284`	`+ Log::error('Error processing SSE message via handler: '.$e->getMessage(), [`
`285`	`285`	`'clientId' => $clientId,`
`286`	`286`	`// Avoid logging potentially sensitive message content in production`
`287`	`287`	`// 'message_summary' => is_array($message) ? json_encode(array_keys($message)) : substr($message, 0, 100)`
`@@ -307,7 +307,7 @@ public function pushMessage(string $clientId, array $message): void`
`307`	`307`
`308`	`308`	`$messageString = json_encode($message);`
`309`	`309`	`if ($messageString === false) {`
`310`		`- throw new Exception('Failed to JSON encode message for pushing: ' . json_last_error_msg());`
	`310`	`+ throw new Exception('Failed to JSON encode message for pushing: '.json_last_error_msg());`
`311`	`311`	`}`
`312`	`312`
`313`	`313`	`$this->adapter->pushMessage(clientId: $clientId, message: $messageString);`