fix: Stdio and SSE example, improve logging (#32)

* fix: Examples stdio and sse * fix: log message
apify · Feb 7, 2025 · 1b1852c · 1b1852c
1 parent 560e33b
commit 1b1852c
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/src/examples/clientSse.ts b/src/examples/clientSse.ts
@@ -22,8 +22,8 @@ const dirname = path.dirname(filename);
 dotenv.config({ path: path.resolve(dirname, '../../.env') });
 
 const SERVER_URL = 'https://actors-mcp-server.apify.actor/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';
+// 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';
 const QUERY = 'web browser for Anthropic';
 
 if (!process.env.APIFY_TOKEN) {

diff --git a/src/examples/clientStdio.ts b/src/examples/clientStdio.ts
@@ -24,7 +24,7 @@ const SERVER_PATH = path.resolve(dirname, '../../dist/index.js');
 const NODE_PATH = execSync(process.platform === 'win32' ? 'where node' : 'which node').toString().trim();
 
 const TOOLS = 'apify/rag-web-browser,lukaskrivka/google-maps-with-contact-details';
-const SELECTED_TOOL = 'apify_rag-web-browser'; // We need to change / to _ in the tool name
+const SELECTED_TOOL = 'apify--rag-web-browser'; // We need to change / to _ in the tool name
 
 if (!process.env.APIFY_TOKEN) {
     console.error('APIFY_TOKEN is required but not set in the environment variables.');

diff --git a/src/main.ts b/src/main.ts
@@ -61,7 +61,7 @@ app.route(Routes.ROOT)
             return;
         }
         try {
-            log.info(`Received GET message at: ${req.url}`);
+            log.info(`Received GET message at: ${Routes.ROOT}`);
             await processParamsAndUpdateTools(req.url);
             res.status(200).json({ message: `Actor is using Model Context Protocol. ${HELP_MESSAGE}` }).end();
         } catch (error) {
@@ -76,7 +76,7 @@ app.route(Routes.ROOT)
 app.route(Routes.SSE)
     .get(async (req: Request, res: Response) => {
         try {
-            log.info(`Received GET message at: ${req.url}`);
+            log.info(`Received GET message at: ${Routes.SSE}`);
             await processParamsAndUpdateTools(req.url);
             transport = new SSEServerTransport(Routes.MESSAGE, res);
             await mcpServer.connect(transport);
@@ -89,7 +89,7 @@ app.route(Routes.SSE)
 app.route(Routes.MESSAGE)
     .post(async (req: Request, res: Response) => {
         try {
-            log.info(`Received POST message at: ${req.url}`);
+            log.info(`Received POST message at: ${Routes.MESSAGE}`);
             if (transport) {
                 await transport.handlePostMessage(req, res);
             } else {