Move observability server to it's own subdomain

Maximo-Guk · Maximo-Guk · commit 644307cc6314 · 2025-04-17T11:54:34.000-05:00
diff --git a/apps/sandbox-container/container/index.ts b/apps/sandbox-container/container/index.ts
@@ -7,8 +7,8 @@ import { Hono } from 'hono'
 import { streamText } from 'hono/streaming'
 import mime from 'mime'
 
-import { ExecParams, FilesWrite } from '../shared/schema.ts'
-import { get_file_name_from_path } from './fileUtils.ts'
+import { ExecParams, FilesWrite } from '../shared/schema'
+import { get_file_name_from_path } from './fileUtils'
 
 import type { FileList } from '../shared/schema.ts'
 
diff --git a/apps/sandbox-container/package.json b/apps/sandbox-container/package.json
@@ -20,6 +20,7 @@
 		"@hono/node-server": "^1.13.8",
 		"@hono/zod-validator": "^0.4.3",
 		"@modelcontextprotocol/sdk": "^1.7.0",
+		"@repo/mcp-common": "workspace:*",
 		"@types/node": "^22.13.10",
 		"agents": "^0.0.42",
 		"cron-schedule": "^5.0.4",
@@ -30,10 +31,10 @@
 		"partyserver": "^0.0.65",
 		"tsx": "^4.19.3",
 		"workers-mcp": "0.1.0-3",
-		"zod": "^3.24.2",
-		"@repo/mcp-common": "workspace:*"
+		"zod": "^3.24.2"
 	},
 	"devDependencies": {
+		"@cloudflare/vitest-pool-workers": "0.8.14",
 		"concurrently": "^9.1.2",
 		"wrangler": "^4.9.1"
 	}
diff --git a/apps/sandbox-container/server/index.ts b/apps/sandbox-container/server/index.ts
@@ -28,9 +28,9 @@ export type Props = {
 }
 
 export default new OAuthProvider({
-	apiRoute: '/workers/sandbox/sse',
+	apiRoute: '/sse',
 	// @ts-ignore
-	apiHandler: ContainerMcpAgent.mount('/workers/sandbox/sse', { binding: 'CONTAINER_MCP_AGENT' }),
+	apiHandler: ContainerMcpAgent.mount('/sse', { binding: 'CONTAINER_MCP_AGENT' }),
 	// @ts-ignore
 	defaultHandler: CloudflareAuthHandler,
 	authorizeEndpoint: '/oauth/authorize',
diff --git a/apps/sandbox-container/tsconfig.json b/apps/sandbox-container/tsconfig.json
@@ -1,16 +1,3 @@
 {
-	"compilerOptions": {
-		"target": "ESNext",
-		"lib": ["ESNext", "DOM"],
-		"jsx": "react-jsx",
-		"module": "ESNext",
-		"moduleResolution": "bundler",
-		"types": ["./worker-configuration.d.ts", "@cloudflare/workers-types/2023-07-01"],
-		"noEmit": true,
-		"esModuleInterop": true,
-		"forceConsistentCasingInFileNames": true,
-		"strict": true,
-		"skipLibCheck": true
-	},
-	"include": ["server/**.ts", "shared/**.ts"]
+	"extends": "@repo/typescript-config/workers.json"
 }
diff --git a/apps/sandbox-container/worker-configuration.d.ts b/apps/sandbox-container/worker-configuration.d.ts
@@ -2,11 +2,14 @@
 // Runtime types generated with workerd@1.20250409.0 2025-04-03
 declare namespace Cloudflare {
 	interface Env {
-		OAUTH_KV: KVNamespace
-		CONTAINER_MCP_AGENT: DurableObjectNamespace<import('./server/index').ContainerMcpAgent>
-		CONTAINER_MANAGER: DurableObjectNamespace<import('./server/index').ContainerManager>
-		CLOUDFLARE_CLIENT_ID: string
-		CLOUDFLARE_CLIENT_SECRET: string
+		OAUTH_KV: KVNamespace;
+		// eslint-disable-next-line @typescript-eslint/consistent-type-imports
+		CONTAINER_MCP_AGENT: DurableObjectNamespace<import("./server/index").ContainerMcpAgent>;
+		// eslint-disable-next-line @typescript-eslint/consistent-type-imports
+		CONTAINER_MANAGER: DurableObjectNamespace<import("./server/index").ContainerManager>;
+		CLOUDFLARE_CLIENT_ID: string;
+		CLOUDFLARE_CLIENT_SECRET: string;
+        ENVIRONMENT: string
 	}
 }
 interface Env extends Cloudflare.Env {}
diff --git a/apps/sandbox-container/wrangler.jsonc b/apps/sandbox-container/wrangler.jsonc
@@ -1,6 +1,6 @@
 {
 	"$schema": "node_modules/wrangler/config-schema.json",
-	"name": "sandbox-container",
+	"name": "sandbox-container-dev",
 	"main": "server/index.ts",
 	"compatibility_date": "2025-04-03",
 	"containers": [
@@ -41,5 +41,8 @@
 	],
 	"dev": {
 		"port": 8976
+	},
+	"vars": {
+		"ENVIRONMENT": "development"
 	}
 }
diff --git a/apps/workers-bindings/src/index.ts b/apps/workers-bindings/src/index.ts
@@ -62,9 +62,9 @@ export class WorkersBindingsMCP extends McpAgent<Env, WorkersBindingsMCPState, P
 
 // Export the OAuth handler as the default
 export default new OAuthProvider({
-	apiRoute: '/workers/bindings/sse',
+	apiRoute: '/sse',
 	// @ts-ignore
-	apiHandler: WorkersBindingsMCP.mount('/workers/bindings/sse'),
+	apiHandler: WorkersBindingsMCP.mount('/sse'),
 	// @ts-ignore
 	defaultHandler: CloudflareAuthHandler,
 	authorizeEndpoint: '/oauth/authorize',
diff --git a/apps/workers-bindings/worker-configuration.d.ts b/apps/workers-bindings/worker-configuration.d.ts
@@ -5,7 +5,9 @@ declare namespace Cloudflare {
 		OAUTH_KV: KVNamespace;
 		CLOUDFLARE_CLIENT_ID: string;
 		CLOUDFLARE_CLIENT_SECRET: string;
+		// eslint-disable-next-line @typescript-eslint/consistent-type-imports
 		MCP_OBJECT: DurableObjectNamespace<import("./src/index").WorkersBindingsMCP>;
+        ENVIRONMENT: string
 	}
 }
 interface Env extends Cloudflare.Env {}
diff --git a/apps/workers-bindings/wrangler.jsonc b/apps/workers-bindings/wrangler.jsonc
@@ -4,7 +4,7 @@
  */
 {
 	"$schema": "node_modules/wrangler/config-schema.json",
-	"name": "workers-bindings",
+	"name": "workers-bindings-dev",
 	"main": "src/index.ts",
 	"compatibility_date": "2025-03-10",
 	"compatibility_flags": ["nodejs_compat"],
@@ -33,6 +33,9 @@
 	},
 	"dev": {
 		"port": 8976
+	},
+	"vars": {
+		"ENVIRONMENT": "development"
 	}
 	/**
 	 * Smart Placement
diff --git a/apps/workers-observability/README.md b/apps/workers-observability/README.md
@@ -69,11 +69,8 @@ Once the Tools (under 🔨) show up in the interface, you can ask Claude to use
 
 ### For Local Development
 
-If you'd like to iterate and test your MCP server, you can do so in local development. This will require you to create another OAuth App on GitHub:
+If you'd like to iterate and test your MCP server, you can do so in local development. This will require you to create another OAuth App on Cloudflare:
 
-- For the Homepage URL, specify `http://localhost:8788`
-- For the Authorization callback URL, specify `http://localhost:8788/callback`
-- Note your Client ID and generate a Client secret.
 - Create a `.dev.vars` file in your project root with:
 
 ```
@@ -107,7 +104,7 @@ You can connect your MCP server to other MCP clients like Windsurf by opening th
 The OAuth Provider library serves as a complete OAuth 2.1 server implementation for Cloudflare Workers. It handles the complexities of the OAuth flow, including token issuance, validation, and management. In this project, it plays the dual role of:
 
 - Authenticating MCP clients that connect to your server
-- Managing the connection to GitHub's OAuth services
+- Managing the connection to Cloudflare's OAuth services
 - Securely storing tokens and authentication state in KV storage
 
 #### Durable MCP
diff --git a/apps/workers-observability/package.json b/apps/workers-observability/package.json
@@ -24,7 +24,6 @@
 	"devDependencies": {
 		"@cloudflare/vitest-pool-workers": "0.8.14",
 		"@cloudflare/workers-types": "4.20250410.0",
-		"@types/jsonwebtoken": "9.0.9",
 		"prettier": "3.5.3",
 		"typescript": "5.5.4",
 		"vitest": "3.0.9",
diff --git a/apps/workers-observability/src/index.ts b/apps/workers-observability/src/index.ts
@@ -67,9 +67,9 @@ export class MyMCP extends McpAgent<Env, State, Props> {
 }
 
 export default new OAuthProvider({
-	apiRoute: '/workers/observability/sse',
+	apiRoute: '/sse',
 	// @ts-ignore
-	apiHandler: MyMCP.mount('/workers/observability/sse'),
+	apiHandler: MyMCP.mount('/sse'),
 	// @ts-ignore
 	defaultHandler: CloudflareAuthHandler,
 	authorizeEndpoint: '/oauth/authorize',
diff --git a/apps/workers-observability/worker-configuration.d.ts b/apps/workers-observability/worker-configuration.d.ts
@@ -5,6 +5,8 @@ declare namespace Cloudflare {
 		OAUTH_KV: KVNamespace;
 		CLOUDFLARE_CLIENT_ID: string;
 		CLOUDFLARE_CLIENT_SECRET: string;
+        ENVIRONMENT: string;
+		// eslint-disable-next-line @typescript-eslint/consistent-type-imports
 		MCP_OBJECT: DurableObjectNamespace<import("./src/index").MyMCP>;
 	}
 }
diff --git a/apps/workers-observability/wrangler.jsonc b/apps/workers-observability/wrangler.jsonc
@@ -16,9 +16,6 @@
 	"observability": {
 		"enabled": true
 	},
-	"dev": {
-		"port": 8976
-	},
 	"durable_objects": {
 		"bindings": [
 			{
@@ -33,14 +30,19 @@
 			"id": "DEV_KV"
 		}
 	],
+	"vars": {
+		"ENVIRONMENT": "development"
+	},
+	"dev": {
+		"port": 8976
+	},
 	"workers_dev": false,
 	"preview_urls": false,
 	"env": {
 		"staging": {
-			"name": "mcp-cloudflare-staging",
+			"name": "mcp-cloudflare-workers-observability-staging",
 			"account_id": "8995c0f49cdcf57eb54d2c1e52b7d2f3",
-			// enable workers-dev for staging
-			"workers_dev": true,
+			"routes": [{ "pattern": "observability-staging.mcp.cloudflare.com", "custom_domain": true }],
 			"durable_objects": {
 				"bindings": [
 					{
@@ -54,12 +56,15 @@
 					"binding": "OAUTH_KV",
 					"id": "18e839155d00407095d793dcf7e78f25"
 				}
-			]
+			],
+			"vars": {
+				"ENVIRONMENT": "staging"
+			}
 		},
 		"production": {
-			"name": "mcp-cloudflare-production",
+			"name": "mcp-cloudflare-workers-observability-production",
 			"account_id": "8995c0f49cdcf57eb54d2c1e52b7d2f3",
-			"routes": ["mcp.cloudflare.com/*"],
+			"routes": [{ "pattern": "observability.mcp.cloudflare.com", "custom_domain": true }],
 			"durable_objects": {
 				"bindings": [
 					{
@@ -73,7 +78,10 @@
 					"binding": "OAUTH_KV",
 					"id": "f9782295993747df90c29c45ca89edb1"
 				}
-			]
+			],
+			"vars": {
+				"ENVIRONMENT": "production"
+			}
 		}
 	}
 }
diff --git a/packages/mcp-common/src/cloudflare-oauth-handler.ts b/packages/mcp-common/src/cloudflare-oauth-handler.ts
@@ -11,7 +11,6 @@ import {
 import { McpError } from './mcp-error'
 
 import type {
-	AuthRequest,
 	OAuthHelpers,
 	TokenExchangeCallbackOptions,
 	TokenExchangeCallbackResult,
@@ -25,9 +24,23 @@ type AuthContext = {
 		CLOUDFLARE_CLIENT_SECRET: string
 	}
 }
-const app = new Hono<AuthContext>()
 
-const AuthQuery = z.object({
+const AuthRequestSchema = z.object({
+	responseType: z.string(),
+	clientId: z.string(),
+	redirectUri: z.string(),
+	scope: z.array(z.string()),
+	state: z.string(),
+	codeChallenge: z.string().optional(),
+	codeChallengeMethod: z.string().optional(),
+})
+
+// AuthRequest but with extra params that we use in our authentication logic
+export const AuthRequestSchemaWithExtraParams = AuthRequestSchema.merge(
+	z.object({ codeVerifier: z.string() })
+)
+
+export const AuthQuery = z.object({
 	code: z.string().describe('OAuth code from CF dash'),
 	state: z.string().describe('Value of the OAuth state'),
 	scope: z.string().describe('OAuth scopes granted'),
@@ -127,16 +140,18 @@ export async function handleTokenExchangeCallback(
 	}
 }
 
-/**f
+const app = new Hono<AuthContext>()
+
+/**
  * OAuth Authorization Endpoint
  *
- * This route initiates the GitHub OAuth flow when a user wants to log in.
+ * This route initiates the Cloudflare OAuth flow when a user wants to log in.
  * It creates a random state parameter to prevent CSRF attacks and stores the
  * original OAuth request information in KV storage for later retrieval.
- * Then it redirects the user to GitHub's authorization page with the appropriate
+ * Then it redirects the user to Cloudflare's authorization page with the appropriate
  * parameters so the user can authenticate and grant permissions.
  */
-app.get('/oauth/authorize', async (c) => {
+app.get(`/oauth/authorize`, async (c) => {
 	try {
 		const oauthReqInfo = await c.env.OAUTH_PROVIDER.parseAuthRequest(c.req.raw)
 		oauthReqInfo.scope = Object.keys(DefaultScopes)
@@ -163,15 +178,15 @@ app.get('/oauth/authorize', async (c) => {
 /**
  * OAuth Callback Endpoint
  *
- * This route handles the callback from GitHub after user authentication.
+ * This route handles the callback from Cloudflare after user authentication.
  * It exchanges the temporary code for an access token, then stores some
  * user metadata & the auth token as part of the 'props' on the token passed
  * down to the client. It ends by redirecting the client back to _its_ callback URL
  */
-app.get('/oauth/callback', zValidator('query', AuthQuery), async (c) => {
+app.get(`/oauth/callback`, zValidator('query', AuthQuery), async (c) => {
 	try {
 		const { state, code } = c.req.valid('query')
-		const oauthReqInfo = JSON.parse(atob(state)) as AuthRequest & { codeVerifier: string }
+		const oauthReqInfo = AuthRequestSchemaWithExtraParams.parse(JSON.parse(atob(state)))
 		// Get the oathReqInfo out of KV
 		if (!oauthReqInfo.clientId) {
 			throw new McpError('Invalid State', 400)
diff --git a/packages/mcp-common/src/config.ts b/packages/mcp-common/src/config.ts
@@ -0,0 +1,8 @@
+import { z } from 'zod'
+
+export type MCPEnvironment = z.infer<typeof MCPEnvironment>
+export const MCPEnvironment = z.enum(['VITEST', 'development', 'staging', 'production'])
+
+export function getEnvironment(environment: string) {
+	return MCPEnvironment.parse(environment)
+}
diff --git a/pnpm-lock.yaml b/pnpm-lock.yaml

Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,6 @@`
`1`	`1`	`{`
`2`	`2`	`"$schema": "node_modules/wrangler/config-schema.json",`
`3`		`- "name": "sandbox-container",`
	`3`	`+ "name": "sandbox-container-dev",`
`4`	`4`	`"main": "server/index.ts",`
`5`	`5`	`"compatibility_date": "2025-04-03",`
`6`	`6`	`"containers": [`
`@@ -41,5 +41,8 @@`
`41`	`41`	`],`
`42`	`42`	`"dev": {`
`43`	`43`	`"port": 8976`
	`44`	`+ },`
	`45`	`+ "vars": {`
	`46`	`+ "ENVIRONMENT": "development"`
`44`	`47`	`}`
`45`	`48`	`}`
Original file line number	Diff line number	Diff line change
`@@ -5,7 +5,9 @@ declare namespace Cloudflare {`
`5`	`5`	`OAUTH_KV: KVNamespace;`
`6`	`6`	`CLOUDFLARE_CLIENT_ID: string;`
`7`	`7`	`CLOUDFLARE_CLIENT_SECRET: string;`
	`8`	`+ // eslint-disable-next-line @typescript-eslint/consistent-type-imports`
`8`	`9`	`MCP_OBJECT: DurableObjectNamespace<import("./src/index").WorkersBindingsMCP>;`
	`10`	`+ ENVIRONMENT: string`
`9`	`11`	`}`
`10`	`12`	`}`
`11`	`13`	`interface Env extends Cloudflare.Env {}`