Update app.py

app.py

@@ -1,7 +1,7 @@
 #!/usr/bin/env python3
 """
-🚗 JAY'S MOBILE WASH - HUGGINGFACE SPACES COMPATIBLE
-iPhone Forwarding + AI Assistant - Optimized for HuggingFace deployment
+🚗 JAY'S MOBILE WASH - GRADIO + FASTAPI VERSION
+iPhone Forwarding + AI Assistant - HuggingFace Spaces Optimized
 """
 
 import os
@@ -14,6 +14,9 @@ from datetime import datetime, timedelta
 from collections import defaultdict
 from threading import Lock
 import gradio as gr
+from fastapi import FastAPI, Request, Form
+from fastapi.responses import PlainTextResponse
+import uvicorn
 
 # Load environment variables
 from dotenv import load_dotenv
@@ -157,7 +160,6 @@ class SimpleAI:
     
     def generate_response(self, user_input, context=None):
         """Generate AI response"""
-        
         intent = self.detect_intent(user_input)
         sentiment = self.analyze_sentiment(user_input)
         
@@ -246,22 +248,22 @@ BUSINESS INFO:
 # Initialize AI processor
 ai = SimpleAI()
 
-# Flask app for webhooks (runs in background)
-from flask import Flask, request
-
-flask_app = Flask(__name__)
+# FastAPI app for webhooks
+fastapi_app = FastAPI()
 
-@flask_app.route('/voice/incoming', methods=['POST'])
-def handle_voice():
+@fastapi_app.post("/voice/incoming")
+async def handle_voice(request: Request):
     """Handle incoming voice calls"""
     try:
+        form = await request.form()
+        
         if not signalwire_client or not VoiceResponse:
-            return "Service unavailable", 503
+            return PlainTextResponse("Service unavailable", status_code=503)
         
-        call_sid = request.form.get('CallSid')
-        from_number = request.form.get('From')
-        to_number = request.form.get('To')
-        forwarded_from = request.form.get('ForwardedFrom')
+        call_sid = form.get('CallSid')
+        from_number = form.get('From')
+        to_number = form.get('To')
+        forwarded_from = form.get('ForwardedFrom')
         
         # Detect forwarding
         is_forwarded = bool(forwarded_from) or (to_number == SIGNALWIRE_PHONE)
@@ -302,29 +304,32 @@ def handle_voice():
         response.say("I didn't catch that. Let me connect you with Jay.", voice='alice')
         response.dial(JAY_PHONE, timeout=30)
         
-        return str(response)
+        return PlainTextResponse(str(response), media_type="application/xml")
         
     except Exception as e:
         logger.error(f"Voice error: {e}")
         response = VoiceResponse()
         response.say("Technical issue. Connecting you with Jay.", voice='alice')
         response.dial(JAY_PHONE, timeout=30)
-        return str(response)
+        return PlainTextResponse(str(response), media_type="application/xml")
 
-@flask_app.route('/voice/process', methods=['POST'])
-def process_speech():
+@fastapi_app.post("/voice/process")
+async def process_speech(request: Request):
     """Process customer speech"""
     try:
-        call_sid = request.args.get('call_sid')
-        is_forwarded = request.args.get('forwarded') == 'True'
-        speech_result = request.form.get('SpeechResult', '')
-        confidence = float(request.form.get('Confidence', '0.0'))
+        form = await request.form()
+        query_params = request.query_params
+        
+        call_sid = query_params.get('call_sid')
+        is_forwarded = query_params.get('forwarded') == 'True'
+        speech_result = form.get('SpeechResult', '')
+        confidence = float(form.get('Confidence', '0.0'))
         
         if not speech_result or confidence < 0.4:
             response = VoiceResponse()
             response.say("I didn't understand clearly. Let me connect you with Jay.", voice='alice')
             response.dial(JAY_PHONE, timeout=30)
-            return str(response)
+            return PlainTextResponse(str(response), media_type="application/xml")
         
         # Analyze intent
         intent = ai.detect_intent(speech_result)
@@ -334,7 +339,7 @@ def process_speech():
             response = VoiceResponse()
             response.say("Let me connect you with Jay right away.", voice='alice')
             response.dial(JAY_PHONE, timeout=30)
-            return str(response)
+            return PlainTextResponse(str(response), media_type="application/xml")
         
         # Generate AI response
         context = {'forwarded': is_forwarded, 'call_sid': call_sid}
@@ -354,22 +359,24 @@ def process_speech():
         )
         
         response.say("Thank you for calling Jay's Mobile Wash! Have a great day!", voice='alice')
-        return str(response)
+        return PlainTextResponse(str(response), media_type="application/xml")
         
     except Exception as e:
         logger.error(f"Speech processing error: {e}")
         response = VoiceResponse()
         response.say("Technical issue. Connecting with Jay.", voice='alice')
         response.dial(JAY_PHONE, timeout=30)
-        return str(response)
+        return PlainTextResponse(str(response), media_type="application/xml")
 
-@flask_app.route('/sms/incoming', methods=['POST'])
-def handle_sms():
+@fastapi_app.post("/sms/incoming")
+async def handle_sms(request: Request):
     """Handle incoming SMS"""
     try:
-        message_sid = request.form.get('MessageSid')
-        from_number = request.form.get('From')
-        message_body = request.form.get('Body', '').strip()
+        form = await request.form()
+        
+        message_sid = form.get('MessageSid')
+        from_number = form.get('From')
+        message_body = form.get('Body', '').strip()
         
         # Log the SMS
         sms_entry = {
@@ -383,7 +390,8 @@ def handle_sms():
         system_state.increment('sms_today')
         
         if not message_body:
-            return send_sms("Hi! How can I help you with Jay's Mobile Wash today?", from_number)
+            await send_sms("Hi! How can I help you with Jay's Mobile Wash today?", from_number)
+            return PlainTextResponse(str(MessagingResponse()) if MessagingResponse else "", media_type="application/xml")
         
         # Analyze message
         intent = ai.detect_intent(message_body)
@@ -395,7 +403,8 @@ def handle_sms():
             'jay' in message_body.lower()):
             
             response_text = f"I'll have Jay respond to you personally. For immediate assistance, call {JAY_PHONE}."
-            return send_sms(response_text, from_number)
+            await send_sms(response_text, from_number)
+            return PlainTextResponse(str(MessagingResponse()) if MessagingResponse else "", media_type="application/xml")
         
         # Generate AI response
         ai_response = ai.generate_response(message_body, {'sms': True})
@@ -406,13 +415,15 @@ def handle_sms():
         
         system_state.increment('ai_responses')
         
-        return send_sms(ai_response, from_number)
+        await send_sms(ai_response, from_number)
+        return PlainTextResponse(str(MessagingResponse()) if MessagingResponse else "", media_type="application/xml")
         
     except Exception as e:
         logger.error(f"SMS error: {e}")
-        return send_sms("Thanks for your message! Jay will get back to you soon.", from_number)
+        await send_sms("Thanks for your message! Jay will get back to you soon.", from_number)
+        return PlainTextResponse(str(MessagingResponse()) if MessagingResponse else "", media_type="application/xml")
 
-def send_sms(message, to_number):
+async def send_sms(message, to_number):
     """Send SMS response"""
     try:
         if signalwire_client:
@@ -431,13 +442,11 @@ def send_sms(message, to_number):
             }
             system_state.add_sms_log(sms_entry)
         
-        return str(MessagingResponse()) if MessagingResponse else ""
     except Exception as e:
         logger.error(f"SMS send error: {e}")
-        return ""
 
-@flask_app.route('/health')
-def health_check():
+@fastapi_app.get("/health")
+async def health_check():
     """Health check endpoint"""
     health = {
         'status': 'healthy',
@@ -584,12 +593,12 @@ def test_ai_response(message):
     except Exception as e:
         return f"Error testing AI response: {e}"
 
-# Start Flask app in background thread
-def run_flask():
-    flask_app.run(host='0.0.0.0', port=7860, debug=False)
+# Start FastAPI in background thread
+def run_fastapi():
+    uvicorn.run(fastapi_app, host="0.0.0.0", port=8000, log_level="info")
 
-flask_thread = threading.Thread(target=run_flask, daemon=True)
-flask_thread.start()
+fastapi_thread = threading.Thread(target=run_fastapi, daemon=True)
+fastapi_thread.start()
 
 # Create Gradio Interface
 with gr.Blocks(
@@ -672,6 +681,7 @@ with gr.Blocks(
             
             - **SignalWire:** {'✅ Connected' if signalwire_client else '❌ Not configured'}
             - **DeepSeek AI:** {'✅ Connected' if DEEPSEEK_API_KEY else '⚠️ Using fallback responses'}
+            - **FastAPI Webhooks:** ✅ Running on port 8000
             - **Health Check:** [/health](./health)
             """)
     
@@ -691,8 +701,8 @@ if __name__ == "__main__":
     print(f"🌐 SignalWire: {'✅ Connected' if signalwire_client else '❌ Not configured'}")
     print(f"🧠 DeepSeek: {'✅ Connected' if DEEPSEEK_API_KEY else '❌ Not configured'}")
     print("="*60)
-    print("🚀 Starting Gradio interface...")
-    print("📞 Flask webhooks running on port 7860")
+    print("🚀 Starting Gradio interface on port 7860...")
+    print("📞 FastAPI webhooks running on port 8000")
     print("="*60)
     
     interface.launch(