15. Model Context Protocol (MCP)

from google.adk.agents import Agent
from google.adk.tools.mcp_tool.mcp_toolset import MCPToolset

# MCPToolset handles:
# 1. Connection management
# 2. Tool discovery
# 3. Request/response serialization
# 4. Error handling

root_agent = Agent(
    model="gemini-2.5-flash",
    name="mcp_agent",
    instruction="You have access to external tools via MCP.",
    tools=[
        MCPToolset(connection_params=...)  # Tools auto-discovered
    ],
)

from google.adk.tools.mcp_tool.mcp_session_manager import StreamableHTTPServerParams
from google.adk.tools.mcp_tool.mcp_toolset import MCPToolset

# HTTP connection for remote MCP servers
mcp_tools = MCPToolset(
    connection_params=StreamableHTTPServerParams(
        url="https://api.example.com/mcp/",
        headers={
            "Authorization": f"Bearer {API_TOKEN}",
            "X-Custom-Header": "value"
        },
    ),
)

# Best for:
# - Cloud-hosted services (GitHub Copilot, hosted APIs)
# - Production deployments
# - Services requiring authentication headers

from google.adk.tools.mcp_tool.mcp_session_manager import StdioConnectionParams
from google.adk.tools.mcp_tool.mcp_toolset import MCPToolset
from mcp import StdioServerParameters

# Stdio connection for local MCP servers
mcp_tools = MCPToolset(
    connection_params=StdioConnectionParams(
        server_params=StdioServerParameters(
            command="npx",
            args=["-y", "firecrawl-mcp"],
            env={"API_KEY": API_KEY}
        ),
        timeout=30,
    ),
)

# Best for:
# - NPM-based MCP servers
# - Local development
# - Servers without hosted endpoints

# Create and activate virtual environment
python3 -m venv .venv
source .venv/bin/activate  # On Windows: .venv\Scripts\activate

# Install dependencies
pip install google-adk python-dotenv

# Set environment variables
export GOOGLE_API_KEY=your_google_api_key
export GITHUB_TOKEN=your_github_token

import os
import asyncio
from dotenv import load_dotenv
from google.adk.agents import Agent
from google.adk.runners import Runner
from google.adk.sessions import InMemorySessionService
from google.adk.tools.mcp_tool.mcp_toolset import MCPToolset
from google.adk.tools.mcp_tool.mcp_session_manager import StreamableHTTPServerParams
from google.genai import types

load_dotenv()

GITHUB_TOKEN = os.environ.get("GITHUB_TOKEN", "")

# Create the GitHub MCP-powered agent
github_agent = Agent(
    model="gemini-2.5-flash",
    name="github_reviewer",
    instruction="""You are an expert code reviewer with access to GitHub.
    
When asked to review a PR:
1. Fetch the PR details and diff
2. Analyze the code changes for:
   - Potential bugs or errors
   - Code style and best practices
   - Security vulnerabilities
   - Performance issues
3. Provide constructive feedback with specific line references
4. Suggest improvements with code examples when helpful

Be thorough but constructive. Focus on significant issues first.""",
    tools=[
        MCPToolset(
            connection_params=StreamableHTTPServerParams(
                url="https://api.githubcopilot.com/mcp/",
                headers={
                    "Authorization": f"Bearer {GITHUB_TOKEN}",
                    "X-MCP-Toolsets": "repos,pulls,issues",
                    "X-MCP-Readonly": "true"
                },
            ),
        )
    ],
)

async def review_pr(repo: str, pr_number: int):
    """Review a GitHub pull request."""
    session_service = InMemorySessionService()
    runner = Runner(
        agent=github_agent,
        app_name="github_reviewer",
        session_service=session_service,
    )
    
    session = await session_service.create_session(
        app_name="github_reviewer",
        user_id="developer"
    )
    
    message = types.Content(
        role="user",
        parts=[types.Part(text=f"Please review PR #{pr_number} in the {repo} repository. Focus on code quality, potential bugs, and security issues.")]
    )
    
    print(f"Reviewing PR #{pr_number} in {repo}...")
    print("-" * 50)
    
    async for event in runner.run_async(
        session_id=session.id,
        user_id="developer",
        new_message=message
    ):
        if hasattr(event, 'content') and event.content:
            for part in event.content.parts:
                if hasattr(part, 'text') and part.text:
                    print(part.text, end="", flush=True)
    
    print("\n" + "-" * 50)

if __name__ == "__main__":
    # Example: Review a PR
    asyncio.run(review_pr("google/adk-python", 42))

# Run the code review agent
python github_reviewer.py

# Or use ADK web interface
adk web

import os
import asyncio
from dotenv import load_dotenv
from google.adk.agents import Agent
from google.adk.runners import Runner
from google.adk.sessions import InMemorySessionService
from google.adk.tools.mcp_tool.mcp_toolset import MCPToolset
from google.adk.tools.mcp_tool.mcp_session_manager import (
    StreamableHTTPServerParams,
    StdioConnectionParams
)
from mcp import StdioServerParameters
from google.genai import types

load_dotenv()

GITHUB_TOKEN = os.environ.get("GITHUB_TOKEN", "")
FIRECRAWL_API_KEY = os.environ.get("FIRECRAWL_API_KEY", "")

# GitHub MCP for code and repository access
github_mcp = MCPToolset(
    connection_params=StreamableHTTPServerParams(
        url="https://api.githubcopilot.com/mcp/",
        headers={
            "Authorization": f"Bearer {GITHUB_TOKEN}",
            "X-MCP-Toolsets": "repos,code",
            "X-MCP-Readonly": "true"
        },
    ),
)

# Firecrawl MCP for web scraping
firecrawl_mcp = MCPToolset(
    connection_params=StdioConnectionParams(
        server_params=StdioServerParameters(
            command="npx",
            args=["-y", "firecrawl-mcp"],
            env={"FIRECRAWL_API_KEY": FIRECRAWL_API_KEY}
        ),
        timeout=60,
    ),
)

# Multi-MCP Research Agent
research_agent = Agent(
    model="gemini-2.5-flash",
    name="research_agent",
    instruction="""You are a technical research assistant with access to:

1. **GitHub** - For code repositories, documentation, and open source projects
2. **Firecrawl** - For scraping and analyzing web content

When researching a topic:
1. First, search GitHub for relevant repositories and code examples
2. Then, scrape relevant documentation or blog posts for context
3. Synthesize findings into a comprehensive answer
4. Include code examples and links to sources

Always cite your sources and provide actionable insights.""",
    tools=[github_mcp, firecrawl_mcp],
)

async def research(query: str):
    """Conduct research using multiple MCP servers."""
    session_service = InMemorySessionService()
    runner = Runner(
        agent=research_agent,
        app_name="research_agent",
        session_service=session_service,
    )
    
    session = await session_service.create_session(
        app_name="research_agent",
        user_id="researcher"
    )
    
    message = types.Content(
        role="user",
        parts=[types.Part(text=query)]
    )
    
    print(f"Researching: {query}")
    print("=" * 60)
    
    async for event in runner.run_async(
        session_id=session.id,
        user_id="researcher",
        new_message=message
    ):
        if hasattr(event, 'content') and event.content:
            for part in event.content.parts:
                if hasattr(part, 'text') and part.text:
                    print(part.text, end="", flush=True)
    
    print("\n" + "=" * 60)

if __name__ == "__main__":
    asyncio.run(research(
        "What are the best practices for building AI agents with ADK? "
        "Include code examples and links to official documentation."
    ))

from google.adk.agents import Agent
from google.adk.tools.mcp_tool.mcp_toolset import MCPToolset
from google.adk.tools.mcp_tool.mcp_session_manager import (
    StreamableHTTPServerParams,
    StdioConnectionParams
)
from mcp import StdioServerParameters

# GitHub MCP (HTTP)
github_mcp = MCPToolset(
    connection_params=StreamableHTTPServerParams(
        url="https://api.githubcopilot.com/mcp/",
        headers={"Authorization": f"Bearer {GITHUB_TOKEN}"},
    ),
)

# Firecrawl MCP (Stdio)
firecrawl_mcp = MCPToolset(
    connection_params=StdioConnectionParams(
        server_params=StdioServerParameters(
            command="npx",
            args=["-y", "firecrawl-mcp"],
            env={"FIRECRAWL_API_KEY": FIRECRAWL_KEY}
        ),
    ),
)

# Agent with multiple MCP servers
root_agent = Agent(
    model="gemini-2.5-flash",
    name="multi_mcp_agent",
    instruction="""You have access to:
    - GitHub for code and repository operations
    - Firecrawl for web scraping and content extraction
    Choose the appropriate tool based on the user's request.""",
    tools=[github_mcp, firecrawl_mcp],
)

# Only expose specific tools from the MCP server
mcp_tools = MCPToolset(
    connection_params=StreamableHTTPServerParams(
        url="https://api.githubcopilot.com/mcp/",
        headers={
            "Authorization": f"Bearer {GITHUB_TOKEN}",
            "X-MCP-Toolsets": "repos,issues",  # Only repos and issues tools
            "X-MCP-Readonly": "true"  # Read-only mode
        },
    ),
    # Optional: filter tools by name pattern
    tool_filter=lambda tool: tool.name.startswith("get_")
)