feat: dev and invoke support for MCP and A2A protocols

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@aws/agentcore",
-  "version": "0.3.0-preview.5.1",
+  "version": "0.3.0-preview.6.0",
   "description": "CLI for Amazon Bedrock AgentCore",
   "license": "Apache-2.0",
   "repository": {

src/assets/__tests__/__snapshots__/assets.snapshot.test.ts.snap

@@ -1645,7 +1645,8 @@ readme = "README.md"
 requires-python = ">=3.10"
 dependencies = [
     {{#if (eq modelProvider "Anthropic")}}"anthropic >= 0.30.0",
-    {{/if}}"aws-opentelemetry-distro",
+    {{/if}}"a2a-sdk[all] >= 0.2.0",
+    "aws-opentelemetry-distro",
     "bedrock-agentcore[a2a] >= 1.0.3",
     "botocore[crt] >= 1.35.0",
     {{#if (eq modelProvider "Gemini")}}"google-genai >= 1.0.0",
@@ -4076,29 +4077,30 @@ Thumbs.db
 
 exports[`Assets Directory Snapshots > Python framework assets > python/python/mcp/standalone/base/main.py should match snapshot 1`] = `
 "from mcp.server.fastmcp import FastMCP
-import uvicorn
 
-mcp = FastMCP("{{ name }}")
+mcp = FastMCP("{{ name }}", host="0.0.0.0", stateless_http=True)
 
 
 @mcp.tool()
 def add_numbers(a: int, b: int) -> int:
-    """Return the sum of two numbers."""
+    """Add two numbers together"""
     return a + b
 
 
 @mcp.tool()
-def greet(name: str) -> str:
-    """Return a greeting for the given name."""
-    return f"Hello, {name}!"
+def multiply_numbers(a: int, b: int) -> int:
+    """Multiply two numbers together"""
+    return a * b
+
+
+@mcp.tool()
+def greet_user(name: str) -> str:
+    """Greet a user by name"""
+    return f"Hello, {name}! Nice to meet you."
 
 
 if __name__ == "__main__":
-    uvicorn.run(
-        mcp.streamable_http_app(),
-        host="0.0.0.0",
-        port=8000,
-    )
+    mcp.run(transport="streamable-http")
 "
 `;
 
@@ -4114,10 +4116,7 @@ description = "AgentCore MCP Server"
 readme = "README.md"
 requires-python = ">=3.10"
 dependencies = [
-    "aws-opentelemetry-distro",
-    "bedrock-agentcore >= 1.0.3",
     "mcp >= 1.19.0",
-    "uvicorn >= 0.30.0",
 ]
 
 [tool.hatch.build.targets.wheel]

src/assets/python/a2a/strands/base/pyproject.toml

@@ -10,7 +10,8 @@ readme = "README.md"
 requires-python = ">=3.10"
 dependencies = [
     {{#if (eq modelProvider "Anthropic")}}"anthropic >= 0.30.0",
-    {{/if}}"aws-opentelemetry-distro",
+    {{/if}}"a2a-sdk[all] >= 0.2.0",
+    "aws-opentelemetry-distro",
     "bedrock-agentcore[a2a] >= 1.0.3",
     "botocore[crt] >= 1.35.0",
     {{#if (eq modelProvider "Gemini")}}"google-genai >= 1.0.0",

src/assets/python/mcp/standalone/base/main.py

@@ -1,24 +1,25 @@
 from mcp.server.fastmcp import FastMCP
-import uvicorn
 
-mcp = FastMCP("{{ name }}")
+mcp = FastMCP("{{ name }}", host="0.0.0.0", stateless_http=True)
 
 
 @mcp.tool()
 def add_numbers(a: int, b: int) -> int:
-    """Return the sum of two numbers."""
+    """Add two numbers together"""
     return a + b
 
 
 @mcp.tool()
-def greet(name: str) -> str:
-    """Return a greeting for the given name."""
-    return f"Hello, {name}!"
+def multiply_numbers(a: int, b: int) -> int:
+    """Multiply two numbers together"""
+    return a * b
+
+
+@mcp.tool()
+def greet_user(name: str) -> str:
+    """Greet a user by name"""
+    return f"Hello, {name}! Nice to meet you."
 
 
 if __name__ == "__main__":
-    uvicorn.run(
-        mcp.streamable_http_app(),
-        host="0.0.0.0",
-        port=8000,
-    )
+    mcp.run(transport="streamable-http")

src/assets/python/mcp/standalone/base/pyproject.toml

@@ -9,10 +9,7 @@ description = "AgentCore MCP Server"
 readme = "README.md"
 requires-python = ">=3.10"
 dependencies = [
-    "aws-opentelemetry-distro",
-    "bedrock-agentcore >= 1.0.3",
     "mcp >= 1.19.0",
-    "uvicorn >= 0.30.0",
 ]
 
 [tool.hatch.build.targets.wheel]

src/cli/aws/__tests__/agentcore.test.ts

@@ -1,4 +1,4 @@
-import { extractResult, parseSSE, parseSSELine } from '../agentcore.js';
+import { extractResult, parseA2AResponse, parseSSE, parseSSELine } from '../agentcore.js';
 import { describe, expect, it } from 'vitest';
 
 describe('parseSSELine', () => {
@@ -97,3 +97,82 @@ describe('extractResult', () => {
     expect(extractResult('')).toBe('');
   });
 });
+
+describe('parseA2AResponse', () => {
+  it('extracts text from artifacts with kind:text parts', () => {
+    const response = JSON.stringify({
+      jsonrpc: '2.0',
+      id: 1,
+      result: {
+        artifacts: [{ parts: [{ kind: 'text', text: 'Hello from A2A' }] }],
+      },
+    });
+    expect(parseA2AResponse(response)).toBe('Hello from A2A');
+  });
+
+  it('extracts text from artifacts with type:text parts (backward compat)', () => {
+    const response = JSON.stringify({
+      jsonrpc: '2.0',
+      id: 1,
+      result: {
+        artifacts: [{ parts: [{ type: 'text', text: 'Hello' }] }],
+      },
+    });
+    expect(parseA2AResponse(response)).toBe('Hello');
+  });
+
+  it('concatenates text from multiple parts', () => {
+    const response = JSON.stringify({
+      jsonrpc: '2.0',
+      id: 1,
+      result: {
+        artifacts: [
+          {
+            parts: [
+              { kind: 'text', text: 'part1' },
+              { kind: 'text', text: 'part2' },
+            ],
+          },
+        ],
+      },
+    });
+    expect(parseA2AResponse(response)).toBe('part1part2');
+  });
+
+  it('returns error message for JSON-RPC error', () => {
+    const response = JSON.stringify({
+      jsonrpc: '2.0',
+      id: 1,
+      error: { code: -32600, message: 'Bad request' },
+    });
+    expect(parseA2AResponse(response)).toBe('Error: Bad request');
+  });
+
+  it('falls back to history for agent messages', () => {
+    const response = JSON.stringify({
+      jsonrpc: '2.0',
+      id: 1,
+      result: {
+        history: [
+          { role: 'user', parts: [{ kind: 'text', text: 'hi' }] },
+          { role: 'agent', parts: [{ kind: 'text', text: 'Hello!' }] },
+        ],
+      },
+    });
+    expect(parseA2AResponse(response)).toBe('Hello!');
+  });
+
+  it('returns stringified result when no text parts found', () => {
+    const response = JSON.stringify({
+      jsonrpc: '2.0',
+      id: 1,
+      result: { id: 'task-1', status: { state: 'completed' } },
+    });
+    const parsed = parseA2AResponse(response);
+    expect(parsed).toContain('task-1');
+  });
+
+  it('returns raw text for non-JSON input', () => {
+    expect(parseA2AResponse('not json')).toBe('not json');
+  });
+});