src/servers/elevation.py

"""
All MCP Server Implementations
Deploy as: src/servers/__init__.py OR separate files

Contains:
- WeatherServer (Open-Meteo)
- SoilPropertiesServer (SoilGrids)
- WaterServer (GRACE)
- ElevationServer (OpenElevation)
- PestsServer (iNaturalist)
"""

import aiohttp
import asyncio
import os
import xarray as xr
import requests
from datetime import datetime
from typing import Dict, Any

# ============================================================================
# ELEVATION SERVER (OpenElevation)
# ============================================================================

class ElevationServer:
    """OpenElevation API Server"""

    async def get_data(self, lat: float, lon: float) -> Dict[str, Any]:
        try:
            url = "https://api.open-elevation.com/api/v1/lookup"
            params = {"locations": f"{lat},{lon}"}

            async with aiohttp.ClientSession() as session:
                async with session.get(url, params=params, timeout=aiohttp.ClientTimeout(total=10)) as response:
                    if response.status == 200:
                        data = await response.json()
                        elevation_m = data["results"][0]["elevation"]
                        return {
                            "status": "success",
                            "data": {
                                "elevation_meters": elevation_m,
                                "elevation_feet": round(elevation_m * 3.28084, 1),
                                "data_source": "OpenElevation API"
                            }
                        }
                    else:
                        return {"status": "error", "error": f"HTTP {response.status}"}
        except Exception as e:
            return {"status": "error", "error": str(e)}