MCP Server

# pip install "mcp>=1.8.0" anthropic
import asyncio
import anthropic
from mcp import ClientSession
from mcp.client.streamable_http import streamablehttp_client

AGROSAT_KEY   = "agrosat_live_..."
ANTHROPIC_KEY = "sk-ant-..."

async def main() -> None:
    async with streamablehttp_client(
        "https://mcp.agrosat.dev/mcp",
        headers={"X-API-Key": AGROSAT_KEY},
    ) as (read, write, _):
        async with ClientSession(read, write) as session:
            await session.initialize()

            # Fetch AgroSat tools and convert to Anthropic format
            tools_resp = await session.list_tools()
            tools = [
                {"name": t.name, "description": t.description, "input_schema": t.inputSchema}
                for t in tools_resp.tools
            ]

            client = anthropic.Anthropic(api_key=ANTHROPIC_KEY)
            messages = [{"role": "user", "content": "What is the crop health at -6.79, 39.21?"}]

            # Agentic loop — Claude calls tools until it has an answer
            while True:
                response = client.messages.create(
                    model="claude-opus-4-7",
                    max_tokens=1024,
                    tools=tools,
                    messages=messages,
                )

                if response.stop_reason == "end_turn":
                    print(response.content[0].text)
                    break

                messages.append({"role": "assistant", "content": response.content})
                tool_results = []
                for block in response.content:
                    if block.type == "tool_use":
                        result = await session.call_tool(block.name, block.input)
                        tool_results.append({
                            "type": "tool_result",
                            "tool_use_id": block.id,
                            "content": result.content[0].text,
                        })
                messages.append({"role": "user", "content": tool_results})

asyncio.run(main())