Function invoke

aws-bedrock-agentcore/javascript/mcp-server/test-invoke.js:32–59

(method, params, id)

let sessionId = null

async function invoke(method, params, id) {
  const payload = { jsonrpc: '2.0', method, id }
  if (params) payload.params = params

  const command = new InvokeAgentRuntimeCommand({
    agentRuntimeArn: RUNTIME_ARN,
    qualifier: 'DEFAULT',
    ...(sessionId ? { runtimeSessionId: sessionId } : {}),
    payload: Buffer.from(JSON.stringify(payload)),
    contentType: 'application/json',
    accept: 'application/json, text/event-stream',
  })

  const response = await client.send(command)

  // Capture session ID from first response
  if (!sessionId && response.runtimeSessionId) {
    sessionId = response.runtimeSessionId
  }

  // Parse response body
  const body =
    typeof response.response === 'string'
      ? response.response
      : await streamToString(response.response)

  return JSON.parse(body)
}

async function streamToString(stream) {
  if (typeof stream === 'string') return stream