Minor changes, add clientSse.ts

Author: jirispilka

README.md

@@ -310,3 +310,4 @@ Upon launching, the Inspector will display a URL that you can access in your bro
 - Provide tools to search for Actors and load them as needed.
 - Add Apify's dataset and key-value store as resources.
 - Add tools such as Actor logs and Actor runs for debugging.
+- Prune Actors input schema to reduce context size.

src/const.ts

@@ -9,9 +9,9 @@ export const defaults = {
     ],
 };
 
-export const ACTOR_OUTPUT_MAX_CHARS_PER_ITEM = 1_000;
+export const ACTOR_OUTPUT_MAX_CHARS_PER_ITEM = 2_000;
 export const ACTOR_OUTPUT_TRUNCATED_MESSAGE = `Output was truncated because it will not fit into context.`
-    + `There is no reason to call this tool again!`;
+    + ` There is no reason to call this tool again!`;
 
 export enum Routes {
     ROOT = '/',

src/examples/clientSse.ts

@@ -0,0 +1,100 @@
+/* eslint-disable no-console */
+/**
+ * Connect to the MCP server using SSE transport and call a tool.
+ * The Actors MCP Server will load default Actors.
+ *
+ * !!! This example needs to be fixed as it does not work !!!
+ */
+
+import path from 'path';
+import { fileURLToPath } from 'url';
+
+import { Client } from '@modelcontextprotocol/sdk/client/index.js';
+import { SSEClientTransport } from '@modelcontextprotocol/sdk/client/sse.js';
+import { CallToolResultSchema } from '@modelcontextprotocol/sdk/types.js';
+import dotenv from 'dotenv';
+import { EventSource } from 'eventsource';
+
+// Resolve dirname equivalent in ES module
+const filename = fileURLToPath(import.meta.url);
+const dirname = path.dirname(filename);
+
+dotenv.config({ path: path.resolve(dirname, '../../.env') });
+
+const SERVER_URL = 'https://actors-mcp-server/sse';
+// We need to change forward slash / to underscore _ in the tool name as Anthropic does not allow forward slashes in the tool name
+const SELECTED_TOOL = 'apify_rag-web-browser';
+
+if (!process.env.APIFY_TOKEN) {
+    console.error('APIFY_TOKEN is required but not set in the environment variables.');
+    process.exit(1);
+}
+
+if (typeof globalThis.EventSource === 'undefined') {
+    globalThis.EventSource = EventSource as unknown as typeof globalThis.EventSource;
+}
+
+async function main(): Promise<void> {
+    const transport = new SSEClientTransport(
+        new URL(SERVER_URL),
+        {
+            requestInit: {
+                headers: {
+                    authorization: `Bearer ${process.env.APIFY_TOKEN}`,
+                },
+            },
+            eventSourceInit: {
+                // The EventSource package augments EventSourceInit with a "fetch" parameter.
+                // You can use this to set additional headers on the outgoing request.
+                // Based on this example: https://github.com/modelcontextprotocol/typescript-sdk/issues/118
+                async fetch(input: Request | URL | string, init?: RequestInit) {
+                    const headers = new Headers(init?.headers || {});
+                    headers.set('authorization', `Bearer ${process.env.APIFY_TOKEN}`);
+                    return fetch(input, { ...init, headers });
+                },
+            // We have to cast to "any" to use it, since it's non-standard
+            } as any, // eslint-disable-line @typescript-eslint/no-explicit-any
+        },
+    );
+    const client = new Client(
+        { name: 'example-client', version: '1.0.0' },
+        { capabilities: {} },
+    );
+
+    try {
+        // Connect to the MCP server
+        await client.connect(transport);
+
+        // List available tools
+        const tools = await client.listTools();
+        console.log('Available tools:', tools);
+
+        if (tools.tools.length === 0) {
+            console.log('No tools available');
+            return;
+        }
+
+        const selectedTool = tools.tools.find((tool) => tool.name === SELECTED_TOOL);
+        if (!selectedTool) {
+            console.error(`The specified tool: ${selectedTool} is not available. Exiting.`);
+            return;
+        }
+
+        // Call a tool
+        console.log('Calling actor ...');
+        const result = await client.callTool(
+            { name: SELECTED_TOOL, arguments: { query: 'web browser for Anthropic' } },
+            CallToolResultSchema,
+        );
+        console.log('Tool result:', JSON.stringify(result, null, 2));
+    } catch (error: unknown) {
+        if (error instanceof Error) {
+            console.error('Error:', error.message);
+            console.error(error.stack);
+        } else {
+            console.error('An unknown error occurred:', error);
+        }
+    }
+}
+
+await main();

src/examples/client_sse.py

@@ -9,23 +9,23 @@
 
 import asyncio
 import os
+from pathlib import Path
 
 import requests
 from dotenv import load_dotenv
 from mcp.client.session import ClientSession
 from mcp.client.sse import sse_client
 
-load_dotenv(dotenv_path="../../.env")
+load_dotenv(Path(__file__).resolve().parent.parent.parent / ".env")
 
-MCP_SERVER_URL = "https://mcp-server.apify.actor"
-ACTORS = "apify/rag-web-browser"
+MCP_SERVER_URL = "https://actors-mcp-server.apify.actor"
 
 HEADERS = {"Authorization": f"Bearer {os.getenv('APIFY_TOKEN')}"}
 
 async def run() -> None:
 
-    print("Start MCP Server with Actors", ACTORS)
-    r = requests.get(MCP_SERVER_URL, params={"actors": ACTORS}, headers=HEADERS)
+    print("Start MCP Server with Actors",)
+    r = requests.get(MCP_SERVER_URL, headers=HEADERS)
     print("MCP Server Response:", r.json(), end="\n\n")
 
     async with sse_client(url=f"{MCP_SERVER_URL}/sse", timeout=60, headers=HEADERS) as (read, write):
@@ -36,7 +36,7 @@ async def run() -> None:
             print("Available Tools:", tools, end="\n\n")
 
             if hasattr(tools, "tools") and not tools.tools:
-                print("No tools available! Start MCP server with Actors")
+                print("No tools available!")
                 return
 
             result = await session.call_tool("apify/rag-web-browser", { "query": "example.com", "maxResults": 3 })