Create app.py

app.py

@@ -0,0 +1,285 @@
+import gradio as gr
+import requests
+import json
+from datetime import datetime
+import os
+
+# Configuration
+MCP_SERVER_URL = os.getenv("MCP_SERVER_URL", "https://elanuk-mcp-hf.hf.space/")
+
+# Bihar districts list
+BIHAR_DISTRICTS = [
+    "Patna", "Gaya", "Bhagalpur", "Muzaffarpur", "Darbhanga", "Siwan", 
+    "Begusarai", "Katihar", "Nalanda", "Rohtas", "Saran", "Samastipur",
+    "Madhubani", "Purnia", "Araria", "Kishanganj", "Supaul", "Madhepura",
+    "Saharsa", "Khagaria", "Munger", "Lakhisarai", "Sheikhpura", "Nawada",
+    "Jamui", "Jehanabad", "Aurangabad", "Arwal", "Kaimur", "Buxar",
+    "Bhojpur", "Saran", "Siwan", "Gopalganj", "East Champaran", "West Champaran",
+    "Sitamarhi", "Sheohar", "Vaishali"
+]
+
+def format_workflow_output(raw_output):
+    """Format the workflow output for better display"""
+    if not raw_output:
+        return "❌ No output received"
+    
+    # Split into lines and format
+    lines = raw_output.split('\n')
+    formatted_lines = []
+    
+    for line in lines:
+        line = line.strip()
+        if not line:
+            formatted_lines.append("")
+            continue
+            
+        # Format headers
+        if line.startswith('🌾') and 'Workflow' in line:
+            formatted_lines.append(f"## {line}")
+        elif line.startswith('=') or line.startswith('-'):
+            continue  # Skip separator lines
+        elif line.startswith('🌤️') or line.startswith('✅ Workflow'):
+            formatted_lines.append(f"### {line}")
+        elif line.startswith('📱') or line.startswith('📞') or line.startswith('🎙️') or line.startswith('🤖'):
+            formatted_lines.append(f"#### {line}")
+        elif line.startswith('✅') or line.startswith('❌'):
+            formatted_lines.append(f"- {line}")
+        elif line.startswith('   '):
+            formatted_lines.append(f"  {line.strip()}")
+        else:
+            formatted_lines.append(line)
+    
+    return '\n'.join(formatted_lines)
+
+def format_alert_summary(raw_data):
+    """Create a formatted summary of the alert data"""
+    if not raw_data or 'alert_data' not in raw_data:
+        return "No alert data available"
+    
+    alert_data = raw_data['alert_data']
+    
+    summary = f"""
+## 🚨 Alert Summary
+
+**📍 Location:** {alert_data['location']['village']}, {alert_data['location']['district']}, {alert_data['location']['state']}
+
+**🌾 Crop Information:**
+- **Crop:** {alert_data['crop']['name'].title()}
+- **Growth Stage:** {alert_data['crop']['stage']}
+- **Season:** {alert_data['crop']['season'].title()}
+
+**🌤️ Weather Conditions:**
+- **Temperature:** {alert_data['weather']['temperature']}
+- **Expected Rainfall:** {alert_data['weather']['expected_rainfall']}
+- **Wind Speed:** {alert_data['weather']['wind_speed']}
+- **Rain Probability:** {alert_data['weather']['rain_probability']}%
+
+**⚠️ Alert Details:**
+- **Type:** {alert_data['alert']['type'].replace('_', ' ').title()}
+- **Urgency:** {alert_data['alert']['urgency'].upper()}
+- **AI Enhanced:** {'✅ Yes' if alert_data['alert']['ai_generated'] else '❌ No'}
+
+**📨 Alert Message:**
+{alert_data['alert']['message']}
+
+**🎯 Action Items:**
+{chr(10).join([f"- {item.replace('_', ' ').title()}" for item in alert_data['alert']['action_items']])}
+"""
+    return summary
+
+def test_mcp_workflow(district):
+    """Test the MCP workflow for a given district"""
+    if not district:
+        return "❌ Please select a district", "", ""
+    
+    try:
+        # Make request to MCP server
+        payload = {
+            "state": "bihar",
+            "district": district.lower()
+        }
+        
+        response = requests.post(
+            f"{MCP_SERVER_URL}/api/run-workflow",
+            json=payload,
+            timeout=30
+        )
+        
+        if response.status_code == 200:
+            result = response.json()
+            
+            # Format outputs
+            workflow_output = format_workflow_output(result.get('message', ''))
+            alert_summary = format_alert_summary(result.get('raw_data', {}))
+            
+            # Create CSV download content
+            csv_content = result.get('csv', '')
+            
+            return workflow_output, alert_summary, csv_content
+            
+        else:
+            error_msg = f"❌ Server Error ({response.status_code}): {response.text}"
+            return error_msg, "", ""
+            
+    except requests.exceptions.Timeout:
+        return "⏰ Request timed out. The server might be processing...", "", ""
+    except requests.exceptions.ConnectionError:
+        return f"🔌 Connection Error: Cannot reach MCP server at {MCP_SERVER_URL}", "", ""
+    except Exception as e:
+        return f"❌ Error: {str(e)}", "", ""
+
+def check_server_health():
+    """Check if the MCP server is running"""
+    try:
+        response = requests.get(f"{MCP_SERVER_URL}/api/health", timeout=10)
+        if response.status_code == 200:
+            data = response.json()
+            return f"✅ Server Online | OpenAI: {'✅' if data.get('openai_available') else '❌'} | Time: {data.get('timestamp', 'N/A')}"
+        else:
+            return f"⚠️ Server responded with status {response.status_code}"
+    except:
+        return f"❌ Server Offline or Unreachable ({MCP_SERVER_URL})"
+
+# Create Gradio interface
+with gr.Blocks(
+    title="BIHAR AgMCP - Agricultural Weather Alerts",
+    theme=gr.themes.Soft(),
+    css="""
+    .gradio-container {
+        max-width: 1200px;
+        margin: auto;
+    }
+    .status-box {
+        padding: 10px;
+        border-radius: 5px;
+        margin: 10px 0;
+    }
+    """
+) as demo:
+    
+    gr.Markdown("""
+    # 🌾 BIHAR AgMCP - Agricultural Weather Alert System
+    
+    **AI-Powered Weather Alerts for Bihar Farmers**
+    
+    This interface tests the MCP (Model Context Protocol) server that generates personalized weather alerts for agricultural activities in Bihar districts.
+    
+    ## 📋 How to Use:
+    1. **Select District**: Choose a Bihar district from the dropdown
+    2. **Run Workflow**: Click the button to generate weather alerts
+    3. **View Results**: See formatted workflow output and alert summary
+    4. **Download Data**: Get CSV export of the alert data
+    
+    The system will:
+    - Select a random village in the district
+    - Choose appropriate crops based on season and region
+    - Generate weather-based agricultural alerts
+    - Create messages for multiple communication channels (SMS, WhatsApp, etc.)
+    """)
+    
+    # Server status
+    with gr.Row():
+        server_status = gr.Textbox(
+            label="🔧 Server Status", 
+            value=check_server_health(),
+            interactive=False,
+            container=True
+        )
+        
+        refresh_btn = gr.Button("🔄 Refresh Status", size="sm")
+        refresh_btn.click(check_server_health, outputs=server_status)
+    
+    # Main interface
+    with gr.Row():
+        with gr.Column(scale=1):
+            district_input = gr.Dropdown(
+                choices=BIHAR_DISTRICTS,
+                label="📍 Select Bihar District",
+                placeholder="Choose a district...",
+                value="Patna"
+            )
+            
+            run_btn = gr.Button(
+                "🚀 Generate Weather Alert", 
+                variant="primary",
+                size="lg"
+            )
+            
+            gr.Markdown("""
+            ### 💡 What happens next?
+            - Weather data collection
+            - Crop stage estimation  
+            - AI-powered alert generation
+            - Multi-channel message creation
+            - CSV data export
+            """)
+    
+    # Results section
+    with gr.Row():
+        with gr.Column(scale=2):
+            workflow_output = gr.Markdown(
+                label="📋 Workflow Output",
+                value="Click 'Generate Weather Alert' to see results..."
+            )
+        
+        with gr.Column(scale=1):
+            alert_summary = gr.Markdown(
+                label="📊 Alert Summary",
+                value="Alert details will appear here..."
+            )
+    
+    # CSV export
+    with gr.Row():
+        csv_output = gr.File(
+            label="📁 Download CSV Data",
+            visible=False
+        )
+    
+    # Event handling
+    def run_workflow_with_csv(district):
+        workflow, summary, csv_content = test_mcp_workflow(district)
+        
+        # Create temporary CSV file if content exists
+        if csv_content:
+            filename = f"bihar_alert_{district.lower()}_{datetime.now().strftime('%Y%m%d_%H%M%S')}.csv"
+            with open(filename, 'w') as f:
+                f.write(csv_content)
+            return workflow, summary, gr.File(value=filename, visible=True)
+        else:
+            return workflow, summary, gr.File(visible=False)
+    
+    run_btn.click(
+        run_workflow_with_csv,
+        inputs=[district_input],
+        outputs=[workflow_output, alert_summary, csv_output]
+    )
+    
+    # Footer
+    gr.Markdown("""
+    ---
+    
+    ### 🔗 System Information:
+    - **State Coverage**: Bihar (38 districts)
+    - **Crops Supported**: Rice, Wheat, Maize, Sugarcane, Mustard, and more
+    - **Weather Sources**: Open-Meteo API with AI enhancement
+    - **Communication Channels**: SMS, WhatsApp, USSD, IVR, Telegram
+    
+    ### 📞 Agent Outputs:
+    The system generates formatted messages for:
+    - **📱 SMS**: Short text alerts for basic phones
+    - **📱 WhatsApp**: Rich media messages with emojis
+    - **📞 USSD**: Interactive menu systems
+    - **🎙️ IVR**: Voice script for phone calls  
+    - **🤖 Telegram**: Bot-friendly formatted messages
+    
+    *Built with MCP (Model Context Protocol) for agricultural intelligence*
+    """)
+
+# Launch configuration for HuggingFace Spaces
+if __name__ == "__main__":
+    demo.launch(
+        share=True,
+        server_name="0.0.0.0",
+        server_port=7860,
+        show_error=True
+    )