added test for agents/mcp

Author: geelen

test/integration/mcp-connection.test.ts

@@ -18,18 +18,21 @@ function getMCPServers() {
       throw new Error('hono-mcp port not found in test state')
     }
 
+    if (!state.cfAgentsPort) {
+      throw new Error('cf-agents port not found in test state')
+    }
+
     return [
       {
         name: 'hono-mcp',
         url: `http://localhost:${state.honoPort}/mcp`,
         expectedTools: 1, // Minimum expected tools count
       },
-      // Add more servers here as they become available
-      // {
-      //   name: 'another-server',
-      //   url: 'http://localhost:9902/mcp',
-      //   expectedTools: 1,
-      // },
+      {
+        name: 'cf-agents',
+        url: `http://localhost:${state.cfAgentsPort}/mcp`,
+        expectedTools: 1, // Minimum expected tools count
+      },
     ]
   } catch (error) {
     throw new Error(`Test environment not properly initialized: ${error}`)
@@ -161,6 +164,15 @@ describe('MCP Connection Integration Tests', () => {
       // Ignore errors - process might already be dead
     }
 
+    try {
+      if (state?.cfAgentsServer && !state.cfAgentsServer.killed) {
+        console.log('🔥 Force cleanup cf-agents server...')
+        state.cfAgentsServer.kill('SIGKILL')
+      }
+    } catch (e) {
+      // Ignore errors - process might already be dead
+    }
+
     try {
       if (state?.staticServer) {
         state.staticServer.close()

test/setup/global-setup.ts

@@ -14,9 +14,11 @@ const testStateFile = join(cacheDir, 'test-state.json')
 
 interface GlobalState {
   honoServer?: ChildProcess
+  cfAgentsServer?: ChildProcess
   staticServer?: Server
   staticPort?: number
   honoPort?: number
+  cfAgentsPort?: number
   processGroupId?: number
   allChildProcesses?: Set<number>
 }
@@ -252,7 +254,48 @@ export default async function globalSetup() {
     await waitForOutput(honoServer, 'Ready on')
     state.honoServer = honoServer
 
-    // Step 4: Start simple static file server for inspector
+    // Step 4: Find available port and start cf-agents server
+    console.log('🔍 Finding available port starting from 9902...')
+    const cfAgentsPort = await findAvailablePortFromBase(9902)
+    console.log(`📍 Using port ${cfAgentsPort} for cf-agents server`)
+
+    console.log('🚀 Starting cf-agents server...')
+    const cfAgentsDir = join(rootDir, 'examples/servers/cf-agents')
+    const cfAgentsServer = spawn('pnpm', ['dev', `--port=${cfAgentsPort}`], {
+      cwd: cfAgentsDir,
+      stdio: ['ignore', 'pipe', 'pipe'],
+      shell: true,
+      detached: false,
+    })
+
+    // Track all child processes
+    if (cfAgentsServer.pid) {
+      state.allChildProcesses!.add(cfAgentsServer.pid)
+    }
+
+    state.cfAgentsPort = cfAgentsPort
+    state.cfAgentsServer = cfAgentsServer
+
+    cfAgentsServer.stdout?.on('data', (data) => {
+      console.log(`[cf-agents] ${data.toString()}`)
+    })
+
+    cfAgentsServer.stderr?.on('data', (data) => {
+      console.log(`[cf-agents] ${data.toString()}`)
+    })
+
+    // Track when the process exits to remove it from our tracking
+    cfAgentsServer.on('exit', () => {
+      if (cfAgentsServer.pid) {
+        state.allChildProcesses!.delete(cfAgentsServer.pid)
+      }
+    })
+
+    // Wait for cf-agents server to be ready
+    await waitForOutput(cfAgentsServer, 'Ready on')
+    state.cfAgentsServer = cfAgentsServer
+
+    // Step 5: Start simple static file server for inspector
     console.log('🌐 Starting static file server for inspector...')
     const inspectorDistDir = join(inspectorDir, 'dist')
     const staticPort = await findAvailablePort(8000)
@@ -315,6 +358,7 @@ export default async function globalSetup() {
       JSON.stringify(
         {
           honoPort: state.honoPort,
+          cfAgentsPort: state.cfAgentsPort,
           staticPort: state.staticPort,
         },
         null,
@@ -330,6 +374,9 @@ export default async function globalSetup() {
     if (state.honoServer) {
       state.honoServer.kill()
     }
+    if (state.cfAgentsServer) {
+      state.cfAgentsServer.kill()
+    }
     if (state.staticServer) {
       state.staticServer.close()
     }