Function readJsonRpcBody

apps/sim/app/api/mcp/serve/[serverId]/route.ts:130–138

(request: NextRequest)

}

async function readJsonRpcBody(request: NextRequest): Promise<unknown> {
  assertContentLengthWithinLimit(request.headers, MAX_MCP_SERVE_BODY_BYTES, 'MCP request body')
  const buffer = await readStreamToBufferWithLimit(request.body, {
    maxBytes: MAX_MCP_SERVE_BODY_BYTES,
    label: 'MCP request body',
    signal: request.signal,
  })
  return JSON.parse(buffer.toString('utf-8'))
}

interface ManagedAbortSignal {
  signal: AbortSignal