Spaces:

aakashdg
/

alert-summary-fc-backend

Sleeping

App Files Files Community

aakashdg commited on 4 days ago

Commit

5e0795d

verified ·

1 Parent(s): 8b7d437

feat (testing location selector ui)

Browse files

Files changed (1) hide show

app.py +486 -155

app.py CHANGED Viewed

@@ -1,34 +1,239 @@
 """
-Farmer.Chat Backend - FastAPI Application
-Deploy to Hugging Face Space: https://huggingface.co/spaces/aakashdg/farmer-chat-backend
 """
 from fastapi import FastAPI, HTTPException
 from fastapi.middleware.cors import CORSMiddleware
-from fastapi.responses import FileResponse, JSONResponse
-from pydantic import BaseModel, Field
 from typing import Optional, Dict, Any
 import os
-import asyncio
-import time
 from datetime import datetime
-# Import pipeline components
 from src.pipeline import FarmerChatPipeline
-from src.pdf_generator import generate_pdf_report
-# CRITICAL FIX: Import OpenAI with httpx configuration
-from openai import OpenAI
-import httpx
-# Initialize FastAPI
-app = FastAPI(
-    title="Farmer.Chat Backend",
-    description="Multi-stage MCP pipeline for agricultural intelligence",
-    version="2.0.0"
-)
-# CORS - Allow all origins for demo (restrict in production)
 app.add_middleware(
     CORSMiddleware,
     allow_origins=["*"],
@@ -37,180 +242,306 @@ app.add_middleware(
     allow_headers=["*"],
 )
-# Initialize OpenAI client with FIXED httpx configuration
-OPENAI_API_KEY = os.environ.get("OPENAI_API_KEY")
-if not OPENAI_API_KEY:
-    raise ValueError("OPENAI_API_KEY environment variable not set!")
-# FIX: Create httpx client without proxy support
-http_client = httpx.Client(
-    timeout=httpx.Timeout(60.0),
-    limits=httpx.Limits(max_keepalive_connections=5, max_connections=10)
-)
-# Initialize OpenAI with custom http client (bypasses proxy issues)
-openai_client = OpenAI(
-    api_key=OPENAI_API_KEY,
-    http_client=http_client
-)
-print("✅ OpenAI client initialized with custom httpx client")
-print(f"   Model: gpt-4o")
-# Default location (Bangalore Agricultural Region)
-DEFAULT_LOCATION = {
-    "name": "Bangalore Agricultural Region",
-    "lat": 12.8716,
-    "lon": 77.4946
 }
-# Initialize pipeline
-pipeline = FarmerChatPipeline(openai_client, DEFAULT_LOCATION)
-# Request/Response Models
-class QueryRequest(BaseModel):
-    query: str = Field(..., min_length=3, max_length=500, description="Farmer's question")
-    location: Optional[Dict[str, Any]] = Field(None, description="Custom location (lat, lon, name)")
-    class Config:
-        json_schema_extra = {
-            "example": {
-                "query": "Should I plant rice today?",
-                "location": {
-                    "name": "Bangalore",
-                    "lat": 12.8716,
-                    "lon": 77.4946
-                }
-            }
-        }
-class QueryResponse(BaseModel):
-    success: bool
-    query: str
-    advice: str
-    routing: Dict[str, Any]
-    data: Dict[str, Any]
-    execution_time_seconds: float
     timestamp: str
-# Health check
 @app.get("/")
 async def root():
     return {
-        "service": "Farmer.Chat Backend",
-        "status": "operational",
-        "version": "2.0.0",
         "endpoints": {
-            "query": "/api/query",
-            "health": "/api/health",
-            "servers": "/api/servers"
         }
     }
-@app.get("/api/health")
-async def health_check():
-    """Health check endpoint"""
-    return {
-        "status": "healthy",
-        "timestamp": datetime.now().isoformat(),
-        "openai_configured": bool(OPENAI_API_KEY),
-        "location": DEFAULT_LOCATION
-    }
-@app.get("/api/servers")
-async def list_servers():
-    """List available MCP servers"""
-    from src.executor import MCP_SERVER_REGISTRY
     return {
-        "total_servers": len(MCP_SERVER_REGISTRY),
-        "servers": MCP_SERVER_REGISTRY
     }
-@app.post("/api/query", response_model=QueryResponse)
-async def process_query(request: QueryRequest):
     """
-    Main query endpoint - processes farmer questions through MCP pipeline
     """
     try:
-        start_time = time.time()
-        # Use custom location if provided, otherwise default
-        location = request.location if request.location else DEFAULT_LOCATION
-        # Update pipeline location if changed
-        if request.location:
-            pipeline.location = location
-        # Process query through pipeline
-        result = await pipeline.process_query(request.query, verbose=False)
-        execution_time = time.time() - start_time
-        return QueryResponse(
-            success=True,
-            query=request.query,
-            advice=result["advice"],
-            routing=result["routing"],
-            data=result["compiled_data"],
-            execution_time_seconds=round(execution_time, 2),
-            timestamp=datetime.now().isoformat()
-        )
-    except Exception as e:
-        raise HTTPException(status_code=500, detail=str(e))
-@app.post("/api/export-pdf")
-async def export_pdf(request: QueryRequest):
-    """
-    Export query result as PDF
-    """
-    try:
-        # Process query
-        result = await pipeline.process_query(request.query, verbose=False)
-        # Generate PDF
-        pdf_path = generate_pdf_report(
-            query=request.query,
-            advice=result["advice"],
-            data=result["compiled_data"],
-            location=pipeline.location
-        )
-        # Return PDF file
-        return FileResponse(
-            pdf_path,
-            media_type="application/pdf",
-            filename=f"farmer-chat-report-{int(time.time())}.pdf"
         )
     except Exception as e:
         raise HTTPException(status_code=500, detail=str(e))
-# Error handlers
-@app.exception_handler(404)
-async def not_found_handler(request, exc):
-    return JSONResponse(
-        status_code=404,
-        content={"error": "Endpoint not found", "path": str(request.url)}
-    )
-@app.exception_handler(500)
-async def server_error_handler(request, exc):
-    return JSONResponse(
-        status_code=500,
-        content={"error": "Internal server error", "detail": str(exc)}
-    )
 if __name__ == "__main__":
     import uvicorn
-    uvicorn.run(app, host="0.0.0.0", port=7860)

+# """
+# Farmer.Chat Backend - FastAPI Application
+# Deploy to Hugging Face Space: https://huggingface.co/spaces/aakashdg/farmer-chat-backend
+# """
+# from fastapi import FastAPI, HTTPException
+# from fastapi.middleware.cors import CORSMiddleware
+# from fastapi.responses import FileResponse, JSONResponse
+# from pydantic import BaseModel, Field
+# from typing import Optional, Dict, Any
+# import os
+# import asyncio
+# import time
+# from datetime import datetime
+# # Import pipeline components
+# from src.pipeline import FarmerChatPipeline
+# from src.pdf_generator import generate_pdf_report
+# # CRITICAL FIX: Import OpenAI with httpx configuration
+# from openai import OpenAI
+# import httpx
+# # Initialize FastAPI
+# app = FastAPI(
+#     title="Farmer.Chat Backend",
+#     description="Multi-stage MCP pipeline for agricultural intelligence",
+#     version="2.0.0"
+# )
+# # CORS - Allow all origins for demo (restrict in production)
+# app.add_middleware(
+#     CORSMiddleware,
+#     allow_origins=["*"],
+#     allow_credentials=True,
+#     allow_methods=["*"],
+#     allow_headers=["*"],
+# )
+# # Initialize OpenAI client with FIXED httpx configuration
+# OPENAI_API_KEY = os.environ.get("OPENAI_API_KEY")
+# if not OPENAI_API_KEY:
+#     raise ValueError("OPENAI_API_KEY environment variable not set!")
+# # FIX: Create httpx client without proxy support
+# http_client = httpx.Client(
+#     timeout=httpx.Timeout(60.0),
+#     limits=httpx.Limits(max_keepalive_connections=5, max_connections=10)
+# )
+# # Initialize OpenAI with custom http client (bypasses proxy issues)
+# openai_client = OpenAI(
+#     api_key=OPENAI_API_KEY,
+#     http_client=http_client
+# )
+# print("✅ OpenAI client initialized with custom httpx client")
+# print(f"   Model: gpt-4o")
+# # Default location (Bangalore Agricultural Region)
+# DEFAULT_LOCATION = {
+#     "name": "Bangalore Agricultural Region",
+#     "lat": 12.8716,
+#     "lon": 77.4946
+# }
+# # Initialize pipeline
+# pipeline = FarmerChatPipeline(openai_client, DEFAULT_LOCATION)
+# # Request/Response Models
+# class QueryRequest(BaseModel):
+#     query: str = Field(..., min_length=3, max_length=500, description="Farmer's question")
+#     location: Optional[Dict[str, Any]] = Field(None, description="Custom location (lat, lon, name)")
+#     class Config:
+#         json_schema_extra = {
+#             "example": {
+#                 "query": "Should I plant rice today?",
+#                 "location": {
+#                     "name": "Bangalore",
+#                     "lat": 12.8716,
+#                     "lon": 77.4946
+#                 }
+#             }
+#         }
+# class QueryResponse(BaseModel):
+#     success: bool
+#     query: str
+#     advice: str
+#     routing: Dict[str, Any]
+#     data: Dict[str, Any]
+#     execution_time_seconds: float
+#     timestamp: str
+# # Health check
+# @app.get("/")
+# async def root():
+#     return {
+#         "service": "Farmer.Chat Backend",
+#         "status": "operational",
+#         "version": "2.0.0",
+#         "endpoints": {
+#             "query": "/api/query",
+#             "health": "/api/health",
+#             "servers": "/api/servers"
+#         }
+#     }
+# @app.get("/api/health")
+# async def health_check():
+#     """Health check endpoint"""
+#     return {
+#         "status": "healthy",
+#         "timestamp": datetime.now().isoformat(),
+#         "openai_configured": bool(OPENAI_API_KEY),
+#         "location": DEFAULT_LOCATION
+#     }
+# @app.get("/api/servers")
+# async def list_servers():
+#     """List available MCP servers"""
+#     from src.executor import MCP_SERVER_REGISTRY
+#     return {
+#         "total_servers": len(MCP_SERVER_REGISTRY),
+#         "servers": MCP_SERVER_REGISTRY
+#     }
+# @app.post("/api/query", response_model=QueryResponse)
+# async def process_query(request: QueryRequest):
+#     """
+#     Main query endpoint - processes farmer questions through MCP pipeline
+#     """
+#     try:
+#         start_time = time.time()
+#         # Use custom location if provided, otherwise default
+#         location = request.location if request.location else DEFAULT_LOCATION
+#         # Update pipeline location if changed
+#         if request.location:
+#             pipeline.location = location
+#         # Process query through pipeline
+#         result = await pipeline.process_query(request.query, verbose=False)
+#         execution_time = time.time() - start_time
+#         return QueryResponse(
+#             success=True,
+#             query=request.query,
+#             advice=result["advice"],
+#             routing=result["routing"],
+#             data=result["compiled_data"],
+#             execution_time_seconds=round(execution_time, 2),
+#             timestamp=datetime.now().isoformat()
+#         )
+#     except Exception as e:
+#         raise HTTPException(status_code=500, detail=str(e))
+# @app.post("/api/export-pdf")
+# async def export_pdf(request: QueryRequest):
+#     """
+#     Export query result as PDF
+#     """
+#     try:
+#         # Process query
+#         result = await pipeline.process_query(request.query, verbose=False)
+#         # Generate PDF
+#         pdf_path = generate_pdf_report(
+#             query=request.query,
+#             advice=result["advice"],
+#             data=result["compiled_data"],
+#             location=pipeline.location
+#         )
+#         # Return PDF file
+#         return FileResponse(
+#             pdf_path,
+#             media_type="application/pdf",
+#             filename=f"farmer-chat-report-{int(time.time())}.pdf"
+#         )
+#     except Exception as e:
+#         raise HTTPException(status_code=500, detail=str(e))
+# # Error handlers
+# @app.exception_handler(404)
+# async def not_found_handler(request, exc):
+#     return JSONResponse(
+#         status_code=404,
+#         content={"error": "Endpoint not found", "path": str(request.url)}
+#     )
+# @app.exception_handler(500)
+# async def server_error_handler(request, exc):
+#     return JSONResponse(
+#         status_code=500,
+#         content={"error": "Internal server error", "detail": str(exc)}
+#     )
+# if __name__ == "__main__":
+#     import uvicorn
+#     uvicorn.run(app, host="0.0.0.0", port=7860)
 """
+Alert Summary Generator Backend
+Modified FastAPI app with location-based alert generation
 """
 from fastapi import FastAPI, HTTPException
 from fastapi.middleware.cors import CORSMiddleware
+from pydantic import BaseModel
 from typing import Optional, Dict, Any
 import os
 from datetime import datetime
+# Import existing pipeline components
 from src.pipeline import FarmerChatPipeline
+from src.client import get_openai_client
+app = FastAPI(title="Farmer.chat Alert Summary API")
+# CORS middleware
 app.add_middleware(
     CORSMiddleware,
     allow_origins=["*"],
     allow_headers=["*"],
 )
+# Initialize OpenAI client and pipeline
+openai_client = get_openai_client()
+DEFAULT_LOCATION = {"latitude": 25.5941, "longitude": 85.1376}  # Patna default
+pipeline = FarmerChatPipeline(openai_client, DEFAULT_LOCATION)
+# Bihar location data
+BIHAR_DATA = {
+    "Araria": ["Araria", "Forbesganj", "Jokihat", "Raniganj"],
+    "Arwal": ["Arwal", "Kaler", "Karpi", "Kurtha"],
+    "Aurangabad": ["Aurangabad", "Daudnagar", "Obra", "Nabinagar"],
+    "Banka": ["Banka", "Amarpur", "Barahat", "Belhar"],
+    "Begusarai": ["Begusarai", "Bakhri", "Barauni", "Teghra"],
+    "Bhagalpur": ["Bhagalpur", "Sabour", "Nathnagar", "Kahalgaon"],
+    "Bhojpur": ["Arrah", "Jagdishpur", "Piro", "Shahpur"],
+    "Buxar": ["Buxar", "Dumraon", "Chausa", "Simri"],
+    "Darbhanga": ["Darbhanga", "Baheri", "Jale", "Benipur"],
+    "East Champaran": ["Motihari", "Raxaul", "Chakia", "Dhaka"],
+    "Gaya": ["Gaya", "Bodh Gaya", "Tekari", "Sherghati"],
+    "Gopalganj": ["Gopalganj", "Barauli", "Baikunthpur", "Kateya"],
+    "Jamui": ["Jamui", "Jhajha", "Sikandra", "Sono"],
+    "Jehanabad": ["Jehanabad", "Ghoshi", "Makhdumpur", "Modanganj"],
+    "Kaimur": ["Bhabua", "Mohania", "Ramgarh", "Chainpur"],
+    "Katihar": ["Katihar", "Barsoi", "Manihari", "Pranpur"],
+    "Khagaria": ["Khagaria", "Gogri", "Mansi", "Alauli"],
+    "Kishanganj": ["Kishanganj", "Bahadurganj", "Thakurganj", "Kochadhaman"],
+    "Lakhisarai": ["Lakhisarai", "Barahiya", "Halsi", "Surajgarha"],
+    "Madhepura": ["Madhepura", "Bihariganj", "Murliganj", "Udakishunganj"],
+    "Madhubani": ["Madhubani", "Jhanjharpur", "Benipatti", "Phulparas"],
+    "Munger": ["Munger", "Jamalpur", "Kharagpur", "Tarapur"],
+    "Muzaffarpur": ["Muzaffarpur", "Motipur", "Kanti", "Saraiya"],
+    "Nalanda": ["Bihar Sharif", "Rajgir", "Hilsa", "Islampur"],
+    "Nawada": ["Nawada", "Rajauli", "Hisua", "Warsaliganj"],
+    "Patna": ["Patna", "Danapur", "Masaurhi", "Phulwari", "Barh"],
+    "Purnia": ["Purnia", "Banmankhi", "Dhamdaha", "Baisi"],
+    "Rohtas": ["Sasaram", "Dehri", "Bikramganj", "Nokha"],
+    "Saharsa": ["Saharsa", "Simri Bakhtiyarpur", "Salkhua", "Sonbarsa"],
+    "Samastipur": ["Samastipur", "Rosera", "Dalsinghsarai", "Patori"],
+    "Saran": ["Chhapra", "Marhaura", "Dariapur", "Amnour"],
+    "Sheikhpura": ["Sheikhpura", "Barbigha", "Chewara", "Ghatkusumbha"],
+    "Sheohar": ["Sheohar", "Piprahi", "Tariyani", "Dumri Katsari"],
+    "Sitamarhi": ["Sitamarhi", "Bairgania", "Belsand", "Parihar"],
+    "Siwan": ["Siwan", "Maharajganj", "Goriakothi", "Barharia"],
+    "Supaul": ["Supaul", "Birpur", "Triveniganj", "Nirmali"],
+    "Vaishali": ["Hajipur", "Mahnar", "Lalganj", "Raghopur"],
+    "West Champaran": ["Bettiah", "Bagaha", "Narkatiaganj", "Ramnagar"],
+}
+# Location coordinates
+LOCATIONS = {
+    "alauli": {'latitude': 25.6392, 'longitude': 86.3854},
+    "amarpur": {'latitude': 25.0217, 'longitude': 86.8932},
+    "amnour": {'latitude': 25.9264, 'longitude': 84.9129},
+    "araria": {'latitude': 26.1346, 'longitude': 87.4654},
+    "arrah": {'latitude': 25.5603, 'longitude': 84.6632},
+    "arwal": {'latitude': 25.2369, 'longitude': 84.6738},
+    "aurangabad": {'latitude': 24.7863, 'longitude': 84.4145},
+    "bagaha": {'latitude': 27.059, 'longitude': 84.2065},
+    "bahadurganj": {'latitude': 26.2702, 'longitude': 87.8373},
+    "baheri": {'latitude': 26.0043, 'longitude': 86.0405},
+    "baikunthpur": {'latitude': 26.2817, 'longitude': 84.7428},
+    "bairgania": {'latitude': 26.7401, 'longitude': 85.2755},
+    "baisi": {'latitude': 25.8396, 'longitude': 87.7509},
+    "bakhri": {'latitude': 25.5743, 'longitude': 86.244},
+    "banka": {'latitude': 24.8669, 'longitude': 86.9126},
+    "banmankhi": {'latitude': 25.8976, 'longitude': 87.1659},
+    "barahat": {'latitude': 24.8869, 'longitude': 87.0296},
+    "barahiya": {'latitude': 25.2636, 'longitude': 86.0055},
+    "barauli": {'latitude': 26.3966, 'longitude': 84.6005},
+    "barauni": {'latitude': 25.4315, 'longitude': 86.0284},
+    "barbigha": {'latitude': 25.207, 'longitude': 85.7715},
+    "barh": {'latitude': 25.451, 'longitude': 85.7002},
+    "barharia": {'latitude': 26.3156, 'longitude': 84.456},
+    "barsoi": {'latitude': 25.6206, 'longitude': 87.9744},
+    "begusarai": {'latitude': 25.4139, 'longitude': 86.1349},
+    "belhar": {'latitude': 24.906, 'longitude': 86.6074},
+    "belsand": {'latitude': 26.4323, 'longitude': 85.3946},
+    "benipatti": {'latitude': 26.4435, 'longitude': 85.9105},
+    "benipur": {'latitude': 26.0754, 'longitude': 86.1245},
+    "bettiah": {'latitude': 26.8023, 'longitude': 84.5074},
+    "bhabua": {'latitude': 25.0763, 'longitude': 83.6336},
+    "bhagalpur": {'latitude': 25.2495, 'longitude': 86.9828},
+    "bihar sharif": {'latitude': 25.1939, 'longitude': 85.5209},
+    "bihariganj": {'latitude': 25.741, 'longitude': 86.9758},
+    "bikramganj": {'latitude': 25.2184, 'longitude': 84.2324},
+    "birpur": {'latitude': 26.5152, 'longitude': 87.0085},
+    "bodh gaya": {'latitude': 24.6776, 'longitude': 84.9727},
+    "buxar": {'latitude': 25.5612, 'longitude': 83.9813},
+    "chainpur": {'latitude': 24.9811, 'longitude': 83.4203},
+    "chakia": {'latitude': 26.4704, 'longitude': 84.9933},
+    "chausa": {'latitude': 25.4514, 'longitude': 83.8621},
+    "chewara": {'latitude': 25.054, 'longitude': 85.9335},
+    "chhapra": {'latitude': 25.7784, 'longitude': 84.7515},
+    "dalsinghsarai": {'latitude': 25.6727, 'longitude': 85.8124},
+    "danapur": {'latitude': 25.6359, 'longitude': 85.0474},
+    "darbhanga": {'latitude': 26.157, 'longitude': 85.8995},
+    "dariapur": {'latitude': 25.8275, 'longitude': 85.0565},
+    "daudnagar": {'latitude': 25.044, 'longitude': 84.4323},
+    "dehri": {'latitude': 24.9259, 'longitude': 84.1729},
+    "dhaka": {'latitude': 26.6924, 'longitude': 85.1986},
+    "dhamdaha": {'latitude': 25.7378, 'longitude': 87.2338},
+    "dumraon": {'latitude': 25.5238, 'longitude': 84.16},
+    "dumri katsari": {'latitude': 26.4691, 'longitude': 85.2195},
+    "forbesganj": {'latitude': 26.2784, 'longitude': 87.2988},
+    "gaya": {'latitude': 24.7964, 'longitude': 85.008},
+    "ghatkusumbha": {'latitude': 25.2127, 'longitude': 85.9308},
+    "ghoshi": {'latitude': 25.1296, 'longitude': 85.0976},
+    "gogri": {'latitude': 25.4294, 'longitude': 86.7107},
+    "gopalganj": {'latitude': 26.5382, 'longitude': 84.4589},
+    "goriakothi": {'latitude': 26.2448, 'longitude': 84.575},
+    "hajipur": {'latitude': 25.6906, 'longitude': 85.209},
+    "halsi": {'latitude': 25.0332, 'longitude': 86.0554},
+    "hilsa": {'latitude': 25.3007, 'longitude': 85.2494},
+    "hisua": {'latitude': 24.8457, 'longitude': 85.3954},
+    "islampur": {'latitude': 25.0969, 'longitude': 85.2604},
+    "jagdishpur": {'latitude': 25.4819, 'longitude': 84.4569},
+    "jale": {'latitude': 26.3563, 'longitude': 85.769},
+    "jamalpur": {'latitude': 25.3139, 'longitude': 86.4897},
+    "jamui": {'latitude': 24.9669, 'longitude': 86.174},
+    "jehanabad": {'latitude': 25.2265, 'longitude': 84.9911},
+    "jhajha": {'latitude': 24.7729, 'longitude': 86.3863},
+    "jhanjharpur": {'latitude': 26.2872, 'longitude': 86.3404},
+    "jokihat": {'latitude': 26.0816, 'longitude': 87.5935},
+    "kahalgaon": {'latitude': 25.2652, 'longitude': 87.2835},
+    "kaler": {'latitude': 25.1549, 'longitude': 84.5414},
+    "kanti": {'latitude': 26.1819, 'longitude': 85.2711},
+    "karpi": {'latitude': 25.1714, 'longitude': 84.7256},
+    "kateya": {'latitude': 26.5723, 'longitude': 84.0811},
+    "katihar": {'latitude': 25.5434, 'longitude': 87.569},
+    "khagaria": {'latitude': 25.5064, 'longitude': 86.4663},
+    "kharagpur": {'latitude': 25.133, 'longitude': 86.5248},
+    "kishanganj": {'latitude': 26.1014, 'longitude': 87.9508},
+    "kochadhaman": {'latitude': 26.1014, 'longitude': 87.9508},
+    "kurtha": {'latitude': 25.1333, 'longitude': 84.8113},
+    "lakhisarai": {'latitude': 25.1678, 'longitude': 86.0594},
+    "lalganj": {'latitude': 25.8521, 'longitude': 85.1896},
+    "madhepura": {'latitude': 25.926, 'longitude': 86.8204},
+    "madhubani": {'latitude': 26.3489, 'longitude': 86.0772},
+    "maharajganj": {'latitude': 26.141, 'longitude': 84.5318},
+    "mahnar": {'latitude': 25.622, 'longitude': 85.5091},
+    "makhdumpur": {'latitude': 25.0739, 'longitude': 84.9879},
+    "manihari": {'latitude': 25.3414, 'longitude': 87.6195},
+    "mansi": {'latitude': 25.546, 'longitude': 86.5504},
+    "marhaura": {'latitude': 25.9302, 'longitude': 84.795},
+    "masaurhi": {'latitude': 25.3516, 'longitude': 84.9873},
+    "modanganj": {'latitude': 25.2591, 'longitude': 85.1584},
+    "mohania": {'latitude': 25.1677, 'longitude': 83.6216},
+    "motihari": {'latitude': 26.6507, 'longitude': 84.9115},
+    "motipur": {'latitude': 26.2571, 'longitude': 85.1689},
+    "munger": {'latitude': 25.3774, 'longitude': 86.4731},
+    "murliganj": {'latitude': 25.8764, 'longitude': 86.9369},
+    "muzaffarpur": {'latitude': 26.1183, 'longitude': 85.3858},
+    "nabinagar": {'latitude': 24.6428, 'longitude': 84.0968},
+    "narkatiaganj": {'latitude': 27.0969, 'longitude': 84.4585},
+    "nathnagar": {'latitude': 25.2184, 'longitude': 86.9177},
+    "nawada": {'latitude': 24.9348, 'longitude': 85.5488},
+    "nirmali": {'latitude': 26.3789, 'longitude': 86.7324},
+    "nokha": {'latitude': 25.0832, 'longitude': 84.0932},
+    "obra": {'latitude': 24.9377, 'longitude': 84.4326},
+    "parihar": {'latitude': 26.7512, 'longitude': 85.6799},
+    "patna": {'latitude': 25.6093, 'longitude': 85.1235},
+    "patori": {'latitude': 25.622, 'longitude': 85.5869},
+    "phulparas": {'latitude': 26.386, 'longitude': 86.4547},
+    "phulwari": {'latitude': 25.543, 'longitude': 85.0523},
+    "piprahi": {'latitude': 26.3489, 'longitude': 86.0772},
+    "piro": {'latitude': 25.3383, 'longitude': 84.3541},
+    "pranpur": {'latitude': 25.4876, 'longitude': 87.7082},
+    "purnia": {'latitude': 25.7774, 'longitude': 87.4731},
+    "raghopur": {'latitude': 25.5714, 'longitude': 85.3241},
+    "rajauli": {'latitude': 24.6343, 'longitude': 85.5609},
+    "rajgir": {'latitude': 25.03, 'longitude': 85.4207},
+    "ramgarh": {'latitude': 25.304, 'longitude': 83.6808},
+    "ramnagar": {'latitude': 27.2909, 'longitude': 84.2936},
+    "raniganj": {'latitude': 26.0553, 'longitude': 87.3077},
+    "raxaul": {'latitude': 26.9869, 'longitude': 84.8447},
+    "rosera": {'latitude': 25.7798, 'longitude': 86.0425},
+    "sabour": {'latitude': 25.2282, 'longitude': 87.0636},
+    "saharsa": {'latitude': 25.8759, 'longitude': 86.5927},
+    "salkhua": {'latitude': 25.6653, 'longitude': 86.5498},
+    "samastipur": {'latitude': 25.8597, 'longitude': 85.7839},
+    "saraiya": {'latitude': 26.0701, 'longitude': 85.1843},
+    "sasaram": {'latitude': 24.951, 'longitude': 84.0149},
+    "shahpur": {'latitude': 25.6593, 'longitude': 84.4295},
+    "sheikhpura": {'latitude': 25.1493, 'longitude': 85.8766},
+    "sheohar": {'latitude': 26.5158, 'longitude': 85.2849},
+    "sherghati": {'latitude': 24.5939, 'longitude': 84.8479},
+    "sikandra": {'latitude': 24.9251, 'longitude': 86.0462},
+    "simri": {'latitude': 25.6499, 'longitude': 84.1384},
+    "simri bakhtiyarpur": {'latitude': 25.7209, 'longitude': 86.5975},
+    "sitamarhi": {'latitude': 26.5943, 'longitude': 85.5004},
+    "siwan": {'latitude': 26.2185, 'longitude': 84.3585},
+    "sonbarsa": {'latitude': 25.7013, 'longitude': 86.7794},
+    "sono": {'latitude': 24.6998, 'longitude': 86.2794},
+    "supaul": {'latitude': 26.0846, 'longitude': 86.5785},
+    "surajgarha": {'latitude': 25.188, 'longitude': 86.2868},
+    "tarapur": {'latitude': 25.1039, 'longitude': 86.647},
+    "tariyani": {'latitude': 26.5158, 'longitude': 85.2849},
+    "teghra": {'latitude': 25.4727, 'longitude': 85.9368},
+    "tekari": {'latitude': 24.9411, 'longitude': 84.843},
+    "thakurganj": {'latitude': 26.4275, 'longitude': 88.129},
+    "triveniganj": {'latitude': 26.127, 'longitude': 86.8873},
+    "udakishunganj": {'latitude': 25.926, 'longitude': 86.8204},
+    "warsaliganj": {'latitude': 24.9348, 'longitude': 85.5488},
 }
+class LocationRequest(BaseModel):
+    location_name: str
+    district: Optional[str] = None
+class AlertResponse(BaseModel):
+    location: str
+    coordinates: Dict[str, float]
+    alert_summary: str
     timestamp: str
+    district: Optional[str] = None
 @app.get("/")
 async def root():
     return {
+        "message": "Farmer.chat Alert Summary API",
+        "version": "1.0.0",
         "endpoints": {
+            "/locations": "Get all available districts and villages",
+            "/generate-alert": "Generate alert summary for a location"
         }
     }
+@app.get("/locations")
+async def get_locations():
+    """Get all available districts and villages in Bihar"""
     return {
+        "state": "Bihar",
+        "districts": BIHAR_DATA,
+        "total_districts": len(BIHAR_DATA),
+        "total_villages": sum(len(villages) for villages in BIHAR_DATA.values())
     }
+@app.post("/generate-alert", response_model=AlertResponse)
+async def generate_alert(request: LocationRequest):
     """
+    Generate comprehensive alert summary for a specific location.
+    Automatically queries all MCP servers (Weather, Soil, Water, Elevation, Pests).
     """
     try:
+        # Get coordinates for the location
+        location_key = request.location_name.lower()
+        coords = LOCATIONS.get(location_key)
+        if not coords:
+            raise HTTPException(
+                status_code=404,
+                detail=f"Location '{request.location_name}' not found in database"
+            )
+        # Update pipeline location
+        pipeline.location = coords
+        # Create comprehensive query for alert generation
+        alert_query = f"""Generate a comprehensive agricultural alert summary for {request.location_name}, Bihar.
+Please provide:
+1. Weather conditions and forecast
+2. Soil analysis and recommendations
+3. Water availability status
+4. Elevation and topography considerations
+5. Pest risk assessment and preventive measures
+Format the response as a clear, actionable alert summary for farmers."""
+        # Process through the pipeline
+        result = await pipeline.process(alert_query, coords)
+        return AlertResponse(
+            location=request.location_name.title(),
+            coordinates=coords,
+            alert_summary=result,
+            timestamp=datetime.utcnow().isoformat(),
+            district=request.district
         )
+    except HTTPException:
+        raise
     except Exception as e:
         raise HTTPException(status_code=500, detail=str(e))
+@app.get("/health")
+async def health_check():
+    return {
+        "status": "healthy",
+        "timestamp": datetime.utcnow().isoformat(),
+        "pipeline_initialized": pipeline is not None
+    }
 if __name__ == "__main__":
     import uvicorn
+    port = int(os.getenv("PORT", 7860))
+    uvicorn.run(app, host="0.0.0.0", port=port)