MCP

from gwenflow import Agent, ChatOpenAI
from gwenflow.tools import MCPServerStdio, MCPServerStdioParams

filesystem = MCPServerStdio(
    MCPServerStdioParams(
        command="npx",
        args=["-y", "@modelcontextprotocol/server-filesystem", "/Users/me/Documents"],
    ),
    name="filesystem",
)

agent = Agent(
    name="Files assistant",
    llm=ChatOpenAI(model="gpt-5-mini"),
    mcp_servers=[filesystem],
)

print(agent.run("List the PDF files in my documents.").content)

from gwenflow.tools import MCPServerSse, MCPServerSseParams

server = MCPServerSse(
    MCPServerSseParams(
        url="https://mcp.example.com/sse",
        headers={"Authorization": "Bearer ..."},
        timeout=5,              # connection, seconds
        sse_read_timeout=300,   # waiting for events, seconds
    ),
    name="crm",
)

for tool in server.get_tools():
    print(tool.name, "-", tool.description)

async with server:
    tools = await server.list_tools()
    result = await server.call_tool("search_contacts", {"query": "Doe"})