more stuff

Author: jahands

apps/workers-builds/src/tools/builds.ts

@@ -1,5 +1,6 @@
-import { queryWorkersObservability } from '@repo/mcp-common/src/api/workers-observability'
-import { zQueryRunRequest } from '@repo/mcp-common/src/types/workers-logs-schemas'
+import { z } from 'zod'
+
+import { getLatestWorkersBuild } from '@repo/mcp-common/src/api/workers-builds.api'
 
 import type { BuildsMCP } from '../index'
 
@@ -12,15 +13,15 @@ import type { BuildsMCP } from '../index'
 export function registerBuildsTools(agent: BuildsMCP) {
 	// Register the worker logs analysis tool by worker name
 	agent.server.tool(
-		'list_workers_builds',
+		'get_latest_workers_build',
 		`
-Query the Workers Builds API to view builds from your Cloudflare Workers.
+Use the Workers Builds API to get the latest build for a Cloudflare Worker.
 `.trim(),
 
 		{
-			query: zQueryRunRequest,
+			scriptId: z.string(),
 		},
-		async ({ query }) => {
+		async ({ scriptId }) => {
 			const accountId = await agent.getActiveAccountId()
 			if (!accountId) {
 				return {
@@ -32,8 +33,13 @@ Query the Workers Builds API to view builds from your Cloudflare Workers.
 					],
 				}
 			}
+
 			try {
-				const res = await queryWorkersObservability(agent.props.accessToken, accountId, query)
+				const res = await getLatestWorkersBuild({
+					apiToken: agent.props.accessToken,
+					accountId,
+					scriptId,
+				})
 				return {
 					content: [
 						{

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

@@ -0,0 +1,31 @@
+import { fetchCloudflareApi } from '../cloudflare-api'
+import { LatestBuildsByScriptResult } from '../types/workers-builds.types'
+import { V4Schema } from '../v4-api'
+
+export async function getLatestWorkersBuild({
+	apiToken,
+	accountId,
+	scriptId,
+}: {
+	apiToken: string
+	accountId: string
+	scriptId: string
+}) {
+	const data = await fetchCloudflareApi({
+		endpoint: `/builds/builds/latest?external_script_ids=${scriptId}`,
+		accountId,
+		apiToken,
+		responseSchema: V4Schema(LatestBuildsByScriptResult),
+		options: {
+			method: 'GET',
+		},
+	})
+	if (!data.result) {
+		return null
+	}
+	const build = data.result.builds[scriptId]
+	if (!build) {
+		return null
+	}
+	return build
+}

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

@@ -135,7 +135,10 @@ export function registerWorkersTools(agent: CloudflareMcpAgent) {
 	// Tool to get a specific worker's script content
 	agent.server.tool(
 		'worker_get_worker',
-		'Get the source code of a Cloudflare Worker',
+		`Get the source code of a Cloudflare Worker
+
+		If you need to get the ID of a Worker, use worker_get_worker_details instead.
+		`.trim(),
 		{ scriptName: workerNameParam },
 		async (params) => {
 			const accountId = await agent.getActiveAccountId()

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

@@ -0,0 +1,68 @@
+import { z } from 'zod'
+
+export type LatestBuildsByScriptResult = z.infer<typeof LatestBuildsByScriptResult>
+export const LatestBuildsByScriptResult = z.object({
+	builds: z.record(
+		z.string(),
+		z.object({
+			build_uuid: z.string(),
+			status: z.string(),
+			build_outcome: z.string().nullable(),
+			initializing_on: z.string().nullable(),
+			running_on: z.string().nullable(),
+			stopped_on: z.string().nullable(),
+			created_on: z.string(),
+			modified_on: z.string(),
+			trigger: z.object({
+				trigger_uuid: z.string(),
+				external_script_id: z.string(),
+				trigger_name: z.string(),
+				build_command: z.string(),
+				deploy_command: z.string(),
+				root_directory: z.string(),
+				branch_includes: z.array(z.string()),
+				branch_excludes: z.array(z.string()),
+				path_includes: z.array(z.string()),
+				path_excludes: z.array(z.string()),
+				build_caching_enabled: z.boolean(),
+				created_on: z.string(),
+				modified_on: z.string(),
+				deleted_on: z.null(),
+				repo_connection: z.object({
+					repo_connection_uuid: z.string(),
+					repo_id: z.string(),
+					repo_name: z.string(),
+					provider_type: z.string(),
+					provider_account_id: z.string(),
+					provider_account_name: z.string(),
+					created_on: z.string(),
+					modified_on: z.string(),
+					deleted_on: z.null(),
+				}),
+			}),
+			build_trigger_metadata: z.object({
+				build_trigger_source: z.string(),
+				branch: z.string(),
+				commit_hash: z.string(),
+				commit_message: z.string(),
+				author: z.string(),
+				build_command: z.string(),
+				deploy_command: z.string(),
+				root_directory: z.string(),
+				build_token_uuid: z.string(),
+				environment_variables: z.record(
+					z.string(),
+					z.object({
+						is_secret: z.boolean(),
+						created_on: z.string(),
+						value: z.string(),
+					})
+				),
+				repo_name: z.string(),
+				provider_account_name: z.string(),
+				provider_type: z.string(),
+			}),
+			pull_request: z.unknown(),
+		})
+	),
+})