Add api to get worker details

Author: jahands

packages/mcp-common/src/api/workers.ts

@@ -1,3 +1,7 @@
+import { fetchCloudflareApi } from '../cloudflare-api'
+import { WorkersService } from '../types/worker'
+import { V4Schema } from '../v4-api'
+
 import type { Cloudflare } from 'cloudflare'
 
 /**
@@ -16,6 +20,33 @@ export async function handleWorkersList({
 	return (await client.workers.scripts.list({ account_id: accountId })).result
 }
 
+/**
+ * Get details of a worker script from Cloudflare API
+ * @param client Cloudflare API Client
+ * @param scriptName Name of the worker script to download
+ * @param accountId Cloudflare account ID
+ * @returns The script name and id
+ */
+export async function handleGetWorkersService({
+	apiToken,
+	scriptName,
+	accountId,
+}: {
+	apiToken: string
+	scriptName: string
+	accountId: string
+}) {
+	return await fetchCloudflareApi({
+		endpoint: `/workers/services/${scriptName}`,
+		accountId,
+		apiToken,
+		responseSchema: V4Schema(WorkersService),
+		options: {
+			method: 'GET',
+		},
+	})
+}
+
 /**
  * Downloads a specific worker script from Cloudflare API
  * @param client Cloudflare API Client

packages/mcp-common/src/tools/worker.ts

@@ -1,6 +1,10 @@
 import { z } from 'zod'
 
-import { handleWorkerScriptDownload, handleWorkersList } from '../api/workers'
+import {
+	handleGetWorkersService,
+	handleWorkerScriptDownload,
+	handleWorkersList,
+} from '../api/workers'
 import { getCloudflareClient } from '../cloudflare-api'
 
 import type { CloudflareMcpAgent } from '../types/cloudflare-mcp-agent'
@@ -28,6 +32,7 @@ export function registerWorkersTools(agent: CloudflareMcpAgent) {
 				],
 			}
 		}
+
 		try {
 			const results = await handleWorkersList({
 				client: getCloudflareClient(agent.props.accessToken),
@@ -38,7 +43,7 @@ export function registerWorkersTools(agent: CloudflareMcpAgent) {
 				.map((worker) => ({
 					name: worker.id,
 					// The API client doesn't know tag exists. The tag is needed in other places such as Workers Builds
-					script_id: z.object({ tag: z.string() }).parse(worker),
+					id: z.object({ tag: z.string() }).parse(worker),
 					modified_on: worker.modified_on || null,
 					created_on: worker.created_on || null,
 				}))
@@ -73,6 +78,60 @@ export function registerWorkersTools(agent: CloudflareMcpAgent) {
 		}
 	})
 
+	// Tool to get a specific worker's script details
+	agent.server.tool(
+		'worker_get_worker_details',
+		'Get the name and id of the Cloudflare Worker',
+		{ scriptName: workerNameParam },
+		async (params) => {
+			const accountId = await agent.getActiveAccountId()
+			console.log(params)
+			if (!accountId) {
+				return {
+					content: [
+						{
+							type: 'text',
+							text: 'No currently active accountId. Try listing your accounts (accounts_list) and then setting an active account (set_active_account)',
+						},
+					],
+				}
+			}
+
+			try {
+				const { scriptName } = params
+				const worker = await handleGetWorkersService({
+					apiToken: agent.props.accessToken,
+					scriptName,
+					accountId,
+				})
+				const text = worker.result
+					? JSON.stringify({
+							name: worker.result.id,
+							id: worker.result?.default_environment.script_tag,
+						})
+					: 'Worker not found'
+				return {
+					content: [
+						{
+							type: 'text',
+							text,
+						},
+					],
+				}
+			} catch (e) {
+				agent.server.recordError(e)
+				return {
+					content: [
+						{
+							type: 'text',
+							text: `Error retrieving worker script: ${e instanceof Error && e.message}`,
+						},
+					],
+				}
+			}
+		}
+	)
+
 	// Tool to get a specific worker's script content
 	agent.server.tool(
 		'worker_get_worker',
@@ -90,6 +149,7 @@ export function registerWorkersTools(agent: CloudflareMcpAgent) {
 					],
 				}
 			}
+
 			try {
 				const { scriptName } = params
 				const scriptContent = await handleWorkerScriptDownload({

packages/mcp-common/src/types/worker.ts

@@ -0,0 +1,41 @@
+import { z } from 'zod'
+
+export type WorkersService = z.infer<typeof WorkersService>
+export const WorkersService = z.object({
+	id: z.string(),
+	default_environment: z.object({
+		environment: z.string(),
+		script_tag: z.string(),
+		created_on: z.string(),
+		modified_on: z.string(),
+		script: z.object({
+			created_on: z.string(),
+			modified_on: z.string(),
+			id: z.string(),
+			tag: z.string(),
+			tags: z.array(z.string()),
+			deployment_id: z.string(),
+			tail_consumers: z.null(),
+			logpush: z.boolean(),
+			has_assets: z.boolean(),
+			has_modules: z.boolean(),
+			etag: z.string(),
+			handlers: z.array(z.string()),
+			last_deployed_from: z.string(),
+			compatibility_date: z.string(),
+			compatibility_flags: z.array(z.string()),
+			usage_model: z.string(),
+		}),
+	}),
+	created_on: z.string(),
+	modified_on: z.string(),
+	usage_model: z.string(),
+	environments: z.array(
+		z.object({
+			environment: z.string(),
+			script_tag: z.string(),
+			created_on: z.string(),
+			modified_on: z.string(),
+		})
+	),
+})