Method handleRequest

src/main/core/mcpServer.ts:208–253

* 处理所有进入 MCP 服务的 HTTP 请求。

(req: IncomingMessage, res: ServerResponse)

   * 处理所有进入 MCP 服务的 HTTP 请求。
   */
  private async handleRequest(req: IncomingMessage, res: ServerResponse): Promise<void> {
    if (req.method === 'OPTIONS') {
      this.sendNoContent(res)
      return
    }

    const requestUrl = new URL(req.url || '/', `http://${req.headers.host || '127.0.0.1'}`)
    const pathname = requestUrl.pathname

    if (req.method === 'GET' && pathname === '/mcp') {
      this.sendRawJson(res, 200, {
        name: 'ZTools MCP',
        protocolVersion: MCP_PROTOCOL_VERSION,
        message: 'Use POST /mcp with JSON-RPC 2.0'
      })
      return
    }

    if (req.method !== 'POST' || pathname !== '/mcp') {
      this.sendMcpError(res, null, -32601, 'Method not found')
      return
    }

    // 同时支持标准 Authorization: Bearer 和 ?key= 查询参数鉴权。
    const authHeader = req.headers['authorization']
    const bearerToken = authHeader?.startsWith('Bearer ') ? authHeader.slice(7) : null
    const queryToken = requestUrl.searchParams.get('key')
    const token = bearerToken || queryToken
    if (!token || token !== this.config.apiKey) {
      this.sendMcpError(res, null, -32001, 'API 密钥无效')
      return
    }

    try {
      const body = await this.readBody(req)
      await this.handleMcpRequest(res, body)
    } catch (error) {
      console.error('[McpServer] 请求处理失败:', error)
      this.sendMcpError(
        res,
        null,
        -32603,
        error instanceof Error ? error.message : 'Internal error'
      )
    }
  }

  /**
   * 读取并解析请求体，仅接受 JSON 对象。