No need for extra abstractions if we are calling notifications directly

Author: Bellangelo

src/Capability/Registry.php

@@ -17,13 +17,12 @@
 use Mcp\Capability\Registry\ResourceReference;
 use Mcp\Capability\Registry\ResourceTemplateReference;
 use Mcp\Capability\Registry\ToolReference;
-use Mcp\Event\PromptListChangedEvent;
-use Mcp\Event\ResourceListChangedEvent;
-use Mcp\Event\ResourceTemplateListChangedEvent;
-use Mcp\Event\ToolListChangedEvent;
 use Mcp\Exception\InvalidArgumentException;
 use Mcp\Schema\Content\PromptMessage;
 use Mcp\Schema\Content\ResourceContents;
+use Mcp\Schema\Notification\PromptListChangedNotification;
+use Mcp\Schema\Notification\ResourceListChangedNotification;
+use Mcp\Schema\Notification\ToolListChangedNotification;
 use Mcp\Schema\Prompt;
 use Mcp\Schema\Resource;
 use Mcp\Schema\ResourceTemplate;
@@ -102,7 +101,7 @@ public function registerTool(Tool $tool, callable|array|string $handler, bool $i
 
         $this->tools[$toolName] = new ToolReference($tool, $handler, $isManual);
 
-        $this->notificationPublisher->enqueue(new ToolListChangedEvent());
+        $this->notificationPublisher->enqueue(ToolListChangedNotification::class);
     }
 
     /**
@@ -121,7 +120,7 @@ public function registerResource(Resource $resource, callable|array|string $hand
 
         $this->resources[$uri] = new ResourceReference($resource, $handler, $isManual);
 
-        $this->notificationPublisher->enqueue(new ResourceListChangedEvent());
+        $this->notificationPublisher->enqueue(ResourceListChangedNotification::class);
     }
 
     /**
@@ -145,7 +144,8 @@ public function registerResourceTemplate(
 
         $this->resourceTemplates[$uriTemplate] = new ResourceTemplateReference($template, $handler, $isManual, $completionProviders);
 
-        $this->notificationPublisher->enqueue(new ResourceTemplateListChangedEvent());
+        // TODO: Create ResourceTemplateListChangedNotification.
+        // $this->notificationPublisher->enqueue(ResourceTemplateListChangedNotification::class);
     }
 
     /**
@@ -169,7 +169,7 @@ public function registerPrompt(
 
         $this->prompts[$promptName] = new PromptReference($prompt, $handler, $isManual, $completionProviders);
 
-        $this->notificationPublisher->enqueue(new PromptListChangedEvent());
+        $this->notificationPublisher->enqueue(PromptListChangedNotification::class);
     }
 
     /**

src/Event/PromptListChangedEvent.php

@@ -13,30 +13,14 @@
 
 namespace Mcp\Server;
 
-use Mcp\Event\PromptListChangedEvent;
-use Mcp\Event\ResourceListChangedEvent;
-use Mcp\Event\ToolListChangedEvent;
 use Mcp\JsonRpc\MessageFactory;
 use Mcp\Schema\JsonRpc\Notification;
-use Mcp\Schema\Notification\PromptListChangedNotification;
-use Mcp\Schema\Notification\ResourceListChangedNotification;
-use Mcp\Schema\Notification\ToolListChangedNotification;
-use Symfony\Contracts\EventDispatcher\Event;
 
 /**
  * @author Aggelos Bellos <aggelosbellos7@gmail.com>
  */
 class NotificationPublisher
 {
-    /**
-     * @var array<class-string<Event>, class-string<Notification>>
-     */
-    public const EVENTS_TO_NOTIFICATIONS = [
-        ResourceListChangedEvent::class => ResourceListChangedNotification::class,
-        PromptListChangedEvent::class => PromptListChangedNotification::class,
-        ToolListChangedEvent::class => ToolListChangedNotification::class,
-    ];
-
     /** @var list<Notification> */
     private array $queue = [];
 
@@ -50,14 +34,12 @@ public static function make(): self
         return new self(MessageFactory::make());
     }
 
-    public function enqueue(Event $event): void
+    /**
+     * @param class-string<Notification> $notificationType
+     * @return void
+     */
+    public function enqueue(string $notificationType): void
     {
-        $eventClass = $event::class;
-        if (!isset(self::EVENTS_TO_NOTIFICATIONS[$eventClass])) {
-            return;
-        }
-
-        $notificationType = self::EVENTS_TO_NOTIFICATIONS[$eventClass];
         $notification = $this->factory->createByType($notificationType, []);
 
         $this->queue[] = $notification;