Method readBody

src/main/core/mcpServer.ts:258–289

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

(req: IncomingMessage)

   * 读取并解析请求体，仅接受 JSON 对象。
   */
  private readBody(req: IncomingMessage): Promise<Record<string, unknown>> {
    return new Promise((resolve, reject) => {
      const chunks: Buffer[] = []
      let size = 0
      const maxBodySize = 1024 * 1024

      req.on('data', (chunk: Buffer) => {
        size += chunk.length
        if (size > maxBodySize) {
          reject(new Error('请求体过大'))
          req.destroy()
          return
        }
        chunks.push(chunk)
      })

      req.on('end', () => {
        const raw = Buffer.concat(chunks).toString('utf-8')
        if (!raw) {
          resolve({})
          return
        }
        try {
          resolve(JSON.parse(raw))
        } catch {
          reject(new Error('无效的 JSON 格式'))
        }
      })

      req.on('error', reject)
    })
  }

  /**
   * 校验 JSON-RPC 基础结构，并将请求转发到 MCP 路由层。