Remove InMemoryAdapter and integrate RedisAdapter as default

Deprecated the InMemoryAdapter and updated configurations to use RedisAdapter as the default SSE adapter. Enhanced logging in MessageController and SseTransport for better traceability and testing. Adjusted tests and dependencies accordingly.

Author: klapaudius

src/Controllers/MessageController.php

@@ -3,19 +3,22 @@
 namespace KLP\KlpMcpServer\Controllers;
 
 use KLP\KlpMcpServer\Server\MCPServer;
+use Psr\Log\LoggerInterface;
 use Symfony\Component\HttpFoundation\JsonResponse;
 use Symfony\Component\HttpFoundation\Request;
 
 class MessageController
 {
-    public function __construct(private readonly MCPServer $server) {}
+    public function __construct(private readonly MCPServer $server, private readonly LoggerInterface $logger) {}
 
     public function handle(Request $request)
     {
         $sessionId = $request->request->get('sessionId') ?? $request->query->get('sessionId');
 
         $messageJson = json_decode($request->getContent(), true, flags: JSON_THROW_ON_ERROR);
 
+        $this->logger?->debug('Received message for clientId:'.$sessionId, ['message' => $messageJson]);
+
         $this->server->requestMessage(clientId: $sessionId, message: $messageJson);
 
         return new JsonResponse(['success' => true]);

src/Resources/config/packages/klp_mcp_server.yaml

@@ -54,8 +54,8 @@ klp_mcp_server:
     # generating the tool list for the client.
     # Register your tools here
     tools:
-        - \KLP\KlpMcpServer\Services\ToolService\Examples\HelloWorldTool::class
-        - \KLP\KlpMcpServer\Services\ToolService\Examples\VersionCheckTool::class
+        - KLP\KlpMcpServer\Services\ToolService\Examples\HelloWorldTool
+        - KLP\KlpMcpServer\Services\ToolService\Examples\VersionCheckTool
 
     # Prompts List
     # https://modelcontextprotocol.io/docs/concepts/prompts

src/Resources/config/services.xml

@@ -12,17 +12,18 @@
 
         <service id="KLP\KlpMcpServer\Controllers\MessageController" class="KLP\KlpMcpServer\Controllers\MessageController">
             <argument type="service" id="klp_mcp_server.server" />
+            <argument type="service" id="logger" on-invalid="null" />
             <tag name="controller.service_arguments" />
         </service>
         <service id="klp_mcp_server.controller.message" alias="KLP\KlpMcpServer\Controllers\MessageController" />
 
-        <service id="klp_mcp_server.adapter.default" alias="klp_mcp_server.adapter.in_memory" />
-        <service id="klp_mcp_server.adapter.in_memory" class="KLP\KlpMcpServer\Transports\SseAdapters\InMemoryAdapter" />
+        <service id="klp_mcp_server.adapter.default" alias="klp_mcp_server.adapter.redis" />
         <service id="klp_mcp_server.adapter.redis" class="KLP\KlpMcpServer\Transports\SseAdapters\RedisAdapter">
             <argument type="service" id="logger" on-invalid="null" />
         </service>
         <service id="klp_mcp_server.transport.sse" class="KLP\KlpMcpServer\Transports\SseTransport">
             <argument type="string">%klp_mcp_server.default_path%</argument>
+            <argument type="service" id="klp_mcp_server.adapter.redis" on-invalid="null" />
             <argument type="service" id="logger" on-invalid="null" />
         </service>
 

src/Transports/SseAdapters/InMemoryAdapter.php

@@ -14,14 +14,16 @@
 class SseTransportTest extends TestCase
 {
     private LoggerInterface|MockObject $loggerMock;
+    private SseAdapterInterface|MockObject $adapterMock;
 
     private SseTransport $instance;
 
     protected function setUp(): void
     {
         parent::setUp();
         $this->loggerMock = $this->createMock(LoggerInterface::class);
-        $this->instance = new SseTransport('/default-path', $this->loggerMock);
+        $this->adapterMock = $this->createMock(SseAdapterInterface::class);
+        $this->instance = new SseTransport('/default-path', $this->adapterMock, $this->loggerMock);
     }
 
     /**
@@ -313,6 +315,7 @@ public function test_receive_returns_empty_array_without_adapter(): void
     public function test_receive_logs_info_when_no_adapter(): void
     {
         // Arrange
+        $this->instance->setAdapter(null);
         $this->loggerMock->expects($this->once())
             ->method('info')
             ->with('SSE Transport::receive called but no adapter is configured.');
@@ -419,6 +422,7 @@ public function test_push_message_calls_adapter_correctly(): void
     public function test_push_message_throws_exception_without_adapter(): void
     {
         // Expect exception
+        $this->instance->setAdapter(null);
         $this->expectException(SseTransportException::class);
         $this->expectExceptionMessage('Cannot push message: SSE Adapter is not configured.');