get standby url from actor id, check if is mcp server based on actor name for now

Author: MQ37

src/const.ts

@@ -37,3 +37,5 @@ export const defaults = {
     enableActorAutoLoading: false,
     maxMemoryMbytes: 4096,
 };
+
+export const APIFY_USERNAME = 'apify';

src/mcp/actors.ts

@@ -1,13 +1,13 @@
 
-export async function isActorMCPServer(actorID: string): Promise<boolean> {
+import { getActorStandbyURL } from "./utils.js";
+
+export async function isActorMCPServer(actorID: string, _apifyToken: string): Promise<boolean> {
     // TODO: implement the logic
-    return actorID === 'apify/actors-mcp-server';
+    return actorID.toLowerCase().includes('mcp-') || actorID.toLowerCase().includes('-mcp');
 }
 
-export async function getActorsMCPServerURL(actorID: string): Promise<string> {
-    // TODO: implement the logic
-    if (actorID === 'apify/actors-mcp-server') {
-        return 'https://actors-mcp-server.apify.actor/sse';
-    }
-    throw new Error(`Actor ${actorID} is not an MCP server`);
+export async function getActorsMCPServerURL(actorID: string, _apifyToken: string): Promise<string> {
+    // TODO: get from API instead
+    const standbyUrl = getActorStandbyURL(actorID)
+    return `${standbyUrl}/sse`;
 }

src/mcp/utils.ts

@@ -8,6 +8,7 @@ import type { ToolWrap } from '../types.js';
 
 import { addTool, getActorsAsTools, removeTool } from '../tools/index.js';
 import { Input } from "../types.js";
+import { APIFY_USERNAME } from "../const.js";
 
 /**
  * Generates a unique server ID based on the provided URL.
@@ -60,3 +61,22 @@ export function parseInputParamsFromUrl(url: string): Input {
     const params = parse(query) as unknown as Input;
     return processInput(params);
 }
+
+/**
+* Returns standby URL for given Actor ID.
+*
+* @param actorID
+* @param standbyBaseUrl
+* @returns
+*/
+export function getActorStandbyURL(actorID: string, standbyBaseUrl = '.apify.actor'): string {
+    const actorOwner = actorID.split('/')[0];
+    const actorName = actorID.split('/')[1];
+    if (!actorOwner || !actorName) {
+        throw new Error(`Invalid actor ID: ${actorID}`);
+    }
+
+    const prefix = actorOwner === APIFY_USERNAME ? '' : `${actorOwner}--`;
+
+    return `https://${prefix}${actorName}${standbyBaseUrl}`;
+}

src/tools/actor.ts

@@ -126,7 +126,7 @@ async function getMCPServersAsTools(
 ): Promise<ToolWrap[]> {
     const actorsMCPServerTools: ToolWrap[] = [];
     for (const actorID of actors) {
-        const serverUrl = await getActorsMCPServerURL(actorID);
+        const serverUrl = await getActorsMCPServerURL(actorID, apifyToken);
 
         let client: Client | undefined;
         try {
@@ -148,22 +148,22 @@ export async function getActorsAsTools(
     console.log('Fetching actors as tools...');
     console.log(actors)
     // Actorized MCP servers
-    const actorsMCPServer: string[] = [];
+    const actorsMCPServers: string[] = [];
     for (const actorID of actors) {
-        if (await isActorMCPServer(actorID)) {
-            actorsMCPServer.push(actorID);
+        if (await isActorMCPServer(actorID, apifyToken)) {
+            actorsMCPServers.push(actorID);
         }
     }
     // Normal Actors as a tool
-    const toolActors = actors.filter((actorID) => !actorsMCPServer.includes(actorID));
-    console.log('actorsMCPserver', actorsMCPServer);
+    const toolActors = actors.filter((actorID) => !actorsMCPServers.includes(actorID));
+    console.log('actorsMCPserver', actorsMCPServers);
     console.log('toolActors', toolActors);
 
     // Normal Actors as a tool
     const normalTools = await getNormalActorsAsTools(toolActors, apifyToken);
 
     // Tools from Actorized MCP servers
-    const mcpServerTools = await getMCPServersAsTools(actorsMCPServer, apifyToken);
+    const mcpServerTools = await getMCPServersAsTools(actorsMCPServers, apifyToken);
 
     return [...normalTools, ...mcpServerTools];
 }