get mcp path from definition

Author: MQ37

src/mcp/actors.ts

@@ -1,15 +1,22 @@
 
-import { getActorStandbyURL } from "./utils.js";
+import { ActorDefinition } from "apify-client";
+import { getActorDefinition, getActorStandbyURL } from "./utils.js";
 
-export async function isActorMCPServer(actorID: string, _apifyToken: string): Promise<boolean> {
-    // TODO: implement the logic
-    return actorID.toLowerCase().includes('mcp-') || actorID.toLowerCase().includes('-mcp');
+export async function isActorMCPServer(actorID: string, apifyToken: string): Promise<boolean> {
+    const mcpPath = await getActorsMCPServerPath(actorID, apifyToken);
+    return (mcpPath?.length || 0) > 0;
+}
+
+export async function getActorsMCPServerPath(actorID: string, apifyToken: string): Promise<string | undefined> {
+    const actorDefinition = await getActorDefinition(actorID, apifyToken);
+    return (actorDefinition as any).webServerMcpPath;
 }
 
 export async function getActorsMCPServerURL(actorID: string, _apifyToken: string): Promise<string> {
     // TODO: get from API instead
     const standbyBaseUrl = process.env.HOSTNAME === 'mcp-securitybyobscurity.apify.com' ?
         'securitybyobscurity.apify.actor' : 'apify.actor';
     const standbyUrl = getActorStandbyURL(actorID, standbyBaseUrl);
-    return `${standbyUrl}/sse`;
+    const mcpPath = await getActorsMCPServerPath(actorID, _apifyToken);
+    return `${standbyUrl}/${mcpPath}`;
 }

src/mcp/utils.ts

@@ -9,6 +9,8 @@ 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";
+import { ActorDefinition } from "apify-client";
+import { ApifyClient } from "../apify-client.js";
 
 /**
  * Generates a unique server ID based on the provided URL.
@@ -81,3 +83,28 @@ export function getActorStandbyURL(actorID: string, standbyBaseUrl = 'apify.acto
 
     return `https://${prefix}${actorName}.${standbyBaseUrl}`;
 }
+
+export async function getActorDefinition(actorID: string, apifyToken: string): Promise<ActorDefinition> {
+    const apifyClient = new ApifyClient({ token: apifyToken
+     })
+    const actor = apifyClient.actor(actorID);
+    const info = await actor.get();
+    if (!info) {
+        throw new Error(`Actor ${actorID} not found`);
+    }
+    const latestBuildID = info.taggedBuilds?.['latest']?.buildId;
+    if (!latestBuildID) {
+        throw new Error(`Actor ${actorID} does not have a latest build`);
+    }
+    const build = apifyClient.build(latestBuildID);
+    const buildInfo = await build.get();
+    if (!buildInfo) {
+        throw new Error(`Build ${latestBuildID} not found`);
+    }
+    const actorDefinition = buildInfo.actorDefinition;
+    if (!actorDefinition) {
+        throw new Error(`Build ${latestBuildID} does not have an actor definition`);
+    }
+
+    return actorDefinition;
+}