add get_http_requests_data tool

Author: andre-j3sus

README.md

@@ -55,6 +55,7 @@ Some features may require a paid Cloudflare Workers plan. Ensure your Cloudflare
 ### Apps
 
 - [workers-observability](apps/workers-observability/): The Workers Observability MCP server
+- [radar](apps/radar/): The Cloudflare Radar MCP server
 
 ### Packages
 

apps/radar/README.md

@@ -1,18 +1,23 @@
-# Model Context Protocol (MCP) Server + Cloudflare Radar
+# Cloudflare Radar MCP Server 📡
 
-This is a [Model Context Protocol (MCP)](https://modelcontextprotocol.io/introduction) server that supports remote MCP connections, with Cloudflare OAuth built-in.
+This is a [Model Context Protocol (MCP)](https://modelcontextprotocol.io/introduction) server that supports remote MCP
+connections, with Cloudflare OAuth built-in.
 
-It features tools powered by the [Cloudflare Radar API](https://developers.cloudflare.com/radar/).
+It integrates tools powered by the [Cloudflare Radar API](https://developers.cloudflare.com/radar/) to provide global
+Internet traffic insights, trends and other utilities.
 
-## Tools
+## 🔨 Available Tools
 
 Currently available tools:
 
-- `list_autonomous_systems`: Lists autonomous systems (filterable by location and sortable by population size)
-- `get_as_details`: Retrieves details of an autonomous system by ASN
-- `get_ip_details`: Provides information about a specific IP address
-- `get_traffic_anomalies`: Lists traffic anomalies (filterable by AS, location, start date, and end date)
-- `scan_url`: Scan a URL using [URL Scanner](https://developers.cloudflare.com/radar/investigate/url-scanner/)
+| **Category**           | **Tool**                  | **Description**                                                                                                           |
+|------------------------|---------------------------|---------------------------------------------------------------------------------------------------------------------------|
+| **HTTP Requests**      | `get_http_requests_data`  | Fetches HTTP request data (timeseries, summaries, and grouped timeseries across dimensions like `deviceType`, `botClass`) |
+| **Autonomous Systems** | `list_autonomous_systems` | Lists ASes; filter by location and sort by population size                                                                |
+|                        | `get_as_details`          | Retrieves detailed info for a specific ASN                                                                                |
+| **IP Addresses**       | `get_ip_details`          | Provides details about a specific IP address                                                                              |
+| **Traffic Anomalies**  | `get_traffic_anomalies`   | Lists traffic anomalies; filter by AS, location, start date, and end date                                                 |
+| **URL Scanner**        | `scan_url`                | Scans a URL via [Cloudflare’s URL Scanner](https://developers.cloudflare.com/radar/investigate/url-scanner/)              |
 
 This MCP server is still a work in progress, and we plan to add more tools in the future.
 
@@ -59,17 +64,17 @@ This will require you to create another OAuth App on Cloudflare:
 
 1. Create a `.dev.vars` file in your project root with:
 
-   ```
-   CLOUDFLARE_CLIENT_ID=your_development_cloudflare_client_id
-   CLOUDFLARE_CLIENT_SECRET=your_development_cloudflare_client_secret
-   URL_SCANNER_API_TOKEN=your_development_url_scanner_api_token
-   ```
+	```
+	CLOUDFLARE_CLIENT_ID=your_development_cloudflare_client_id
+	CLOUDFLARE_CLIENT_SECRET=your_development_cloudflare_client_secret
+	URL_SCANNER_API_TOKEN=your_development_url_scanner_api_token
+	```
 
 2. Start the local development server:
 
-   ```bash
-   npx wrangler dev
-   ```
+	```bash
+	npx wrangler dev
+	```
 
 3. To test locally, open Inspector, and connect to `http://localhost:8788/sse`.
-   Once you follow the prompts, you'll be able to "List Tools".
+	 Once you follow the prompts, you'll be able to "List Tools".

apps/radar/src/tools/radar.ts

@@ -2,12 +2,21 @@ import { getCloudflareClient } from '@repo/mcp-common/src/cloudflare-api'
 import { PaginationLimitParam, PaginationOffsetParam } from '@repo/mcp-common/src/types/shared'
 
 import {
+	AsnArrayParam,
 	AsnParam,
 	AsOrderByParam,
+	ContinentArrayParam,
+	DataFormatParam,
+	DateEndArrayParam,
 	DateEndParam,
+	DateRangeArrayParam,
+	DateRangeParam,
+	DateStartArrayParam,
 	DateStartParam,
+	HttpDimensionParam,
 	IpParam,
-	SingleLocationParam,
+	LocationArrayParam,
+	LocationParam,
 } from '../types/radar'
 
 import type { RadarMCP } from '../index'
@@ -19,7 +28,7 @@ export function registerRadarTools(agent: RadarMCP) {
 		{
 			limit: PaginationLimitParam,
 			offset: PaginationOffsetParam,
-			location: SingleLocationParam,
+			location: LocationParam.optional(),
 			orderBy: AsOrderByParam,
 		},
 		async ({ limit, offset, location, orderBy }) => {
@@ -130,21 +139,22 @@ export function registerRadarTools(agent: RadarMCP) {
 			limit: PaginationLimitParam,
 			offset: PaginationOffsetParam,
 			asn: AsnParam.optional(),
-			location: SingleLocationParam,
-			// TODO maybe we don't need this param since we have the other two dateRange: DateRangeParam.optional(),
-			dateStart: DateStartParam,
-			dateEnd: DateEndParam,
+			location: LocationParam.optional(),
+			dateRange: DateRangeParam.optional(),
+			dateStart: DateStartParam.optional(),
+			dateEnd: DateEndParam.optional(),
 		},
-		async ({ limit, offset, asn, location, dateStart, dateEnd }) => {
+		async ({ limit, offset, asn, location, dateStart, dateEnd, dateRange }) => {
 			try {
 				const client = getCloudflareClient(agent.props.accessToken)
 				const r = await client.radar.trafficAnomalies.get({
 					limit: limit ?? undefined,
 					offset: offset ?? undefined,
 					asn: asn ?? undefined,
 					location: location ?? undefined,
-					dateStart: dateStart,
-					dateEnd: dateEnd,
+					dateRange: dateRange ?? undefined,
+					dateStart: dateStart ?? undefined,
+					dateEnd: dateEnd ?? undefined,
 					status: 'VERIFIED',
 				})
 
@@ -170,4 +180,64 @@ export function registerRadarTools(agent: RadarMCP) {
 			}
 		}
 	)
+
+	agent.server.tool(
+		'get_http_requests_data',
+		'Retrieve HTTP request trends. Provide either a `dateRange`, or both `dateStart` and `dateEnd`, to define the time window. ' +
+		'Use arrays to compare multiple filters — the array index determines which series each filter value belongs to.' +
+		'For each filter series, you must provide a corresponding `dateRange`, or a `dateStart`/`dateEnd` pair.',
+		{
+			dateRange: DateRangeArrayParam.optional(),
+			dateStart: DateStartArrayParam.optional(),
+			dateEnd: DateEndArrayParam.optional(),
+			asn: AsnArrayParam,
+			continent: ContinentArrayParam,
+			location: LocationArrayParam,
+			format: DataFormatParam,
+			dimension: HttpDimensionParam,
+		},
+		async ({ dateStart, dateEnd, dateRange, asn, location, continent, format, dimension }) => {
+			try {
+				if (!dimension && format !== 'timeseries') {
+					throw new Error(
+						`Missing 'dimension' parameter. The '${format}' format requires a dimension to group the data.`
+					)
+				}
+
+				const client = getCloudflareClient(agent.props.accessToken)
+				const endpoint = (...args: any) => format === 'timeseries'
+					? client.radar.http[format](...args)
+					: client.radar.http[format][dimension!](...args)
+
+				const r = await endpoint({
+					asn: asn ?? undefined,
+					continent: continent ?? undefined,
+					location: location ?? undefined,
+					dateRange: dateRange,
+					dateStart: dateStart,
+					dateEnd: dateEnd,
+				})
+
+				return {
+					content: [
+						{
+							type: 'text',
+							text: JSON.stringify({
+								result: r,
+							}),
+						},
+					],
+				}
+			} catch (error) {
+				return {
+					content: [
+						{
+							type: 'text',
+							text: `Error getting HTTP data: ${error instanceof Error && error.message}`,
+						},
+					],
+				}
+			}
+		}
+	)
 }

apps/radar/src/types/radar.ts

@@ -4,7 +4,7 @@
 import { z } from 'zod'
 
 import type { ASNListParams } from 'cloudflare/resources/radar/entities/asns.mjs'
-import type { TrafficAnomalyGetParams } from 'cloudflare/resources/radar/traffic-anomalies.mjs'
+import type { HTTPTimeseriesParams } from 'cloudflare/resources/radar/http.mjs'
 
 export const AsnParam = z
 	.number()
@@ -13,37 +13,120 @@ export const AsnParam = z
 
 export const IpParam = z.string().ip().describe('IPv4 or IPv6 address in standard notation.')
 
-export const DateRangeParam: z.ZodType<TrafficAnomalyGetParams['dateRange']> = z
+export const DateRangeParam = z
 	.string()
 	.toLowerCase()
 	.regex(
-		/^((([1-9]|[1-9][0-9]|[1-2][0-9][0-9]|3[0-5][0-9]|36[0-4])[d](control)?)|(([1-9]|[1-4][0-9]|5[0-2])[w](control)?))$/,
+		/^((([1-9]|[1-9][0-9]|[1-2][0-9][0-9]|3[0-5][0-9]|36[0-4])d(control)?)|(([1-9]|[1-4][0-9]|5[0-2])w(control)?))$/,
 		'Invalid Date Range'
 	)
 	.describe(
-		"Date range string in the format of 'Xd' or 'Xw', where X is a number of days (1–364) or weeks (1–52), optionally suffixed with 'control'."
+		'Filters results by date range. ' +
+			'For example, use `7d` and `7dcontrol` to compare this week with the previous week. ' +
+			'Use this parameter or set specific start and end dates (`dateStart` and `dateEnd` parameters).'
 	)
 
-export const DateStartParam: z.ZodType<TrafficAnomalyGetParams['dateStart']> = z
+export const DateRangeArrayParam: z.ZodType<HTTPTimeseriesParams['dateRange']> = z
+	.array(DateRangeParam)
+	.describe(
+		'Filters results by date range. ' +
+			'For example, use `7d` and `7dcontrol` to compare this week with the previous week. ' +
+			'Use this parameter or set specific start and end dates (`dateStart` and `dateEnd` parameters).'
+	)
+
+export const DateStartParam = z
 	.string()
 	.datetime()
-	.describe('Start date in ISO 8601 format (e.g., 2023-04-01T00:00:00Z).')
+	.describe(
+		'Start date in ISO 8601 format (e.g., 2023-04-01T00:00:00Z). ' +
+			'Either use this parameter together with `dateEnd`, or use `dateRange`.'
+	)
 
-export const DateEndParam: z.ZodType<TrafficAnomalyGetParams['dateEnd']> = z
+export const DateStartArrayParam: z.ZodType<HTTPTimeseriesParams['dateStart']> = z
+	.array(DateStartParam)
+	.describe(
+		'Start of the date range. ' +
+			'Either use this parameter together with `dateEnd` or use `dateRange`.'
+	)
+
+export const DateEndParam = z
 	.string()
 	.datetime()
-	.describe('End date in ISO 8601 format (e.g., 2023-04-30T23:59:59Z).')
+	.describe(
+		'End date in ISO 8601 format (e.g., 2023-04-30T23:59:59Z). ' +
+			'Either use this parameter together with `dateStart`, or use `dateRange`.'
+	)
+
+export const DateEndArrayParam: z.ZodType<HTTPTimeseriesParams['dateEnd']> = z
+	.array(DateEndParam)
+	.describe(
+		'End of the date range. ' +
+			'Either use this parameter together with `dateStart`, or use `dateRange`.'
+	)
 
-export const SingleLocationParam: z.ZodType<ASNListParams['location']> = z
+export const LocationParam: 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).',
 	})
+	.describe('Filters results by location. Specify a valid alpha-2 location code.')
+
+export const LocationArrayParam: z.ZodType<HTTPTimeseriesParams['location']> = z
+	.array(
+		z.string().regex(/^(-?[a-zA-Z]{2})$/, {
+			message: 'Each value must be a valid alpha-2 location code, optionally prefixed with `-`.',
+		})
+	)
 	.optional()
-	.describe('Optional alpha-2 country code (e.g., "US", "DE").')
+	.describe(
+		'Filters results by location. Provide an array of alpha-2 country codes (e.g., "US", "PT"). ' +
+			'Prefix a code with `-` to exclude it (e.g., ["-US", "PT"] excludes the US and includes Portugal).'
+	)
+
+export const ContinentArrayParam: z.ZodType<HTTPTimeseriesParams['continent']> = z
+	.array(
+		z.string().regex(/^(-?[a-zA-Z]{2})$/, {
+			message: 'Each value must be a valid alpha-2 continent code, optionally prefixed with `-`.',
+		})
+	)
+	.optional()
+	.describe(
+		'Filters results by continent. Provide an array of alpha-2 continent codes (e.g., "EU", "NA"). ' +
+			'Prefix a code with `-` to exclude it (e.g., ["-EU", "NA"] excludes Europe and includes North America).'
+	)
+
+export const AsnArrayParam: z.ZodType<HTTPTimeseriesParams['asn']> = z
+	.array(z.string().refine((val) => val !== '0', { message: 'ASN cannot be 0' }))
+	.optional()
+	.describe(
+		'Filters results by ASN. Provide an array of ASN strings. ' +
+			'Prefix with `-` to exclude (e.g., ["-174", "3356"] excludes AS174 and includes AS3356). '
+	)
 
 export const AsOrderByParam: z.ZodType<ASNListParams['orderBy']> = z
 	.enum(['ASN', 'POPULATION'])
 	.optional()
 	.describe('Optional order by parameter: "ASN" or "POPULATION".')
+
+export const DataFormatParam = z
+	.enum(['timeseries', 'summary', 'timeseriesGroups'])
+	.describe(
+		"Specifies the data format: 'summary' for aggregated results by dimension, 'timeseries' for a time-based view of HTTP requests, or 'timeseriesGroups' to group timeseries data by dimensions."
+	)
+
+export const HttpDimensionParam = z
+	.enum([
+		'deviceType',
+		'httpProtocol',
+		'httpVersion',
+		'botClass',
+		'ipVersion',
+		'tlsVersion',
+		'os',
+		'postQuantum',
+	])
+	.optional()
+	.describe(
+		"Dimension used to group HTTP data. Allowed only when the format is 'summary' or 'timeseriesGroups'."
+	)