add radar tools (wip)

Author: andre-j3sus

.gitignore

@@ -48,5 +48,6 @@ yarn-error.log*
 .sentryclirc.lock/
 tmp.json
 tmp.ts
+.idea
 
-apps/sandbox-container/workdir
+apps/sandbox-container/workdir

apps/workers-observability/src/index.ts

@@ -13,6 +13,7 @@ import { registerWorkersTools } from '@repo/mcp-common/src/tools/worker'
 import { registerLogsTools } from './tools/logs'
 
 import type { AccountSchema, UserSchema } from '@repo/mcp-common/src/cloudflare-oauth-handler'
+import { registerRadarTools } from "@repo/mcp-common/src/tools/radar";
 
 // Context from the auth process, encrypted & stored in the auth token
 // and provided to the DurableMCP as this.props
@@ -42,6 +43,9 @@ export class ObservabilityMCP extends McpAgent<Env, State, Props> {
 
 		// Register Cloudflare Workers logs tools
 		registerLogsTools(this)
+
+		// Register Cloudflare Radar tools
+		registerRadarTools(this)
 	}
 
 	getActiveAccountId() {

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

@@ -0,0 +1,48 @@
+import { getCloudflareClient } from '../cloudflare-api'
+import { type CloudflareMcpAgent } from '../types/cloudflare-mcp-agent'
+import {  AsOrderByParam, SingleLocationParam } from '../types/radar'
+import { PaginationLimitParam, PaginationOffsetParam } from '../types/shared'
+
+export function registerRadarTools(agent: CloudflareMcpAgent) {
+	agent.server.tool(
+		'radar_ases_list',
+		'List Autonomous Systems',
+		{
+			limit: PaginationLimitParam,
+			offset: PaginationOffsetParam,
+			location: SingleLocationParam,
+			orderBy: AsOrderByParam,
+		},
+		async ({ limit, offset, location, orderBy }) => {
+			try {
+				const client = getCloudflareClient(agent.props.accessToken)
+				const r = await client.radar.entities.asns.list({
+					limit: limit ?? undefined,
+					offset: offset ?? undefined,
+					location: location ?? undefined,
+					orderBy: orderBy ?? undefined,
+				})
+
+				return {
+					content: [
+						{
+							type: 'text',
+							text: JSON.stringify({
+								result: r,
+							}),
+						},
+					],
+				}
+			} catch (error) {
+				return {
+					content: [
+						{
+							type: 'text',
+							text: `Error listing ASes: ${error instanceof Error && error.message}`,
+						},
+					],
+				}
+			}
+		}
+	)
+}

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

@@ -0,0 +1,25 @@
+/**
+ * This file contains the validators for the radar tools.
+ */
+import { z } from 'zod'
+
+import type { ASNListParams } from 'cloudflare/resources/radar/entities/asns.mjs'
+
+export const AsnParam: z.ZodType<ASNListParams['asn']> = z
+	.string()
+	.optional()
+	.refine((val) => val?.split(',').every((asn) => parseInt(asn, 10) > 0), {
+		message: 'ASNs must be positive integers',
+	})
+
+export const SingleLocationParam: z.ZodType<ASNListParams['location']> = z
+	.string()
+	.regex(/^[a-zA-Z]{2}$/, {
+		message:
+			'Invalid location code. Must be a valid alpha-2 location code (two letters, case insensitive).',
+	})
+	.optional()
+
+export const AsOrderByParam: z.ZodType<ASNListParams['orderBy']> = z
+	.enum(['ASN', 'POPULATION'])
+	.optional()

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

@@ -2,3 +2,6 @@ import { z } from 'zod'
 
 export const PaginationPerPageParam = z.number().nullable().optional()
 export const PaginationPageParam = z.number().nullable().optional()
+
+export const PaginationLimitParam = z.number().nullable().optional()
+export const PaginationOffsetParam = z.number().nullable().optional()