fix (adding Starlette app for SSE to tackle hf proxy issues)

mcp_server.py

@@ -1,18 +1,17 @@
 """
-Farmer.chat MCP Server
-Minimal wrapper exposing existing servers as MCP tools
-
-Usage:
-  Local (stdio):  python mcp_server.py
-  Remote (SSE):   Mount in FastAPI with mcp.sse_app()
+MCP SSE Transport for HuggingFace Spaces
+Manual SSE setup that works behind HF's proxy
 """
 
 from mcp.server.fastmcp import FastMCP
-import asyncio
+from mcp.server.sse import SseServerTransport
+from starlette.applications import Starlette
+from starlette.routing import Route, Mount
+from starlette.requests import Request
+
 import sys
 import os
 
-# Add parent dir to path for imports
 sys.path.insert(0, os.path.dirname(os.path.abspath(__file__)))
 
 from src.servers.weather import WeatherServer
@@ -67,8 +66,10 @@ async def get_pest_observations(latitude: float, longitude: float) -> dict:
 
 
 @mcp.tool()
-async def get_all_data(latitude: float, longitude: float) -> dict:
+async def get_all_farm_data(latitude: float, longitude: float) -> dict:
     """Get data from all sources in parallel (weather, soil, water, elevation, pests)."""
+    import asyncio
+    
     results = await asyncio.gather(
         weather.get_data(latitude, longitude),
         soil.get_data(latitude, longitude),
@@ -91,7 +92,41 @@ async def get_all_data(latitude: float, longitude: float) -> dict:
 
 
 # ============================================================================
-# RUN
+# SSE TRANSPORT SETUP (Works with HF Spaces)
+# ============================================================================
+
+def create_sse_app():
+    """Create Starlette app with proper SSE transport for remote hosting."""
+    
+    sse_transport = SseServerTransport("/messages/")
+    
+    async def handle_sse(request: Request):
+        async with sse_transport.connect_sse(
+            request.scope,
+            request.receive,
+            request._send,
+        ) as (read_stream, write_stream):
+            await mcp._mcp_server.run(
+                read_stream,
+                write_stream,
+                mcp._mcp_server.create_initialization_options(),
+            )
+    
+    return Starlette(
+        debug=True,
+        routes=[
+            Route("/sse", endpoint=handle_sse),
+            Mount("/messages/", app=sse_transport.handle_post_message),
+        ],
+    )
+
+
+# Create the SSE app for mounting
+sse_app = create_sse_app()
+
+
+# ============================================================================
+# STANDALONE RUN (for local testing)
 # ============================================================================
 
 if __name__ == "__main__":