add tests

Author: MQ37

tests/integration/actor.server-sse.test.ts

@@ -18,6 +18,7 @@ const mcpUrl = `${httpServerHost}/sse`;
 
 createIntegrationTestsSuite({
     suiteName: 'Actors MCP Server SSE',
+    serverType: 'sse',
     getActorsMcpServer: () => mcpServer,
     createClientFn: async (options) => await createMcpSseClient(mcpUrl, options),
     beforeAllFn: async () => {

tests/integration/actor.server-streamable.test.ts

@@ -18,6 +18,7 @@ const mcpUrl = `${httpServerHost}/mcp`;
 
 createIntegrationTestsSuite({
     suiteName: 'Actors MCP Server Streamable HTTP',
+    serverType: 'http-streamable',
     getActorsMcpServer: () => mcpServer,
     createClientFn: async (options) => await createMcpStreamableClient(mcpUrl, options),
     beforeAllFn: async () => {

tests/integration/stdio.test.ts

@@ -3,5 +3,6 @@ import { createIntegrationTestsSuite } from './suite.js';
 
 createIntegrationTestsSuite({
     suiteName: 'MCP stdio',
+    serverType: 'stdio',
     createClientFn: createMcpStdioClient,
 });

tests/integration/suite.ts

@@ -1,4 +1,5 @@
 import type { Client } from '@modelcontextprotocol/sdk/client/index.js';
+import { ToolListChangedNotificationSchema } from '@modelcontextprotocol/sdk/types.js';
 import { afterAll, afterEach, beforeAll, beforeEach, describe, expect, it } from 'vitest';
 
 import { defaults, HelperTools } from '../../src/const.js';
@@ -10,6 +11,7 @@ import { addActor, expectArrayWeakEquals, type McpClientOptions } from '../helpe
 interface IntegrationTestsSuiteOptions {
     suiteName: string;
     getActorsMcpServer?: () => ActorsMcpServer;
+    serverType: 'stdio' | 'sse' | 'http-streamable';
     createClientFn: (options?: McpClientOptions) => Promise<Client>;
     beforeAllFn?: () => Promise<void>;
     afterAllFn?: () => Promise<void>;
@@ -56,6 +58,7 @@ export function createIntegrationTestsSuite(
 ) {
     const {
         suiteName,
+        serverType,
         getActorsMcpServer,
         createClientFn,
         beforeAllFn,
@@ -329,5 +332,25 @@ export function createIntegrationTestsSuite(
             expect(notificationCount).toBe(1);
             await client.close();
         });
+
+        // Skip for streamable since in this case we do NOT support SSE inside streamable transport
+        it.runIf(serverType !== 'http-streamable')('should notify client about tool list changed', async () => {
+            const client = await createClientFn({ enableAddingActors: true });
+
+            // This flag is set to true when a 'notifications/tools/list_changed' notification is received,
+            // indicating that the tool list has been updated dynamically.
+            let hasReceivedNotification = false;
+            client.setNotificationHandler(ToolListChangedNotificationSchema, async (notification) => {
+                if (notification.method === 'notifications/tools/list_changed') {
+                    hasReceivedNotification = true;
+                }
+            });
+            // Add Actor dynamically
+            await client.callTool({ name: HelperTools.ACTOR_ADD, arguments: { actorName: ACTOR_PYTHON_EXAMPLE } });
+
+            expect(hasReceivedNotification).toBe(true);
+
+            await client.close();
+        });
     });
 }