可信 MCP

import asyncio
import os
from google.adk.tools.mcp_tool.mcp_session_manager import StreamableHTTPConnectionParams
from veadk import Agent
from veadk.tools.mcp_tool.trusted_mcp_toolset import TrustedMcpToolset

async def main():
    toolset = TrustedMcpToolset(
        connection_params=StreamableHTTPConnectionParams(
            url=os.environ["TRUSTED_MCP_URL"],
            headers={"x-trusted-mcp": "true"},
        ),
    )
    try:
        tools = await toolset.get_tools()
        print("Available tools:", [tool.name for tool in tools])
        agent = Agent(name="trusted_assistant", tools=[toolset])
        print(await agent.run("Describe the tools available to you"))
    finally:
        await toolset.close()

asyncio.run(main())