fix: hono node v16 (#374)

<!--
Thank you for your pull request. Please review below requirements.
Bug fixes and new features should include tests and possibly benchmarks.
Contributors guide:
https://github.com/eggjs/egg/blob/master/CONTRIBUTING.md

感谢您贡献代码。请确认下列 checklist 的完成情况。
Bug 修复和新功能必须包含测试，必要时请附上性能测试。
Contributors guide:
https://github.com/eggjs/egg/blob/master/CONTRIBUTING.md
-->

##### Checklist
<!-- Remove items that do not apply. For completed items, change [ ] to
[x]. -->

- [ ] `npm test` passes
- [ ] tests and/or benchmarks are included
- [ ] documentation is changed or added
- [ ] commit message follows commit guidelines

##### Affected core subsystem(s)
<!-- Provide affected core subsystem(s). -->


##### Description of change
<!-- Provide a description of the change below this comment. -->

<!--
- any feature?
- close https://github.com/eggjs/egg/ISSUE_URL
-->

<!-- This is an auto-generated comment: release notes by coderabbit.ai
-->
## Summary by CodeRabbit

* **Refactor**
* Several MCP-related components now load lazily at runtime and
controller registration is instance-based to reduce startup overhead and
improve compatibility.
* **Bug Fixes**
* Improved transport message-key handling to reduce transient
lookup/type issues and increase reliability.
* **Tests**
* Test setup now runs conditionally on newer runtimes to avoid failures
on older Node versions.

<sub>✏️ Tip: You can customize this high-level summary in your review
settings.</sub>
<!-- end of auto-generated comment: release notes by coderabbit.ai -->

Author: akitaSummer

core/mcp-client/test/fixtures/streamable-mcp-server/http.ts

@@ -1,7 +1,6 @@
 import http from 'node:http';
 
 import { McpServer } from '@modelcontextprotocol/sdk/server/mcp.js';
-import { StreamableHTTPServerTransport } from '@modelcontextprotocol/sdk/server/streamableHttp.js';
 import * as z from 'zod/v4';
 
 // Create an MCP server
@@ -39,6 +38,7 @@ export const headers = {};
 export let httpServer;
 export async function startStreamableServer(port = 17243){
   const httpServer = http.createServer(async (req, res) => {
+    const { StreamableHTTPServerTransport } = require('@modelcontextprotocol/sdk/server/streamableHttp.js');
     const url = new URL(`http://127.0.0.1:${port}${req.url!}`);
     const headerKey = `${req.method}${url.pathname}`;
     const serverCode = req.headers['x-mcp-server-code'] as string;
@@ -47,7 +47,7 @@ export async function startStreamableServer(port = 17243){
     headers[serverCode][headerKey].push(req.headers);
     if (req.method === 'POST') {
       try {
-        const transport: StreamableHTTPServerTransport = new StreamableHTTPServerTransport({
+        const transport: typeof StreamableHTTPServerTransport = new StreamableHTTPServerTransport({
           sessionIdGenerator: undefined,
         });
         await server.connect(transport);

plugin/controller/app.ts

@@ -11,7 +11,6 @@ import { ControllerMetadataManager } from './lib/ControllerMetadataManager';
 import { EggControllerPrototypeHook } from './lib/EggControllerPrototypeHook';
 import { RootProtoManager } from './lib/RootProtoManager';
 import { EggControllerLoader } from './lib/EggControllerLoader';
-import { MCPControllerRegister } from './lib/impl/mcp/MCPControllerRegister';
 import { middlewareGraphHook } from './lib/MiddlewareGraphHook';
 import assert from 'node:assert';
 
@@ -28,6 +27,8 @@ export default class ControllerAppBootHook {
   private controllerLoadUnitHandler: ControllerLoadUnitHandler;
   private readonly controllerPrototypeHook: EggControllerPrototypeHook;
 
+  private mcpControllerRegister?: typeof import('./lib/impl/mcp/MCPControllerRegister').MCPControllerRegister;
+
   constructor(app: Application) {
     this.app = app;
     this.controllerRegisterFactory = new ControllerRegisterFactory(this.app);
@@ -36,6 +37,11 @@ export default class ControllerAppBootHook {
     this.app.controllerMetaBuilderFactory = ControllerMetaBuilderFactory;
     this.loadUnitHook = new AppLoadUnitControllerHook(this.controllerRegisterFactory, this.app.rootProtoManager);
     this.controllerPrototypeHook = new EggControllerPrototypeHook();
+
+    if (parseInt(process.versions.node.split('.')[0], 10) >= 18) {
+      // eslint-disable-next-line @typescript-eslint/no-var-requires
+      this.mcpControllerRegister = require('./lib/impl/mcp/MCPControllerRegister').MCPControllerRegister;
+    }
   }
 
   configWillLoad() {
@@ -75,8 +81,8 @@ export default class ControllerAppBootHook {
 
     // init http root proto middleware
     this.prepareMiddleware(this.app.config.coreMiddleware);
-    if (this.mcpEnable()) {
-      this.controllerRegisterFactory.registerControllerRegister(ControllerType.MCP, MCPControllerRegister.create);
+    if (this.mcpEnable() && this.mcpControllerRegister) {
+      this.controllerRegisterFactory.registerControllerRegister(ControllerType.MCP, this.mcpControllerRegister.create);
       // Don't let the mcp's body be consumed
       this.app.config.coreMiddleware.unshift('mcpBodyMiddleware');
 
@@ -134,20 +140,20 @@ export default class ControllerAppBootHook {
     // and register methods after collect is done.
     HTTPControllerRegister.instance?.doRegister(this.app.rootProtoManager);
 
-    this.app.config.mcp.hooks = MCPControllerRegister.hooks;
+    this.app.config.mcp.hooks = this.mcpControllerRegister?.hooks;
   }
 
   configDidLoad() {
     GlobalGraph.instance!.registerBuildHook(middlewareGraphHook);
   }
 
   async willReady() {
-    if (this.mcpEnable()) {
-      await MCPControllerRegister.connectStatelessStreamTransport();
-      const names = MCPControllerRegister.instance?.mcpConfig.getMultipleServerNames();
+    if (this.mcpEnable() && this.mcpControllerRegister) {
+      await this.mcpControllerRegister.connectStatelessStreamTransport();
+      const names = this.mcpControllerRegister.instance?.mcpConfig.getMultipleServerNames();
       if (names && names.length > 0) {
         for (const name of names) {
-          await MCPControllerRegister.connectStatelessStreamTransport(name);
+          await this.mcpControllerRegister.connectStatelessStreamTransport(name);
         }
       }
     }
@@ -165,6 +171,6 @@ export default class ControllerAppBootHook {
     this.app.eggPrototypeLifecycleUtil.deleteLifecycle(this.controllerPrototypeHook);
     ControllerMetadataManager.instance.clear();
     HTTPControllerRegister.clean();
-    MCPControllerRegister.clean();
+    this.mcpControllerRegister?.clean();
   }
 }

plugin/controller/lib/impl/mcp/MCPControllerRegister.ts

@@ -70,10 +70,10 @@ class InnerSSEServerTransport extends SSEServerTransport {
       // eslint-disable-next-line @typescript-eslint/no-use-before-define
       const map = MCPControllerRegister.instance?.sseTransportsRequestMap.get(this);
       if (map && 'id' in message) {
-        const { resolve, reject } = map[message.id] ?? {};
+        const { resolve, reject } = map[message.id!] ?? {};
         if (resolve) {
           res ? reject(res) : resolve(res);
-          delete map[message.id];
+          delete map[String(message.id)];
         }
       }
     }

plugin/controller/test/mcp/helper.test.ts

@@ -7,10 +7,16 @@ import { InMemoryTransport } from '@modelcontextprotocol/sdk/inMemory.js';
 import * as z from 'zod/v4';
 import assert from 'assert';
 
-import { MCPServerHelper } from '../../lib/impl/mcp/MCPServerHelper';
 import { Client } from '@modelcontextprotocol/sdk/client/index.js';
 
 describe('plugin/controller/test/mcp/mcp.test.ts', () => {
+
+  if (parseInt(process.versions.node, 10) < 18) {
+    return;
+  }
+
+  // eslint-disable-next-line @typescript-eslint/no-var-requires
+  const { MCPServerHelper } = require('../../lib/impl/mcp/MCPServerHelper');
   it('MCPServerHelper should work', async () => {
     const PromptType = {
       name: z.string(),

plugin/mcp-client/test/fixtures/streamable-mcp-server/http.ts

@@ -1,7 +1,6 @@
 import http from 'node:http';
 
 import { McpServer } from '@modelcontextprotocol/sdk/server/mcp.js';
-import { StreamableHTTPServerTransport } from '@modelcontextprotocol/sdk/server/streamableHttp.js';
 import * as z from 'zod/v4';
 
 // Create an MCP server
@@ -38,6 +37,8 @@ export const headers = {};
 export let httpServer;
 export async function startStreamableServer(port = 17243) {
   const httpServer = http.createServer(async (req, res) => {
+    // eslint-disable-next-line @typescript-eslint/no-var-requires
+    const { StreamableHTTPServerTransport } = require('@modelcontextprotocol/sdk/server/streamableHttp.js');
     const url = new URL(`http://127.0.0.1:${port}${req.url!}`);
     const headerKey = `${req.method}${url.pathname}`;
     const serverCode = req.headers['x-mcp-server-code'] as string;
@@ -46,7 +47,7 @@ export async function startStreamableServer(port = 17243) {
     headers[serverCode][headerKey].push(req.headers);
     if (req.method === 'POST') {
       try {
-        const transport: StreamableHTTPServerTransport = new StreamableHTTPServerTransport({
+        const transport: typeof StreamableHTTPServerTransport = new StreamableHTTPServerTransport({
           sessionIdGenerator: undefined,
         });
         await server.connect(transport);