A2A and MCP Integration

import httpx
from a2a.client import A2ACardResolver, A2AClient
from a2a.types import (
    MessageSendParams,
    MessageSendConfiguration,
    Message,
    TextPart,
    JSONRPCErrorResponse,
    SendStreamingMessageRequest,
)
from uuid import uuid4

headers = {
    "Authorization": f"Bearer <NARADA_API_KEY>"
}

agent = "https://api.narada.ai/fast/v2/a2a"
async with httpx.AsyncClient(timeout=30, headers=headers) as client:
    card_resolver = A2ACardResolver(
        client, base_url=agent, agent_card_path="/.well-known/agent.json"
    )
    card = await card_resolver.get_agent_card()

    client = A2AClient(client, agent_card=card)

    # Create message
    message = Message(
        role="user",
        parts=[TextPart(text="/Operator navigate to google.com")],
        message_id=str(uuid4()),
        context_id=uuid4().hex,
    )

    # Send streaming request
    response_stream = client.send_message_streaming(
        SendStreamingMessageRequest(
            id=str(uuid4()),
            params=MessageSendParams(
                id=str(uuid4()),
                message=message,
                configuration=MessageSendConfiguration(accepted_output_modes=["text"]),
            ),
        )
    )

    # Print streaming responses
    async for result in response_stream:
        if isinstance(result.root, JSONRPCErrorResponse):
            print(f"Error: {result.root.error}")
        else:
            event = result.root.result
            print(f"stream event => {event.model_dump_json(exclude_none=True)}")

from fastmcp import Client
from fastmcp.client.transports import StreamableHttpTransport

headers = {
    "Authorization": f"Bearer <NARADA_API_KEY>"
}

url = "https://api.narada.ai/fast/v2/mcp"
client = Client(
    transport=StreamableHttpTransport(
        url,
        headers=headers,
    ),
)

async with client:
    await client.ping()

    # Create a new task
    result = await client.call_tool(
        name="narada",
        arguments={
            "prompt": "/Operator navigate to google.com"
        }
    )
    print(result.content)