Feat!: MCP Protocol 2025-03-26 Support

.github/workflows/tests.yml

@@ -10,7 +10,7 @@ jobs:
       fail-fast: false
       matrix:
         php: [8.1, 8.2, 8.3, 8.4]
-      max-parallel: 4
+      max-parallel: 2
 
     name: Tests PHP${{ matrix.php }}
 

composer.json

@@ -13,9 +13,10 @@
     "require": {
         "php": ">=8.1",
         "opis/json-schema": "^2.4",
+        "php-mcp/schema": "^1.0",
         "phpdocumentor/reflection-docblock": "^5.6",
+        "psr/clock": "^1.0",
         "psr/container": "^1.0 || ^2.0",
-        "psr/event-dispatcher": "^1.0",
         "psr/log": "^1.0 || ^2.0 || ^3.0",
         "psr/simple-cache": "^1.0 || ^2.0 || ^3.0",
         "react/event-loop": "^1.5",
@@ -29,6 +30,7 @@
         "mockery/mockery": "^1.6",
         "pestphp/pest": "^2.36.0|^3.5.0",
         "react/async": "^4.0",
+        "react/child-process": "^0.6.6",
         "symfony/var-dumper": "^6.4.11|^7.1.5"
     },
     "suggest": {

examples/02-discovery-http-userprofile/McpElements.php

@@ -2,6 +2,7 @@
 
 namespace Mcp\HttpUserProfileExample;
 
+use PhpMcp\Server\Attributes\CompletionProvider;
 use PhpMcp\Server\Attributes\McpPrompt;
 use PhpMcp\Server\Attributes\McpResource;
 use PhpMcp\Server\Attributes\McpResourceTemplate;
@@ -40,8 +41,11 @@ public function __construct(LoggerInterface $logger)
         description: 'Get profile information for a specific user ID.',
         mimeType: 'application/json'
     )]
-    public function getUserProfile(string $userId): array
-    {
+
+    public function getUserProfile(
+        #[CompletionProvider(providerClass: UserIdCompletionProvider::class)]
+        string $userId
+    ): array {
         $this->logger->info('Reading resource: user profile', ['userId' => $userId]);
         if (! isset($this->users[$userId])) {
             // Throwing an exception that Processor can turn into an error response
@@ -87,7 +91,7 @@ public function sendWelcomeMessage(string $userId, ?string $customMessage = null
         $user = $this->users[$userId];
         $message = "Welcome, {$user['name']}!";
         if ($customMessage) {
-            $message .= ' '.$customMessage;
+            $message .= ' ' . $customMessage;
         }
         // Simulate sending
         $this->logger->info("Simulated sending message to {$user['email']}: {$message}");
@@ -105,8 +109,11 @@ public function sendWelcomeMessage(string $userId, ?string $customMessage = null
      * @throws McpServerException If user not found.
      */
     #[McpPrompt(name: 'generate_bio_prompt')]
-    public function generateBio(string $userId, string $tone = 'professional'): array
-    {
+    public function generateBio(
+        #[CompletionProvider(providerClass: UserIdCompletionProvider::class)]
+        string $userId,
+        string $tone = 'professional'
+    ): array {
         $this->logger->info('Executing prompt: generate_bio', ['userId' => $userId, 'tone' => $tone]);
         if (! isset($this->users[$userId])) {
             throw McpServerException::invalidParams("User not found for bio prompt: {$userId}");

examples/02-discovery-http-userprofile/UserIdCompletionProvider.php

@@ -0,0 +1,19 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Mcp\HttpUserProfileExample;
+
+use PhpMcp\Server\Contracts\CompletionProviderInterface;
+use PhpMcp\Server\Contracts\SessionInterface;
+
+class UserIdCompletionProvider implements CompletionProviderInterface
+{
+    public function getCompletions(string $currentValue, SessionInterface $session): array
+    {
+        $availableUserIds = ['101', '102', '103'];
+        $filteredUserIds = array_filter($availableUserIds, fn(string $userId) => str_contains($userId, $currentValue));
+
+        return $filteredUserIds;
+    }
+}

examples/02-discovery-http-userprofile/server.php

@@ -39,10 +39,13 @@
 chdir(__DIR__);
 require_once '../../vendor/autoload.php';
 require_once 'McpElements.php';
+require_once 'UserIdCompletionProvider.php';
 
+use PhpMcp\Schema\ServerCapabilities;
 use PhpMcp\Server\Defaults\BasicContainer;
 use PhpMcp\Server\Server;
 use PhpMcp\Server\Transports\HttpServerTransport;
+use PhpMcp\Server\Transports\StreamableHttpServerTransport;
 use Psr\Log\AbstractLogger;
 use Psr\Log\LoggerInterface;
 
@@ -64,27 +67,24 @@ public function log($level, \Stringable|string $message, array $context = []): v
 
     $server = Server::make()
         ->withServerInfo('HTTP User Profiles', '1.0.0')
+        ->withCapabilities(ServerCapabilities::make(completions: true, logging: true))
         ->withLogger($logger)
         ->withContainer($container)
         ->build();
 
     $server->discover(__DIR__, ['.']);
 
-    $transport = new HttpServerTransport(
-        host: '127.0.0.1',
-        port: 8080,
-        mcpPathPrefix: 'mcp'
-    );
+    $transport = new HttpServerTransport('127.0.0.1', 8080, 'mcp');
+    // $transport = new StreamableHttpServerTransport('127.0.0.1', 8080, 'mcp');
 
     $server->listen($transport);
 
     $logger->info('Server listener stopped gracefully.');
     exit(0);
-
 } catch (\Throwable $e) {
     fwrite(STDERR, "[MCP SERVER CRITICAL ERROR]\n");
-    fwrite(STDERR, 'Error: '.$e->getMessage()."\n");
-    fwrite(STDERR, 'File: '.$e->getFile().':'.$e->getLine()."\n");
-    fwrite(STDERR, $e->getTraceAsString()."\n");
+    fwrite(STDERR, 'Error: ' . $e->getMessage() . "\n");
+    fwrite(STDERR, 'File: ' . $e->getFile() . ':' . $e->getLine() . "\n");
+    fwrite(STDERR, $e->getTraceAsString() . "\n");
     exit(1);
 }

examples/06-custom-dependencies-stdio/server.php

@@ -94,8 +94,10 @@ public function log($level, \Stringable|string $message, array $context = []): v
 
     $logger->info('Server listener stopped gracefully.');
     exit(0);
-
 } catch (\Throwable $e) {
-    fwrite(STDERR, "[MCP SERVER CRITICAL ERROR]\n".$e."\n");
+    fwrite(STDERR, "[MCP SERVER CRITICAL ERROR]\n");
+    fwrite(STDERR, 'Error: ' . $e->getMessage() . "\n");
+    fwrite(STDERR, 'File: ' . $e->getFile() . ':' . $e->getLine() . "\n");
+    fwrite(STDERR, $e->getTraceAsString() . "\n");
     exit(1);
 }