OpenAI Agents SDK

pip install openai-agents

from agents import Agent, Runner
from agents.mcp import MCPServerStreamableHttp

async def main():
    # Connect to ChatAds MCP server
    async with MCPServerStreamableHttp(
        name="ChatAds",
        params={
            "url": "https://api.getchatads.com/mcp/mcp",
            "headers": {
                "x-api-key": "cak_your_api_key_here"
            },
            "timeout": 30,
        },
        cache_tools_list=True,
        max_retry_attempts=3,
    ) as chatads_server:
        # Create agent with ChatAds tools
        agent = Agent(
            name="Shopping Assistant",
            instructions="Help users find product recommendations. Use ChatAds tools when users ask about products.",
            model="gpt-4o",
            mcp_servers=[chatads_server],
        )

        # Run the agent - it will automatically use chatads_message_send
        result = await Runner.run(agent, "I need noise-cancelling headphones for commuting")
        print(result.final_output)

import asyncio
asyncio.run(main())

export OPENAI_API_KEY="sk-..."
python your_agent.py

agent = Agent(
    name="Shopping Assistant",
    model="gpt-4o",  # or gpt-4, gpt-3.5-turbo, etc.
    instructions="You help users find products. When they mention a product, use ChatAds to find affiliate links.",
    mcp_servers=[chatads_server],
)

{
  "data": {
    "status": "filled",
    "offers": [
      {
        "link_text": "Sony WH-1000XM5",
        "url": "https://amazon.com/dp/...",
        "confidence_level": "high"
      }
    ],
    "requested": 1,
    "returned": 1
  },
  "error": null,
  "meta": {
    "request_id": "abc-123"
  }
}

from agents import Agent, Runner
from agents.mcp import MCPServerStreamableHttp

async def create_shopping_assistant():
    async with MCPServerStreamableHttp(
        name="ChatAds",
        params={
            "url": "https://api.getchatads.com/mcp/mcp",
            "headers": {"x-api-key": "cak_your_api_key"},
            "timeout": 30,
        },
        cache_tools_list=True,
    ) as chatads:
        agent = Agent(
            name="ShopBot",
            model="gpt-4o",
            instructions="""You are a helpful shopping assistant.
            When users ask about products, use the chatads_message_send tool
            to find relevant affiliate links. Include the link naturally
            in your response.""",
            mcp_servers=[chatads],
        )

        # Conversation loop
        while True:
            user_input = input("You: ")
            if user_input.lower() == "quit":
                break

            result = await Runner.run(agent, user_input)
            print(f"Bot: {result.final_output}")

import asyncio
asyncio.run(create_shopping_assistant())

from agents import Agent, Runner
from agents.mcp import MCPServerStreamableHttp
from agents.exceptions import AgentError, ToolError

async def main():
    try:
        async with MCPServerStreamableHttp(
            name="ChatAds",
            params={
                "url": "https://api.getchatads.com/mcp/mcp",
                "headers": {"x-api-key": "cak_your_api_key"},
            },
            max_retry_attempts=3,
        ) as chatads:
            agent = Agent(
                name="Assistant",
                instructions="Help users find products.",
                model="gpt-4o",
                mcp_servers=[chatads],
            )
            result = await Runner.run(agent, "Find me a good laptop")
            print(result.final_output)

    except ToolError as e:
        print(f"ChatAds tool error: {e}")
    except AgentError as e:
        print(f"Agent error: {e}")